Compare commits

...
2 Commits
Author SHA1 Message Date
RafaelandWOZCODE 688615dbee UPDATE: bump protospack-v2 to 3.40.0-beta.21 (live-status sink offsets)
Co-Authored-By: WOZCODE <contact@withwoz.com>
2026-08-29 12:16:18 -03:00
RafaelandWOZCODE ce48e69162 FIX: decode int64 as Number in the PipelineV2 gRPC client
PipelineV2SinkTableOffset.committed_offset is int64. Without a `longs`
option proto-loader decodes it as a Long.js object ({low,high,unsigned}),
which then serialized to the frontend as an object and blew up the card's
DecimalPipe (NG02100) on every 10s poll — the visible symptom was the
raw/deduped layers flickering. Kafka offsets fit in 2^53, so `longs: Number`
is exact and keeps the JSON a plain number.

Co-Authored-By: WOZCODE <contact@withwoz.com>
2026-08-28 19:45:06 -03:00
3 changed files with 9 additions and 5 deletions
+4 -4
View File
@@ -16,7 +16,7 @@
"@aws-sdk/lib-dynamodb": "^3.414.0",
"@aws-sdk/signature-v4": "^3.370.0",
"@dadosfera/dadosfera-logs": "^1.0.0-beta.4",
"@dadosfera/protospack-v2": "^3.40.0-beta.20",
"@dadosfera/protospack-v2": "3.40.0-beta.21",
"@grpc/grpc-js": "^1.9.3",
"@grpc/proto-loader": "^0.7.9",
"@nestjs/cli": "^9.5.0",
@@ -1735,9 +1735,9 @@
}
},
"node_modules/@dadosfera/protospack-v2": {
"version": "3.40.0-beta.20",
"resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.40.0-beta.20.tgz",
"integrity": "sha512-A12jgcVMCylfXZyXZYLuZNFJBuEBV1ZYmo3w01qhemKrFAzXRjOnPTBGHngdWNHahIaEYdocieBoIzl0n6OvFw==",
"version": "3.40.0-beta.21",
"resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.40.0-beta.21.tgz",
"integrity": "sha512-1mfFCXc8BFiYHcmFJSXt2KLqB3mQ1oPKQ/X39LCoB8buQHewvH1R7I7ZB67nrBxQ6XiTq6ojPT6PQRRgJtFgBg==",
"license": "ISC",
"dependencies": {
"@grpc/grpc-js": "^1.9.3",
+1 -1
View File
@@ -34,7 +34,7 @@
"@aws-sdk/lib-dynamodb": "^3.414.0",
"@aws-sdk/signature-v4": "^3.370.0",
"@dadosfera/dadosfera-logs": "^1.0.0-beta.4",
"@dadosfera/protospack-v2": "^3.40.0-beta.20",
"@dadosfera/protospack-v2": "3.40.0-beta.21",
"@grpc/grpc-js": "^1.9.3",
"@grpc/proto-loader": "^0.7.9",
"@nestjs/cli": "^9.5.0",
@@ -25,6 +25,10 @@ export class PipelinesClientConfiguration {
loader: {
keepCase: true,
enums: String,
// int64 fields (PipelineV2SinkTableOffset.committed_offset) decode as
// plain JS numbers instead of Long.js objects, so they serialize as
// JSON numbers for the frontend. Safe: Kafka offsets fit in 2^53.
longs: Number,
objects: true,
arrays: true,
},