Fix Reddit comment streams (#1698)

CrowdDotDev · Oct 16, 2023 · b0f5c64 · b0f5c64
1 parent 5e82450
commit b0f5c64
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/services/libs/integrations/src/integrations/reddit/api/getMoreComments.ts b/services/libs/integrations/src/integrations/reddit/api/getMoreComments.ts
@@ -37,7 +37,7 @@ async function getMoreComments(
       url: `http://oauth.reddit.com/api/morechildren?api_type=json`,
       params: {
         depth: 99,
-        link_id: input.postId,
+        link_id: `t3_${input.postId}`,
         children: input.children,
       },
       headers: {

diff --git a/services/libs/integrations/src/integrations/reddit/processStream.ts b/services/libs/integrations/src/integrations/reddit/processStream.ts
@@ -156,7 +156,11 @@ const processMoreCommentStream: ProcessStreamHandler = async (ctx) => {
     ctx,
   )
 
-  const comments = response.json.data.things
+  const comments = response?.json?.data?.things
+
+  if (!comments) {
+    return
+  }
 
   if (comments.length === 0) {
     return