From de6213b1b7d1c8bffb08a28de52f58d9e44d7f1d Mon Sep 17 00:00:00 2001
From: NicolasCantu <nicolas.cantu@pm.me>
Date: Tue, 4 Mar 2025 14:53:56 +0100
Subject: [PATCH] requestDataFromPeers takes roles

---
 src/services/database.service.ts | 6 ++++--
 src/services/service.ts          | 6 ++++--
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/services/database.service.ts b/src/services/database.service.ts
index 2f81270..f1321aa 100755
--- a/src/services/database.service.ts
+++ b/src/services/database.service.ts
@@ -212,6 +212,7 @@ export class Database {
       }
       const processId = diff.process_id;
       const stateId = diff.state_id;
+      const roles = diff.roles;
       try {
         const valueBytes = await service.fetchValueFromStorage(hash);
         if (valueBytes) {
@@ -230,7 +231,7 @@ export class Database {
           console.log('Request data from managers of the process');
           // get the diff from db
           if (!requestedStateId.includes(stateId)) {
-            await service.requestDataFromPeers(processId, stateId);
+            await service.requestDataFromPeers(processId, [stateId], [roles]);
             requestedStateId.push(stateId);
           }
         }
@@ -264,8 +265,9 @@ export class Database {
             const diff = await service.getDiffByValue(hash);
             const processId = diff.process_id;
             const stateId = diff.state_id;
+            const roles = diff.roles;
             if (!requestedStateId.includes(stateId)) {
-              await service.requestDataFromPeers(processId, stateId);
+              await service.requestDataFromPeers(processId, [stateId], [roles]);
               requestedStateId.push(stateId);
             }
           }
diff --git a/src/services/service.ts b/src/services/service.ts
index 785088f..47d90fd 100755
--- a/src/services/service.ts
+++ b/src/services/service.ts
@@ -1195,9 +1195,11 @@ export default class Services {
     }
   }
 
-  public async requestDataFromPeers(processId: string, stateId: string) {
+  public async requestDataFromPeers(processId: string, stateIds: string[], roles: Record<string, RoleDefinition>[]) {
+    console.log('Requesting data from peers');
+    console.log(roles);
     try {
-      const res = this.sdkClient.request_data(processId, [stateId]);
+      const res = this.sdkClient.request_data(processId, stateIds, roles);
       await this.handleApiReturn(res);
     } catch (e) {
       console.error(e);