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[]) { + 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);