diff --git a/src/modules/transaction/transaction/domain/usecases/handlers/pos-transaction.handler.ts b/src/modules/transaction/transaction/domain/usecases/handlers/pos-transaction.handler.ts index 012655d..41e5128 100644 --- a/src/modules/transaction/transaction/domain/usecases/handlers/pos-transaction.handler.ts +++ b/src/modules/transaction/transaction/domain/usecases/handlers/pos-transaction.handler.ts @@ -31,6 +31,9 @@ export class PosTransactionHandler implements IEventHandler { ) {} async handle(event: ChangeDocEvent) { + const envSkipTransaction = process.env.SKIP_TRANSACTION_FEATURE ?? 'false'; + const activeSkipTransaction = envSkipTransaction == 'true'; + const apmTransactions = apm.startTransaction( `ChangeDocEvent ${event?.data?.database}`, 'handler', @@ -107,6 +110,7 @@ export class PosTransactionHandler implements IEventHandler { // Check if this transaction should be sent to the "black hole" (not saved) // This is only applicable for SETTLED transactions const shouldSkipSaving = + activeSkipTransaction && data.status === STATUS.SETTLED && (await this.formulaService.sentToBlackHole());