Ajouter les modifications du module BackendsModule

Author: tacxou

Makefile

@@ -44,7 +44,7 @@ exec: ## Run a shell in the container
 		--platform $(PLATFORM) \
 		--network dev \
 		-v $(CURDIR):/data \
-		$(IMG_NAME) sh
+		$(IMG_NAME) bash
 
 dbs: ## Start databases
 	@docker volume create $(BASE_NAME)-mongodb

src/cli/backends.command.ts

@@ -0,0 +1,33 @@
+import { ModuleRef } from '@nestjs/core';
+import { Command, CommandRunner, SubCommand } from 'nest-commander';
+import { BackendsService } from '~/core/backends/backends.service';
+
+@SubCommand({ name: 'syncall' })
+export class BackendsSyncallCommand extends CommandRunner {
+  public constructor(
+    protected moduleRef: ModuleRef,
+    private readonly backendsService: BackendsService,
+  ) {
+    super();
+  }
+
+  // eslint-disable-next-line @typescript-eslint/no-unused-vars
+  async run(inputs: string[], options: any): Promise<void> {
+    const result = await this.backendsService.syncAllIdentities({
+      async: true,
+    });
+    for (const identity of Object.values(result)) {
+      console.log(identity);
+    }
+  }
+}
+
+@Command({ name: 'backends', arguments: '<task>', subCommands: [BackendsSyncallCommand] })
+export class BackendsCommand extends CommandRunner {
+  public constructor(protected moduleRef: ModuleRef) {
+    super();
+  }
+
+  // eslint-disable-next-line @typescript-eslint/no-unused-vars
+  async run(inputs: string[], options: any): Promise<void> {}
+}

src/cli/cli.module.ts

@@ -10,6 +10,8 @@ import config, { MongoosePlugin } from '~/config';
 import { AgentsModule } from '~/core/agents/agents.module';
 import { KeyringsCommand, KeyringsCreateQuestions } from './keyrings.command';
 import { KeyringsModule } from '~/core/keyrings/keyrings.module';
+import { BackendsCommand } from './backends.command';
+import { BackendsModule } from '~/core/backends/backends.module';
 
 @Module({
   imports: [
@@ -54,10 +56,12 @@ import { KeyringsModule } from '~/core/keyrings/keyrings.module';
     }),
     AgentsModule,
     KeyringsModule,
+    BackendsModule,
   ],
   providers: [
     ...AgentsCommand.registerWithSubCommands(),
     ...KeyringsCommand.registerWithSubCommands(),
+    ...BackendsCommand.registerWithSubCommands(),
     AgentCreateQuestions,
     KeyringsCreateQuestions,
   ],

src/core/backends/backends.module.ts

@@ -9,5 +9,6 @@ import { TasksModule } from '../tasks/tasks.module';
   imports: [ConfigModule, IdentitiesModule, JobsModule, TasksModule],
   controllers: [BackendsController],
   providers: [BackendsService],
+  exports: [BackendsService],
 })
 export class BackendsModule {}

src/core/backends/backends.service.ts

@@ -212,6 +212,11 @@ export class BackendsService extends AbstractQueueProcessor {
       state: JobState.CREATED,
       ...optionals,
     });
+    await this.identitiesService.model.findByIdAndUpdate(concernedTo, {
+      $set: {
+        state: IdentityState.PROCESSING,
+      },
+    });
     if (!options?.async) {
       let error: Error;
       try {

src/management/identities/_enums/states.enum.ts

@@ -1,5 +1,6 @@
 export enum IdentityState {
-  SYNCED = 3,
+  SYNCED = 99,
+  PROCESSING = 50,
   TO_SYNC = 2,
   TO_VALIDATE = 1,
   UNKNOWN = 0,