feat(api): add importUserLastLoggedAt script

Author: P-Jeremy

api/src/identity-access-management/scripts/import-user-last-logged-at.script.js

@@ -0,0 +1,44 @@
+import Joi from 'joi';
+
+import { csvFileParser } from '../../shared/application/scripts/parsers.js';
+import { Script } from '../../shared/application/scripts/script.js';
+import { ScriptRunner } from '../../shared/application/scripts/script-runner.js';
+import { DomainTransaction } from '../../shared/domain/DomainTransaction.js';
+import { usecases } from '../domain/usecases/index.js';
+
+export const csvSchemas = [
+  { name: 'userId', schema: Joi.number().required() },
+  { name: 'last_activity', schema: Joi.date().required() },
+];
+
+export class ImportUserLAstLogeedAtScript extends Script {
+  constructor() {
+    super({
+      description: 'This script allows to update user last logged at',
+      permanent: false,
+      options: {
+        file: {
+          type: 'string',
+          describe: 'CSV file path',
+          demandOption: true,
+          coerce: csvFileParser(csvSchemas),
+        },
+      },
+    });
+  }
+  async handle({ options, importUserLastLoggedAt = usecases.importUserLastLoggedAt }) {
+    const { file } = options;
+
+    await DomainTransaction.execute(async () => {
+      for (const row of file) {
+        const { userId, last_activity } = row;
+        await importUserLastLoggedAt({
+          userId,
+          lastActivity: last_activity,
+        });
+      }
+    });
+  }
+}
+
+await ScriptRunner.execute(import.meta.url, ImportUserLAstLogeedAtScript);

api/tests/identity-access-management/unit/scripts/import-user-last-logged-at.script.test.js

@@ -0,0 +1,59 @@
+import * as url from 'node:url';
+
+import sinon from 'sinon';
+
+import { ImportUserLAstLogeedAtScript } from '../../../../src/identity-access-management/scripts/import-user-last-logged-at.script.js';
+import { expect } from '../../../test-helper.js';
+
+const currentDirectory = url.fileURLToPath(new URL('.', import.meta.url));
+
+describe('ImportUserLAstLogeedAtScript', function () {
+  describe('Options', function () {
+    it('parses CSV file correctly', async function () {
+      // given
+      const testCsvFile = `${currentDirectory}files/new-update-last-logged-at.csv`;
+      const script = new ImportUserLAstLogeedAtScript();
+
+      // when
+      const { options } = script.metaInfo;
+      const fileData = await options.file.coerce(testCsvFile);
+
+      // then
+      expect(fileData).to.deep.equal([
+        { userId: 1234, last_activity: new Date('2017-09-05T14:00:08Z') },
+        { userId: 4567, last_activity: new Date('2018-03-02T15:26:16Z') },
+      ]);
+    });
+  });
+
+  describe('#handle', function () {
+    let script;
+    let importUserLastLoggedAt;
+
+    beforeEach(function () {
+      script = new ImportUserLAstLogeedAtScript();
+      importUserLastLoggedAt = sinon.stub();
+    });
+
+    it('runs the script', async function () {
+      // given
+      const file = [
+        { userId: 1234, last_activity: '2017-09-05 14:00:08+0000' },
+        { userId: 4567, last_activity: '2018-03-02 15:26:16+0000' },
+      ];
+
+      // when
+      await script.handle({ options: { file }, importUserLastLoggedAt });
+
+      // then
+      expect(importUserLastLoggedAt).to.have.been.calledWith({
+        userId: 1234,
+        lastActivity: '2017-09-05 14:00:08+0000',
+      });
+      expect(importUserLastLoggedAt).to.have.been.calledWith({
+        userId: 4567,
+        lastActivity: '2018-03-02 15:26:16+0000',
+      });
+    });
+  });
+});