Alessandro Magionami
6d0f08b7b5
* feat(workspaces): approve join request * chore(workspaces): add missing dep to resolver call * chore(workspaces): use commandFactory
36 lines
1017 B
TypeScript
36 lines
1017 B
TypeScript
import { EmitArg, EventBus, EventBusEmit } from '@/modules/shared/services/eventBus'
|
|
import { Knex } from 'knex'
|
|
|
|
export const commandFactory =
|
|
<TOperation extends (...args: Parameters<TOperation>) => ReturnType<TOperation>>({
|
|
db,
|
|
eventBus,
|
|
operationFactory
|
|
}: {
|
|
db: Knex
|
|
eventBus?: EventBus
|
|
operationFactory: (arg: { db: Knex; emit: EventBusEmit }) => TOperation
|
|
}) =>
|
|
async (...args: Parameters<TOperation>): Promise<Awaited<ReturnType<TOperation>>> => {
|
|
const events: EmitArg[] = []
|
|
const emit: EventBusEmit = async ({ eventName, payload }) => {
|
|
events.push({ eventName, payload })
|
|
}
|
|
|
|
const trx = await db.transaction()
|
|
try {
|
|
const result = await operationFactory({ db, emit })(...args)
|
|
|
|
await trx.commit()
|
|
if (eventBus) {
|
|
for (const event of events) {
|
|
await eventBus.emit(event)
|
|
}
|
|
}
|
|
return result as Awaited<ReturnType<TOperation>>
|
|
} catch (err) {
|
|
trx.rollback()
|
|
throw err
|
|
}
|
|
}
|