use new MockRelay class in relay.test.ts

This commit is contained in:
Sepehr Safari
2024-01-20 10:41:05 +03:30
parent 829633b0d6
commit dbad25b2fa

View File

@@ -2,43 +2,57 @@ import { expect, test } from 'bun:test'
import { finalizeEvent, generateSecretKey, getPublicKey } from './pure.ts' import { finalizeEvent, generateSecretKey, getPublicKey } from './pure.ts'
import { Relay } from './relay.ts' import { Relay } from './relay.ts'
import { newMockRelay } from './test-helpers.ts' import { MockRelay } from './test-helpers.ts'
test('connectivity', async () => { test('connectivity', async () => {
const { url } = newMockRelay() const mockRelay = new MockRelay()
const relay = new Relay(url)
const relay = new Relay(mockRelay.getUrl())
await relay.connect() await relay.connect()
expect(relay.connected).toBeTrue() expect(relay.connected).toBeTrue()
relay.close() relay.close()
mockRelay.close()
mockRelay.stop()
}) })
test('connectivity, with Relay.connect()', async () => { test('connectivity, with Relay.connect()', async () => {
const { url } = newMockRelay() const mockRelay = new MockRelay()
const relay = await Relay.connect(url)
const relay = await Relay.connect(mockRelay.getUrl())
expect(relay.connected).toBeTrue() expect(relay.connected).toBeTrue()
relay.close() relay.close()
mockRelay.close()
mockRelay.stop()
}) })
test('querying', async done => { test('querying', async done => {
const { url, authors } = newMockRelay() const mockRelay = new MockRelay()
const kind = 0 const kind = 0
const relay = new Relay(url) const relay = new Relay(mockRelay.getUrl())
await relay.connect() await relay.connect()
relay.subscribe( relay.subscribe(
[ [
{ {
authors: authors, authors: mockRelay.getAuthors(),
kinds: [kind], kinds: [kind],
}, },
], ],
{ {
onevent(event) { onevent(event) {
expect(authors).toContain(event.pubkey) expect(mockRelay.getAuthors()).toContain(event.pubkey)
expect(event).toHaveProperty('kind', kind) expect(event).toHaveProperty('kind', kind)
relay.close() relay.close()
mockRelay.close()
mockRelay.stop()
done() done()
}, },
}, },
@@ -46,12 +60,13 @@ test('querying', async done => {
}) })
test('listening and publishing and closing', async done => { test('listening and publishing and closing', async done => {
const mockRelay = new MockRelay()
const sk = generateSecretKey() const sk = generateSecretKey()
const pk = getPublicKey(sk) const pk = getPublicKey(sk)
const kind = 23571 const kind = 23571
const { url } = newMockRelay() const relay = new Relay(mockRelay.getUrl())
const relay = new Relay(url)
await relay.connect() await relay.connect()
let sub = relay.subscribe( let sub = relay.subscribe(
@@ -66,11 +81,15 @@ test('listening and publishing and closing', async done => {
expect(event).toHaveProperty('pubkey', pk) expect(event).toHaveProperty('pubkey', pk)
expect(event).toHaveProperty('kind', kind) expect(event).toHaveProperty('kind', kind)
expect(event).toHaveProperty('content', 'content') expect(event).toHaveProperty('content', 'content')
sub.close()
sub.close() // close the subscription and will trigger onclose()
}, },
oneose() {},
onclose() { onclose() {
relay.close() relay.close()
mockRelay.close()
mockRelay.stop()
done() done()
}, },
}, },