@rosejs/subscribe v1.0.3

Rose framework

import dotenv from 'dotenv'
import Subscribe from '@rosejs/subscribe'

import { destroy } from '@api/jwtspjrlzyle'

import { T } from '@api/iujsdvldqkag'

dotenv.config()

const sub: Subscribe = new Subscribe()

sub.use('iujsdvldqkag:delete:1', async (instance: T.ModelAttributes) => {

    await destroy({ user: instance.pk })

})

const start = async (): Promise<void> => sub.run()

const stop = (): Promise<void> => sub.stop()

export default { start, stop }