FEAT: Pipeline Version 2

src/modules/connection-test/connection-test.service.ts

@@ -96,13 +96,15 @@ export class ConnectionTestService {
         plugin,
       }),
     ).catch(async (e) => {
-      await this.connectionsService.deleteConnection({
-        body: { id: connection_id },
-        metadata,
-      });
+      if (!body.connection_id) {
+        await this.connectionsService.deleteConnection({
+          body: { id: connection_id },
+          metadata,
+        });
+      }
       throw e;
     });
-    if (!operation_result) {
+    if (!operation_result && !body.connection_id) {
       await this.connectionsService.deleteConnection({
         body: { id: connection_id },
         metadata,

src/modules/connection-test/dto/connection-test.ts

@@ -1,5 +1,5 @@
 import { ApiProperty, ApiPropertyOptional, OmitType } from '@nestjs/swagger';
-import { IsString, IsOptional, IsNumber, Max } from 'class-validator';
+import { IsString, IsOptional } from 'class-validator';
 import { DatabaseConnectionPropertiesDto } from 'src/modules/connection/dtos/connection';
 import { CreateConnectionDto } from 'src/modules/connection/dtos/connection';
 export class ColumnDto {
@@ -29,8 +29,6 @@ export class ConnectionTestPingReq {
   host: string;
 
   @ApiPropertyOptional()
-  @IsNumber()
-  @Max(65535)
   @IsOptional()
   port: number;