From 5d68b1a2d581f374f53082f52aa01e87f9d49f9e Mon Sep 17 00:00:00 2001
From: capJavert <ante@kickass.website>
Date: Fri, 31 May 2024 11:53:41 +0200
Subject: [PATCH] fix: encode nested jsonb fields

---
 src/workers/cdc/common.ts | 21 ++++++++++++++++-----
 1 file changed, 16 insertions(+), 5 deletions(-)

diff --git a/src/workers/cdc/common.ts b/src/workers/cdc/common.ts
index 6df4fac10..0f886b83c 100644
--- a/src/workers/cdc/common.ts
+++ b/src/workers/cdc/common.ts
@@ -1,4 +1,8 @@
-import { ContentUpdatedMessage } from '@dailydotdev/schema';
+import {
+  ContentMeta,
+  ContentQuality,
+  ContentUpdatedMessage,
+} from '@dailydotdev/schema';
 import { DataSource } from 'typeorm';
 import { EntityTarget } from 'typeorm/common/EntityTarget';
 import {
@@ -11,6 +15,7 @@ import { ChangeObject } from '../../types';
 import { PostKeyword, Source } from '../../entity';
 import { triggerTypedEvent } from '../../common';
 import { logger } from '../../logger';
+import { JsonValue } from '@bufbuild/protobuf';
 
 export const isChanged = <T>(before: T, after: T, property: keyof T): boolean =>
   before[property] != after[property];
@@ -83,15 +88,21 @@ export const notifyPostContentUpdated = async ({
     summary: articlePost.summary,
     content: freeformPost.content,
     language: post.language,
-    contentMeta: post.contentMeta,
+    contentMeta: post.contentMeta
+      ? ContentMeta.fromJson(post.contentMeta as JsonValue, {
+          ignoreUnknownFields: true,
+        })
+      : undefined,
     relatedPosts: relatedPosts.map((item) => ({
       ...item,
       createdAt: +item.createdAt,
     })),
     contentCuration: post.contentCuration,
-    contentQuality: {
-      isAiProbability: post.contentQuality?.is_ai_probability,
-    },
+    contentQuality: post.contentQuality
+      ? ContentQuality.fromJson(post.contentQuality, {
+          ignoreUnknownFields: true,
+        })
+      : undefined,
   });
 
   await triggerTypedEvent(