RediFlow

A clean simple wrapper targeted at redis streams and redis List and basic pub-sub functionality in a very intuitive class based api

Usage

const rediFlow = new RediFlow({})
const stream = rediFlow.createStream('mystream')

const replica2 = await stream.createConsumerGroup(stream.streamName, 'replica-2', { startId: '$' })
const replica1 = await stream.createConsumerGroup(stream.streamName, 'replica-1', { startId: '$' })

const replica1Observable = await replica1.observeStream(1)
const replica2Observable = await replica2.observeStream(1)

replica1Observable.subscribe(async ({ ids, data }) => {
  console.log({ handledBy: 'replica-1', data, ids })
  await replica1.acknowledge(ids)
  await stream.delete(ids)
})

replica2Observable.subscribe(async ({ ids, data }) => {
  console.log({ handledBy: 'replica-2', data, ids })
  await replica1.acknowledge(ids)
  await stream.delete(ids)
})

await stream.addToStream({ cool: { boom: 1 } }, '*')
await stream.addToStream({ cool: { boom: 2 } }, '*')
await stream.addToStream({ cool: { boom: 3 } }, '*')
await stream.addToStream({ cool: { boom: 4 } }, '*')
await stream.addToStream({ cool: { boom: 5 } }, '*')
await stream.addToStream({ cool: { boom: 6 } }, '*')

LICENSE

MIT