mirror of
https://github.com/nbd-wtf/nostr-tools.git
synced 2025-12-09 08:38:50 +00:00
finish removing ramda.
This commit is contained in:
34
pool.js
34
pool.js
@@ -1,8 +1,6 @@
|
|||||||
import {getEventHash, signEvent} from './event'
|
import {getEventHash, signEvent} from './event'
|
||||||
import {relayConnect, normalizeRelayURL} from './relay'
|
import {relayConnect, normalizeRelayURL} from './relay'
|
||||||
|
|
||||||
const R = require('ramda')
|
|
||||||
|
|
||||||
export function relayPool(globalPrivateKey) {
|
export function relayPool(globalPrivateKey) {
|
||||||
const relays = {}
|
const relays = {}
|
||||||
const globalSub = []
|
const globalSub = []
|
||||||
@@ -101,21 +99,23 @@ export function relayPool(globalPrivateKey) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
await R.map(async relay => {
|
Object.values(relays)
|
||||||
try {
|
.filter(({policy}) => policy.write)
|
||||||
await relay.publish(event)
|
.map(async ({relay}) => {
|
||||||
statusCallback(0, relay.url)
|
try {
|
||||||
let {unsub} = relay.sub(
|
await relay.publish(event)
|
||||||
() => {
|
statusCallback(0, relay.url)
|
||||||
statusCallback(1, relay.url)
|
let {unsub} = relay.sub(
|
||||||
},
|
() => {
|
||||||
{id: event.id}
|
statusCallback(1, relay.url)
|
||||||
)
|
},
|
||||||
setTimeout(unsub, 5000)
|
{id: event.id}
|
||||||
} catch (err) {
|
)
|
||||||
statusCallback(-1, relay.url)
|
setTimeout(unsub, 5000)
|
||||||
}
|
} catch (err) {
|
||||||
}, R.filter(R.pipe(R.prop('policy'), R.prop('write'), R.equals(true)), relays))
|
statusCallback(-1, relay.url)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
return event
|
return event
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user