handleHandshakeMsg with partial members updates
This commit is contained in:
parent
c76d5121b1
commit
b468620701
@ -1083,7 +1083,14 @@ export default class Services {
|
|||||||
const handshakeMsg: HandshakeMessage = JSON.parse(parsedMsg);
|
const handshakeMsg: HandshakeMessage = JSON.parse(parsedMsg);
|
||||||
this.updateRelay(url, handshakeMsg.sp_address);
|
this.updateRelay(url, handshakeMsg.sp_address);
|
||||||
const processes = handshakeMsg.processes_list;
|
const processes = handshakeMsg.processes_list;
|
||||||
|
const members = handshakeMsg.peers_list;
|
||||||
|
if (this.membersList && Object.keys(this.membersList).length === 0) {
|
||||||
this.membersList = handshakeMsg.peers_list;
|
this.membersList = handshakeMsg.peers_list;
|
||||||
|
} else {
|
||||||
|
for (const [processId, member] of Object.entries(handshakeMsg.peers_list)) {
|
||||||
|
this.membersList[processId] = member;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// Write processes to db
|
// Write processes to db
|
||||||
setTimeout(async () => {
|
setTimeout(async () => {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user