combine count & list test. use sano cli version in CI.

Author: VegetarianOrc

.github/workflows/ci.yml

@@ -22,7 +22,7 @@ env:
   IS_MAIN_OR_RELEASE: ${{ vars.IS_TEMPORALIO_SDK_TYPESCRIPT_REPO == 'true' && github.event_name != 'pull_request' && ( github.ref == 'refs/heads/main' || startsWith(github.ref, 'refs/tags/') || startsWith(github.ref, 'refs/heads/releases')) }}
 
   # Use these variables to force specific version of CLI/Time Skipping Server for SDK tests
-  # TESTS_CLI_VERSION: 'v1.7.0'
+  TESTS_CLI_VERSION: 'v1.7.1-standalone-nexus-operations'
   # TESTS_TIME_SKIPPING_SERVER_VERSION: 'v1.24.1'
 
 jobs:

packages/test/src/test-nexus-standalone.ts

@@ -19,6 +19,7 @@ import * as temporalnexus from '@temporalio/nexus';
 import * as workflow from '@temporalio/workflow';
 import { CancelledFailure, TerminatedFailure, ApplicationFailure, NexusOperationFailure } from '@temporalio/common';
 import { helpers, makeTestFunction } from './helpers-integration';
+import { waitUntil } from './helpers';
 
 const test = makeTestFunction({
   workflowsPath: __filename,
@@ -227,7 +228,7 @@ test('terminate operation', async (t) => {
   });
 });
 
-test('list operations', async (t) => {
+test('count and list operations', async (t) => {
   const { createWorker, registerNexusEndpoint } = helpers(t);
   const { endpointName } = await registerNexusEndpoint();
   const { handler } = makeTestHandler();
@@ -245,6 +246,13 @@ test('list operations', async (t) => {
       });
       opIds.add(id);
     }
+
+    // Visibility has update delay, repeating query until the activity count is as expected
+    await waitUntil(async () => {
+      const result = await client.nexus.count(`Endpoint="${endpointName}"`);
+      return result.count == 3;
+    }, 10000);
+
     const seen = new Set<string>();
     for await (const op of client.nexus.list({ query: `Endpoint="${endpointName}"` })) {
       seen.add(op.operationId);
@@ -256,24 +264,6 @@ test('list operations', async (t) => {
   });
 });
 
-test('count operations', async (t) => {
-  const { createWorker, registerNexusEndpoint } = helpers(t);
-  const { endpointName } = await registerNexusEndpoint();
-  const { handler } = makeTestHandler();
-  const worker = await createWorker({ nexusServices: [handler] });
-
-  await worker.runUntil(async () => {
-    const { client } = t.context.env;
-    const svc = client.nexus.createServiceClient({ endpoint: endpointName, service: testService });
-    await svc.startOperation(testService.operations.echo, 'count-test', {
-      id: 'count-op-' + randomUUID(),
-      scheduleToCloseTimeout: '10s',
-    });
-    const result = await client.nexus.count(`Endpoint="${endpointName}"`);
-    t.true(result.count >= 1);
-  });
-});
-
 test('get handle by ID', async (t) => {
   const { createWorker, registerNexusEndpoint } = helpers(t);
   const { endpointName } = await registerNexusEndpoint();