From f404054438c9fd90fdd0965c8c296e40dcf5f455 Mon Sep 17 00:00:00 2001
From: Sosthene <contact@sosthene.net>
Date: Sun, 15 Jun 2025 22:27:52 +0200
Subject: [PATCH] Add process udpate in MessageBus

---
 src/sdk/MessageBus.ts | 53 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 53 insertions(+)

diff --git a/src/sdk/MessageBus.ts b/src/sdk/MessageBus.ts
index ff4dff8..ee9f072 100644
--- a/src/sdk/MessageBus.ts
+++ b/src/sdk/MessageBus.ts
@@ -406,6 +406,47 @@ export default class MessageBus {
     });
   }
 
+  public updateProcess(processId: string, lastStateId: string, newData: Record<string, any>, privateFields: string[], roles: Record<string, RoleDefinition> | null): Promise<any> {
+    return new Promise<any>((resolve: (updatedProcess: any) => void, reject: (error: string) => void) => {
+      this.checkToken().then(() => {
+        const userStore = UserStore.getInstance();
+        const accessToken = userStore.getAccessToken()!;
+
+        const correlationId = uuidv4();
+        this.initMessageListener(correlationId);
+
+        const unsubscribe = EventBus.getInstance().on('PROCESS_UPDATED', (responseId: string, updatedProcess: any) => {
+          console.log('PROCESS_UPDATED', updatedProcess);
+          if (responseId !== correlationId) {
+            return;
+          }
+          unsubscribe();
+          this.destroyMessageListener();
+          resolve(updatedProcess);
+        });
+
+        const unsubscribeError = EventBus.getInstance().on('ERROR_PROCESS_UPDATED', (responseId: string, error: string) => {
+          if (responseId !== correlationId) {
+            return;
+          }
+          unsubscribeError();
+          this.destroyMessageListener();
+          reject(error);
+        });
+
+        this.sendMessage({
+          type: 'UPDATE_PROCESS',
+          processId,
+          lastStateId,
+          newData,
+          privateFields,
+          roles,
+          accessToken
+        });
+      }).catch(console.error);
+    });
+  }
+
   public notifyProcessUpdate(processId: string, stateId: string): Promise<void> {
     return new Promise<void>((resolve: () => void, reject: (error: string) => void) => {
       this.checkToken().then(() => {
@@ -640,6 +681,18 @@ export default class MessageBus {
         EventBus.getInstance().emit('STATE_VALIDATED', correlationId, message.validatedProcess);
         break;
 
+      case 'PROCESS_UPDATED':
+        if (this.errors[correlationId]) {
+          const error = this.errors[correlationId];
+          delete this.errors[correlationId];
+          EventBus.getInstance().emit('ERROR_PROCESS_UPDATED', correlationId, error);
+          return;
+        }
+        console.log('PROCESS_UPDATED', message);
+        EventBus.getInstance().emit('MESSAGE_RECEIVED', message);
+        EventBus.getInstance().emit('PROCESS_UPDATED', correlationId, message.updatedProcess);
+        break;
+        
       case 'ERROR':
         console.error('Error:', message);
         this.errors[correlationId] = message.error;