Fix codecs (#6)

pagopa · Aug 7, 2024 · 0578394 · 0578394
1 parent f7d3593
commit 0578394
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 9 deletions.
diff --git a/src/agreement/index.ts b/src/agreement/index.ts
@@ -15,7 +15,7 @@ export function encodeOutboundAgreementEvent(event: AgreementEvent): string {
   return JSON.stringify({
     event_version: event.event_version,
     type: event.type,
-    data: agreementEventToBinaryData(event),
+    data: Buffer.from(agreementEventToBinaryData(event)).toString("hex"),
     stream_id: event.stream_id,
     version: event.version,
     timestamp: event.timestamp,

diff --git a/src/eservice/index.ts b/src/eservice/index.ts
@@ -15,7 +15,7 @@ export function encodeOutboundEServiceEvent(event: EServiceEvent): string {
   return JSON.stringify({
     event_version: event.event_version,
     type: event.type,
-    data: eServiceEventToBinaryData(event),
+    data: Buffer.from(eServiceEventToBinaryData(event)).toString("hex"),
     stream_id: event.stream_id,
     version: event.version,
     timestamp: event.timestamp,

diff --git a/src/purpose/index.ts b/src/purpose/index.ts
@@ -15,7 +15,7 @@ export function encodeOutboundPurposeEvent(event: PurposeEvent): string {
   return JSON.stringify({
     event_version: event.event_version,
     type: event.type,
-    data: purposeEventToBinaryData(event),
+    data: Buffer.from(purposeEventToBinaryData(event)).toString("hex"),
     stream_id: event.stream_id,
     version: event.version,
     timestamp: event.timestamp,

diff --git a/src/tenant/index.ts b/src/tenant/index.ts
@@ -15,7 +15,7 @@ export function encodeOutboundTenantEvent(event: TenantEvent): string {
   return JSON.stringify({
     event_version: event.event_version,
     type: event.type,
-    data: tenantEventToBinaryData(event),
+    data: Buffer.from(tenantEventToBinaryData(event)).toString("hex"),
     stream_id: event.stream_id,
     version: event.version,
     timestamp: event.timestamp,

diff --git a/src/utils.ts b/src/utils.ts
@@ -17,9 +17,5 @@ export const VersionedEvent = z.discriminatedUnion("event_version", [
 export function protobufDecoder<I extends object>(
   decoder: MessageType<I>
 ): ZodTransformer<ZodAny, I> {
-  return z
-    .any()
-    .transform((v) =>
-      decoder.fromBinary(Buffer.from(Object.values(v) as never, "hex"))
-    );
+  return z.any().transform((v) => decoder.fromBinary(Buffer.from(v, "hex")));
 }