feat: add execution log

Author: philippfromme

demo/App.jsx

@@ -119,11 +119,29 @@ function App() {
       .then(response => response.json());
   };
 
+  const searchJobs = async (processInstanceKey, elementId) => {
+    return fetch(`/api/searchJobs/${processInstanceKey}?elementId=${elementId}`)
+      .then(response => response.json());
+  };
+
+  const searchUserTasks = async (processInstanceKey, elementId) => {
+    return fetch(`/api/searchUserTasks/${processInstanceKey}?elementId=${elementId}`)
+      .then(response => response.json());
+  };
+
+  const searchMessageSubscriptions = async (processInstanceKey, elementId) => {
+    return fetch(`/api/searchMessageSubscriptions/${processInstanceKey}?elementId=${elementId}`)
+      .then(response => response.json());
+  };
+
   const { current: onConfigChanged } = useRef(debounce(config => setConfig(config), 300));
 
   // eslint-disable-next-line no-undef
   const operateURL = process.env.CAMUNDA_OPERATE_BASE_URL;
 
+  // eslint-disable-next-line no-undef
+  const tasklistURL = process.env.CAMUNDA_TASKLIST_BASE_URL;
+
   return (
     <>
       <div className="modeler" ref={ modelerRef }>
@@ -160,11 +178,15 @@ function App() {
               getProcessInstance,
               getProcessInstanceVariables,
               getProcessInstanceElementInstances,
-              getProcessInstanceIncident
+              getProcessInstanceIncident,
+              searchJobs,
+              searchUserTasks,
+              searchMessageSubscriptions
             } }
             config={ config }
             onConfigChanged={ onConfigChanged }
             operateBaseUrl={ operateURL }
+            tasklistBaseUrl={ tasklistURL }
             documentationUrl="https://docs.camunda.io/"
             onTaskExecutionStarted={ (element) => {
               console.log('Task execution started:', element.id);

demo/plugins/RPA.jsx

@@ -6,11 +6,11 @@ import logHtml from './log.html';
 export const RPATab = () => {
   const render = useCallback(({ output }) => {
 
-    if (!output.variables?.RPA_Result) {
+    if (!output?.variables?.RPA_Result) {
       return;
     }
 
-    return <iframe width="100%" srcDoc={ logHtml } />;
+    return <iframe width="100%" height="100%" srcDoc={ logHtml } />;
   }, []);
 
   return <TaskTesting.Tab

demo/server.mjs

@@ -184,6 +184,80 @@ app.get('/api/getProcessInstanceIncident/:processInstanceKey', async (req, res)
   }
 });
 
+app.get('/api/searchJobs/:processInstanceKey', async (req, res) => {
+  try {
+    if (!camundaRestClient) {
+      return res.json({ success: false, error: 'Camunda environment not configured' });
+    }
+
+    const { processInstanceKey } = req.params;
+    const { elementId } = req.query;
+
+    const response = await camundaRestClient.callApiEndpoint({
+      urlPath: 'jobs/search',
+      method: 'POST',
+      body: {
+        filter: {
+          processInstanceKey,
+          ...(elementId && { elementId })
+        }
+      }
+    });
+
+    res.json({ success: true, response });
+  } catch (err) {
+    res.status(500).json({ success: false, error: err.message });
+  }
+});
+
+app.get('/api/searchUserTasks/:processInstanceKey', async (req, res) => {
+  try {
+    if (!camundaRestClient) {
+      return res.json({ success: false, error: 'Camunda environment not configured' });
+    }
+
+    const { processInstanceKey } = req.params;
+    const { elementId } = req.query;
+
+    const response = await camundaRestClient.searchUserTasks({
+      filter: {
+        processInstanceKey,
+        ...(elementId && { elementId })
+      }
+    });
+
+    res.json({ success: true, response });
+  } catch (err) {
+    res.status(500).json({ success: false, error: err.message });
+  }
+});
+
+app.get('/api/searchMessageSubscriptions/:processInstanceKey', async (req, res) => {
+  try {
+    if (!camundaRestClient) {
+      return res.json({ success: false, error: 'Camunda environment not configured' });
+    }
+
+    const { processInstanceKey } = req.params;
+    const { elementId } = req.query;
+
+    const response = await camundaRestClient.callApiEndpoint({
+      urlPath: 'message-subscriptions/search',
+      method: 'POST',
+      body: {
+        filter: {
+          processInstanceKey,
+          ...(elementId && { elementId })
+        }
+      }
+    });
+
+    res.json({ success: true, response });
+  } catch (err) {
+    res.status(500).json({ success: false, error: err.message });
+  }
+});
+
 function createJobWorker() {
   if (!camundaRestClient) {
     console.warn('Camunda environment not configured, job worker not started');