[FEATURE] Supprimer les learners précédent l'ajout de l'import à format (Pix-15428)

api/src/organizational-entities/application/organization/organization.admin.controller.js

@@ -20,7 +20,10 @@ const attachChildOrganization = async function (request, h) {
 };
 
 const addOrganizationFeatureInBatch = async function (request, h) {
-  await usecases.addOrganizationFeatureInBatch({ filePath: request.payload.path });
+  await usecases.addOrganizationFeatureInBatch({
+    userId: request.auth.credentials.userId,
+    filePath: request.payload.path,
+  });
   return h.response().code(204);
 };
 

api/src/organizational-entities/domain/usecases/add-organization-feature-in-batch.js

@@ -6,6 +6,7 @@ import { createReadStream } from 'node:fs';
 
 import { CsvColumn } from '../../../../lib/infrastructure/serializers/csv/csv-column.js';
 import { getDataBuffer } from '../../../prescription/learner-management/infrastructure/utils/bufferize/get-data-buffer.js';
+import { withTransaction } from '../../../shared/domain/DomainTransaction.js';
 import { CsvParser } from '../../../shared/infrastructure/serializers/csv/csv-parser.js';
 import { FeatureParamsNotProcessable } from '../errors.js';
 import { OrganizationFeature } from '../models/OrganizationFeature.js';
@@ -30,28 +31,28 @@ const organizationFeatureCsvHeader = {
   ],
 };
 
-/**
- * @param {Object} params - A parameter object.
- * @param {string} params.featureId - feature id to add.
- * @param {string} params.filePath - path of csv file wich contains organizations and params.
- * @param {OrganizationFeatureRepository} params.organizationFeatureRepository - organizationRepository to use.
- * @param {Object} params.dependencies
- * @returns {Promise<void>}
- */
-async function addOrganizationFeatureInBatch({ filePath, organizationFeatureRepository }) {
-  const stream = createReadStream(filePath);
-  const buffer = await getDataBuffer(stream);
-
-  const csvParser = new CsvParser(buffer, organizationFeatureCsvHeader);
-  const csvData = csvParser.parse();
-  const data = csvData.map(({ featureId, organizationId, params }) => {
-    try {
-      return new OrganizationFeature({ featureId, organizationId, params: params });
-    } catch (err) {
-      throw new FeatureParamsNotProcessable();
-    }
-  });
-  return organizationFeatureRepository.saveInBatch(data);
-}
+export const addOrganizationFeatureInBatch = withTransaction(
+  /**
+   * @param {Object} params - A parameter object.
+   * @param {Number} params.userId - user connected performing action
+   * @param {string} params.filePath - path of csv file wich contains organizations and params.
+   * @param {OrganizationFeatureRepository} params.organizationFeatureRepository - organizationRepository to use.
+   * @param {Object} params.dependencies
+   * @returns {Promise<void>}
+   */
+  async ({ filePath, organizationFeatureRepository }) => {
+    const stream = createReadStream(filePath);
+    const buffer = await getDataBuffer(stream);
 
-export { addOrganizationFeatureInBatch };
+    const csvParser = new CsvParser(buffer, organizationFeatureCsvHeader);
+    const csvData = csvParser.parse();
+    const data = csvData.map(({ featureId, organizationId, params }) => {
+      try {
+        return new OrganizationFeature({ featureId, organizationId, params: params });
+      } catch (err) {
+        throw new FeatureParamsNotProcessable();
+      }
+    });
+    return organizationFeatureRepository.saveInBatch(data);
+  },
+);

api/tests/organizational-entities/unit/domain/usecases/add-organization-feature-in-batch_test.js

@@ -1,12 +1,17 @@
 import { FeatureParamsNotProcessable } from '../../../../../src/organizational-entities/domain/errors.js';
 import { OrganizationFeature } from '../../../../../src/organizational-entities/domain/models/OrganizationFeature.js';
 import { addOrganizationFeatureInBatch } from '../../../../../src/organizational-entities/domain/usecases/add-organization-feature-in-batch.js';
+import { DomainTransaction } from '../../../../../src/shared/domain/DomainTransaction.js';
 import { catchErr, createTempFile, expect, removeTempFile, sinon } from '../../../../test-helper.js';
 
 describe('Unit | Domain | UseCases | add-organization-feature-in-batch', function () {
   let organizationFeatureRepository, featureId, filePath, csvData;
 
   beforeEach(function () {
+    sinon.stub(DomainTransaction, 'execute').callsFake((callback) => {
+      return callback();
+    });
+
     featureId = 1;
     csvData = [
       new OrganizationFeature({ featureId, organizationId: 123, params: `{ "id": 123 }` }),