feat: cancel process instance if task testing is canceled

Related to camunda/camunda-modeler#5296

Author: jarekdanielak

demo/App.jsx

@@ -218,6 +218,10 @@ function App() {
       .then(response => response.json());
   };
 
+  const cancelProcessInstance = async (processInstanceKey) => {
+    return fetch(`/api/cancelProcessInstance/${processInstanceKey}`, { method: 'POST' });
+  };
+
   const { current: onConfigChanged } = useRef(debounce(config => setConfig(config), 300));
 
   // eslint-disable-next-line no-undef
@@ -246,7 +250,8 @@ function App() {
             startInstance,
             getProcessInstance,
             getProcessInstanceVariables,
-            getProcessInstanceIncident
+            getProcessInstanceIncident,
+            cancelProcessInstance
           } }
           config={ config }
           onConfigChanged={ onConfigChanged }

demo/server.mjs

@@ -165,6 +165,26 @@ app.get('/api/getProcessInstanceIncident/:processInstanceKey', async (req, res)
   }
 });
 
+app.post('/api/cancelProcessInstance/:processInstanceKey', async (req, res) => {
+  try {
+    if (!camunda) {
+      return res.json({ success: false, error: 'Camunda environment not configured' });
+    }
+
+    const { processInstanceKey } = req.params;
+
+    const client = camunda.getCamundaRestClient();
+
+    const response = await client.cancelProcessInstance({
+      processInstanceKey
+    });
+
+    res.json({ success: true, response });
+  } catch (err) {
+    res.status(500).json({ success: false, error: err.message, source: err.source });
+  }
+});
+
 const PORT = process.env.PORT || 3000;
 
 app.listen(PORT, () => {

lib/TaskExecution.js

@@ -39,6 +39,8 @@ export default class TaskExecution extends EventEmitter {
     /** @type {TaskExecutionStatus} */
     this._status = 'idle';
 
+    this._processInstanceKey = null;
+
     const eventBus = injector.get('eventBus');
 
     eventBus.on([ 'selection.changed', 'commandStack.changed' ], () => {
@@ -99,7 +101,7 @@ export default class TaskExecution extends EventEmitter {
       return;
     }
 
-    const processInstanceKey = getProcessInstanceKey(startInstanceResult.response);
+    const processInstanceKey = this._processInstanceKey = getProcessInstanceKey(startInstanceResult.response);
 
     if (!processInstanceKey) {
       this._emitError('Failed to retrieve process instance key from start instance response');
@@ -199,6 +201,11 @@ export default class TaskExecution extends EventEmitter {
       clearInterval(this._interval);
     }
 
+    if (this._processInstanceKey) {
+      this._api.cancelProcessInstance(this._processInstanceKey);
+      this._processInstanceKey = null;
+    }
+
     this._changeStatus('idle');
   }
 

lib/types.d.ts

@@ -78,6 +78,7 @@ export type TaskExecutionApi = {
   getProcessInstance: (processInstanceKey: string) => Promise<GetProcessInstanceResult>;
   getProcessInstanceVariables: (processInstanceKey: string) => Promise<GetProcessInstanceVariablesResult>;
   getProcessInstanceIncident: (processInstanceKey: string) => Promise<GetProcessInstanceIncidentResult>;
+  cancelProcessInstance: (processInstanceKey: string) => Promise<any>;
 };
 
 export type TaskExecutionStatus =