4nk/sdk_signer
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix unconsistent async patterns + add a few missing try/catch
All checks were successful
Build and Push to Registry / build-and-push (push) Successful in 1m53s
Details

Browse Source
This commit is contained in:
Sosthene 2025-09-08 21:56:26 +02:00
parent 8449083237
commit 83b21cb815
2 changed files with 29 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/relay-manager.ts
View File

@ -309,7 +309,7 @@ export class RelayManager {
}
// Relay Message Handling
private handleRelayMessage(relayId: string, message: any): void {
private async handleRelayMessage(relayId: string, message: any): Promise<void> {
console.log(`📨 Received message from relay ${relayId}:`);
if (message.flag === 'Handshake') {
@ -321,7 +321,7 @@ export class RelayManager {
// Handle different types of relay responses
if (message.flag) {
// Handle protocol-specific responses
this.handleProtocolMessage(relayId, message);
await this.handleProtocolMessage(relayId, message);
} else if (message.type === 'heartbeat') {
// Update heartbeat
const relay = this.relays.get(relayId);
@ -337,14 +337,16 @@ export class RelayManager {
}
}
private handleProtocolMessage(relayId: string, message: any): void {
private async handleProtocolMessage(relayId: string, message: any): Promise<void> {
// Handle different AnkFlag responses
switch (message.flag) {
case "NewTx":
console.log(`📨 NewTx response from relay ${relayId}`);
setImmediate(() => {
Service.getInstance().parseNewTx(message.content);
});
try {
await Service.getInstance().parseNewTx(message.content);
} catch (error) {
console.error(`❌ Error parsing NewTx from relay ${relayId}:`, error);
}
break;
case "Commit":
console.log(`📨 Commit response from relay ${relayId}`);
@ -353,9 +355,11 @@ export class RelayManager {
break;
case "Cipher":
console.log(`📨 Cipher response from relay ${relayId}`);
setImmediate(() => {
Service.getInstance().parseCipher(message.content);
});
try {
await Service.getInstance().parseCipher(message.content);
} catch (error) {
console.error(`❌ Error parsing Cipher from relay ${relayId}:`, error);
}
break;
case "Handshake":
console.log(`📨 Handshake response from relay ${relayId}`);

12
src/service.ts
View File

@ -1159,8 +1159,12 @@ export class Service {
}
if (apiReturn.new_tx_to_send && apiReturn.new_tx_to_send.transaction.length != 0) {
try {
await this.sendNewTxMessage(JSON.stringify(apiReturn.new_tx_to_send));
await new Promise(r => setTimeout(r, 500));
} catch (error) {
console.error('❌ Error sending NewTx message:', error);
}
}
if (apiReturn.secrets) {
@ -1245,11 +1249,19 @@ export class Service {
if (apiReturn.commit_to_send) {
const commit = apiReturn.commit_to_send;
try {
await this.sendCommitMessage(JSON.stringify(commit));
} catch (error) {
console.error('❌ Error sending Commit message:', error);
}
}
if (apiReturn.ciphers_to_send && apiReturn.ciphers_to_send.length != 0) {
try {
await this.sendCipherMessages(apiReturn.ciphers_to_send);
} catch (error) {
console.error('❌ Error sending Cipher messages:', error);
}
}
}