This commit is contained in:
parent
c858f4e252
commit
41bc1a0ea7
@ -67,8 +67,9 @@ describe('scan persistence', () => {
|
|||||||
it('marks only explicitly acknowledged events synced', async () => {
|
it('marks only explicitly acknowledged events synced', async () => {
|
||||||
const first = await recordScan('ONE', 'Code 128')
|
const first = await recordScan('ONE', 'Code 128')
|
||||||
await recordScan('TWO', 'Code 128')
|
await recordScan('TWO', 'Code 128')
|
||||||
const events = await database.outbox.toArray()
|
const event = await database.outbox.where('aggregateId').equals(first.id).first()
|
||||||
await acknowledgeOutboxEvent(events[0]!.id)
|
expect(event).toBeDefined()
|
||||||
|
await acknowledgeOutboxEvent(event!.id)
|
||||||
const stats = await getOutboxStats()
|
const stats = await getOutboxStats()
|
||||||
expect(stats.synced).toBe(1)
|
expect(stats.synced).toBe(1)
|
||||||
expect(stats.pending).toBe(1)
|
expect(stats.pending).toBe(1)
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user