Merge branch 'beta' into feature/catalog-update

DOCS: Add 'docs' field to schemas in docsfera.json and update protospack-v2 to version 3.38.0-beta.19 in package-lock.json
DOC: Update @dadosfera/protospack-v2 to version 3.38.0-beta.19 in package.json and package-lock.json
2026-09-02 04:34:49 +00:00 · 2025-12-19 08:21:52 -03:00 · 2025-12-18 17:43:54 -03:00 · 2025-12-18 17:11:18 -03:00 · 2025-12-18 16:16:00 -03:00 · 2025-12-18 12:33:29 -03:00
5 changed files with 41 additions and 9 deletions
@@ -9649,6 +9649,9 @@
                "public",
                "private"
              ]
+            },
+            "docs": {
+              "type": "string"
            }
          },
          "required": [
@@ -9903,6 +9906,9 @@
                "public",
                "private"
              ]
+            },
+            "docs": {
+              "type": "string"
            }
          },
          "required": [
@@ -9942,6 +9948,9 @@
            },
            "embed": {
              "$ref": "#/components/schemas/EmbedObject"
+            },
+            "docs": {
+              "type": "string"
            }
          },
          "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.18",
+        "@dadosfera/protospack-v2": "3.38.0-beta.19",
        "@grpc/grpc-js": "^1.9.3",
        "@grpc/proto-loader": "^0.7.9",
        "@nestjs/cli": "^9.5.0",
@@ -2972,10 +2972,9 @@
      }
    },
    "node_modules/@dadosfera/protospack-v2": {
-      "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",
+      "version": "3.38.0-beta.19",
+      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.38.0-beta.19.tgz",
+      "integrity": "sha512-qevGunl1IKv4POa2hhXNaDpqlh/bvnq5Hxo6534OHYPZ//S+XcRZgTrxFnylK3+uoROM8epF3Mey5GwynxY7Tw==",
      "dependencies": {
        "@grpc/grpc-js": "^1.9.3",
        "rxjs": "^7.5.5"
@@ -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.18",
+    "@dadosfera/protospack-v2": "3.38.0-beta.19",
    "@grpc/grpc-js": "^1.9.3",
    "@grpc/proto-loader": "^0.7.9",
    "@nestjs/cli": "^9.5.0",
@@ -98,6 +98,8 @@ export class IDataAsset {
  embed?: EmbedObject;
  @ApiPropertyOptional({ enum: DataAssetShareType })
  share_type?: DataAssetShareType;
+  @ApiPropertyOptional()
+  docs?: string;
 }

 export class IOneDataAsset {
@@ -200,6 +202,8 @@ export class IUpdateDataRequest {
  embed: EmbedObject;
  @ApiPropertyOptional({ enum: DataAssetShareType })
  share_type?: DataAssetShareType;
+  @ApiPropertyOptional()
+  docs?: string;
 }
 export class ICreateDataAsset implements CreateDataAssetRequest {
  @ApiProperty()
@@ -214,6 +218,8 @@ export class ICreateDataAsset implements CreateDataAssetRequest {
  location: string;
  @ApiPropertyOptional()
  embed: EmbedObject;
+  @ApiPropertyOptional()
+  docs: string;
 }

 export class IPreview {
@@ -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')
Author	SHA1	Message	Date
vinicius gadea	6948156693	Merge branch 'beta' into feature/catalog-update	2025-12-19 08:21:52 -03:00
viniciusgadea	0aaa4384c3	DOCS: Add 'docs' field to schemas in docsfera.json and update protospack-v2 to version 3.38.0-beta.19 in package-lock.json	2025-12-18 17:43:54 -03:00
viniciusgadea	039c652b28	DOC: Update @dadosfera/protospack-v2 to version 3.38.0-beta.19 in package.json and package-lock.json	2025-12-18 17:11:18 -03:00
viniciusgadea	653d4f53b5	FEAT: Add optional 'docs' field to IDataAsset, IUpdateDataRequest, and ICreateDataAsset	2025-12-18 16:16:00 -03:00
Marcos Rodrigues Silva	31f8c2c1a6	Merge pull request #424 from dadosfera/feature/user-form FEAT: protected update route with admin seqid or if user request to e…	2025-12-18 12:33:29 -03:00
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 Silva	3f8dc5cabe	Merge pull request #421 from dadosfera/feature/user-form Feature/user form	2025-12-18 09:53:12 -03:00