Merge pull request #2851 from RedisInsight/feature/RI-5220_display_db_information

Feature/ri 5220 display db information

Author: mariasergeenko

redisinsight/api/src/modules/cloud/job/dto/import-database.cloud-job.data.dto.ts

@@ -1,5 +1,5 @@
 import { ApiProperty } from '@nestjs/swagger';
-import { IsNotEmpty, IsNumber } from 'class-validator';
+import { IsNotEmpty, IsNumber, IsString } from 'class-validator';
 
 export class ImportDatabaseCloudJobDataDto {
   @ApiProperty({
@@ -17,4 +17,20 @@ export class ImportDatabaseCloudJobDataDto {
   @IsNumber()
   @IsNotEmpty()
   databaseId: number;
+
+  @ApiProperty({
+    description: 'Subscription region',
+    type: String,
+  })
+  @IsString()
+  @IsNotEmpty()
+  region: string;
+
+  @ApiProperty({
+    description: 'Subscription provider',
+    type: String,
+  })
+  @IsString()
+  @IsNotEmpty()
+  provider: string;
 }

redisinsight/api/src/modules/cloud/job/exceptions/cloud-database-already-exists-free.exception.ts

@@ -5,7 +5,7 @@ import { CustomErrorCodes } from 'src/constants';
 export class CloudDatabaseAlreadyExistsFreeException extends HttpException {
   constructor(
     message = ERROR_MESSAGES.CLOUD_DATABASE_ALREADY_EXISTS_FREE,
-    options?: HttpExceptionOptions & { subscriptionId?: number, databaseId?: number },
+    options?: HttpExceptionOptions & { subscriptionId?: number, databaseId?: number, region?: string, provider?: string },
   ) {
     const response = {
       message,
@@ -15,6 +15,8 @@ export class CloudDatabaseAlreadyExistsFreeException extends HttpException {
       resource: {
         subscriptionId: options?.subscriptionId,
         databaseId: options?.databaseId,
+        region: options?.region,
+        provider: options?.provider,
       },
     };
 

redisinsight/api/src/modules/cloud/job/jobs/cloud-job.ts

@@ -24,6 +24,8 @@ export class CloudJobOptions {
   stateCallbacks?: ((self: CloudJob) => any)[] = [];
 
   name?: CloudJobName;
+
+  child?: boolean;
 }
 
 export abstract class CloudJob {
@@ -57,18 +59,22 @@ export abstract class CloudJob {
     }
 
     this.debounce = debounce(() => {
-      try {
-        (this.options?.stateCallbacks || []).forEach((cb) => {
-          cb?.(this)?.catch?.(() => {});
-        });
-      } catch (e) {
-        // silently ignore callback
-      }
+      this.triggerChangeStateCallbacks();
     }, 1_000, {
       maxWait: 2_000,
     });
   }
 
+  private triggerChangeStateCallbacks() {
+    try {
+      (this.options?.stateCallbacks || []).forEach((cb) => {
+        cb?.(this)?.catch?.(() => {});
+      });
+    } catch (e) {
+      // silently ignore callback
+    }
+  }
+
   public async run() {
     try {
       this.changeState({
@@ -127,8 +133,9 @@ export abstract class CloudJob {
     return new TargetJob(
       {
         ...this.options,
-        stateCallbacks: [() => this.changeState()],
         ...options,
+        stateCallbacks: [() => this.changeState()],
+        child: true,
       },
       data,
       this.dependencies,
@@ -154,7 +161,11 @@ export abstract class CloudJob {
   protected changeState(state = {}) {
     Object.entries(state).forEach(([key, value]) => { this[key] = value; });
 
-    this.debounce();
+    if (this.options.child) {
+      this.triggerChangeStateCallbacks();
+    } else {
+      this.debounce();
+    }
   }
 
   protected checkSignal() {

redisinsight/api/src/modules/cloud/job/jobs/create-free-database.cloud-job.ts

@@ -128,7 +128,11 @@ export class CreateFreeDatabaseCloudJob extends CloudJob {
         timeout: cloudConfig.cloudDatabaseConnectionTimeout,
       });
 
-      this.result = { resourceId: database.id };
+      this.result = {
+        resourceId: database.id,
+        region: freeSubscription?.region,
+        provider: freeSubscription?.provider,
+      };
 
       this.changeState({ status: CloudJobStatus.Finished });
 

redisinsight/api/src/modules/cloud/job/jobs/create-free-subscription-and-database.cloud-job.ts

@@ -12,7 +12,7 @@ import { CloudCapiKeyService } from 'src/modules/cloud/capi-key/cloud-capi-key.s
 import { CloudSubscription } from 'src/modules/cloud/subscription/models';
 
 export class CreateFreeSubscriptionAndDatabaseCloudJob extends CloudJob {
-  protected name = CloudJobName.CreateFreeDatabase;
+  protected name = CloudJobName.CreateFreeSubscriptionAndDatabase;
 
   constructor(
     readonly options: CloudJobOptions,
@@ -62,7 +62,11 @@ export class CreateFreeSubscriptionAndDatabaseCloudJob extends CloudJob {
       this.options,
     );
 
-    this.result = { resourceId: database.id };
+    this.result = {
+      resourceId: database.id,
+      region: freeSubscription?.region,
+      provider: freeSubscription?.provider,
+    };
 
     this.changeState({ status: CloudJobStatus.Finished });
 

redisinsight/api/src/modules/cloud/job/jobs/create-free-subscription.cloud-job.ts

@@ -70,6 +70,8 @@ export class CreateFreeSubscriptionCloudJob extends CloudJob {
         throw new CloudDatabaseAlreadyExistsFreeException(undefined, {
           subscriptionId: freeSubscription.id,
           databaseId: databases[0].databaseId,
+          region: freeSubscription?.region,
+          provider: freeSubscription?.provider,
         });
       }
 

redisinsight/api/src/modules/cloud/job/jobs/import-free-database.cloud-job.ts

@@ -17,13 +17,15 @@ import { CloudCapiKeyService } from 'src/modules/cloud/capi-key/cloud-capi-key.s
 const cloudConfig = config.get('cloud');
 
 export class ImportFreeDatabaseCloudJob extends CloudJob {
-  protected name = CloudJobName.CreateFreeDatabase;
+  protected name = CloudJobName.ImportFreeDatabase;
 
   constructor(
     readonly options: CloudJobOptions,
     private readonly data: {
       subscriptionId: number,
       databaseId: number,
+      region: string,
+      provider: string,
     },
     protected readonly dependencies: {
       cloudDatabaseCapiService: CloudDatabaseCapiService,
@@ -84,7 +86,11 @@ export class ImportFreeDatabaseCloudJob extends CloudJob {
       timeout: cloudConfig.cloudDatabaseConnectionTimeout,
     });
 
-    this.result = { resourceId: database.id };
+    this.result = {
+      resourceId: database.id,
+      region: this.data?.region,
+      provider: this.data?.provider,
+    };
 
     this.changeState({ status: CloudJobStatus.Finished });