feat(api): record passage started event

by using module content as content hash

Author: er-lim

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

@@ -1,13 +1,26 @@
+import { withTransaction } from '../../../shared/domain/DomainTransaction.js';
 import { NotFoundError } from '../../../shared/domain/errors.js';
 import { ModuleDoesNotExistError } from '../errors.js';
+import { PassageStartedEvent } from '../models/passage-events/passage-events.js';
 
-const createPassage = async function ({ moduleId, userId, moduleRepository, passageRepository, userRepository }) {
-  await _getModule({ moduleId, moduleRepository });
+const createPassage = withTransaction(async function ({
+  moduleId,
+  userId,
+  moduleRepository,
+  passageRepository,
+  passageEventRepository,
+  userRepository,
+}) {
+  const module = await _getModule({ moduleId, moduleRepository });
   if (userId !== null) {
     await userRepository.get(userId);
   }
-  return passageRepository.save({ moduleId, userId });
-};
+
+  const passage = await passageRepository.save({ moduleId, userId });
+  await _recordPassageEvent({ module, passage, passageEventRepository });
+
+  return passage;
+});
 
 async function _getModule({ moduleId, moduleRepository }) {
   try {
@@ -20,4 +33,12 @@ async function _getModule({ moduleId, moduleRepository }) {
   }
 }
 
+async function _recordPassageEvent({ module, passage, passageEventRepository }) {
+  const { id: passageId, createdAt: occurredAt } = passage;
+  const contentHash = module.hash();
+  const passageStartedEvent = new PassageStartedEvent({ contentHash, passageId, occurredAt });
+
+  await passageEventRepository.record(passageStartedEvent);
+}
+
 export { createPassage };

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

@@ -1,4 +1,7 @@
 import { ModuleDoesNotExistError } from '../../../../../src/devcomp/domain/errors.js';
+import { Module } from '../../../../../src/devcomp/domain/models/module/Module.js';
+import { Passage } from '../../../../../src/devcomp/domain/models/Passage.js';
+import { PassageStartedEvent } from '../../../../../src/devcomp/domain/models/passage-events/passage-events.js';
 import { createPassage } from '../../../../../src/devcomp/domain/usecases/create-passage.js';
 import { UserNotFoundError } from '../../../../../src/shared/domain/errors.js';
 import { NotFoundError } from '../../../../../src/shared/domain/errors.js';
@@ -48,11 +51,38 @@ describe('Unit | Devcomp | Domain | UseCases | create-passage', function () {
     });
   });
 
-  it('should call passage repository to save the passage', async function () {
+  it('should save the passage and record passage started event', async function () {
     // given
     const moduleId = Symbol('moduleId');
+    const passageId = Symbol('passageId');
     const userId = Symbol('userId');
-    const repositoryResult = Symbol('repository-result');
+
+    const slug = 'les-adresses-email';
+    const title = 'Les adresses email';
+    const isBeta = false;
+    const grains = [Symbol('text')];
+    const transitionTexts = [];
+    const details = Symbol('details');
+    const hash = 'AZERTY123456';
+    let module = new Module({ id: moduleId, slug, title, isBeta, grains, details, transitionTexts });
+    module = {
+      ...module,
+      hash: sinon.stub().returns(hash),
+    };
+
+    const passageCreatedAt = new Date('2025-03-05');
+    const passage = new Passage({
+      id: passageId,
+      moduleId,
+      userId,
+      createdAt: passageCreatedAt,
+    });
+
+    const passageStartedEvent = new PassageStartedEvent({
+      contentHash: hash,
+      occurredAt: passageCreatedAt,
+      passageId,
+    });
 
     const userRepositoryStub = {
       get: sinon.stub(),
@@ -61,17 +91,22 @@ describe('Unit | Devcomp | Domain | UseCases | create-passage', function () {
     const moduleRepositoryStub = {
       getBySlug: sinon.stub(),
     };
-    moduleRepositoryStub.getBySlug.withArgs({ slug: moduleId }).resolves();
+    moduleRepositoryStub.getBySlug.withArgs({ slug: moduleId }).resolves(module);
     const passageRepositoryStub = {
       save: sinon.stub(),
     };
-    passageRepositoryStub.save.resolves(repositoryResult);
+    passageRepositoryStub.save.resolves(passage);
+
+    const passageEventRepositoryStub = {
+      record: sinon.stub(),
+    };
 
     // when
     const result = await createPassage({
       moduleId,
       userId,
       passageRepository: passageRepositoryStub,
+      passageEventRepository: passageEventRepositoryStub,
       moduleRepository: moduleRepositoryStub,
       userRepository: userRepositoryStub,
     });
@@ -81,6 +116,8 @@ describe('Unit | Devcomp | Domain | UseCases | create-passage', function () {
       moduleId,
       userId,
     });
-    expect(result).to.equal(repositoryResult);
+    expect(module.hash).to.have.been.calledOnce;
+    expect(passageEventRepositoryStub.record).to.have.been.calledOnceWith(passageStartedEvent);
+    expect(result).to.equal(passage);
   });
 });