Skip to content

Commit 1e493f0

Browse files
committed
Adding a test
1 parent 85eab3d commit 1e493f0

3 files changed

Lines changed: 49 additions & 3 deletions

File tree

temporal-sdk/src/main/java/io/temporal/client/NexusClientInterceptor.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,6 @@
44
import io.grpc.Deadline;
55
import io.temporal.api.common.v1.Payload;
66
import io.temporal.api.common.v1.SearchAttributes;
7-
import io.temporal.api.enums.v1.NexusOperationIdConflictPolicy;
8-
import io.temporal.api.enums.v1.NexusOperationIdReusePolicy;
97
import io.temporal.api.enums.v1.NexusOperationWaitStage;
108
import io.temporal.api.failure.v1.Failure;
119
import io.temporal.api.nexus.v1.NexusOperationExecutionListInfo;

temporal-sdk/src/main/java/io/temporal/client/NexusClientOperationOptions.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package io.temporal.client;
22

33
import io.temporal.common.SearchAttributes;
4-
54
import java.time.Duration;
65
import java.util.Collections;
76
import java.util.List;
Lines changed: 49 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
package io.temporal.client.nexus;
2+
3+
import io.temporal.client.NexusClient;
4+
import io.temporal.client.NexusClientImpl;
5+
import io.temporal.client.NexusClientInterceptor;
6+
import io.temporal.client.NexusClientOperationOptions;
7+
import io.temporal.testing.internal.SDKTestWorkflowRule;
8+
import io.temporal.workflow.shared.TestWorkflows;
9+
import org.junit.Assert;
10+
import org.junit.Rule;
11+
import org.junit.Test;
12+
13+
public class NexusClientTest {
14+
15+
@Rule
16+
public SDKTestWorkflowRule testWorkflowRule =
17+
SDKTestWorkflowRule.newBuilder()
18+
.setWorkflowTypes(NexusClientTest.PlaceholderWorkflowImpl.class)
19+
.build();
20+
21+
private NexusClient createNexusClient() {
22+
return NexusClientImpl.newInstance(
23+
testWorkflowRule.getWorkflowServiceStubs(),
24+
NexusClientOperationOptions.newBuilder()
25+
.setNamespace(testWorkflowRule.getWorkflowClient().getOptions().getNamespace())
26+
.build());
27+
}
28+
29+
@Test
30+
public void listNexusOperationExecutions() {
31+
NexusClient client = createNexusClient();
32+
NexusClientInterceptor.ListNexusOperationExecutionsInput input =
33+
new NexusClientInterceptor.ListNexusOperationExecutionsInput(null, 100, null);
34+
35+
NexusClientInterceptor.ListNexusOperationExecutionsOutput output =
36+
client.listNexusOperationExecutions(input);
37+
38+
Assert.assertNotNull(output);
39+
Assert.assertNotNull(output.getOperations());
40+
Assert.assertNotNull(output.getNextPageToken());
41+
}
42+
43+
public static class PlaceholderWorkflowImpl implements TestWorkflows.TestWorkflow1 {
44+
@Override
45+
public String execute(String input) {
46+
return input;
47+
}
48+
}
49+
}

0 commit comments

Comments
 (0)