aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

up

Browse source
This commit is contained in:
boufni95 2023-12-14 20:03:32 +01:00
parent b0cd176005
commit 807a3b5ccc
2 changed files with 6 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/services/nostr/handler.ts
View file

@ -97,14 +97,14 @@ export default class Handler {
async Connect() { async Connect() {
const log = getLogger({}) const log = getLogger({})
log("conneting to relay...", this.settings.relays[0]) log("conneting to relay...", this.settings.relays[0])
const s = relayInit(this.settings.relays[0]) // TODO: create multiple conns for multiple relays const relay = relayInit(this.settings.relays[0]) // TODO: create multiple conns for multiple relays
s.on('connect', () => { console.log("connected") }) relay.on('connect', () => { console.log("connected") })
s.on('disconnect', () => { relay.on('disconnect', () => {
log("relay disconnected, will try to reconnect") log("relay disconnected, will try to reconnect")
s.close() relay.close()
this.Connect() this.Connect()
}) })
const sub = s.sub([ const sub = relay.sub([
{ {
since: Math.ceil(Date.now() / 1000), since: Math.ceil(Date.now() / 1000),
kinds: [21000], kinds: [21000],

1
src/services/nostr/tools/relay.ts
View file

@ -92,6 +92,7 @@ export function relayInit(
} }
ws.onopen = () => { ws.onopen = () => {
console.log("Waas")
listeners.connect.forEach(cb => cb()) listeners.connect.forEach(cb => cb())
resolve() resolve()
} }