feat(api): wrap usecase with withTransaction

for terminate passage

Author: er-lim

api/src/devcomp/domain/usecases/terminate-passage.js

@@ -1,8 +1,14 @@
+import { withTransaction } from '../../../shared/domain/DomainTransaction.js';
 import { NotFoundError } from '../../../shared/domain/errors.js';
 import { PassageDoesNotExistError, PassageTerminatedError } from '../errors.js';
 import { PassageTerminatedEvent } from '../models/passage-events/passage-events.js';
 
-async function terminatePassage({ passageId, requestTimestamp, passageRepository, passageEventRepository }) {
+const terminatePassage = withTransaction(async function ({
+  passageId,
+  requestTimestamp,
+  passageRepository,
+  passageEventRepository,
+}) {
   const passage = await _getPassage({ passageId, passageRepository });
   if (passage.terminatedAt) {
     throw new PassageTerminatedError();
@@ -15,7 +21,7 @@ async function terminatePassage({ passageId, requestTimestamp, passageRepository
   });
   await passageEventRepository.record(event);
   return terminatedPassage;
-}
+});
 
 async function _getPassage({ passageId, passageRepository }) {
   try {

api/tests/devcomp/unit/domain/usecases/terminate-passage_test.js

@@ -1,10 +1,15 @@
 import { PassageDoesNotExistError, PassageTerminatedError } from '../../../../../src/devcomp/domain/errors.js';
 import { PassageTerminatedEvent } from '../../../../../src/devcomp/domain/models/passage-events/passage-events.js';
 import { terminatePassage } from '../../../../../src/devcomp/domain/usecases/terminate-passage.js';
+import { DomainTransaction } from '../../../../../src/shared/domain/DomainTransaction.js';
 import { NotFoundError } from '../../../../../src/shared/domain/errors.js';
 import { catchErr, expect, sinon } from '../../../../test-helper.js';
 
 describe('Unit | Devcomp | Domain | UseCases | terminate-passage', function () {
+  beforeEach(function () {
+    sinon.stub(DomainTransaction, 'execute').callsFake((lambda) => lambda());
+  });
+
   describe('#terminatePassage', function () {
     describe('when passage is not found', function () {
       it('should throw a PassageDoesNotExistError', async function () {