Function handler

packages/cli/src/commands/worker/init.ts:22–98

(argv: Arguments<InitOptions>)

};

export const handler = async (argv: Arguments<InitOptions>): Promise<void> => {
  const projectName = argv.projectName;
  const targetDir = projectName
    ? path.resolve(process.cwd(), projectName)
    : process.cwd();

  const templateDir = path.resolve(__dirname, '../../templates/worker');

  console.log(chalk.cyan('\n🚀 Initializing Tianji Worker project...\n'));

  // Check if target directory exists and is not empty
  if (projectName) {
    if (await fs.pathExists(targetDir)) {
      const files = await fs.readdir(targetDir);
      if (files.length > 0) {
        console.error(
          chalk.red(
            `Error: Directory "${projectName}" already exists and is not empty.`
          )
        );
        process.exit(1);
      }
    }
  } else {
    // If using current directory, check if it's not empty
    const files = await fs.readdir(targetDir);
    if (files.length > 0) {
      console.error(
        chalk.red(
          'Error: Current directory is not empty. Please use an empty directory or provide a project name.'
        )
      );
      process.exit(1);
    }
  }

  const spinner = ora('Creating project files...').start();

  try {
    // Ensure target directory exists
    await fs.ensureDir(targetDir);

    // Copy template files
    await fs.copy(templateDir, targetDir);

    // Update package.json with project name if provided
    if (projectName) {
      const packageJsonPath = path.join(targetDir, 'package.json');
      const packageJson = await fs.readJson(packageJsonPath);
      packageJson.name = projectName;
      await fs.writeJson(packageJsonPath, packageJson, { spaces: 2 });

      // Update .tianjirc with project name
      const tianjiRcPath = path.join(targetDir, '.tianjirc');
      const tianjiRc = await fs.readJson(tianjiRcPath);
      tianjiRc.name = projectName;
      await fs.writeJson(tianjiRcPath, tianjiRc, { spaces: 2 });
    }