Function handler

packages/cli/src/commands/worker/pull.ts:35–237

(argv: Arguments<PullOptions>)

};

export const handler = async (argv: Arguments<PullOptions>): Promise<void> => {
  console.log(chalk.cyan('\n📥 Pulling Tianji Worker from remote...\n'));

  try {
    // Check if user is logged in
    if (!(await isLoggedIn())) {
      console.error(
        chalk.red('Error: Not logged in. Please run "tianji login" first.\n')
      );
      process.exit(1);
    }

    // Load global config
    const globalConfig = await loadGlobalConfig();
    if (!globalConfig) {
      console.error(
        chalk.red(
          'Error: Configuration not found. Please run "tianji login" first.\n'
        )
      );
      process.exit(1);
    }

    const currentDir = process.cwd();
    const projectConfig = await loadProjectConfig(currentDir);
    const hasTianjirc = projectConfig !== null;

    // Determine worker ID
    let workerId: string | undefined;
    if (argv.workerId) {
      // Command line argument takes priority
      workerId = argv.workerId;
    } else if (hasTianjirc && projectConfig.workerId) {
      // Use worker ID from .tianjirc
      workerId = projectConfig.workerId;
    }

    if (!workerId) {
      console.error(
        chalk.red(
          'Error: Worker ID is required. Please provide it as an argument or ensure .tianjirc contains a workerId.\n'
        )
      );
      console.log(chalk.white('Usage: tianji worker pull <worker-id>\n'));
      process.exit(1);
    }

    // Check directory status
    const files = await fs.readdir(currentDir);
    const isEmptyDir = files.length === 0;

    if (!hasTianjirc && !isEmptyDir) {
      // Directory is not empty and not a Tianji worker project
      console.error(
        chalk.red(
          'Error: Current directory is not empty and is not a Tianji worker project.\n'
        )
      );