feat(api): removed yargs deprecated methods

Author: alicegoarnisson

Diff for: api/scripts/prod/clean-ke-snapshots.js

@@ -29,6 +29,10 @@ function getKnowlegdeElementSnapshotCount() {
   return getKnowlegdeElementSnapshotsQuery().count({ count: 1 }).first();
 }
 
+UPDATE products
+SET details = jsonb_set(details, '{specs,storage}', '"1TB SSD"')
+WHERE name = 'Laptop';
+
 // Définition du script
 export class CleanKeSnapshotScript extends Script {
   constructor() {

Diff for: api/scripts/prod/generate-knowledge-element-snapshots-for-campaigns.js

@@ -1,7 +1,5 @@
 import * as url from 'node:url';
 
-import yargs from 'yargs';
-
 import { disconnect, knex } from '../../db/knex-database-connection.js';
 import * as knowledgeElementSnapshotRepository from '../../src/prescription/campaign/infrastructure/repositories/knowledge-element-snapshot-repository.js';
 import { KnowledgeElementCollection } from '../../src/prescription/shared/domain/models/KnowledgeElementCollection.js';
@@ -12,39 +10,7 @@ import { PromiseUtils } from '../../src/shared/infrastructure/utils/promise-util
 const DEFAULT_MAX_SNAPSHOT_COUNT = 5000;
 const DEFAULT_CONCURRENCY = 3;
 
-function _validateAndNormalizeMaxSnapshotCount(maxSnapshotCount) {
-  if (isNaN(maxSnapshotCount)) {
-    maxSnapshotCount = DEFAULT_MAX_SNAPSHOT_COUNT;
-  }
-  if (maxSnapshotCount <= 0 || maxSnapshotCount > 50000) {
-    throw new Error(`Nombre max de snapshots ${maxSnapshotCount} ne peut pas être inférieur à 1 ni supérieur à 50000.`);
-  }
-
-  return maxSnapshotCount;
-}
-
-function _validateAndNormalizeConcurrency(concurrency) {
-  if (isNaN(concurrency)) {
-    concurrency = DEFAULT_CONCURRENCY;
-  }
-  if (concurrency <= 0 || concurrency > 10) {
-    throw new Error(`Concurrent ${concurrency} ne peut pas être inférieur à 1 ni supérieur à 10.`);
-  }
-
-  return concurrency;
-}
-
-function _validateAndNormalizeArgs({ concurrency, maxSnapshotCount }) {
-  const finalMaxSnapshotCount = _validateAndNormalizeMaxSnapshotCount(maxSnapshotCount);
-  const finalConcurrency = _validateAndNormalizeConcurrency(concurrency);
-
-  return {
-    maxSnapshotCount: finalMaxSnapshotCount,
-    concurrency: finalConcurrency,
-  };
-}
-
-async function getEligibleCampaignParticipations(maxSnapshotCount) {
+async function getEligibleCampaignParticipations(maxSnapshotCount = DEFAULT_MAX_SNAPSHOT_COUNT) {
   return knex('campaign-participations')
     .select('campaign-participations.id', 'campaign-participations.userId', 'campaign-participations.sharedAt')
     .leftJoin(
@@ -60,7 +26,7 @@ async function getEligibleCampaignParticipations(maxSnapshotCount) {
 
 async function generateKnowledgeElementSnapshots(
   campaignParticipationData,
-  concurrency,
+  concurrency = DEFAULT_CONCURRENCY,
   dependencies = { knowledgeElementRepository, knowledgeElementSnapshotRepository },
 ) {
   return PromiseUtils.map(
@@ -90,23 +56,9 @@ const modulePath = url.fileURLToPath(import.meta.url);
 const isLaunchedFromCommandLine = process.argv[1] === modulePath;
 
 async function main() {
-  const commandLineArgs = yargs
-    .option('maxSnapshotCount', {
-      description: 'Nombre de snapshots max. à générer.',
-      type: 'number',
-      default: DEFAULT_MAX_SNAPSHOT_COUNT,
-    })
-    .option('concurrency', {
-      description: 'Concurrence',
-      type: 'number',
-      default: DEFAULT_CONCURRENCY,
-    })
-    .help().argv;
-  const { maxSnapshotCount, concurrency } = _validateAndNormalizeArgs(commandLineArgs);
-
-  const campaignParticipationData = await getEligibleCampaignParticipations(maxSnapshotCount);
+  const campaignParticipationData = await getEligibleCampaignParticipations();
 
-  await generateKnowledgeElementSnapshots(campaignParticipationData, concurrency);
+  await generateKnowledgeElementSnapshots(campaignParticipationData);
 }
 
 (async () => {
@@ -115,7 +67,6 @@ async function main() {
       await main();
     } catch (error) {
       console.error('\x1b[31mErreur : %s\x1b[0m', error.message);
-      yargs.showHelp();
       process.exitCode = 1;
     } finally {
       await disconnect();