Merge pull request #484 from dadosfera/feature/table-schema-filter

Feature/table schema filter
FEAT: list schema and filter assets by schema
2026-09-01 20:28:17 +00:00 · 2026-04-23 15:16:11 -03:00 · 2026-04-23 15:15:14 -03:00 · 2026-04-20 10:46:37 -03:00 · 2026-04-16 15:02:20 -03:00 · 2026-04-16 14:58:19 -03:00
25 changed files with 885 additions and 708 deletions
@@ -22,7 +22,7 @@ ENV PUPPETEER_SKIP_CHROMIUM_DOWNLOAD=true \
 # run aws cli without mounting secret, because CI already has AWS credentials
 FROM build_base AS ci_image
 RUN aws codeartifact login --tool npm --namespace @dadosfera --repository dadosfera-npm --domain dadosfera --domain-owner 611330257153 --region us-east-1
-RUN npm ci
+RUN npm ci --ignore-scripts
 COPY . .


@@ -37,7 +37,7 @@ FROM build_base AS dev
 RUN --mount=type=secret,id=aws,target=/root/.aws/credentials \
  aws codeartifact login --tool npm --namespace @dadosfera --repository dadosfera-npm --domain dadosfera --domain-owner 611330257153 --region us-east-1
 # flag --build-from-source is required to force-build sqlite3
-RUN npm ci
+RUN npm ci --ignore-scripts
 COPY . .
 ENTRYPOINT npm run start:dev

@@ -22,7 +22,7 @@ ENV PUPPETEER_SKIP_CHROMIUM_DOWNLOAD=true \
 FROM build_base AS build
 RUN --mount=type=secret,id=aws,target=/root/.aws/credentials \
  aws codeartifact login --tool npm --namespace @dadosfera --repository dadosfera-npm --domain dadosfera --domain-owner 611330257153 --region us-east-1
-RUN npm ci
+RUN  npm ci --ignore-scripts
 COPY . .
 RUN npm run build

@@ -3001,14 +3001,7 @@
          "parameters": [],
          "responses": {
            "200": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
+              "description": ""
            }
          },
          "tags": [
@@ -3583,14 +3576,7 @@
          ],
          "responses": {
            "200": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
+              "description": ""
            }
          },
          "tags": [
@@ -4533,6 +4519,50 @@
          ]
        }
      },
+      "/platform/pipeline/{pipelineId}/pipeline_run/{runId}/cancel": {
+        "post": {
+          "operationId": "PlatformApiController_cancelPipelineRun",
+          "summary": "Cancel a running pipeline run",
+          "parameters": [
+            {
+              "name": "pipelineId",
+              "required": true,
+              "in": "path",
+              "schema": {
+                "type": "string"
+              }
+            },
+            {
+              "name": "runId",
+              "required": true,
+              "in": "path",
+              "schema": {
+                "type": "string"
+              }
+            }
+          ],
+          "responses": {
+            "201": {
+              "description": "",
+              "content": {
+                "application/json": {
+                  "schema": {
+                    "type": "object"
+                  }
+                }
+              }
+            }
+          },
+          "tags": [
+            "Platform API"
+          ],
+          "security": [
+            {
+              "access-token": []
+            }
+          ]
+        }
+      },
      "/platform/jobs/{jobId}/input": {
        "put": {
          "operationId": "PlatformApiController_updateJobInput",
@@ -4675,13 +4705,21 @@
          ]
        }
      },
-      "/platform/jobs/jdbc/{jobId}": {
-        "get": {
-          "operationId": "PlatformApiController_getJdbcJob",
-          "summary": "Get JDBC job details",
+      "/platform/pipelines/{pipelineId}/inputs/{inputId}": {
+        "delete": {
+          "operationId": "PlatformApiController_deleteTable",
+          "summary": "Mark a table as deleted and delete its associated job via platform-api",
          "parameters": [
            {
-              "name": "jobId",
+              "name": "pipelineId",
+              "required": true,
+              "in": "path",
+              "schema": {
+                "type": "string"
+              }
+            },
+            {
+              "name": "inputId",
              "required": true,
              "in": "path",
              "schema": {
@@ -4691,50 +4729,7 @@
          ],
          "responses": {
            "200": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
-            }
-          },
-          "tags": [
-            "Platform API"
-          ],
-          "security": [
-            {
-              "access-token": []
-            }
-          ]
-        }
-      },
-      "/platform/jobs/jdbc/{jobId}/sync-mode": {
-        "post": {
-          "operationId": "PlatformApiController_updateJdbcSyncMode",
-          "summary": "Update JDBC job sync mode",
-          "parameters": [
-            {
-              "name": "jobId",
-              "required": true,
-              "in": "path",
-              "schema": {
-                "type": "string"
-              }
-            }
-          ],
-          "responses": {
-            "201": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
+              "description": ""
            }
          },
          "tags": [
@@ -4774,114 +4769,6 @@
          ]
        }
      },
-      "/platform/jobs/singer/{jobId}": {
-        "get": {
-          "operationId": "PlatformApiController_getSingerJob",
-          "summary": "Get Singer job details",
-          "parameters": [
-            {
-              "name": "jobId",
-              "required": true,
-              "in": "path",
-              "schema": {
-                "type": "string"
-              }
-            }
-          ],
-          "responses": {
-            "200": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
-            }
-          },
-          "tags": [
-            "Platform API"
-          ],
-          "security": [
-            {
-              "access-token": []
-            }
-          ]
-        }
-      },
-      "/platform/jobs/singer/{jobId}/sync-mode": {
-        "post": {
-          "operationId": "PlatformApiController_updateSingerSyncMode",
-          "summary": "Update Singer job sync mode",
-          "parameters": [
-            {
-              "name": "jobId",
-              "required": true,
-              "in": "path",
-              "schema": {
-                "type": "string"
-              }
-            }
-          ],
-          "responses": {
-            "201": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
-            }
-          },
-          "tags": [
-            "Platform API"
-          ],
-          "security": [
-            {
-              "access-token": []
-            }
-          ]
-        }
-      },
-      "/platform/jobs/s3/{jobId}": {
-        "get": {
-          "operationId": "PlatformApiController_getS3Job",
-          "summary": "Get S3 job details",
-          "parameters": [
-            {
-              "name": "jobId",
-              "required": true,
-              "in": "path",
-              "schema": {
-                "type": "string"
-              }
-            }
-          ],
-          "responses": {
-            "200": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
-            }
-          },
-          "tags": [
-            "Platform API"
-          ],
-          "security": [
-            {
-              "access-token": []
-            }
-          ]
-        }
-      },
      "/platform/health": {
        "get": {
          "operationId": "PlatformApiController_healthCheck",
@@ -5546,6 +5433,48 @@
          ]
        }
      },
+      "/catalog/schemas": {
+        "get": {
+          "operationId": "CatalogController_findSchemas",
+          "parameters": [
+            {
+              "name": "dadosfera-lang",
+              "in": "header",
+              "required": false,
+              "schema": {
+                "enum": [
+                  "pt-br",
+                  "en-us"
+                ],
+                "type": "string"
+              }
+            }
+          ],
+          "responses": {
+            "200": {
+              "description": "",
+              "content": {
+                "application/json": {
+                  "schema": {
+                    "type": "object"
+                  }
+                }
+              }
+            }
+          },
+          "tags": [
+            "Catalog"
+          ],
+          "security": [
+            {
+              "access-token": []
+            },
+            {
+              "access-token": []
+            }
+          ]
+        }
+      },
      "/catalog/data-asset/{id}": {
        "get": {
          "operationId": "CatalogController_getDataAsset",
@@ -10125,6 +10054,21 @@
            "entities"
          ]
        },
+        "Column": {
+          "type": "object",
+          "properties": {
+            "name": {
+              "type": "string"
+            },
+            "type": {
+              "type": "string"
+            }
+          },
+          "required": [
+            "name",
+            "type"
+          ]
+        },
        "TableColumns": {
          "type": "object",
          "properties": {
@@ -10140,13 +10084,7 @@
            "references": {
              "type": "array",
              "items": {
-                "type": "string"
-              }
-            },
-            "identifier_columns": {
-              "type": "array",
-              "items": {
-                "type": "string"
+                "$ref": "#/components/schemas/Column"
              }
            },
            "destination": {
@@ -10154,13 +10092,20 @@
            },
            "type": {
              "type": "string"
+            },
+            "identifier_columns": {
+              "type": "array",
+              "items": {
+                "type": "string"
+              }
+            },
+            "reference_column": {
+              "$ref": "#/components/schemas/Column"
            }
          },
          "required": [
            "name",
            "columns",
-            "references",
-            "identifier_columns",
            "destination",
            "type"
          ]
@@ -10466,7 +10411,7 @@
            "enabled"
          ]
        },
-        "CustomerLink": {
+        "CustomerLinkItem": {
          "type": "object",
          "properties": {
            "href": {
@@ -10488,28 +10433,61 @@
            "description"
          ]
        },
-        "CustomerLinksResponse": {
+        "CustomerSidebarSection": {
          "type": "object",
          "properties": {
-            "links": {
+            "title": {
+              "type": "object"
+            },
+            "items": {
              "type": "array",
              "items": {
-                "$ref": "#/components/schemas/CustomerLink"
+                "oneOf": [
+                  {
+                    "$ref": "#/components/schemas/CustomerSidebarMenuItem"
+                  },
+                  {
+                    "$ref": "#/components/schemas/CustomerSidebarLinkItem"
+                  }
+                ]
              }
            }
          },
          "required": [
-            "links"
+            "title",
+            "items"
          ]
        },
+        "CustomerLinksConfig": {
+          "type": "object",
+          "properties": {
+            "home": {
+              "type": "array",
+              "items": {
+                "$ref": "#/components/schemas/CustomerLinkItem"
+              }
+            },
+            "sidebar": {
+              "type": "array",
+              "items": {
+                "$ref": "#/components/schemas/CustomerSidebarSection"
+              }
+            }
+          }
+        },
+        "CustomerLinksResponse": {
+          "type": "object",
+          "properties": {
+            "links": {
+              "$ref": "#/components/schemas/CustomerLinksConfig"
+            }
+          }
+        },
        "CustomerLinkRequest": {
          "type": "object",
          "properties": {
            "links": {
-              "type": "array",
-              "items": {
-                "$ref": "#/components/schemas/CustomerLink"
-              }
+              "$ref": "#/components/schemas/CustomerLinksConfig"
            }
          },
          "required": [
@@ -17,7 +17,7 @@
        "@aws-sdk/signature-v4": "^3.370.0",
        "@dadosfera/dadosfera-logs": "^1.0.0-beta.4",
        "@dadosfera/protospack": "2.5.3",
-        "@dadosfera/protospack-v2": "3.38.0-beta.28",
+        "@dadosfera/protospack-v2": "file:../protospack-v2/dadosfera-protospack-v2-0.0.0.tgz",
        "@grpc/grpc-js": "^1.9.3",
        "@grpc/proto-loader": "^0.7.9",
        "@nestjs/cli": "^9.5.0",
@@ -31,7 +31,7 @@
        "@nestjs/schematics": "^9.2.0",
        "@nestjs/swagger": "^6.3.0",
        "@nestjs/testing": "^9.4.3",
-        "axios": "^0.30.2",
+        "axios": "0.30.3",
        "cache-manager": "^5.1.4",
        "cache-manager-ioredis-yet": "^1.1.0",
        "class-transformer": "^0.5.1",
@@ -47,6 +47,7 @@
        "jwk-to-pem": "^2.0.5",
        "mixpanel": "^0.17.0",
        "ms": "^3.0.0-canary.1",
+        "multer": "^2.0.2",
        "openid-client": "^5.7.1",
        "passport": "^0.6.0",
        "passport-facebook": "^3.0.0",
@@ -1744,9 +1745,9 @@
      }
    },
    "node_modules/@dadosfera/protospack-v2": {
-      "version": "3.38.0-beta.28",
-      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.38.0-beta.28.tgz",
-      "integrity": "sha512-w3Au0qschqZJ6OSHVDKaR2KeeCF2ncuJ4k7iZQceOLo1zxUU3TpDyLYyp/rp1DoSG763uIgqm3kJUXv7RlmfNw==",
+      "version": "0.0.0",
+      "resolved": "file:../protospack-v2/dadosfera-protospack-v2-0.0.0.tgz",
+      "integrity": "sha512-qIJcW1zQyRr6hyg4d/6AQW9GPB2Sywzol76bRPw6rztd00eiVAlcfB8YPL+dtqwzhIYwmnWn3Fgzb5ibyOZUtw==",
      "license": "ISC",
      "dependencies": {
        "@grpc/grpc-js": "^1.9.3",
@@ -2928,6 +2929,20 @@
        "node": ">= 0.6"
      }
    },
+    "node_modules/@nestjs/platform-express/node_modules/concat-stream": {
+      "version": "1.6.2",
+      "resolved": "https://registry.npmjs.org/concat-stream/-/concat-stream-1.6.2.tgz",
+      "integrity": "sha512-27HBghJxjiZtIk3Ycvn/4kbJk/1uZuJFfuPEns6LaEvpvG1f0hTea8lilrouyo9mVc2GWdcEZ8OLoGmSADlrCw==",
+      "engines": [
+        "node >= 0.8"
+      ],
+      "dependencies": {
+        "buffer-from": "^1.0.0",
+        "inherits": "^2.0.3",
+        "readable-stream": "^2.2.2",
+        "typedarray": "^0.0.6"
+      }
+    },
    "node_modules/@nestjs/platform-express/node_modules/content-disposition": {
      "version": "0.5.4",
      "resolved": "https://registry.npmjs.org/content-disposition/-/content-disposition-0.5.4.tgz",
@@ -3097,6 +3112,24 @@
      "integrity": "sha512-Tpp60P6IUJDTuOq/5Z8cdskzJujfwqfOTkrwIwj7IRISpnkJnT6SyJ4PCPnGMoFjC9ddhal5KVIYtAt97ix05A==",
      "license": "MIT"
    },
+    "node_modules/@nestjs/platform-express/node_modules/multer": {
+      "version": "1.4.4-lts.1",
+      "resolved": "https://registry.npmjs.org/multer/-/multer-1.4.4-lts.1.tgz",
+      "integrity": "sha512-WeSGziVj6+Z2/MwQo3GvqzgR+9Uc+qt8SwHKh3gvNPiISKfsMfG4SvCOFYlxxgkXt7yIV2i1yczehm0EOKIxIg==",
+      "deprecated": "Multer 1.x is impacted by a number of vulnerabilities, which have been patched in 2.x. You should upgrade to the latest 2.x version.",
+      "dependencies": {
+        "append-field": "^1.0.0",
+        "busboy": "^1.0.0",
+        "concat-stream": "^1.5.2",
+        "mkdirp": "^0.5.4",
+        "object-assign": "^4.1.1",
+        "type-is": "^1.6.4",
+        "xtend": "^4.0.0"
+      },
+      "engines": {
+        "node": ">= 6.0.0"
+      }
+    },
    "node_modules/@nestjs/platform-express/node_modules/negotiator": {
      "version": "0.6.3",
      "resolved": "https://registry.npmjs.org/negotiator/-/negotiator-0.6.3.tgz",
@@ -3121,6 +3154,25 @@
        "url": "https://github.com/sponsors/ljharb"
      }
    },
+    "node_modules/@nestjs/platform-express/node_modules/readable-stream": {
+      "version": "2.3.8",
+      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-2.3.8.tgz",
+      "integrity": "sha512-8p0AUk4XODgIewSi0l8Epjs+EVnWiK7NoDIEGU0HhE7+ZyY8D1IMY7odu5lRrFXGg71L15KG8QrPmum45RTtdA==",
+      "dependencies": {
+        "core-util-is": "~1.0.0",
+        "inherits": "~2.0.3",
+        "isarray": "~1.0.0",
+        "process-nextick-args": "~2.0.0",
+        "safe-buffer": "~5.1.1",
+        "string_decoder": "~1.1.1",
+        "util-deprecate": "~1.0.1"
+      }
+    },
+    "node_modules/@nestjs/platform-express/node_modules/readable-stream/node_modules/safe-buffer": {
+      "version": "5.1.2",
+      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",
+      "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
+    },
    "node_modules/@nestjs/platform-express/node_modules/safe-buffer": {
      "version": "5.2.1",
      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
@@ -3195,6 +3247,19 @@
        "node": ">= 0.8"
      }
    },
+    "node_modules/@nestjs/platform-express/node_modules/string_decoder": {
+      "version": "1.1.1",
+      "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.1.1.tgz",
+      "integrity": "sha512-n/ShnvDi6FHbbVfviro+WojiFzv+s8MPMHBczVePfUpDJLwoLT0ht1l4YwBCbi8pJAveEEdnkHyPyTP/mzRfwg==",
+      "dependencies": {
+        "safe-buffer": "~5.1.0"
+      }
+    },
+    "node_modules/@nestjs/platform-express/node_modules/string_decoder/node_modules/safe-buffer": {
+      "version": "5.1.2",
+      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",
+      "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
+    },
    "node_modules/@nestjs/platform-express/node_modules/tslib": {
      "version": "2.5.3",
      "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.5.3.tgz",
@@ -5534,9 +5599,9 @@
      }
    },
    "node_modules/axios": {
-      "version": "0.30.2",
-      "resolved": "https://registry.npmjs.org/axios/-/axios-0.30.2.tgz",
-      "integrity": "sha512-0pE4RQ4UQi1jKY6p7u6i1Tkzqmu+d+/tHS7Q7rKunWLB9WyilBTpHHpXzPNMDj5hTbK0B0PTLSz07yqMBiF6xg==",
+      "version": "0.30.3",
+      "resolved": "https://registry.npmjs.org/axios/-/axios-0.30.3.tgz",
+      "integrity": "sha512-5/tmEb6TmE/ax3mdXBc/Mi6YdPGxQsv+0p5YlciXWt3PHIn0VamqCXhRMtScnwY3lbgSXLneOuXAKUhgmSRpwg==",
      "license": "MIT",
      "dependencies": {
        "follow-redirects": "^1.15.4",
@@ -6509,7 +6574,6 @@
      "engines": [
        "node >= 6.0"
      ],
-      "license": "MIT",
      "dependencies": {
        "buffer-from": "^1.0.0",
        "inherits": "^2.0.3",
@@ -9128,6 +9192,11 @@
        "url": "https://github.com/sponsors/sindresorhus"
      }
    },
+    "node_modules/isarray": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/isarray/-/isarray-1.0.0.tgz",
+      "integrity": "sha512-VLghIWNM6ELQzo7zwmcg0NmTVyWKYjvIeM83yjp0wRDTmUnrM678fQbcKBo6n2CJEF0szoG//ytg+TKla89ALQ=="
+    },
    "node_modules/isexe": {
      "version": "2.0.0",
      "resolved": "https://registry.npmjs.org/isexe/-/isexe-2.0.0.tgz",
@@ -10725,7 +10794,6 @@
      "version": "2.0.2",
      "resolved": "https://registry.npmjs.org/multer/-/multer-2.0.2.tgz",
      "integrity": "sha512-u7f2xaZ/UG8oLXHvtF/oWTRvT44p9ecwBBqTwgJVq0+4BW1g8OW01TyMEGWBHbyMOYVHXslaut7qEQ1meATXgw==",
-      "license": "MIT",
      "dependencies": {
        "append-field": "^1.0.0",
        "busboy": "^1.6.0",
@@ -11728,6 +11796,11 @@
        "url": "https://github.com/chalk/ansi-styles?sponsor=1"
      }
    },
+    "node_modules/process-nextick-args": {
+      "version": "2.0.1",
+      "resolved": "https://registry.npmjs.org/process-nextick-args/-/process-nextick-args-2.0.1.tgz",
+      "integrity": "sha512-3ouUOpQhtgrbOa17J7+uxOTpITYWaGP7/AhoR3+A+/1e9skrzelGi/dXzEYyvbxubEF6Wn2ypscTKiKJFFn1ag=="
+    },
    "node_modules/process-warning": {
      "version": "1.0.0",
      "resolved": "https://registry.npmjs.org/process-warning/-/process-warning-1.0.0.tgz",
@@ -10,7 +10,7 @@
  },
  "scripts": {
    "co:login": "aws codeartifact login --tool npm --namespace @dadosfera --repository dadosfera-npm --domain dadosfera --domain-owner 611330257153 --region us-east-1",
-    "proto-update": "npm i @dadosfera/protospack-v2@latest --save-exact",
+    "proto-update": "npm i @dadosfera/protospack-v2@v3.40.0-beta.1 --save-exact",
    "prebuild": "rimraf dist",
    "build": "nest build",
    "format": "prettier --write \"src/**/*.ts\" \"test/**/*.ts\"",
@@ -35,7 +35,7 @@
    "@aws-sdk/signature-v4": "^3.370.0",
    "@dadosfera/dadosfera-logs": "^1.0.0-beta.4",
    "@dadosfera/protospack": "2.5.3",
-    "@dadosfera/protospack-v2": "3.38.0-beta.28",
+    "@dadosfera/protospack-v2": "3.40.0-beta.7",
    "@grpc/grpc-js": "^1.9.3",
    "@grpc/proto-loader": "^0.7.9",
    "@nestjs/cli": "^9.5.0",
@@ -49,7 +49,7 @@
    "@nestjs/schematics": "^9.2.0",
    "@nestjs/swagger": "^6.3.0",
    "@nestjs/testing": "^9.4.3",
-    "axios": "^0.30.2",
+    "axios": "0.30.3",
    "cache-manager": "^5.1.4",
    "cache-manager-ioredis-yet": "^1.1.0",
    "class-transformer": "^0.5.1",
@@ -65,6 +65,7 @@
    "jwk-to-pem": "^2.0.5",
    "mixpanel": "^0.17.0",
    "ms": "^3.0.0-canary.1",
+    "multer": "^2.0.2",
    "openid-client": "^5.7.1",
    "passport": "^0.6.0",
    "passport-facebook": "^3.0.0",
@@ -80,7 +81,7 @@
    "swagger-ui-express": "^4.6.3"
  },
  "overrides": {
-    "multer": "2.0.2",
+    "axios": "0.30.3",
    "form-data": "^4.0.4",
    "body-parser": "^1.20.3",
    "cross-spawn": "^7.0.5",
@@ -117,5 +118,8 @@
    "ts-node": "^10.9.1",
    "tsconfig-paths": "^3.14.2",
    "typescript": "^4.9.5"
+  },
+  "resolutions": {
+    "axios": "0.30.3"
  }
 }
@@ -0,0 +1,65 @@
+import {
+  BadRequestException,
+  CanActivate,
+  ExecutionContext,
+  Inject,
+  Injectable,
+  OnModuleInit,
+} from '@nestjs/common';
+import { ClientGrpc } from '@nestjs/microservices';
+import { map, Observable } from 'rxjs';
+import { PackTheMetadata } from 'src/utils/PackTheMetadata';
+import {
+  ReadService,
+  ProtoServices,
+} from '@dadosfera/protospack-v2/dist/lib/PipelineV2';
+import { PipelinesClientConfiguration } from 'src/modules/pipelinesV2/pipelines-client';
+import { PlatformApiService } from 'src/modules/platform-api/platform-api.service';
+import DadosferaLogger from '@dadosfera/dadosfera-logs';
+
+@Injectable()
+export class PipelineExecutionGuard implements CanActivate {
+  logger: DadosferaLogger;
+
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private readonly platformApiService: PlatformApiService,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
+
+  async canActivate(context: ExecutionContext): Promise<boolean> {
+    try {
+      this.logger.info(
+        'PipelineExecutionGuard: Checking if pipeline can be executed...',
+      );
+      const request = context.switchToHttp().getRequest();
+      const pipelineId = request.params.pipelineId;
+      const user = request.user;
+      const idRegex = /[^0-9a-zA-Z_$]+/g;
+      const convertedId = pipelineId.replace(idRegex, '_');
+  
+      const status = await this.platformApiService.proxy(
+        'GET',
+        `/pipeline/${convertedId}/pipeline_run`,
+        user,
+      );
+
+      const currentStatus = status[status.length - 1]
+
+      this.logger.info('Pipeline current status response:' +  JSON.stringify(currentStatus));
+  
+      if (currentStatus.last_status.toLowerCase() === 'running') {
+        this.logger.error('Pipeline is running, cannot update input now');
+        throw new BadRequestException('Pipeline is running, cannot update input now');
+      } else {
+        return true;
+      }
+    } catch (error) {
+      this.logger.error('Error in PipelineExecutionGuard: ' + error.message);
+      throw new BadRequestException('Error checking pipeline status: ' + error.message);
+    }
+
+  }
+}
@@ -489,6 +489,7 @@ export class AuthController {
      const userDto = {
        id: api_key.user_id,
        name: api_key.username,
+        email: api_key.username,
        customer: {
          id: api_key.customer_id,
          name: api_key.customer_name,
@@ -437,7 +437,8 @@ export class AuthClientService implements OnModuleInit {

    const userDto: UserDTO = {
      id: user.id,
-      name: user.username,
+      name: user.name,
+      email: user.email,
      jobTitle: user?.jobTitle || null,
      department: user?.department || null,
      hierarchy: user?.hierarchy || null,
@@ -144,6 +144,7 @@ export interface BulkEditResponse {
 export type UserDTO = {
  id: string,
  name: string,
+  email: string,
  jobTitle?: string,
  department?: string,
  hierarchy?: string,
@@ -241,6 +241,34 @@ export class CatalogController {
    return res;
  }

+  @Get('schemas')
+  @RequireSomePermission(
+    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
+    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
+  )
+  async findSchemas(@User() user: RequestUser) {
+    const { username, user_id, customer_id, customer_name } = user;
+    this.logger.info(`/catalog - ON FIND SCHEMAS ROUTE`, {
+      username,
+      customer_name,
+    });
+
+    const metadata = PackTheMetadata({
+      username,
+      user_id,
+      customer_id,
+      customer_name,
+    });
+
+    try {
+      const res = await this.catalogService.findSchemas(metadata);
+      return res;
+    } catch (error) {
+      throw new HttpException(error.message, HttpStatus.NOT_FOUND);
+    }
+
+  }
+
  @Get('data-asset/:id')
  @RequireSomePermission(
    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
@@ -214,15 +214,6 @@ class CatalogService implements OnModuleInit {

    this.logger.debug('Extracted filters:', { filters });

-    console.log('MAESTRO VAI CHAMAR PI-FACTORY COM (ANTES AJUSTE):', {
-      search,
-      page,
-      size,
-      sort_by,
-      order,
-      filters,
-    });
-
    if (
      filters.manually !== undefined &&
      filters.manually !== null &&
@@ -233,15 +224,6 @@ class CatalogService implements OnModuleInit {
      delete filters.manually;
    }

-    console.log('MAESTRO VAI CHAMAR PI-FACTORY COM (DEPOIS AJUSTE):', {
-      search,
-      page,
-      size,
-      sort_by,
-      order,
-      filters,
-    });
-
    if (filters.owner) {
      const { users: customer_users } =
        await this.userService.findAllUsersByCustomerId(customer_id);
@@ -517,6 +499,22 @@ class CatalogService implements OnModuleInit {
    return response;
  }

+  async findSchemas(metadata: Metadata) {
+    this.logger.info('CatalogService - findSchemas');
+
+    try {
+      const response = await lastValueFrom(
+        this.catalogReadService.GetSchemas({}, metadata),
+      );
+
+      return response;
+
+    } catch (error) {
+      this.logger.error('Error fetching schemas:', error);
+      throw error;
+    }
+  }
+
  async getAssetsUsersAndRoles(data_assets: Array<any>, customer_id: string) {
    const { users: customer_users } =
      await this.userService.findAllUsersByCustomerId(customer_id);
@@ -9,12 +9,12 @@ import {
 } from '@nestjs/common';

 import { firstValueFrom, lastValueFrom } from 'rxjs';
-import { Link } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/entities';
 import { DucClient } from '../duc/client.config';
 import { ClientGrpc } from '@nestjs/microservices';
 import { ProtoServices } from '@dadosfera/protospack-v2/dist/lib/Duc';
-import { CustomerUpdateRequest } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/messages';
+import { CustomerSetLinksRequest } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/messages';
 import { CustomersProtoService } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/write-service';
+import { CustomerLinksConfig } from './dtos/customers';
 import ErrorCodes from 'src/utils/errorCodes';
 import jwt from 'jsonwebtoken';
 import {
@@ -67,12 +67,12 @@ export class CustomersService implements OnModuleInit {
    )
  }

-  async getLinks(customerId: string) {
+  async getLinks(customerId: string): Promise<CustomerLinksConfig | null> {
    try {
      const result = await lastValueFrom(
-        this.customerService.CustomerFindOneById({ id: customerId }),
+        this.customerService.CustomerGetLinks({ customerId }),
      );
-      return result.customer?.links || [];
+      return (result.links as CustomerLinksConfig) || null;
    } catch (err) {
      if (err.details === ErrorCodes.CUSTOMER.NOT_FOUND)
        throw new HttpException(err.details, HttpStatus.NOT_FOUND);
@@ -80,17 +80,17 @@ export class CustomersService implements OnModuleInit {
    }
  }

-  async setLinks(customerId: string, links: Link[]) {
+  async setLinks(customerId: string, links: CustomerLinksConfig) {
    if (!customerId || !links) {
      throw new HttpException(null, HttpStatus.BAD_REQUEST);
    }

    try {
      return await firstValueFrom(
-        this.customerService.CustomerUpdate({
-          id: customerId,
-          links,
-        } as CustomerUpdateRequest),
+        this.customerService.CustomerSetLinks({
+          customerId,
+          links: links as CustomerSetLinksRequest['links'],
+        }),
      );
    } catch (err) {
      if (err.details === ErrorCodes.CUSTOMER.NOT_FOUND)
@@ -1,7 +1,6 @@
-import { Link } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/entities';
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';

-export class CustomerLink implements Link {
+export class CustomerLinkItem {
  @ApiProperty()
  href: string;
  @ApiProperty()
@@ -9,15 +8,59 @@ export class CustomerLink implements Link {
  @ApiProperty()
  description: string;
  @ApiPropertyOptional()
-  iconSrc: string;
+  iconSrc?: string;
 }
+
+export class CustomerSidebarLinkItem {
+  @ApiProperty()
+  type: 'link';
+  @ApiProperty({ type: Object })
+  title: Record<string, string>;
+  @ApiProperty()
+  link: string;
+  @ApiPropertyOptional()
+  icon?: string;
+}
+
+export class CustomerSidebarMenuItem {
+  @ApiProperty()
+  type: 'menu';
+  @ApiProperty({ type: Object })
+  title: Record<string, string>;
+  @ApiPropertyOptional()
+  icon?: string;
+  @ApiProperty({ type: [CustomerSidebarLinkItem] })
+  items: CustomerSidebarLinkItem[];
+}
+
+export class CustomerSidebarSection {
+  @ApiProperty({ type: Object })
+  title: Record<string, string>;
+  @ApiProperty({
+    type: 'array',
+    items: {
+      oneOf: [
+        { $ref: '#/components/schemas/CustomerSidebarMenuItem' },
+        { $ref: '#/components/schemas/CustomerSidebarLinkItem' },
+      ],
+    },
+  })
+  items: (CustomerSidebarMenuItem | CustomerSidebarLinkItem)[];
+}
+
+export class CustomerLinksConfig {
+  @ApiPropertyOptional({ type: [CustomerLinkItem] })
+  home?: CustomerLinkItem[];
+  @ApiPropertyOptional({ type: [CustomerSidebarSection] })
+  sidebar?: CustomerSidebarSection[];
+}
+
 export class CustomerLinkRequest {
-  @ApiProperty({ type: [CustomerLink] })
-  links: CustomerLink[];
+  @ApiProperty({ type: CustomerLinksConfig })
+  links: CustomerLinksConfig;
 }

 export class CustomerLinksResponse {
-  @ApiProperty({ type: [CustomerLink] })
-  links: CustomerLink[];
-}
-
+  @ApiPropertyOptional({ type: CustomerLinksConfig })
+  links?: CustomerLinksConfig;
+}
@@ -11,17 +11,19 @@ export class TableColumns {
  name: string;
  @ApiProperty()
  columns: string[];
-  @ApiProperty()
+  @ApiPropertyOptional({ type: [Column] })
  references: Column[];
  @ApiProperty()
-  identifier_columns: string[];
-  @ApiProperty()
  destination: Record<'raw' | 'qualify', {
    table_name: string;
    table_schema: string;
  }> | null;
  @ApiProperty()
  type: string;
+  @ApiPropertyOptional({ type: [String] })
+  identifier_columns?: string[];
+  @ApiPropertyOptional({ type: Column })
+  reference_column?: Column;
 }
 export class AvailableEntity {
  @ApiProperty()
@@ -99,6 +99,7 @@ export class InputsController {
      customer: info.customer,
    });

+    this.logger.info(JSON.stringify(body))
    const response = await this.inputService.create({ body, info });

    return response;
@@ -17,6 +17,8 @@ import {
  InputCreateGenericRequest,
  InputCreateS3Request,
  InputNewCreateRequest,
+  InputUpdateResponse,
+  RollbackInputRequest,
  TestConnectionRequest,
 } from '@dadosfera/protospack-v2/dist/lib/Input/interfaces/messages';
 import { Info } from '@dadosfera/protospack-v2/dist/lib/Input/interfaces/entities';
@@ -71,8 +73,8 @@ export class InputsService {
      objectCamelToSnake(createInputResponse);
      return createInputResponse;
    },
-    update: async (updateInputDTO: UpdateInputRequest) => {
-      this.logger.info('InputClientService - Update');
+    update: async (updateInputDTO: UpdateInputRequest): Promise<InputUpdateResponse> => {
+      this.logger.info('InputClientService - Update' + JSON.stringify(updateInputDTO));
      const updateInputResponse = await lastValueFrom(
        this.inputWriteService.InputUpdate(updateInputDTO),
      );
@@ -164,6 +166,11 @@ export class InputsService {
    const inputCreateGenericRequest: InputCreateGenericRequest = {
      input: {
        ...body,
+        tables: (body.tables || []).map((table) => ({
+          ...table,
+          identifier_columns: table.identifier_columns || [],
+          reference_column: table.reference_column || table.references?.[0],
+        })),
      },
      info,
    };
@@ -202,21 +209,44 @@ export class InputsService {
  async update(id: string, data, info: Info) {
    // this.validateCron({ ...data, info });
    try {
-      const updateInputResponse: any = await this.OLD_inputClient.update({
+      const {
+        tablesUpdate,
+        dataAssetUpdate,
+        input
+      } = await this.OLD_inputClient.update({
        id,
-        info,
        ...data,
+        info,
      });

-      updateInputResponse.input = this.adjustInputPayload(
-        updateInputResponse?.input,
+      const updateInputResponse = this.adjustInputPayload(
+        input,
      );
-      return updateInputResponse;
+      return {
+        input: updateInputResponse,
+        tablesUpdate,
+        dataAssetUpdate
+      };
    } catch (err) {
      throw new HttpException(err.message, HttpStatus.NOT_FOUND);
    }
  }

+  async rollbackUpdate(
+    data: RollbackInputRequest
+  ) {
+    this.logger.info('PipelinesClientService - rollbackUpdate');
+    this.logger.info('Rolling back input update with data: ' + JSON.stringify(data));
+    const updatePipelineResponse = await lastValueFrom(
+      this.inputWriteService.RollbackInputUpdate(
+        data
+      ),
+    );
+    this.logger.info('Done');
+
+    return updatePipelineResponse;
+  }
+
  async remove(idRequest: IIdRequest) {
    return lastValueFrom(this.inputWriteService.InputRemove(idRequest));
  }
@@ -258,4 +288,12 @@ export class InputsService {
    };
    return formatedPayload;
  }
+
+  async markTableDeleted(data: { input_id: string; table_name: string; info: Info }) {
+    return lastValueFrom(this.inputWriteService.MarkTableDeleted(data));
+  }
+
+  async unmarkTableDeleted(data: { input_id: string; table_name: string; info: Info }) {
+    return lastValueFrom((this.inputWriteService as any).UnmarkTableDeleted(data));
+  }
 }
@@ -14,7 +14,7 @@ import {
  Patch,
  HttpException,
  BadRequestException,
-  CacheTTL,
+  UseGuards,
 } from '@nestjs/common';
 import {
  ApiCreatedResponse,
@@ -24,7 +24,6 @@ import {
  ApiTags,
 } from '@nestjs/swagger';
 import {
-  AuthenticateCondition,
  RequireAllPermissions,
  RequireSomePermission,
 } from 'src/decorators/authentication.decorator';
@@ -49,9 +48,11 @@ import { GrpcToHttpExceptionFilter } from 'src/error/grpc-to-http-exception.filt
 import { LanguageEnum } from 'src/utils/languages.enum';
 import { Language } from 'src/decorators/language.decorator';
 import { ApiInternalOnlyEndpoint } from 'src/decorators/swagger.decorator';
-import { TableColumns } from '../inputs/dtos/input.model';
-import { UpdateInputRequest } from '../inputs/dtos/old_interfaces';
 import { Info } from '@dadosfera/protospack-v2/dist/lib/Input/interfaces/entities';
+import { PipelineExecutionGuard } from 'src/guards/pipeline-execution.guard';
+
+type PipelineTable = { name: string; job_id?: string; is_deleted?: boolean; [key: string]: any };
+type PipelineTablesConfig = { input_id?: string; tables: PipelineTable[] };

@ApiTags('PipelinesV2')
@ApiHeaders([{ name: 'dadosfera-lang', enum: LanguageEnum, required: false }])
@@ -62,6 +63,7 @@ export class PipelinesController {
  constructor(
    @Inject(DadosferaLogger)
    dadosferaLogger: DadosferaLogger,
+
    private pipelinesClientService: PipelinesService,
    private oldPipelinesService: OldPipelineService,
  ) {
@@ -222,30 +224,27 @@ export class PipelinesController {
      language,
    });

-    const result = await this.pipelinesClientService
-      .findOne({ id }, metadata)
-      .then((res) => {
-        //{pipeline:{tables: {tables: [], input_id: ''}}}
-        let tables = JSON.parse(res.pipeline.config.tables);
-        const input_id = tables?.input_id;
-        if (tables?.tables) tables = tables.tables;
-        Object.assign(res.pipeline, {
-          transformations: res.pipeline.transformations
-            ? JSON.parse(res.pipeline.transformations)
-            : [],
-          config: {
-            cron: res.pipeline.config.cron,
-            tables,
-            input_id
-          },
-          properties: res.pipeline.properties
-            ? JSON.parse(res.pipeline.properties)
-            : {},
-        });
-        return res;
-      });
+    const pipelineRes = await this.pipelinesClientService.findOne({ id }, metadata);

-    return result;
+    const parsed: PipelineTablesConfig = JSON.parse(pipelineRes.pipeline.config.tables);
+    const input_id = parsed.input_id;
+    const tables: PipelineTable[] = parsed.tables ?? [];
+
+    Object.assign(pipelineRes.pipeline, {
+      transformations: pipelineRes.pipeline.transformations
+        ? JSON.parse(pipelineRes.pipeline.transformations)
+        : [],
+      config: {
+        cron: pipelineRes.pipeline.config.cron,
+        tables,
+        input_id,
+      },
+      properties: pipelineRes.pipeline.properties
+        ? JSON.parse(pipelineRes.pipeline.properties)
+        : {},
+    });
+
+    return pipelineRes;
  }

  @Patch('/:id')
@@ -285,6 +284,7 @@ export class PipelinesController {

  @Patch('/:pipelineId/inputs/:id')
  @RequireSomePermission(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
+  @UseGuards(PipelineExecutionGuard)
  async updatePipelineInput(
    @Language() language: LanguageEnum,
    @Body() pipelineInputDTO: UpdatePlatformInputRequest,
@@ -294,13 +294,14 @@ export class PipelinesController {
  ) {
    this.logger.info('PipelinesController - update', { user });

-
    const { customer_id, customer_name, user_id, username } = user;
    const info: Info = {
      user_id: user.user_id,
      customer: user.customer_name,
      customer_id: user.customer_id,
+      pipeline_id: pipelineId
    };
+
    const metadata = PackTheMetadata({
      customer_id,
      customer_name,
@@ -12,6 +12,8 @@ import { ConnectorModule } from '../connector/connector.module';
 import { InputsModule } from '../inputs/inputs.module';
 import { TransformationsModule } from '../transformations/transformations.module';
 import { PlatformApiModule } from '../platform-api/platform-api.module';
+import { NimbusServicesModule } from 'src/services/nimbus/nimbus.module';
+import { NimbusService } from 'src/services/nimbus/nimbus.service';

 const client = new PipelinesClientConfiguration();

@@ -22,10 +24,11 @@ const client = new PipelinesClientConfiguration();
    ConnectorModule,
    InputsModule,
    TransformationsModule,
-    PlatformApiModule
+    PlatformApiModule,
+    NimbusServicesModule
  ],
  controllers: [PipelinesController],
-  providers: [PipelinesService, DadosferaLogger],
+  providers: [PipelinesService, DadosferaLogger, NimbusService],
  exports: [PipelinesService],
 })
 export class PipelinesV2Module {}
@@ -29,6 +29,11 @@ import ErrorCodes from 'src/utils/errorCodes';
 import ErrorBuilder from 'src/utils/ErrorBuilder';
 import { PlatformApiService } from '../platform-api/platform-api.service';
 import { Info } from '@dadosfera/protospack-v2/dist/lib/Input/interfaces/entities';
+import { TableUpdate } from '@dadosfera/protospack-v2/dist/lib/Input/interfaces/messages';
+import { AxiosError } from 'axios';
+import { NimbusService } from 'src/services/nimbus/nimbus.service';
+
+type RollbackPromise = () => Promise<any>;

 export class PipelinesService implements OnModuleInit {
  logger: DadosferaLogger;
@@ -42,7 +47,8 @@ export class PipelinesService implements OnModuleInit {
    private readonly connectorService: ConnectorClientService,
    private readonly inputsService: InputsService,
    private readonly transformationsService: TransformationsService,
-    private readonly platformAPI: PlatformApiService
+    private readonly platformAPI: PlatformApiService,
+    private readonly nimbusService: NimbusService
  ) {
    this.logger = dadosferaLogger.logger;
  }
@@ -348,133 +354,227 @@ export class PipelinesService implements OnModuleInit {
  async updatePipelineInput(pipelineId: string, inputId: string, updateInputDTO: UpdatePlatformInputRequest, info: Info, user: RequestUser, metadata: Metadata) {
    this.logger.info('InputClientService - Update');

-    this.logger.info('Update Dynamo Reference');
+    const {
+      input: oldInput
+    } = await this.inputsService.findOne({
+      id: inputId,
+      info: info
+    });
+
+    this.logger.info('Update Dynamo Reference :' + JSON.stringify(oldInput));
    const pipelineIdFormat = pipelineId.split('-').join('_');
+    const rollback: RollbackPromise[] = [];
+
    const updateInputResponse = await this.inputsService.update(
      inputId,
      updateInputDTO,
      info
-    )
+    );

-    const requests = [];
+    const inputRollback = () => {
+      this.logger.info("exec rollback to input: " + JSON.stringify(oldInput));
+      return this.inputsService.rollbackUpdate(
+        {
+          id: inputId,
+          dataAssetUpdate: updateInputResponse.dataAssetUpdate,
+          tables: oldInput.tables,
+          info
+        }
+      ) as Promise<any>;
+    }

-    this.logger.info('Dynamo Response', updateInputResponse);
+    rollback.push(inputRollback);
+
+    this.logger.info("Input Update Response: " + JSON.stringify(updateInputResponse))
+
+    const nimbusUpdates = updateInputResponse?.tablesUpdate || [];
+
+    nimbusUpdates.forEach(update => {
+      const nimbusRollback = () => {
+        return this.nimbusService.renameTable(
+          info.customer,
+          update.database,
+          {
+            table_name: update.table_name,
+            table_schema: update.table_schema
+          },
+          {
+            table_name: update.old_table_name,
+            table_schema: update.old_table_schema
+          }
+        );
+      }
+      rollback.push(nimbusRollback);
+    });
+
+    try {
+      await this.updateNimbus(info.customer, nimbusUpdates);
+    } catch (error) {
+      this.logger.error(error);
+      if (error instanceof AxiosError) {
+        this.logger.error(JSON.stringify(error.response.data));
+      }
+      await this.executeRenameRollback(rollback);
+
+      throw new Error("Error Nimbus updating tables");
+    }
+
+    try {
+      await this.updatePlatformJobs(
+        pipelineIdFormat,
+        updateInputResponse.input.type,
+        updateInputDTO,
+        user
+      );
+    } catch (error) {
+      this.logger.error(error);
+      await this.executeRenameRollback(rollback)
+      throw new Error("Error Platform API updating jobs");
+    }
+
+    return updateInputResponse;
+  }
+
+  private async executeRenameRollback(request: RollbackPromise[]) {
+    this.logger.info('rollback steps: ' + request.length)
+    const result = await Promise.allSettled(request.map(func => func()));
+    result.forEach(promise => {
+      this.logger.info("Promise finish with status: " + promise.status)
+
+      if (promise.status === "rejected") {
+        this.logger.error("reject with: " + JSON.stringify(promise.reason || {}))
+      }
+
+      if (promise.status === "fulfilled") {
+        this.logger.info("success with: " + JSON.stringify(promise.value || {}))
+      }
+    });
+
+  }
+
+  private async updateNimbus(customer: string, changes: TableUpdate[]) {
+    // throw new Error("teste error nimbus");
+    this.logger.info('Nimbus Changes: ' + JSON.stringify(changes));
+    if(!changes || changes.length === 0) return;
+
+    const requests = changes.map(change => {
+      return this.nimbusService.renameTable(customer, change.database, {
+        table_name: change.old_table_name,
+        table_schema: change.old_table_schema
+      }, {
+        table_name: change.table_name,
+        table_schema: change.table_schema
+      });
+    })
+
+    const values = await Promise.allSettled(requests);
+
+    const success = values.map(request => request.status === "fulfilled")
+
+    this.logger.info("Updates with succes: " + success.length);
+
+    values.forEach(promise => {
+      this.logger.info("Promise finish with status: " + promise.status)
+
+      if (promise.status === "rejected") {
+        this.logger.error("reject with: " + JSON.stringify(promise.reason || {}));
+        throw new Error(promise.reason );
+      }
+
+      if (promise.status === "fulfilled") {
+        this.logger.info("success with: " + JSON.stringify(promise.value || {}));
+      }
+    });
+
+  }
+
+  async updatePlatformJobs(pipelineId: string, pipelineType: string, updateInputDTO: UpdatePlatformInputRequest, user: RequestUser) {
+    const jobsUpdated = [];

    for (const [index, table] of updateInputDTO.tables.entries()) {
-      const id = `${pipelineIdFormat}_${index}`;
-      this.logger.info('Updating input reference for table', table.name);
-      const body = {}
+      const jobUpdate = {
+        job_id: `${pipelineId}_${index}`,
+      }
+
+      if (table.type !== "incremental_with_qualify") {
+        delete table.destinations?.qualify;
+      }
+
+      if (table.memory) {
+        jobUpdate["memory"] = {
+          amount: table.memory * 1000
+        }
+      }
+      
+      this.logger.info('Updating input reference for table: ' + table.name);
+      let hasUpdateSyncMode = false;
+
+      const jobSyncMode = {}
+
      if (table.columns) {
-        body['column_include_list'] = table.columns;
+        hasUpdateSyncMode = true;
+        jobSyncMode['column_include_list'] = table.columns;
      }

      if (table.reference_column) {
-        body['incremental_column_name'] = table.reference_column.name;
-        body['incremental_column_type'] = table.reference_column.type;
+        hasUpdateSyncMode = true;
+        jobSyncMode['incremental_column_name'] = table.reference_column.name;
+        jobSyncMode['incremental_column_type'] = table.reference_column.type;
      }

      if (table.identifier_columns) {
-        body['primary_keys'] = table.identifier_columns;
-      }
-
-      this.logger.info('Request body', body);
-      const updateCollumns = this.platformAPI.proxy(
-        'PATCH',
-        `/jobs/${id}/input`,
-        user,
-        body
-      )
-      requests.push(updateCollumns);
-
-      if (table.memory) {
-        this.logger.info('Updating memory allocation for table', table.name);
-        const updateMemory = this.platformAPI.proxy(
-          'PUT',
-          `/jobs/${id}/memory`,
-          user,
-          {
-            amount: table.memory
-          }
-        )
-        requests.push(updateMemory);
+        hasUpdateSyncMode = true;
+        jobSyncMode['primary_keys'] = table.identifier_columns;
      }

      if (table.type) {
-          const updateSyncMode = this.updatePipelineSyncMode(table, id, user);
-          requests.push(updateSyncMode);
+        hasUpdateSyncMode = true;
+        
+        jobSyncMode['target_load_type'] = table.type;
      }
-    }

-    this.logger.info('Create Platform Request for each JOB');
+      if(hasUpdateSyncMode) {
+        jobUpdate["sync_mode"] = jobSyncMode;
+      }

-    if (updateInputDTO.cron) {
-      const crnUpdatedRequest = new Promise(async (resolve, reject) => {
-        const response = await this.updatePipelineCron(updateInputDTO.cron, pipelineIdFormat, user);
-
-        if (response.error) {
-          this.logger.error('Error updating pipeline cron', response.error);
-          return reject(new ErrorBuilder(response.error));
+      if (Object.keys(table.destinations).length > 1) {
+        let hasChanges = false
+        const jobRenameTables = {
+            raw: {},
+            qualify: {}
        }
-        this.logger.error('Pipeline cron updated successfully', response);
-        return resolve(response);
-      });
-      requests.push(crnUpdatedRequest);
+
+        if (Object.keys(table.destinations.raw).length > 1) {
+          hasChanges = true;
+          jobRenameTables.raw = table.destinations.raw;
+        }
+
+        if (Object.keys(table.destinations.qualify).length > 1) {
+          hasChanges = true;
+          jobRenameTables.qualify = table.destinations.qualify;
+        }
+
+        if (hasChanges) {
+          jobUpdate['rename_tables'] = jobRenameTables;
+        }
+      }
+
+      jobsUpdated.push(jobUpdate);
    }

-    this.logger.info('Executing all request for the platform api');
+    this.logger.info('Request body:' + JSON.stringify({
+      jobs_updated: jobsUpdated
+    }));

-    const results = await Promise.allSettled(requests);
-    this.logger.info('Platform api response', results);
-
-    return updateInputResponse;
-    
-  }
-
-  private async updatePipelineSyncMode(table: UpdateTableDTO,  pipelineId: string, user: RequestUser) {
-    const body = {
-      target_load_type: table.type
-    }
-
-    if (table.type === 'incremental_with_qualify') {
-      body['incremental_column_name'] = table.reference_column.name;
-      body['incremental_column_type'] = table.reference_column.type;
-      body['primary_keys'] = table.identifier_columns;
-    }
-
-    if (table.type === 'incremental') {
-      body['incremental_column_name'] = table.reference_column.name;
-      body['incremental_column_type'] = table.reference_column.type;
-    }
-
-    this.logger.info('Updating pipeline sync mode', {
-      pipelineId,
-      body
-    });
-
-    return this.platformAPI.proxy(
-      "POST",
-      `/jobs/jdbc/${pipelineId}/sync-mode`,
+    const response = await this.platformAPI.proxy(
+      'PUT',
+        `/pipeline/${pipelineId}/jobs`,
      user,
-      body
+      {
+        job_updates: jobsUpdated
+      }
    )
+    this.logger.info('Platform api response: ' + JSON.stringify(response));
  }

-  private async updatePipelineCron(cron: string, pipelineId: string, user: RequestUser) {
-    try {
-      const response = await this.platformAPI.proxy(
-        'PATCH',
-        `/pipeline/${pipelineId}`,
-        user,
-        {
-          cron
-        }
-      );
-
-      return response
-    } catch (error) {
-        return {
-          error: error.message
-        }
-    }
-  }
 }
@@ -11,6 +11,8 @@ import {
  Inject,
  BadRequestException,
  HttpException,
+  NotFoundException,
+  UseGuards,
 } from '@nestjs/common';
 import { ApiTags, ApiOperation } from '@nestjs/swagger';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
@@ -29,6 +31,8 @@ import { validateCronAgainstScheduleLimit } from '../../utils/cron-validation';
 import { CatalogService } from '../catalog/catalog.service';
 import { PackTheMetadata } from '../../utils/PackTheMetadata';
 import { ValidationTableDTO } from './platform-api.dto';
+import { InputsService } from '../inputs/inputs.service';
+import { PipelineExecutionGuard } from 'src/guards/pipeline-execution.guard';


 type ValidateTablesDTO = {
@@ -54,6 +58,7 @@ export class PlatformApiController {
    private readonly dynamoDBService: DynamoDBService,
    private readonly customersService: CustomersService,
    private readonly catalogService: CatalogService,
+    private readonly inputsService: InputsService,
    @Inject(DadosferaLogger) dadosferaLogger: DadosferaLogger,
  ) {
    this.logger = dadosferaLogger.logger;
@@ -129,7 +134,7 @@ export class PlatformApiController {
  }

  private readonly VALID_CONNECTORS = ['jdbc', 'singer', 's3'];
-  private readonly MAX_MEMORY_MB = 12000; // 12GB maximum memory per pipeline/job
+  private readonly MAX_MEMORY_MB = 12000; // 12GB maximum memory per pipelines/job

  /**
   * Validate that connector is provided and is a valid type.
@@ -400,55 +405,9 @@ export class PlatformApiController {
    }
  }

-  /**
-   * Sync sync-mode changes to DynamoDB for JDBC connectors.
-   * Always passes both target_load_type and incremental_column_name to ensure proper sync.
-   */
-  private async syncJdbcSyncModeToDynamoDB(
-    jobId: string,
-    body: any,
-    user: RequestUser,
-  ): Promise<void> {
-    // JDBC sync mode uses target_load_type field
-    const changes: any = {};
-
-    if ('target_load_type' in body) {
-      changes.target_load_type = body.target_load_type;
-    }
-
-    // Handle incremental_column_name:
-    // - If provided in body, use that value
-    // - If changing to full_load, explicitly clear it
-    if ('incremental_column_name' in body) {
-      changes.incremental_column_name = body.incremental_column_name;
-      changes.incremental_column_type = body.incremental_column_type;
-    } else if (body.target_load_type === 'full_load') {
-      // Changing to full_load without specifying incremental_column - clear it
-      changes.incremental_column_name = null;
-    }
-
-    await this.syncJobInputToDynamoDB(jobId, changes, user, 'jdbc');
-  }
-
-  /**
-   * Sync sync-mode changes to DynamoDB for Singer connectors.
-   */
-  private async syncSingerSyncModeToDynamoDB(
-    jobId: string,
-    body: any,
-    user: RequestUser,
-  ): Promise<void> {
-    // Singer sync mode uses replication_method field
-    // Map to DynamoDB type: FULL_TABLE -> full_load, INCREMENTAL -> incremental
-    if ('replication_method' in body) {
-      const type = body.replication_method === 'INCREMENTAL' ? 'incremental' : 'full_load';
-      await this.syncJobInputToDynamoDB(jobId, { load_type: type }, user, 'singer');
-    }
-  }
-
  // ==================== PIPELINE ROUTES ====================

-  @Post('pipeline')
+  @Post('pipelines')
  @ApiOperation({ summary: 'Create a new pipeline' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.CREATE)
  async createPipeline(@Body() body: any, @User() user: RequestUser) {
@@ -569,7 +528,7 @@ export class PlatformApiController {
    );
  }

-  @Get('pipeline/:pipelineId')
+  @Get('pipelines/:pipelineId')
  @ApiOperation({ summary: 'Get pipeline by ID' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
  async getPipeline(
@@ -580,7 +539,7 @@ export class PlatformApiController {
    return this.platformApiService.proxy('GET', `/pipeline/${normalizedId}`, user);
  }

-  @Patch('pipeline/:pipelineId')
+  @Patch('pipelines/:pipelineId')
  @ApiOperation({ summary: 'Update pipeline by ID' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async updatePipeline(
@@ -631,7 +590,7 @@ export class PlatformApiController {
    return result;
  }

-  @Delete('pipeline/:pipelineId')
+  @Delete('pipelines/:pipelineId')
  @ApiOperation({ summary: 'Delete pipeline by ID' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.DELETE)
  async deletePipeline(
@@ -661,7 +620,7 @@ export class PlatformApiController {
    return result;
  }

-  @Post('pipeline/execute')
+  @Post('pipelines/execute')
  @ApiOperation({ summary: 'Execute a pipeline' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async executePipeline(@Body() body: any, @User() user: RequestUser) {
@@ -671,10 +630,10 @@ export class PlatformApiController {
      ...body,
      customer_id: user.customer_name,
    };
-    return this.platformApiService.proxy('POST', '/pipeline/execute', user, enrichedBody);
+    return this.platformApiService.proxy('POST', '/pipelines/execute', user, enrichedBody);
  }

-  @Post('pipeline/pause')
+  @Post('pipelines/pause')
  @ApiOperation({ summary: 'Pause a pipeline' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async pausePipeline(@Body() body: any, @User() user: RequestUser) {
@@ -687,7 +646,7 @@ export class PlatformApiController {
    return this.platformApiService.proxy('POST', '/pipeline/pause', user, enrichedBody);
  }

-  @Post('pipeline/unpause')
+  @Post('pipelines/unpause')
  @ApiOperation({ summary: 'Unpause a pipeline' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async unpausePipeline(@Body() body: any, @User() user: RequestUser) {
@@ -700,7 +659,7 @@ export class PlatformApiController {
    return this.platformApiService.proxy('POST', '/pipeline/unpause', user, enrichedBody);
  }

-  @Put('pipeline/:pipelineId/memory')
+  @Put('pipelines/:pipelineId/memory')
  @ApiOperation({ summary: 'Update pipeline memory configuration' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async updatePipelineMemory(
@@ -723,7 +682,7 @@ export class PlatformApiController {

  // ==================== PIPELINE METADATA ROUTES ====================

-  @Put('pipeline/:pipelineId/metadata')
+  @Put('pipelines/:pipelineId/metadata')
  @ApiOperation({ summary: 'Update pipeline metadata' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async updatePipelineMetadata(
@@ -792,7 +751,7 @@ export class PlatformApiController {

  // ==================== PIPELINE RUN ROUTES ====================

-  @Get('pipeline/:pipelineId/pipeline_run')
+  @Get('pipelines/:pipelineId/pipeline_run')
  @ApiOperation({ summary: 'Get pipeline runs for a pipeline' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
  async getPipelineRuns(
@@ -810,7 +769,7 @@ export class PlatformApiController {
    );
  }

-  @Get('pipeline/:pipelineId/pipeline_run/:runId')
+  @Get('pipelines/:pipelineId/pipeline_run/:runId')
  @ApiOperation({ summary: 'Get specific pipeline run' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
  async getPipelineRun(
@@ -827,7 +786,7 @@ export class PlatformApiController {
    );
  }

-  @Get('pipeline/pipeline_run/:runId/logs')
+  @Get('pipelines/pipeline_run/:runId/logs')
  @ApiOperation({ summary: 'Get pipeline run logs' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
  async getPipelineRunLogs(
@@ -845,6 +804,34 @@ export class PlatformApiController {
    );
  }

+  @Post('pipelines/:pipelineId/pipeline_run/:runId/cancel')
+  @ApiOperation({ summary: 'Cancel a running pipeline run' })
+  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
+  async cancelPipelineRun(
+    @Param('pipelineId') pipelineId: string,
+    @Param('runId') runId: string,
+    @User() user: RequestUser,
+  ) {
+    const normalizedPipelineId = this.normalizePipelineId(pipelineId);
+    const normalizedRunId = this.normalizePipelineId(runId);
+
+    const status = await this.platformApiService.proxy(
+      'GET',
+      `/pipeline/${normalizedPipelineId}/pipeline_run`,
+      user,
+    );
+
+    if (status.length === 1) {
+      throw new BadRequestException('The first pipeline cannot be canceled');
+    }
+
+    return this.platformApiService.proxy(
+      'POST',
+      `/pipeline/${normalizedPipelineId}/pipeline_run/${normalizedRunId}/cancel`,
+      user,
+    );
+  }
+
  // ==================== JOBS - COLUMN EDITING ROUTES ====================

  @Put('jobs/:jobId/input')
@@ -944,226 +931,53 @@ export class PlatformApiController {
    );
  }

-  // ==================== JOBS - JDBC SYNC MODE ROUTES ====================
-
-  @Get('jobs/jdbc/:jobId')
-  @ApiOperation({ summary: 'Get JDBC job details' })
-  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
-  async getJdbcJob(@Param('jobId') jobId: string, @User() user: RequestUser) {
-    // Normalize job ID for Platform API (replace - with _)
-    const normalizedJobId = this.normalizeJobId(jobId);
-    return this.platformApiService.proxy('GET', `/jobs/jdbc/${normalizedJobId}`, user);
-  }
-
-  @Post('jobs/jdbc/:jobId/sync-mode')
-  @ApiOperation({ summary: 'Update JDBC job sync mode' })
-  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
-  async updateJdbcSyncMode(
-    @Param('jobId') jobId: string,
-    @Body() body: any,
+  @Delete('pipelines/:pipelineId/inputs/:inputId')
+  @ApiOperation({ summary: 'Mark a table as deleted and delete its associated job via platform-api' })
+  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.DELETE)
+  @UseGuards(PipelineExecutionGuard)
+  async deleteTable(
+    @Param('pipelineId') pipelineId: string,
+    @Param('inputId') inputId: string,
+    @Body() body: { table_name: string },
    @User() user: RequestUser,
  ) {
-    // Normalize job ID for Platform API (replace - with _)
-    const normalizedJobId = this.normalizeJobId(jobId);
+    const tableName = body.table_name;
+    const info = {
+      customer_id: user.customer_id,
+      customer: user.customer_name,
+      user_id: user.user_id,
+    };

-    const result = await this.platformApiService.proxy(
-      'POST',
-      `/jobs/jdbc/${normalizedJobId}/sync-mode`,
-      user,
-      body,
-    );
-
-    // Sync to DynamoDB (pass raw jobId for pipeline extraction)
-    await this.syncJdbcSyncModeToDynamoDB(jobId, body, user);
-
-    return result;
-  }
-
-  @Post('jobs/:jobId/rename-tables')
-  @ApiOperation({ summary: 'Rename job output tables and sync to catalog' })
-  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
-  async renameJobTables(
-    @Param('jobId') jobId: string,
-    @Body() body: RenameTablesBody,
-    @User() user: RequestUser,
-  ) {
-    const normalizedJobId = this.normalizeJobId(jobId);
-
-    const currentJob = await this.getJobByAnyConnectorType(normalizedJobId, user);
-
-    const result = await this.platformApiService.proxy(
-      'POST',
-      `/jobs/${normalizedJobId}/rename-tables`,
-      user,
-      body,
-    );
+    this.logger.info('deleteTable: marking table as deleted', { inputId, tableName });
+    const updatedInput: any = await this.inputsService.markTableDeleted({ input_id: inputId, table_name: tableName, info });
+    this.logger.info('deleteTable: table marked as deleted', { inputId, tableName });

    try {
-      await this.syncTableRenameToCatalog(jobId, body, currentJob, user);
+      const normalizedPipelineId = this.normalizePipelineId(pipelineId);
+      this.logger.info('deleteTable: fetching pipeline from platform-api', { pipelineId, normalizedPipelineId });
+      const platformPipeline = await this.platformApiService.proxy('GET', `/pipeline/${normalizedPipelineId}`, user);
+      this.logger.info('deleteTable: pipeline fetched', { jobCount: platformPipeline?.jobs?.length });
+
+      const job = platformPipeline?.jobs?.find((j: any) => j.input?.table_name === tableName);
+      if (!job) throw new NotFoundException(`Job for table '${tableName}' not found in pipeline`);
+
+      this.logger.info('deleteTable: deleting job from platform-api', { jobId: job.job_id });
+      await this.platformApiService.proxy('DELETE', `/jobs/${job.job_id}`, user);
+      this.logger.info('deleteTable: job deleted', { jobId: job.job_id });
+
+      return { name: tableName, is_deleted: updatedInput.is_deleted ?? true, deleted_at: updatedInput.deleted_at };
    } catch (error) {
-      this.logger.error('Catalog sync failed, rolling back Snowflake rename', { jobId, error: error.message });
-
-      const reverseBody = this.buildSnowflakeRollbackBody(body, currentJob.output_config || {});
-      if (reverseBody) {
-        try {
-          await this.platformApiService.proxy('POST', `/jobs/${normalizedJobId}/rename-tables`, user, reverseBody);
-          this.logger.info('Snowflake rename rolled back', { jobId });
-        } catch (rollbackError) {
-          this.logger.error('Snowflake rollback failed', { jobId, error: rollbackError.message });
-        }
-      }
-
-      throw new HttpException('Table rename failed: catalog sync error, Snowflake reverted', 500);
-    }
-
-    return result;
-  }
-
-  private buildSnowflakeRollbackBody(
-    body: RenameTablesBody,
-    outputConfig: any,
-  ): RenameTablesBody | null {
-    const reverse: RenameTablesBody = {};
-
-    if (body.raw) {
-      const nested = outputConfig.raw;
-      const oldTableName = nested?.table_name || outputConfig.table_name;
-      const oldTableSchema = nested?.table_schema || 'PUBLIC';
-      if (oldTableName) reverse.raw = { table_name: oldTableName, table_schema: oldTableSchema };
-    }
-
-    if (body.qualify) {
-      const nested = outputConfig.qualify;
-      if (nested?.table_name) reverse.qualify = { table_name: nested.table_name, table_schema: nested.table_schema || 'STAGED' };
-    }
-
-    return Object.keys(reverse).length > 0 ? reverse : null;
-  }
-
-  /**
-   * Sync table rename to Elasticsearch and Nimbus.
-   *
-   * For each target (raw, qualify):
-   *  1. Resolve old table name from output_config
-   *  2. Find the ES data asset by pipeline + table + schema
-   *  3. Update ES, Nimbus table-metadata, column-metadata, and data-preview
-   *  4. If any step fails, rollback all completed steps for that target
-   */
-  private async syncTableRenameToCatalog(
-    jobId: string,
-    body: RenameTablesBody,
-    currentJob: any,
-    user: RequestUser,
-  ): Promise<void> {
-    const pipelineId = this.extractPipelineIdFromJobId(jobId);
-    const outputConfig = currentJob.output_config || {};
-    const nimbusUrl = this.catalogService._getNimbusUrl({ info: { customer: user.customer_name } });
-    const databaseName = `DADOSFERA_PRD_${user.customer_name.toUpperCase()}`;
-
-    const targets = this.buildRenameTargets(body, outputConfig);
-
-    for (const { key, oldTableName, oldTableSchema, newValues } of targets) {
-      const rollbackSteps: Array<() => Promise<void>> = [];
-
+      this.logger.error('deleteTable: platform-api delete failed, attempting rollback', { tableName, error: error.message });
      try {
-        const dataAsset = await this.elasticsearchService.findDataAssetByTable(
-          user.customer_name, oldTableName, oldTableSchema,
-        );
-
-        if (!dataAsset) {
-          this.logger.warn(`No data asset found for ${key}`, { jobId, pipelineId, oldTableName, oldTableSchema });
-          continue;
-        }
-
-        const { _es_id: esAssetId, nimbus_id: nimbusId } = dataAsset;
-        const oldValues = { table_name: oldTableName, table_schema: oldTableSchema };
-
-        // ES update
-        const esFields = { name: newValues.table_name, table_name: newValues.table_name, table_schema: newValues.table_schema, display_name: newValues.table_name };
-        await this.elasticsearchService.updateDataAsset(user.customer_name, esAssetId, esFields);
-        rollbackSteps.push(() => this.elasticsearchService.updateDataAsset(
-          user.customer_name, esAssetId,
-          { name: oldTableName, table_name: oldTableName, table_schema: oldTableSchema, display_name: oldTableName },
-        ));
-
-        const newTableNameUpper = newValues.table_name.toUpperCase();
-        const newTableSchemaUpper = newValues.table_schema.toUpperCase();
-        const oldTableNameUpper = oldTableName.toUpperCase();
-        const oldTableSchemaUpper = oldTableSchema.toUpperCase();
-
-        // Nimbus table-metadata
-        if (nimbusId) {
-          await this.catalogService.renameTableOnNimbus(nimbusUrl, nimbusId, { table_name: newTableNameUpper, table_schema: newTableSchemaUpper });
-          rollbackSteps.push(() => this.catalogService.renameTableOnNimbus(nimbusUrl, nimbusId, { table_name: oldTableNameUpper, table_schema: oldTableSchemaUpper }));
-        }
-
-        // Nimbus column-metadata
-        await this.catalogService.renameColumnMetadataOnNimbus(
-          nimbusUrl, databaseName, oldTableNameUpper, oldTableSchemaUpper, newTableNameUpper, newTableSchemaUpper,
-        );
-        rollbackSteps.push(() => this.catalogService.renameColumnMetadataOnNimbus(
-          nimbusUrl, databaseName, newTableNameUpper, newTableSchemaUpper, oldTableNameUpper, oldTableSchemaUpper,
-        ));
-
-        // Nimbus data-preview
-        await this.catalogService.renameDataPreviewOnNimbus(
-          nimbusUrl, databaseName, oldTableNameUpper, oldTableSchemaUpper, newTableNameUpper, newTableSchemaUpper,
-        );
-        rollbackSteps.push(() => this.catalogService.renameDataPreviewOnNimbus(
-          nimbusUrl, databaseName, newTableNameUpper, newTableSchemaUpper, oldTableNameUpper, oldTableSchemaUpper,
-        ));
-
-        this.logger.info(`Synced catalog rename for ${key}`, { jobId, oldTableName, newTableName: newValues.table_name });
-      } catch (error) {
-        this.logger.error(`Catalog sync failed for ${key}, rolling back catalog`, { jobId, error: error.message });
-        await this.executeRollback(rollbackSteps, key, jobId);
-        throw error;
+        await this.inputsService.unmarkTableDeleted({ input_id: inputId, table_name: tableName, info });
+      } catch (rollbackError) {
+        this.logger.error('deleteTable: rollback failed', { tableName, error: rollbackError.message });
      }
+      throw error;
    }
  }

-  private buildRenameTargets(
-    body: RenameTablesBody,
-    outputConfig: any,
-  ): Array<{ key: string; oldTableName: string; oldTableSchema: string; newValues: { table_name: string; table_schema: string } }> {
-    const DEFAULT_SCHEMAS = { raw: 'PUBLIC', qualify: 'STAGED' };
-    const targets: Array<{ key: string; oldTableName: string; oldTableSchema: string; newValues: { table_name: string; table_schema: string } }> = [];
-
-    for (const key of ['raw', 'qualify'] as const) {
-      if (!body[key]) continue;
-
-      const nested = outputConfig[key];
-
-      // qualify: only sync if output_config.qualify already exists
-      if (key === 'qualify' && !nested?.table_name) continue;
-
-      const oldTableName = nested?.table_name || outputConfig.table_name;
-      if (!oldTableName) continue;
-
-      targets.push({
-        key,
-        oldTableName,
-        oldTableSchema: nested?.table_schema || DEFAULT_SCHEMAS[key],
-        newValues: body[key],
-      });
-    }
-
-    return targets;
-  }
-
-  private async executeRollback(
-    steps: Array<() => Promise<void>>,
-    targetKey: string,
-    jobId: string,
-  ): Promise<void> {
-    for (const rollback of steps.reverse()) {
-      try {
-        await rollback();
-      } catch (error) {
-        this.logger.error(`Rollback failed for ${targetKey}`, { jobId, error: error.message });
-      }
-    }
-  }
+  // ==================== JOBS - JDBC SYNC MODE ROUTES ====================

  @Get('jobs/jdbc/configs/allowed_datatypes')
  @ApiOperation({ summary: 'Get allowed datatypes for JDBC' })
@@ -1176,52 +990,6 @@ export class PlatformApiController {
    );
  }

-  // ==================== JOBS - SINGER REPLICATION ROUTES ====================
-
-  @Get('jobs/singer/:jobId')
-  @ApiOperation({ summary: 'Get Singer job details' })
-  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
-  async getSingerJob(@Param('jobId') jobId: string, @User() user: RequestUser) {
-    // Normalize job ID for Platform API (replace - with _)
-    const normalizedJobId = this.normalizeJobId(jobId);
-    return this.platformApiService.proxy('GET', `/jobs/singer/${normalizedJobId}`, user);
-  }
-
-  @Post('jobs/singer/:jobId/sync-mode')
-  @ApiOperation({ summary: 'Update Singer job sync mode' })
-  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
-  async updateSingerSyncMode(
-    @Param('jobId') jobId: string,
-    @Body() body: any,
-    @User() user: RequestUser,
-  ) {
-    // Normalize job ID for Platform API (replace - with _)
-    const normalizedJobId = this.normalizeJobId(jobId);
-
-    const result = await this.platformApiService.proxy(
-      'POST',
-      `/jobs/singer/${normalizedJobId}/sync-mode`,
-      user,
-      body,
-    );
-
-    // Sync to DynamoDB (pass raw jobId for pipeline extraction)
-    await this.syncSingerSyncModeToDynamoDB(jobId, body, user);
-
-    return result;
-  }
-
-  // ==================== JOBS - S3 ROUTES ====================
-
-  @Get('jobs/s3/:jobId')
-  @ApiOperation({ summary: 'Get S3 job details' })
-  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
-  async getS3Job(@Param('jobId') jobId: string, @User() user: RequestUser) {
-    // Normalize job ID for Platform API (replace - with _)
-    const normalizedJobId = this.normalizeJobId(jobId);
-    return this.platformApiService.proxy('GET', `/jobs/s3/${normalizedJobId}`, user);
-  }
-
  // ==================== HEALTH ROUTE ====================

  @Get('health')
@@ -8,9 +8,10 @@ import { ElasticsearchModule } from '../../services/elasticsearch';
 import { DynamoDBModule } from '../../services/dynamodb';
 import { CustomersModule } from '../customers/customers.module';
 import { CatalogModule } from '../catalog/catalog.module';
+import { InputsModule } from '../inputs/inputs.module';

@Module({
-  imports: [ElasticsearchModule, DynamoDBModule, CustomersModule, CatalogModule],
+  imports: [ElasticsearchModule, DynamoDBModule, CustomersModule, CatalogModule, InputsModule],
  controllers: [PlatformApiController],
  providers: [PlatformApiService, DadosferaLogger],
  exports: [PlatformApiService],
@@ -89,12 +89,12 @@ export class PlatformApiService {

      // Propagate non-2xx responses as HttpExceptions
      if (response.status >= 400) {
-        this.logger.error('Platform API upstream error', {
+        this.logger.error('Platform API upstream error' + JSON.stringify({
          status: response.status,
          data: response.data,
          path,
          method: method.toUpperCase(),
-        });
+        }));
        throw new HttpException(response.data, response.status);
      }

@@ -107,6 +107,8 @@ export class PlatformApiService {
        method: method.toUpperCase(),
      });

+      this.logger.error(error)
+
      if (error instanceof HttpException) {
        throw error;
      }
@@ -125,9 +125,13 @@ export class DynamoDBService {
      },
    });

-    const { Item } = await this.documentClient.send(getCommand);
-
-    return Item as InputDocument | null;
+    try {
+      const { Item } = await this.documentClient.send(getCommand);
+      return Item as InputDocument | null;
+    } catch (error) {
+      this.logger.error('DynamoDB: findInput failed', { inputId, clientId, error: error.message });
+      throw error;
+    }
  }

  async deleteInput(clientId: string, inputId: string): Promise<void> {
@@ -203,7 +207,6 @@ export class DynamoDBService {
        updatedTable.reference_column = changes.reference_column;
      }
    }
-
    tables[tableIndex] = updatedTable;

    // Save updated document
@@ -231,4 +234,5 @@ export class DynamoDBService {
      throw error;
    }
  }
+
 }
@@ -0,0 +1,9 @@
+import { Module } from "@nestjs/common";
+import { NimbusService } from "./nimbus.service";
+import DadosferaLogger from "@dadosfera/dadosfera-logs";
+
+@Module({
+  providers: [NimbusService, DadosferaLogger],
+  exports: [NimbusService],
+})
+export class NimbusServicesModule {}
@@ -0,0 +1,56 @@
+import DadosferaLogger from "@dadosfera/dadosfera-logs";
+import { Inject, Injectable } from "@nestjs/common";
+import axios from "axios";
+
+type TableUpdate = {
+    table_schema: string;
+    table_name: string;
+}
+
+@Injectable()
+export class NimbusService {
+    private logger: DadosferaLogger;
+  
+    constructor(
+      @Inject(DadosferaLogger) dadosferaLogger: DadosferaLogger,
+    ) {
+      this.logger = dadosferaLogger.logger;
+    }
+
+    private buildUrl(customerName: string) {
+        if (process.env.ENV === 'prd') {
+            return `https://nimbus-${customerName}.dadosfera.ai`;
+          }
+      
+          return `https://nimbus-${customerName}.${process.env.ENV.replace(
+            'local',
+            'stg',
+          )}.dadosfera.ai`;
+    }
+
+    async renameTable(customerName: string, database: string, old: TableUpdate, update: TableUpdate) {
+        const nimbusUrl = this.buildUrl(customerName);
+
+        const path = `/api/catalog/rename-tables/?database_name=${encodeURIComponent(database)}&table_name=${encodeURIComponent(old.table_name)}&table_schema=${encodeURIComponent(old.table_schema)}`;
+
+        try {
+            this.logger.info("Request for PATCH " + nimbusUrl + path);
+            this.logger.info("Payload: " + JSON.stringify(update));
+            const { data } = await axios.patch(nimbusUrl + path, {
+                table_name: update.table_name,
+                table_schema: update.table_schema
+            })
+
+            return data;
+        } catch (error) {
+            this.logger.error(error);
+            return {
+                message: error.message,
+                database,
+                old, 
+                update
+            }
+        }
+
+    }
+}
Author	SHA1	Message	Date
Marcos Rodrigues Silva	fe1caa003e	Merge pull request #484 from dadosfera/feature/table-schema-filter Feature/table schema filter	2026-04-23 15:16:11 -03:00
marcos-silva-rodrigues	e980c58507	FEAT: list schema and filter assets by schema	2026-04-23 15:15:14 -03:00
Marcos Rodrigues Silva	ff5f8672e2	Merge pull request #483 from dadosfera/beta Beta	2026-04-20 10:46:37 -03:00
Marcos Rodrigues Silva	d51456ecf7	Merge pull request #482 from dadosfera/hotfix/disable-edit-pipeline FIX: block cancel first pipeline	2026-04-16 15:02:20 -03:00
marcos-silva-rodrigues	0cb9da13d0	FIX: block cancel first pipeline	2026-04-16 14:58:19 -03:00
Marcos Rodrigues Silva	f198449c16	Merge pull request #481 from dadosfera/hotfix/disable-edit-pipeline Hotfix/disable edit pipeline	2026-04-13 14:29:58 -03:00
marcos-silva-rodrigues	0d627b0451	FEAT: guard to prevent pipeline update when pipeline is running	2026-04-13 14:23:44 -03:00
Marcos Rodrigues Silva	ff8eb3197d	Merge pull request #478 from dadosfera/beta Beta	2026-04-09 18:17:58 -03:00
Marcos Rodrigues Silva	abd4e6f90a	Merge pull request #480 from dadosfera/hotfix/remove-platform-endpoints FIX: remove full table	2026-04-09 17:41:32 -03:00
marcos-silva-rodrigues	901518d26c	FIX: remove full table	2026-04-09 17:38:28 -03:00
Marcos Rodrigues Silva	17a4c0ef82	Merge pull request #479 from dadosfera/hotfix/remove-platform-endpoints FEAT: remove endpoints	2026-04-09 17:24:57 -03:00
marcos-silva-rodrigues	4ab8147149	FEAT: remove endpoints	2026-04-09 17:23:58 -03:00
marcos-silva-rodrigues	0086528d51	FEAT: update connectors	2026-04-07 18:05:30 -03:00
vinicius gadea	bf12598915	Merge pull request #476 from dadosfera/feat/beta-delete-pipeline-job Feat/beta delete pipeline job	2026-04-02 17:35:06 -03:00
viniciusgadea	efb0b58648	FEAT: update deleteTable endpoint to use pipelineId in path and refactor parameters	2026-04-02 17:28:42 -03:00
viniciusgadea	8a9b58b612	FIX: rename method normalizeJobId to normalizePipelineId for clarity	2026-04-02 16:40:35 -03:00
viniciusgadea	837a9d7265	FEAT: update job deletion logic to mark tables as deleted and adjust API endpoints accordingly	2026-04-02 15:40:07 -03:00
viniciusgadea	d0122a9c20	FEAT: remove unused status field from InputDocument and updateInputTable method	2026-04-01 14:43:51 -03:00
viniciusgadea	968f75b688	FEAT: update job deletion endpoint to include inputId in path and implement rollback for table deletion	2026-04-01 14:26:55 -03:00
viniciusgadea	877cb9d281	FEAT: refine PipelineTablesConfig type definition and update parsing logic in PipelinesController	2026-03-31 18:38:25 -03:00
viniciusgadea	59efdb6272	FEAT: update job deletion and mark associated table as deleted in DynamoDB. Update protospack-v2	2026-03-31 16:36:59 -03:00
Marcos Rodrigues Silva	7b1049224c	Merge pull request #477 from dadosfera/hotfix/axios-vulnerability FIX: preventing the axios vulnerability	2026-03-31 15:01:03 -03:00
marcos-silva-rodrigues	0369f10b5c	FIX: preventing the axios vulnerability	2026-03-31 14:52:52 -03:00
viniciusgadea	ecca9106f0	FEAT: remove PipelinesV2Module from PlatformApiModule imports	2026-03-31 11:17:32 -03:00
viniciusgadea	efc1f49d92	FEAT: update delete job endpoint summary and remove unused InputsModule from platform-api module	2026-03-31 10:55:31 -03:00
viniciusgadea	2d46ac3213	FEAT: add delete job endpoint and update related services; update protospack-v2 version to 3.40.0-beta.3	2026-03-31 10:54:50 -03:00
Marcos Rodrigues Silva	271174176b	Merge pull request #473 from dadosfera/feat/qualify FEAT: update input	2026-03-30 12:06:08 -03:00
marcos-silva-rodrigues	dcf7aed51c	MERGE: resolve package conflicts	2026-03-30 12:05:36 -03:00
marcos-silva-rodrigues	7fbce8b5be	FEAT: update input	2026-03-30 12:02:27 -03:00
vinicius gadea	049eca9700	Merge pull request #472 from dadosfera/feat/cancel-pipeline-run-beta FEAT: update protospack-v2 to version 3.40.0-beta.1 and adjust relate…	2026-03-26 14:54:32 -03:00
viniciusgadea	3bcd78bb32	FEAT: update protospack-v2 to version 3.40.0-beta.1 and adjust related scripts	2026-03-26 14:53:33 -03:00
vinicius gadea	f603b64679	Merge pull request #471 from dadosfera/feat/cancel-pipeline-run-beta Feat/cancel pipeline run beta	2026-03-26 11:29:09 -03:00
viniciusgadea	b640465624	Merge remote-tracking branch 'origin/beta' into feat/cancel-pipeline-run-beta	2026-03-26 11:19:30 -03:00
viniciusgadea	98282471a9	FIX: remove unused data asset methods from ElasticsearchService	2026-03-26 11:08:40 -03:00
viniciusgadea	8983430889	REF: remove last_run_status tracking and related Elasticsearch update logic from pipeline cancellation	2026-03-26 10:32:09 -03:00
viniciusgadea	d3aeca12cd	FIX: remove last_run_canceled_at from PipelineDocument and update last_run_status handling	2026-03-26 10:32:09 -03:00
viniciusgadea	ce619942a3	FEAT: add endpoint to cancel running pipeline runs and update Elasticsearch status	2026-03-26 10:32:09 -03:00
Marcos Rodrigues Silva	71b3f278a5	Merge pull request #469 from dadosfera/feat/override-menu2 Feat/override menu2	2026-03-25 18:02:14 -03:00
viniciusgadea	c92542ed90	FEAT: update protospack-v2 version to 3.39.0 in package.json and package-lock.json	2026-03-25 15:53:02 -03:00
viniciusgadeaandClaude Sonnet 4.6	69a9d78642	FIX: add multer@2.0.2 and update package-lock.json — missing transitive dep of protospack-v2@3.38.0-beta.30 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-03-25 15:41:02 -03:00
viniciusgadea	bf4f3cfd8c	FEAT: update CustomerSidebarSection and related DTOs to use object type for title; update protospack-v2 version; update from id to customerId	2026-03-25 15:40:57 -03:00
viniciusgadeaandClaude Sonnet 4.6	01afa69fcb	FIX: remove duplicate identifier_columns declaration in TableColumns DTO Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-03-25 15:37:15 -03:00
viniciusgadea	80f3913fd2	FEAT: update CustomerSidebarSection to support both menu and link items	2026-03-25 15:24:59 -03:00
viniciusgadea	10293ad6a9	FEAT: update customer links handling and DTOs for improved structure sidebar. update protospack-v2	2026-03-25 15:24:59 -03:00
Marcos Rodrigues Silva	e4d0c9c3e6	Merge pull request #465 from dadosfera/feat/qualify FEAT: update nimbus after input	2026-03-24 14:10:42 -03:00
marcos-silva-rodrigues	21c57e5620	FEAT: update nimbus after input	2026-03-24 12:28:20 -03:00
marcos-silva-rodrigues	959210e354	FIX: npm ci	2026-03-19 14:56:58 -03:00
marcos-silva-rodrigues	f10953e949	FIX: multer package	2026-03-19 14:45:28 -03:00
Marcos Rodrigues Silva	13903b9bb9	Merge pull request #463 from dadosfera/fix/user-from-me-endpoint FIX: send correct name and email from user payload	2026-03-19 14:36:58 -03:00
marcos-silva-rodrigues	2e3a13d421	FIX: send correct name and email from user payload	2026-03-19 14:35:14 -03:00
vinicius gadea	fa17fc3001	Merge pull request #462 from dadosfera/feat/sidebar-menu FIX: add multer@2.0.2 and update package-lock.json — missing transiti…	2026-03-19 14:00:58 -03:00
viniciusgadeaandClaude Sonnet 4.6	b7171556b8	FIX: add multer@2.0.2 and update package-lock.json — missing transitive dep of protospack-v2@3.38.0-beta.30 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-03-19 13:58:02 -03:00
vinicius gadea	254a638392	Merge pull request #457 from dadosfera/feat/sidebar-menu Feat/sidebar menu	2026-03-19 10:41:12 -03:00
viniciusgadea	74b3bd6b46	FEAT: update CustomerSidebarSection and related DTOs to use object type for title; update protospack-v2 version; update from id to customerId	2026-03-19 08:14:56 -03:00
Marcos Rodrigues Silva	9a29ef5401	Merge pull request #461 from dadosfera/feat/qualify FEAT: using batch route to update pipeline	2026-03-18 15:05:36 -03:00
marcos-silva-rodrigues	3f21faaa66	FEAT: using batch route to update pipeline	2026-03-18 11:25:55 -03:00
viniciusgadea	bf19d29a1d	FIX: docsfera.json	2026-03-17 15:38:35 -03:00
viniciusgadeaandClaude Sonnet 4.6	6523f707e3	FIX: remove duplicate identifier_columns declaration in TableColumns DTO Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-03-17 15:37:08 -03:00
viniciusgadeaandClaude Sonnet 4.6	8b0bf84d34	FIX: resolve merge conflict in package.json for protospack-v2 version Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-03-17 15:34:12 -03:00
viniciusgadea	9ef4c51ba1	FEAT: update CustomerSidebarSection to support both menu and link items	2026-03-17 15:25:55 -03:00
vinicius gadea	19521489fa	Merge branch 'beta' into feat/sidebar-menu	2026-03-17 10:22:37 -03:00
Rafael Santana	2ce9aad005	Merge pull request #460 from dadosfera/force-deploy FIX: uppercase table_name and table_schema in Nimbus rename calls	2026-03-16 10:42:41 -03:00
Rafael Santana	2125884c6c	Merge pull request #459 from dadosfera/force-deploy FIX: uppercase table_name and table_schema in ES lookup	2026-03-16 10:19:02 -03:00
Rafael Santana	f4c9226ef9	Merge pull request #458 from dadosfera/force-deploy FIX: rename-tables proxy path and ES lookup	2026-03-13 18:29:53 -03:00
viniciusgadea	ff3999a6aa	FEAT: update customer links handling and DTOs for improved structure sidebar. update protospack-v2	2026-03-13 17:35:56 -03:00
Rafael Santana	209470482a	Merge pull request #456 from dadosfera/force-deploy UPDATE: force deployment of maestro	2026-03-12 18:03:19 -03:00
Marcos Rodrigues Silva	c26194554c	Merge pull request #455 from dadosfera/fix/header-validation Fix/header validation	2026-03-11 11:58:23 -03:00