Use last message timestamp when upserting Slack Messages

dust-tt · Sep 6, 2023 · c3defda · c3defda
1 parent 59aae41
commit c3defda
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/connectors/src/connectors/slack/temporal/activities.ts b/connectors/src/connectors/slack/temporal/activities.ts
@@ -385,9 +385,7 @@ export async function syncNonThreaded(
   const documentId = `slack-${channelId}-messages-${startDateStr}-${endDateStr}`;
   const firstMessage = messages[0];
   let sourceUrl: string | undefined = undefined;
-  const createdAt = firstMessage?.ts
-    ? parseInt(firstMessage.ts, 10) * 1000
-    : undefined;
+
   if (firstMessage && firstMessage.ts) {
     const linkRes = await client.chat.getPermalink({
       channel: channelId,
@@ -397,6 +395,10 @@ export async function syncNonThreaded(
       sourceUrl = linkRes.permalink;
     }
   }
+  const lastMessage = messages[messages.length - 1];
+  const createdAt = lastMessage?.ts
+    ? parseInt(lastMessage.ts, 10) * 1000
+    : undefined;
 
   const tags = getTagsForPage(documentId, channelId, channelName);
   await SlackMessages.upsert({
@@ -531,9 +533,7 @@ export async function syncThread(
 
   const firstMessage = allMessages[0];
   let sourceUrl: string | undefined = undefined;
-  const createdAt = firstMessage?.ts
-    ? parseInt(firstMessage.ts, 10) * 1000
-    : undefined;
+
   if (firstMessage && firstMessage.ts) {
     const linkRes = await client.chat.getPermalink({
       channel: channelId,
@@ -543,6 +543,10 @@ export async function syncThread(
       sourceUrl = linkRes.permalink;
     }
   }
+  const lastMessage = allMessages[allMessages.length - 1];
+  const createdAt = lastMessage?.ts
+    ? parseInt(lastMessage.ts, 10) * 1000
+    : undefined;
 
   const tags = getTagsForPage(documentId, channelId, channelName, threadTs);