WIP

Author: philippfromme

README.md

@@ -120,7 +120,7 @@ Requires a live Camunda 8 instance configured in `demo/.env` (same as `npm start
 npm run scenarios:record
 
 # Record a single scenario
-npm run scenarios:record:one test/scenarios/service-task-success/scenario.mjs
+npm run scenarios:record:single test/scenarios/service-task-success/scenario.mjs
 
 # Review what changed
 npm run scenarios:diff
@@ -129,7 +129,7 @@ npm run scenarios:diff
 ### Adding a new scenario
 
 1. Create a new folder under `test/scenarios/` with a minimal `process.bpmn` and a `scenario.mjs` that exports the scenario definition. Use a unique `processId` and a scoped job type (e.g. `task-testing:<scenario-name>`) to avoid collisions on a shared cluster.
-2. Run `npm run scenarios:record:one test/scenarios/<name>/scenario.mjs` to produce the fixture JSON.
+2. Run `npm run scenarios:record:single test/scenarios/<name>/scenario.mjs` to produce the fixture JSON.
 3. Write a spec in `test/` that uses `replayScenario` / `createReplayApi` to exercise the component with the new fixture.
 4. Commit both the `process.bpmn` and the generated JSON fixture.
 

demo/api.mjs

@@ -0,0 +1,141 @@
+/**
+ * Shared Camunda REST API wrapper.
+ *
+ * createApi(client) returns an object whose methods mirror the SDK calls used
+ * by both demo/server.mjs and test/scenarios/run.mjs. Every method returns a
+ * `{ success: true, response }` or `{ success: false, error }` object so
+ * callers never need their own try/catch. Recording stays with the caller.
+ *
+ * Response-shape helpers are also exported here since they depend only on the
+ * result structures produced by these methods.
+ */
+
+async function safe(promise) {
+  try {
+    const response = await promise;
+    return { success: true, response };
+  } catch (err) {
+    return { success: false, error: err.message };
+  }
+}
+
+/**
+ * @param {import('@camunda8/sdk').CamundaRestClient} client
+ */
+export function createApi(client) {
+  return {
+
+    /** @param {Array<{ name: string, content: string }>} resources */
+    deployResources(resources) {
+      return safe(client.deployResources(resources));
+    },
+
+    /**
+     * Starts a process instance scoped to a single element, which is also
+     * used as the TERMINATE_PROCESS_INSTANCE instruction target.
+     */
+    createProcessInstance({ processDefinitionKey, variables = {}, elementId }) {
+      return safe(client.createProcessInstance({
+        processDefinitionKey,
+        variables,
+        startInstructions: [ { elementId } ],
+        runtimeInstructions: [
+          { type: 'TERMINATE_PROCESS_INSTANCE', afterElementId: elementId }
+        ]
+      }));
+    },
+
+    searchProcessInstances(processInstanceKey) {
+      return safe(client.searchProcessInstances({
+        filter: { processInstanceKey }
+      }));
+    },
+
+    searchVariables(processInstanceKey) {
+      return safe(client.searchVariables({
+        filter: { processInstanceKey }
+      }));
+    },
+
+    searchJobs(processInstanceKey, elementId) {
+      return safe(client.callApiEndpoint({
+        urlPath: 'jobs/search',
+        method: 'POST',
+        body: {
+          filter: {
+            processInstanceKey,
+            ...(elementId && { elementId })
+          }
+        }
+      }));
+    },
+
+    searchUserTasks(processInstanceKey, elementId) {
+      return safe(client.searchUserTasks({
+        filter: {
+          processInstanceKey,
+          ...(elementId && { elementId })
+        }
+      }));
+    },
+
+    searchMessageSubscriptions(processInstanceKey, elementId) {
+      return safe(client.callApiEndpoint({
+        urlPath: 'message-subscriptions/search',
+        method: 'POST',
+        body: {
+          filter: {
+            processInstanceKey,
+            ...(elementId && { elementId })
+          }
+        }
+      }));
+    },
+
+    searchElementInstances(processInstanceKey) {
+      return safe(client.searchElementInstances({
+        filter: { processInstanceKey }
+      }));
+    },
+
+    searchIncidents(processInstanceKey) {
+      return safe(client.searchIncidents({
+        filter: { processInstanceKey }
+      }));
+    }
+  };
+}
+
+// ---------------------------------------------------------------------------
+// Response-shape helpers
+// ---------------------------------------------------------------------------
+
+export function getProcessDefinitionKey(deployResponse, processId) {
+  const items = deployResponse && (deployResponse.deployments || deployResponse.processes || []);
+  for (const item of items) {
+    const def = item.processDefinition || item;
+    if (def.processDefinitionId === processId) {
+      return def.processDefinitionKey;
+    }
+  }
+  return null;
+}
+
+export function getProcessInstanceKey(startResponse) {
+  if (!startResponse) return null;
+  return String(
+    startResponse.processInstanceKey ||
+    (startResponse.items && startResponse.items[0] && startResponse.items[0].processInstanceKey) ||
+    ''
+  ) || null;
+}
+
+export function getProcessInstanceState(piResult) {
+  const items = piResult && piResult.response && piResult.response.items;
+  return items && items[0] && items[0].state;
+}
+
+export function hasProcessInstanceIncident(piResult) {
+  const items = piResult && piResult.response && piResult.response.items;
+  return !!(items && items[0] && items[0].hasIncident);
+}