Inputs models refactor

src/modules/pipelines/pipelines.service.ts

@@ -10,11 +10,25 @@ export class PipelinesService {
   constructor(private pipelineClient: PipelinesClientService) {}
 
   adjustPayload(payload) {
-    if (payload.input?.input_generic) {
-      payload.input = DecodeGrpcStruct(payload.input?.input_generic);
-    } else {
-      payload.input = payload.input?.input_s3 || payload.input?.input_jdbc;
+    const { input } = payload;
+    if (input) {
+      if (input.input_generic) {
+        const { credentials } = input.input_generic;
+        return {
+          ...input.input_generic,
+          credentials: credentials && JSON.parse(credentials),
+        };
+      }
+      if (input.input_s3) return input.input_s3;
+      if (input.input_jdbc) return input.input_jdbc;
+
+      const { credentials } = input;
+      return {
+        ...input,
+        credentials: credentials && JSON.parse(credentials),
+      };
     }
+    return input;
   }
 
   async create(createPipelineDto) {