[TECH] Ecrire dans PG le contenu pédagogique lorsqu'on provoque la cr…

…éation d'une nouvelle release (PIX-15470)

 #10667

api/src/learning-content/application/jobs/lcms-create-release-job-controller.js

@@ -0,0 +1,20 @@
+import { JobController } from '../../../shared/application/jobs/job-controller.js';
+import { logger } from '../../../shared/infrastructure/utils/logger.js';
+import { LcmsCreateReleaseJob } from '../../domain/models/LcmsCreateReleaseJob.js';
+import { usecases } from '../../domain/usecases/index.js';
+
+export class LcmsCreateReleaseJobController extends JobController {
+  constructor() {
+    super(LcmsCreateReleaseJob.name);
+  }
+
+  async handle() {
+    try {
+      await usecases.createLearningContentRelease();
+      logger.info('Learning Content cache updated with newly created release');
+    } catch (e) {
+      logger.error('Error while updating cache with newly created release', e);
+      throw e;
+    }
+  }
+}

api/src/learning-content/application/learning-content-controller.js

@@ -1,17 +1,10 @@
 import { sharedUsecases } from '../../shared/domain/usecases/index.js';
-import { logger } from '../../shared/infrastructure/utils/logger.js';
 import { usecases } from '../domain/usecases/index.js';
 
 const createRelease = async function (request, h) {
-  sharedUsecases
-    .createLcmsRelease()
-    .then(() => {
-      logger.info('Release created and cache reloaded');
-    })
-    .catch((e) => {
-      logger.error('Error while creating the release and reloading cache', e);
-    });
-  return h.response({}).code(204);
+  const { userId } = request.auth.credentials;
+  await usecases.scheduleCreateLearningContentReleaseJob({ userId });
+  return h.response({}).code(202);
 };
 
 const refreshCache = async function (request, h) {

api/src/learning-content/application/learning-content-route.js

@@ -19,7 +19,8 @@ export async function register(server) {
         tags: ['api', 'lcms'],
         notes: [
           'Cette route est restreinte aux utilisateurs authentifiés avec le rôle Super Admin',
-          'Elle permet de demander la création d’une nouvelle version au référentiel et de recharger le cache',
+          'Elle permet de lancer un job pour demander la création d’une nouvelle version au référentiel\n' +
+            ' et de recharger le cache',
         ],
       },
     },
@@ -74,7 +75,8 @@ export async function register(server) {
         tags: ['api', 'cache'],
         notes: [
           'Cette route est restreinte aux utilisateurs authentifiés avec le rôle Super Admin',
-          'Elle permet de précharger les entrées du cache de l’application (les requêtes les plus longues)',
+          'Elle permet de lancer un job pour précharger les entrées du cache de l’application \n' +
+            '(les requêtes les plus longues)',
         ],
       },
     },

api/src/learning-content/domain/models/LcmsCreateReleaseJob.js

@@ -0,0 +1,5 @@
+export class LcmsCreateReleaseJob {
+  constructor({ userId }) {
+    this.userId = userId;
+  }
+}

api/src/learning-content/domain/usecases/create-learning-content-release.js

@@ -0,0 +1,31 @@
+import { withTransaction } from '../../../shared/domain/DomainTransaction.js';
+
+export const createLearningContentRelease = withTransaction(
+  /** @param {import('./dependencies.js').Dependencies} */
+  async function createLearningContentRelease({
+    LearningContentCache,
+    frameworkRepository,
+    areaRepository,
+    competenceRepository,
+    thematicRepository,
+    tubeRepository,
+    challengeRepository,
+    skillRepository,
+    courseRepository,
+    tutorialRepository,
+    missionRepository,
+  }) {
+    const learningContent = await LearningContentCache.instance.update();
+
+    await frameworkRepository.save(learningContent.frameworks);
+    await areaRepository.save(learningContent.areas);
+    await competenceRepository.save(learningContent.competences);
+    await thematicRepository.save(learningContent.thematics);
+    await tubeRepository.save(learningContent.tubes);
+    await skillRepository.save(learningContent.skills);
+    await challengeRepository.save(learningContent.challenges);
+    await courseRepository.save(learningContent.courses);
+    await tutorialRepository.save(learningContent.tutorials);
+    await missionRepository.save(learningContent.missions);
+  },
+);

api/src/learning-content/domain/usecases/dependencies.js

@@ -4,6 +4,7 @@ import { challengeRepository } from '../../infrastructure/repositories/challenge
 import { competenceRepository } from '../../infrastructure/repositories/competence-repository.js';
 import { courseRepository } from '../../infrastructure/repositories/course-repository.js';
 import { frameworkRepository } from '../../infrastructure/repositories/framework-repository.js';
+import { lcmsCreateReleaseJobRepository } from '../../infrastructure/repositories/jobs/lcms-create-release-job-repository.js';
 import { lcmsRefreshCacheJobRepository } from '../../infrastructure/repositories/jobs/lcms-refresh-cache-job-repository.js';
 import { missionRepository } from '../../infrastructure/repositories/mission-repository.js';
 import { skillRepository } from '../../infrastructure/repositories/skill-repository.js';
@@ -23,6 +24,7 @@ export const dependencies = {
   tutorialRepository,
   missionRepository,
   lcmsRefreshCacheJobRepository,
+  lcmsCreateReleaseJobRepository,
   LearningContentCache,
 };
 

api/src/learning-content/domain/usecases/schedule-create-learning-content-release-job.js

@@ -0,0 +1,10 @@
+import { LcmsCreateReleaseJob } from '../models/LcmsCreateReleaseJob.js';
+
+/**
+ * @param {{
+ *   userId: number
+ * } & import('./dependencies.js').Dependencies}
+ */
+export async function scheduleCreateLearningContentReleaseJob({ userId, lcmsCreateReleaseJobRepository }) {
+  await lcmsCreateReleaseJobRepository.performAsync(new LcmsCreateReleaseJob({ userId }));
+}

api/src/learning-content/infrastructure/repositories/jobs/lcms-create-release-job-repository.js

@@ -0,0 +1,13 @@
+import { JobRepository, JobRetry } from '../../../../shared/infrastructure/repositories/jobs/job-repository.js';
+import { LcmsCreateReleaseJob } from '../../../domain/models/LcmsCreateReleaseJob.js';
+
+class LcmsCreateReleaseJobRepository extends JobRepository {
+  constructor() {
+    super({
+      name: LcmsCreateReleaseJob.name,
+      retry: JobRetry.NO_RETRY,
+    });
+  }
+}
+
+export const lcmsCreateReleaseJobRepository = new LcmsCreateReleaseJobRepository();