Function logs

apps/cli/src/commands/logs.ts:61–106

(workspaceId: string)

}

export function logs(workspaceId: string): void {
  const logFile = resolveLogFile(workspaceId);
  let position = 0;

  /**
   * Output any new content appended since the last read.
   * Returns true when the workflow completion marker is detected.
   */
  function flush(): boolean {
    try {
      const { size } = fs.statSync(logFile);
      if (size <= position) return false;

      const data = readRange(logFile, position, size);
      process.stdout.write(data);
      position = size;

      return COMPLETION_PATTERN.test(data);
    } catch {
      // File deleted or unreadable — treat as done
      return true;
    }
  }

  console.log(`Tailing workflow log: ${logFile}`);

  // 1. Output existing content
  if (flush()) {
    process.exit(0);
  }

  // 2. Watch for appended content via chokidar
  const watcher = watch(logFile, { persistent: true });

  const shutdown = (): void => {
    watcher.close().finally(() => process.exit(0));
    // Safety net — force exit if watcher.close() stalls
    setTimeout(() => process.exit(0), 1000).unref();
  };

  watcher.on('change', () => {
    if (flush()) shutdown();
  });

  process.on('SIGINT', shutdown);
}