Handle commit msg error return from relay
This commit is contained in:
parent
91e967867c
commit
d8948a9776
@ -1276,4 +1276,12 @@ export default class Services {
|
|||||||
public getAddressesForMemberId(memberId: string): string[] | null {
|
public getAddressesForMemberId(memberId: string): string[] | null {
|
||||||
return this.membersList[memberId];
|
return this.membersList[memberId];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async handleCommitError(response: string) {
|
||||||
|
const content = JSON.parse(response);
|
||||||
|
// Wait and retry
|
||||||
|
setTimeout(async () => {
|
||||||
|
await this.sendCommitMessage(JSON.stringify(content));
|
||||||
|
}, 1000)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
@ -38,6 +38,10 @@ export async function initWebsocket(url: string) {
|
|||||||
case 'Cipher':
|
case 'Cipher':
|
||||||
await services.parseCipher(parsedMessage.content);
|
await services.parseCipher(parsedMessage.content);
|
||||||
break;
|
break;
|
||||||
|
case 'Commit':
|
||||||
|
// Basically if we see this it means we have an error
|
||||||
|
await services.handleCommitError(parsedMessage.content);
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error('Received an invalid message:', error);
|
console.error('Received an invalid message:', error);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user