Function flushPendingRestartNotifications

src/cli.ts:867–900

({
  stateDir,
  platformPlugin,
}: {
  stateDir: string;
  platformPlugin: {
    start(): Promise<void>;
    sendText(params: { externalScopeId: string; content: string }): Promise<{
      success: boolean;
    } | null | undefined>;
  };
})

}

async function flushPendingRestartNotifications({
  stateDir,
  platformPlugin,
}: {
  stateDir: string;
  platformPlugin: {
    start(): Promise<void>;
    sendText(params: { externalScopeId: string; content: string }): Promise<{
      success: boolean;
    } | null | undefined>;
  };
}) {
  const filePath = pendingRestartNotificationsFile(stateDir);
  const queued = readPendingRestartNotifications(filePath);
  if (queued.length === 0) {
    return;
  }
  const remaining: PendingRestartNotification[] = [];
  await platformPlugin.start();
  for (const item of queued) {
    try {
      const result = await platformPlugin.sendText({
        externalScopeId: item.externalScopeId,
        content: item.content,
      });
      if (!result?.success) {
        remaining.push(item);
      }
    } catch {
      remaining.push(item);
    }
  }
  writePendingRestartNotifications(filePath, remaining);
}

async function enqueuePendingRestartNotification({
  stateDir,