Update relay publishing over nostr-tools due to a breaking change

This commit is contained in:
Bojan Mojsilovic 2023-09-14 13:35:06 +02:00
parent 57532220a4
commit 71d8015a72

View File

@ -422,7 +422,7 @@ export const sendEvent = async (event: NostrEvent, relays: Relay[], relaySetting
continue; continue;
} }
responses.push(new Promise<string>((resolve, reject) => { responses.push(new Promise<string>(async (resolve, reject) => {
const timeout = setTimeout(() => { const timeout = setTimeout(() => {
console.log(`Publishing post to ${relay.url} has timed out`); console.log(`Publishing post to ${relay.url} has timed out`);
reasons.push('timeout'); reasons.push('timeout');
@ -430,25 +430,16 @@ export const sendEvent = async (event: NostrEvent, relays: Relay[], relaySetting
}, 8_000); }, 8_000);
try { try {
let pub = relay.publish(signedNote);
console.log('publishing to relay: ', relay) console.log('publishing to relay: ', relay)
pub.on('ok', () => { let pub = await relay.publish(signedNote);
console.log(`${relay.url} has accepted our event`);
clearTimeout(timeout);
resolve('success');
});
pub.on('failed', (reason: any) => { console.log(`${relay.url} has accepted our event`);
console.log(`failed to publish to ${relay.url}: ${reason}`) clearTimeout(timeout);
clearTimeout(timeout); resolve('success');
reasons.push(reason);
reject('failed');
});
} catch (e) { } catch (e) {
console.log('Failed publishing note: ', e); console.log(`Failed publishing note to ${relay.url}: `, e);
clearTimeout(timeout); clearTimeout(timeout);
reasons.push(`${e}`); reasons.push(`${e}`);
reject(e); reject(e);