Merge pull request #423 from dadosfera/fix/reference-column-object-format

FIX: inject customer_id in pipeline execute/pause/unpause routes
2026-10-06 20:19:09 +00:00 · 2025-12-18 10:53:31 -03:00 · 2025-12-18 10:30:09 -03:00 · 2025-12-18 10:29:09 -03:00 · 2025-12-18 10:24:29 -03:00
5 changed files with 68 additions and 8 deletions
@@ -8166,6 +8166,15 @@
            "hierarchy": {
              "type": "string"
            },
+            "bio": {
+              "type": "string"
+            },
+            "companyName": {
+              "type": "string"
+            },
+            "companySite": {
+              "type": "string"
+            },
            "mfaStatus": {
              "type": "string"
            },
@@ -8196,6 +8205,9 @@
            "jobTitle",
            "department",
            "hierarchy",
+            "bio",
+            "companyName",
+            "companySite",
            "mfaStatus",
            "createdAt",
            "updatedAt",
@@ -8329,6 +8341,15 @@
            "hierarchy": {
              "type": "string"
            },
+            "bio": {
+              "type": "string"
+            },
+            "companyName": {
+              "type": "string"
+            },
+            "companySite": {
+              "type": "string"
+            },
            "customer": {
              "$ref": "#/components/schemas/Customer"
            },
@@ -8356,6 +8377,9 @@
            "jobTitle",
            "department",
            "hierarchy",
+            "bio",
+            "companyName",
+            "companySite",
            "mfaStatus",
            "createdAt",
            "updatedAt",
@@ -8545,6 +8569,15 @@
            "hierarchy": {
              "type": "string"
            },
+            "bio": {
+              "type": "string"
+            },
+            "companyName": {
+              "type": "string"
+            },
+            "companySite": {
+              "type": "string"
+            },
            "mfaStatus": {
              "type": "string"
            },
@@ -8568,6 +8601,9 @@
            "jobTitle",
            "department",
            "hierarchy",
+            "bio",
+            "companyName",
+            "companySite",
            "mfaStatus",
            "createdAt",
            "updatedAt",
@@ -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.17",
+        "@dadosfera/protospack-v2": "3.38.0-beta.18",
        "@grpc/grpc-js": "^1.9.3",
        "@grpc/proto-loader": "^0.7.9",
        "@nestjs/cli": "^9.5.0",
@@ -2972,9 +2972,9 @@
      }
    },
    "node_modules/@dadosfera/protospack-v2": {
-      "version": "3.38.0-beta.17",
-      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.38.0-beta.17.tgz",
-      "integrity": "sha512-3E6m0ZKy5QOfuuTig05RC7Kj+zrh1GqZlTp6aePECDTrIyLhp2GIrALqJuD3LEjT+LG6eA88X2b4iXfV17Qmkg==",
+      "version": "3.38.0-beta.18",
+      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.38.0-beta.18.tgz",
+      "integrity": "sha512-rD2UOKa0P17A6YXIpclXF7F9b86mhRNE7fImTrbFamOcHpGmXBBVU8U53mCfLzzOA+MdDZ4/1uDNurCyQCjsLQ==",
      "license": "ISC",
      "dependencies": {
        "@grpc/grpc-js": "^1.9.3",
@@ -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.17",
+    "@dadosfera/protospack-v2": "3.38.0-beta.18",
    "@grpc/grpc-js": "^1.9.3",
    "@grpc/proto-loader": "^0.7.9",
    "@nestjs/cli": "^9.5.0",
@@ -630,21 +630,39 @@ export class PlatformApiController {
  @ApiOperation({ summary: 'Execute a pipeline' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async executePipeline(@Body() body: any, @User() user: RequestUser) {
-    return this.platformApiService.proxy('POST', '/pipeline/execute', user, body);
+    // Inject customer_id (actually customer_name) into body for Platform-API
+    // Note: Platform-API was created before customer_id existed, so it expects customer_name in the customer_id field
+    const enrichedBody = {
+      ...body,
+      customer_id: user.customer_name,
+    };
+    return this.platformApiService.proxy('POST', '/pipeline/execute', user, enrichedBody);
  }

  @Post('pipeline/pause')
  @ApiOperation({ summary: 'Pause a pipeline' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async pausePipeline(@Body() body: any, @User() user: RequestUser) {
-    return this.platformApiService.proxy('POST', '/pipeline/pause', user, body);
+    // Inject customer_id (actually customer_name) into body for Platform-API
+    // Note: Platform-API was created before customer_id existed, so it expects customer_name in the customer_id field
+    const enrichedBody = {
+      ...body,
+      customer_id: user.customer_name,
+    };
+    return this.platformApiService.proxy('POST', '/pipeline/pause', user, enrichedBody);
  }

  @Post('pipeline/unpause')
  @ApiOperation({ summary: 'Unpause a pipeline' })
  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
  async unpausePipeline(@Body() body: any, @User() user: RequestUser) {
-    return this.platformApiService.proxy('POST', '/pipeline/unpause', user, body);
+    // Inject customer_id (actually customer_name) into body for Platform-API
+    // Note: Platform-API was created before customer_id existed, so it expects customer_name in the customer_id field
+    const enrichedBody = {
+      ...body,
+      customer_id: user.customer_name,
+    };
+    return this.platformApiService.proxy('POST', '/pipeline/unpause', user, enrichedBody);
  }

  @Put('pipeline/:pipelineId/memory')
@@ -38,6 +38,12 @@ export class User {
  department?: string;
  @ApiProperty()
  hierarchy?: string;
+  @ApiProperty()
+  bio?: string;
+  @ApiProperty()
+  companyName?: string;
+  @ApiProperty()
+  companySite?: string;
  @ApiPropertyOptional()
  customer?: Customer;
  @ApiProperty()
Author	SHA1	Message	Date
Rafael Santana	adeb022818	Merge pull request #423 from dadosfera/fix/reference-column-object-format FIX: inject customer_id in pipeline execute/pause/unpause routes	2025-12-18 10:53:31 -03:00
RafaelandClaude Opus 4.5	f61c241dde	FIX: inject customer_id in pipeline execute/pause/unpause routes Users no longer need to provide customer_id in the request body for execute, pause, and unpause pipeline operations - it's now automatically injected from the authenticated user's session. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2025-12-18 10:30:09 -03:00
Marcos Rodrigues Silva	e326cab44d	Merge pull request #422 from dadosfera/feature/user-form FIX: send new user info	2025-12-18 10:29:09 -03:00
Marcos Rodrigues	61109f8ae9	FIX: send new user info	2025-12-18 10:24:29 -03:00