feat: Enhance LifecycleService with detailed logging and lifecycle source management

Author: tacxou

apps/api/src/management/lifecycle/lifecycle.service.ts

@@ -108,16 +108,31 @@ export class LifecycleService extends AbstractServiceSchema implements OnApplica
    * It also logs the lifecycle sources for debugging purposes.
    */
   public async onApplicationBootstrap(): Promise<void> {
-    if (isConsoleEntrypoint) {
-      this.logger.debug('Skipping LifecycleService bootstrap in console mode.');
-      return;
-    }
-
     this.logger.verbose('Bootstrap LifecycleService application...');
 
     const lifecycleRules = await this.loadLifecycleRules();
     await this.loadCustomStates();
 
+    for (const lfr of lifecycleRules) {
+      for (const idRule of lfr.identities) {
+        for (const source of idRule.sources) {
+          if (!this.lifecycleSources[source]) {
+            this.lifecycleSources[source] = [];
+          }
+          this.lifecycleSources[source].push(idRule);
+        }
+      }
+    }
+
+    this.logger.debug('Lifecycle sources loaded:', JSON.stringify(this.lifecycleSources, null, 2));
+
+    console.log('lifecycleRules:', lifecycleRules);
+
+    if (isConsoleEntrypoint) {
+      this.logger.debug('Skipping LifecycleService bootstrap in console mode.');
+      return;
+    }
+
     const cronExpression = this.configService.get<string>('lifecycle.triggerCronExpression') || '*/5 * * * *';
     const job = new CronJob(cronExpression, this.handleCron.bind(this, { lifecycleRules }));
     this.schedulerRegistry.addCronJob(`lifecycle-trigger`, job);
@@ -135,10 +150,16 @@ export class LifecycleService extends AbstractServiceSchema implements OnApplica
     this.logger.log('LifecycleService bootstraped');
   }
 
+  public async listLifecycles(): Promise<any> {
+    const lifecycles = this.lifecycleSources ? Object.keys(this.lifecycleSources) : [];
+    return this.lifecycleSources;
+  }
+
   private async handleCron({ lifecycleRules }: { lifecycleRules: ConfigRulesObjectSchemaDTO[] }): Promise<void> {
     this.logger.debug(`Running lifecycle trigger cron job...`);
 
     for (const lfr of lifecycleRules) {
+      console.log('Processing lifecycle rule:', JSON.stringify(lfr, null, 2));
       for (const idRule of lfr.identities) {
         if (idRule.trigger) {
           const dateKey = idRule.dateKey || 'lastLifecycleUpdate';
@@ -509,6 +530,8 @@ export class LifecycleService extends AbstractServiceSchema implements OnApplica
       // If the lifecycle has changed, we need to process the new lifecycle
     }
 
+    console.log('AH', after.lifecycle, this.lifecycleSources);
+
     if (this.lifecycleSources[after.lifecycle]) {
       this.logger.debug(`Processing lifecycle sources for identity <${after._id}> with lifecycle <${after.lifecycle}>`);
 
@@ -520,6 +543,13 @@ export class LifecycleService extends AbstractServiceSchema implements OnApplica
           continue; // Skip processing if it's a trigger-based rule
         }
 
+        console.log('LCS',
+          {
+            ...lcs.rules,
+            _id: after._id,
+            ignoreLifecycle: { $ne: true },
+          },);
+
         const res = await this.identitiesService.model.findOneAndUpdate(
           {
             ...lcs.rules,
@@ -537,6 +567,7 @@ export class LifecycleService extends AbstractServiceSchema implements OnApplica
             upsert: false, // Do not create a new document if no match is found
           }
         );
+        console.log('RES', res);
 
         if (!res) {
           this.logger.debug(`No identity found matching rules for lifecycle <${after.lifecycle}>`);