Function notifyFn

src/runtime/server.ts:262–271

(adapterName: string, channelId: string, text: string)

  // Build the unified notify function for scheduler → IM push
  const { isMessageSender } = await import("./adapters/types.js");
  const notifyFn = async (adapterName: string, channelId: string, text: string) => {
    const adapter = adapterMap.get(adapterName);
    if (!adapter || !isMessageSender(adapter)) {
      console.warn(
        `[Scheduler] Target adapter "${adapterName}" not found or doesn't support sendMessage`,
      );
      return;
    }
    await adapter.sendMessage(channelId, text);
  };

  // Scheduler adapter (starts AFTER all IM adapters and loads job.json)
  let schedulerAdapter: import("./adapters/scheduler.js").SchedulerAdapter | null = null;