#165 pb cron et expiration des invitations

#165

Author: alainabbas

…on/identities-init-invitation-expire.yml …defaults/cron/identities-init-expire.ymlapps/api/defaults/cron/identities-init-invitation-expire.yml renamed to apps/api/defaults/cron/identities-init-expire.yml apps/api/defaults/cron/identities-init-invitation-expire.yml renamed to apps/api/defaults/cron/identities-init-expire.yml

@@ -1,7 +1,7 @@
 tasks:
-  - name: "identities-init-invitation-expire"
+  - name: "identities-init-expire"
     description: "Expiration des invitations d'initialisation de compte"
     enabled: true
     schedule: "1 * * * *"  # Tous les jours à 08:00
-    handler: "identities-init-invitation-expire"
+    handler: "identities-init-expire"
     options:

apps/api/src/core/cron/_functions/cron-command-options.function.ts

@@ -8,6 +8,15 @@ function getHandlerDescriptor(handler: string) {
   return getCronConsoleHandlers().find((entry) => entry.handler === handler);
 }
 
+/**
+ * Mots de la commande console d'un handler : utilise `command` déclaré via @CronConsoleHandler,
+ * sinon (handler non déclaré) découpe l'identifiant sur les tirets.
+ */
+export function resolveCronConsoleCommandWords(handler: string): string[] {
+  const descriptor = getHandlerDescriptor(handler);
+  return (descriptor?.command || handler.replace(/-/g, ' ')).split(/\s+/).filter(Boolean);
+}
+
 export function resolveCronConsoleArgumentFlag(argument: CronConsoleHandlerArgument): string {
   return argument.flag || `--${argument.name}`;
 }

apps/api/src/core/cron/cron-hooks.service.ts

@@ -9,7 +9,7 @@ import { loadcronTasks } from './_functions/load-cron-tasks.function';
 import { ConfigService } from '@nestjs/config';
 import { createHandlerLogger } from '~/_common/functions/handler-logger';
 import { resolveConfigVariables } from '~/_common/functions/resolve-config-variables.function';
-import { buildCronCommandArgs } from './_functions/cron-command-options.function';
+import { buildCronCommandArgs, resolveCronConsoleCommandWords } from './_functions/cron-command-options.function';
 
 @Injectable()
 export class CronHooksService {
@@ -177,7 +177,9 @@ export class CronHooksService {
     }
 
     // Supprimer les jobs qui ne sont plus dans les tâches désirées
-    for (const [name, job] of existingJobs) {
+    // Itère sur une copie : getCronJobs() renvoie la Map interne du registre, et un delete + add
+    // sur la même clé la replace en fin de Map, ce qui la ferait revisiter indéfiniment.
+    for (const [name, job] of Array.from(existingJobs)) {
       if (!name.startsWith('cron-task-')) continue;
 
       const desired = desiredTasks.get(name);
@@ -301,7 +303,7 @@ export class CronHooksService {
     const { positionalArgs, flagArgs } = buildCronCommandArgs(handler, resolvedOptions);
 
     const cmd = 'yarn';
-    const cmdArgs = ['run', 'console', ...handler.split('-'), ...positionalArgs, ...flagArgs];
+    const cmdArgs = ['run', 'console', ...resolveCronConsoleCommandWords(handler), ...positionalArgs, ...flagArgs];
 
     const handlerLogger = createHandlerLogger(this.configService, name);
     this.logger.log(`Spawning command: ${cmd} ${cmdArgs.join(' ')}`);

apps/api/src/management/identities/identities.command.ts

@@ -331,7 +331,7 @@ type IdentitiesInitExpireOptions = {
 };
 
 @CronConsoleHandler({
-  handler: 'identities-init-invitation-expire',
+  handler: 'identities-init-expire',
   command: 'identities init expire',
   label: "Expiration des invitations d'initialisation de compte",
   arguments: [