mirror of
https://github.com/nbd-wtf/nostr-tools.git
synced 2025-12-09 00:28:51 +00:00
changed the relay in the test, must also change the event queried for.
This commit is contained in:
@@ -23,40 +23,37 @@ test('connectivity, with Relay.connect()', async () => {
|
|||||||
test('querying', async () => {
|
test('querying', async () => {
|
||||||
await relay.connect()
|
await relay.connect()
|
||||||
|
|
||||||
let resolve1: () => void
|
let resolveEvent: () => void
|
||||||
let resolve2: () => void
|
let resolveEose: () => void
|
||||||
|
|
||||||
let waiting = Promise.all([
|
const evented = new Promise<void>(resolve => {
|
||||||
new Promise<void>(resolve => {
|
resolveEvent = resolve
|
||||||
resolve1 = resolve
|
})
|
||||||
}),
|
const eosed = new Promise<void>(resolve => {
|
||||||
new Promise<void>(resolve => {
|
resolveEose = resolve
|
||||||
resolve2 = resolve
|
})
|
||||||
}),
|
|
||||||
])
|
|
||||||
|
|
||||||
relay.subscribe(
|
relay.subscribe(
|
||||||
[
|
[
|
||||||
{
|
{
|
||||||
ids: ['3abc6cbb215af0412ab2c9c8895d96a084297890fd0b4018f8427453350ca2e4'],
|
authors: ['9bbe185a20f50607b6e021c68a2c7275649770d3f8277c120d2b801a2b9a64fc'],
|
||||||
|
kinds: [0],
|
||||||
},
|
},
|
||||||
],
|
],
|
||||||
{
|
{
|
||||||
onevent(event) {
|
onevent(event) {
|
||||||
expect(event).toHaveProperty('id', '3abc6cbb215af0412ab2c9c8895d96a084297890fd0b4018f8427453350ca2e4')
|
expect(event).toHaveProperty('pubkey', '9bbe185a20f50607b6e021c68a2c7275649770d3f8277c120d2b801a2b9a64fc')
|
||||||
expect(event).toHaveProperty('content', '+')
|
expect(event).toHaveProperty('kind', 0)
|
||||||
expect(event).toHaveProperty('kind', 7)
|
resolveEvent()
|
||||||
resolve1()
|
|
||||||
},
|
},
|
||||||
oneose() {
|
oneose() {
|
||||||
resolve2()
|
resolveEose()
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
||||||
let [t1, t2] = await waiting
|
await eosed
|
||||||
expect(t1).toBeUndefined()
|
await evented
|
||||||
expect(t2).toBeUndefined()
|
|
||||||
}, 10000)
|
}, 10000)
|
||||||
|
|
||||||
test('listening and publishing and closing', async () => {
|
test('listening and publishing and closing', async () => {
|
||||||
|
|||||||
Reference in New Issue
Block a user