fix(tiktok): store and use conversation_id as recipient for outgoing messages

Add sourceConversationId field to IncomingContact/OutgoingContact and ContactInbox
schema, populate it from TikTok's conversation_id on incoming messages, and use it
(falling back to sourceId) when sending messages via TikTok Business API.

Author: Deathgiver

apps/worker/src/integration/handlers/received-message.ts

@@ -383,6 +383,7 @@ const detectContactAndConversation = async (props: {
             contactId: newContact.id,
             originalContactId: newContact.id,
             source: inbox.channel,
+            sourceConversationId: incomingContact.sourceConversationId,
             sourceId: incomingContact.sourceId,
             channel: inbox.channel,
           })

integrations/tiktok/src/handlers/message/incoming-message.ts

@@ -87,6 +87,7 @@ export const receiveMessage = async ({
 
   const contact: IncomingContact = {
     sourceId: customerOpenId,
+    sourceConversationId: content.conversation_id,
     firstName: isEcho
       ? (content.to ?? content.to_user?.id ?? content.from_user.id)
       : (content.from ?? content.from_user.id),

integrations/tiktok/src/handlers/message/outgoing-message/index.ts

@@ -19,7 +19,7 @@ export const sendMessage: MessageHandlers<TiktokAuthValue>["sendMessage"] =
     } = props
 
     const businessId = ctx.auth.metadata.openId
-    const conversationId = contact.sourceId
+    const conversationId = contact.sourceConversationId ?? contact.sourceId
     const messageIds: string[] = []
 
     try {
@@ -69,7 +69,7 @@ export const sendFlowStep: MessageHandlers<TiktokAuthValue>["sendFlowStep"] =
     } = props
 
     const businessId = ctx.auth.metadata.openId
-    const conversationId = contact.sourceId
+    const conversationId = contact.sourceConversationId ?? contact.sourceId
     const messageIds: string[] = []
 
     try {

integrations/tiktok/src/handlers/message/outgoing-message/send-text.ts

@@ -15,7 +15,7 @@ export function* convertFlowStepText(
     yield {
       business_id: businessId,
       recipient_type: "CONVERSATION",
-      recipient: contact.sourceId,
+      recipient: contact.sourceConversationId ?? contact.sourceId,
       message_type: "TEXT",
       text: { body: step.text },
     }
@@ -33,7 +33,7 @@ export function* convertFlowStepText(
     yield {
       business_id: businessId,
       recipient_type: "CONVERSATION",
-      recipient: contact.sourceId,
+      recipient: contact.sourceConversationId ?? contact.sourceId,
       message_type: "TEMPLATE",
       template,
     }

packages/database/drizzle/20260609132605_create_integration_mailchimp_table/snapshot.json

@@ -2,11 +2,7 @@
   "version": "8",
   "dialect": "postgres",
   "id": "00ec001e-ef94-4702-afde-69c8fba361c5",
-  "prevIds": [
-    "2837a2eb-228b-4d67-9094-c00454c0ed1b",
-    "351fc50a-eea1-42ef-b92f-193cf6838d66",
-    "c3f29eb6-e631-4178-8eaf-342854b85a0e"
-  ],
+  "prevIds": ["c744036c-a1a7-46d5-9952-109e12fc83a3"],
   "ddl": [
     {
       "values": ["pending", "success", "error", "processing"],

packages/database/drizzle/20260610051033_nullable_file_workspace_id/snapshot.json

@@ -2,7 +2,7 @@
   "version": "8",
   "dialect": "postgres",
   "id": "42a183eb-a770-4d7e-912b-81ce54d3aa5e",
-  "prevIds": ["c744036c-a1a7-46d5-9952-109e12fc83a3"],
+  "prevIds": ["00ec001e-ef94-4702-afde-69c8fba361c5"],
   "ddl": [
     {
       "values": ["pending", "success", "error", "processing"],

packages/database/drizzle/20260610084543_drop_contact_last_activity_at/snapshot.json

@@ -2,11 +2,7 @@
   "version": "8",
   "dialect": "postgres",
   "id": "42b9360b-d40a-4c49-b18f-df5ec19f9e88",
-  "prevIds": [
-    "2837a2eb-228b-4d67-9094-c00454c0ed1b",
-    "351fc50a-eea1-42ef-b92f-193cf6838d66",
-    "c3f29eb6-e631-4178-8eaf-342854b85a0e"
-  ],
+  "prevIds": ["42a183eb-a770-4d7e-912b-81ce54d3aa5e"],
   "ddl": [
     {
       "values": ["pending", "success", "error", "processing"],

packages/database/drizzle/20260611080913_add_source_conversation_id/migration.sql

@@ -0,0 +1 @@
+ALTER TABLE "ContactInbox" ADD COLUMN "sourceConversationId" text;--> statement-breakpoint