feat(worker): refresh zalo and tiktok tokens twice daily

Zalo and TikTok tokens only live ~24-25h, so the single 02:00 cron left
a ~1h margin: one missed or late run and every channel expired mid-day.
The refreshChannelTokens job now accepts an optional channel filter and
a second scheduler runs the two short-lived channels again at 14:00,
keeping them at most ~12h from a refresh. Long-lived Meta/WhatsApp
tokens stay on the daily run.

Author: Deathgiver

apps/worker/src/schedule/handlers/refresh-channel-tokens.ts

@@ -29,10 +29,13 @@ const refreshTokenAdapter: Record<
   telegram: undefined,
 }
 
-export async function refreshChannelTokens(): Promise<void> {
+export async function refreshChannelTokens(
+  channels?: ChannelType[],
+): Promise<void> {
   const entries = Object.entries(refreshTokenAdapter).filter(
     (entry): entry is [ChannelType, () => Promise<void>] =>
-      entry[1] !== undefined,
+      entry[1] !== undefined &&
+      (!channels || channels.includes(entry[0] as ChannelType)),
   )
 
   const results = await Promise.allSettled(

apps/worker/src/schedule/handlers/register-schedules.ts

@@ -1,3 +1,4 @@
+import { channelTypes } from "@chatbotx.io/database/partials"
 import {
   PURGE_WORKSPACES_INTERVAL_MINUTES,
   ScheduleJobData,
@@ -294,6 +295,26 @@ export const registerSchedules = async () => {
     },
   )
 
+  // Zalo and TikTok tokens only live ~24-25h, so the single 02:00 run leaves
+  // almost no margin: one missed run and they expire mid-day. This extra
+  // midday run keeps them at most ~12h from a refresh; the long-lived
+  // Meta/WhatsApp tokens stay on the daily run above.
+  await scheduleQueue.upsertJobScheduler(
+    "refreshShortLivedChannelTokens",
+    {
+      pattern: "0 14 * * *",
+    },
+    {
+      name: ScheduleJobData.refreshChannelTokens,
+      data: {
+        type: ScheduleJobData.refreshChannelTokens,
+        data: {
+          channels: [channelTypes.enum.zalo, channelTypes.enum.tiktok],
+        },
+      },
+    },
+  )
+
   if (isCloud) {
     await scheduleQueue.upsertJobScheduler(
       ScheduleJobData.unsubscribeExpiredTrials,

apps/worker/src/schedule/worker.ts

@@ -141,7 +141,7 @@ async function startScheduleWorker() {
           return
 
         case ScheduleJobData.refreshChannelTokens:
-          await refreshChannelTokens()
+          await refreshChannelTokens(job.data.data.channels)
           return
 
         case ScheduleJobData.unsubscribeExpiredTrials:

packages/worker-config/src/queues/schedule/index.ts

@@ -1,3 +1,4 @@
+import type { ChannelType } from "@chatbotx.io/database/partials"
 import { Queue } from "bullmq"
 import { z } from "zod"
 import {
@@ -168,7 +169,9 @@ export type ScheduleJobPurgeAutomationThrottle = {
 
 export type ScheduleJobRefreshChannelTokens = {
   type: typeof ScheduleJobData.refreshChannelTokens
-  data: Record<string, never>
+  // No `channels` = refresh every channel. The short-lived scheduler passes
+  // ["zalo", "tiktok"] for the extra midday run (see register-schedules.ts).
+  data: { channels?: ChannelType[] }
 }
 
 export type ScheduleJobUnsubscribeExpiredTrials = {