highperfocused/nostream
1
0
Fork 0
mirror of https://github.com/Cameri/nostream.git synced 2025-03-17 21:31:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

test: add unit tests for EventRepository.created

Browse Source
This commit is contained in:
Ricardo Arturo Cabral Mejia 2022-08-16 13:29:22 +00:00
parent 9efdb8d209
commit 5da7d3a157
No known key found for this signature in database
GPG Key ID: 5931EBF43A650245
4 changed files with 83 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.nycrc.json
View File

@ -36,7 +36,7 @@
"src/constants"
],
"require": [
"ts-node/register/transpile-only",
"ts-node/register",
"source-map-support/register"
],
"reporter": [

2
src/@types/event.ts
View File

@ -3,7 +3,7 @@ import { Pubkey, TagName } from './base'
export type EventId = string
export type Tag = TagBase | []
export type Tag = TagBase & string[]
export interface TagBase {
0: TagName

4
src/repositories/event-repository.ts
View File

@ -116,7 +116,10 @@ export class EventRepository implements IEventRepository {
}
public async create(event: Event): Promise<number> {
return this.insert(event).then(prop('rowCount') as () => number)
}
private insert(event: Event): Knex.QueryBuilder {
const row = applySpec({
event_id: pipe(prop('id'), toBuffer),
event_pubkey: pipe(prop('pubkey'), toBuffer),
@ -131,7 +134,6 @@ export class EventRepository implements IEventRepository {
.insert(row)
.onConflict()
.ignore()
.then(prop('rowCount') as () => number)
}

82
test/unit/repositories/event-repository.spec.ts
View File

@ -1,7 +1,8 @@
import * as chai from 'chai'
import knex from 'knex'
import knex, { Knex } from 'knex'
import * as sinon from 'sinon'
import sinonChai from 'sinon-chai'
import { Event } from '../../../src/@types/event'
import { IEventRepository } from '../../../src/@types/repositories'
import { SubscriptionFilter } from '../../../src/@types/subscription'
@ -14,20 +15,23 @@ import { EventRepository } from '../../../src/repositories/event-repository'
describe('EventRepository', () => {
let repository: IEventRepository
let sandbox: sinon.SinonSandbox
let dbClient: Knex
beforeEach(() => {
sandbox = sinon.createSandbox()
repository = new EventRepository(knex({
dbClient = knex({
client: 'pg'
}))
})
repository = new EventRepository(dbClient)
})
afterEach(() => {
sandbox.restore()
})
describe('findByFilters', () => {
describe('.findByFilters', () => {
it('returns a function with stream and then', () => {
expect(repository.findByFilters([{}])).to.have.property('stream')
expect(repository.findByFilters([{}])).to.have.property('then')
@ -359,4 +363,74 @@ describe('EventRepository', () => {
})
})
})
describe('.create', () => {
let insertStub: sinon.SinonStub
beforeEach(() => {
insertStub = sandbox.stub(repository, 'insert' as any)
})
it('calls insert with given event and returns row count', async () => {
const event: Event = {
id: '6b3cdd0302ded8068ad3f0269c74423ca4fee460f800f3d90103b63f14400407',
pubkey:
'22e804d26ed16b68db5259e78449e96dab5d464c8f470bda3eb1a70467f2c793',
created_at: 1648351380,
kind: 1,
tags: [
[
'p',
'8355095016fddbe31fcf1453b26f613553e9758cf2263e190eac8fd96a3d3de9',
'wss://nostr-pub.wellorder.net',
],
[
'e',
'7377fa81fc6c7ae7f7f4ef8938d4a603f7bf98183b35ab128235cc92d4bebf96',
'wss://nostr-relay.untethr.me',
],
],
content:
"I've set up mirroring between relays: https://i.imgur.com/HxCDipB.png",
sig: 'b37adfed0e6398546d623536f9ddc92b95b7dc71927e1123266332659253ecd0ffa91ddf2c0a82a8426c5b363139d28534d6cac893b8a810149557a3f6d36768',
}
insertStub.returns({ then: sinon.stub().yields({ rowCount: 1 }) })
const result = await repository.create(event)
expect(insertStub).to.have.been.calledOnceWithExactly(event)
expect(result).to.equal(1)
})
})
describe('.insert', () => {
it('inserts event if there is no conflict', () => {
const event: Event = {
id: '6b3cdd0302ded8068ad3f0269c74423ca4fee460f800f3d90103b63f14400407',
pubkey:
'22e804d26ed16b68db5259e78449e96dab5d464c8f470bda3eb1a70467f2c793',
created_at: 1648351380,
kind: 1,
tags: [
[
'p',
'8355095016fddbe31fcf1453b26f613553e9758cf2263e190eac8fd96a3d3de9',
'wss://nostr-pub.wellorder.net',
],
[
'e',
'7377fa81fc6c7ae7f7f4ef8938d4a603f7bf98183b35ab128235cc92d4bebf96',
'wss://nostr-relay.untethr.me',
],
],
content:
"I've set up mirroring between relays: https://i.imgur.com/HxCDipB.png",
sig: 'b37adfed0e6398546d623536f9ddc92b95b7dc71927e1123266332659253ecd0ffa91ddf2c0a82a8426c5b363139d28534d6cac893b8a810149557a3f6d36768',
}
const query = (repository as any).insert(event).toString()
expect(query).to.equal('insert into "events" ("event_content", "event_created_at", "event_id", "event_kind", "event_pubkey", "event_signature", "event_tags") values (\'I\'\'ve set up mirroring between relays: https://i.imgur.com/HxCDipB.png\', 1648351380, X\'6b3cdd0302ded8068ad3f0269c74423ca4fee460f800f3d90103b63f14400407\', 1, X\'22e804d26ed16b68db5259e78449e96dab5d464c8f470bda3eb1a70467f2c793\', X\'b37adfed0e6398546d623536f9ddc92b95b7dc71927e1123266332659253ecd0ffa91ddf2c0a82a8426c5b363139d28534d6cac893b8a810149557a3f6d36768\', \'[["p","8355095016fddbe31fcf1453b26f613553e9758cf2263e190eac8fd96a3d3de9","wss://nostr-pub.wellorder.net"],["e","7377fa81fc6c7ae7f7f4ef8938d4a603f7bf98183b35ab128235cc92d4bebf96","wss://nostr-relay.untethr.me"]]\') on conflict do nothing')
})
})
})