diff --git a/backend/services/mpc-service/src/infrastructure/external/mpc-system/coordinator-client.ts b/backend/services/mpc-service/src/infrastructure/external/mpc-system/coordinator-client.ts index dffefdda..95670ac3 100644 --- a/backend/services/mpc-service/src/infrastructure/external/mpc-system/coordinator-client.ts +++ b/backend/services/mpc-service/src/infrastructure/external/mpc-system/coordinator-client.ts @@ -96,22 +96,24 @@ export class MPCCoordinatorClient implements OnModuleInit { try { const response = await this.client.post('/api/v1/sessions/join', { - session_id: request.sessionId, - party_id: request.partyId, - join_token: request.joinToken, + joinToken: request.joinToken, + partyId: request.partyId, + deviceType: 'server', // Required field + deviceId: 'mpc-service', }); + // Response format: { sessionId, partyIndex, status, participants } return { - sessionId: response.data.session_info.session_id, - sessionType: response.data.session_info.session_type, - thresholdN: response.data.session_info.threshold_n, - thresholdT: response.data.session_info.threshold_t, - participants: response.data.other_parties.map((p: any) => ({ - partyId: p.party_id, - partyIndex: p.party_index, - })), - publicKey: response.data.session_info.public_key, - messageHash: response.data.session_info.message_hash, + sessionId: response.data.sessionId, + sessionType: 'keygen', // JoinByToken doesn't return session type, assume keygen + thresholdN: 3, // Default 2-of-3 + thresholdT: 2, + participants: response.data.participants?.map((p: any) => ({ + partyId: p.partyId, + partyIndex: p.partyIndex || 0, + })) || [], + publicKey: undefined, + messageHash: undefined, }; } catch (error) { const message = this.getErrorMessage(error);