twenty/packages/twenty-sdk/src/cli/commands/app-sync.command.ts

import chalk from 'chalk';
import { CURRENT_EXECUTION_DIRECTORY } from '../constants/current-execution-directory';
import { ApiService } from '../services/api.service';
import { GenerateService } from '../services/generate.service';
import { type ApiResponse } from '../types/config.types';
import { loadManifest } from '../utils/load-manifest';

export class AppSyncCommand {
  private apiService = new ApiService();
  private generateService = new GenerateService();

  async execute(
    appPath: string = CURRENT_EXECUTION_DIRECTORY,
  ): Promise<ApiResponse<any>> {
    try {
      console.log(chalk.blue('🚀 Syncing Twenty Application'));
      console.log(chalk.gray(`📁 App Path: ${appPath}`));
      console.log('');

      return await this.synchronize({ appPath });
    } catch (error) {
      console.error(
        chalk.red('Sync failed:'),
        error instanceof Error ? error.message : error,
      );
      throw error;
    }
  }

  private async synchronize({ appPath }: { appPath: string }) {
    const { manifest, packageJson, yarnLock, shouldGenerate } =
      await loadManifest(appPath);

    let serverlessSyncResult = await this.apiService.syncApplication({
      manifest,
      packageJson,
      yarnLock,
    });

    if (shouldGenerate) {
      await this.generateService.generateClient(appPath);

      const { manifest: manifestWithClient } = await loadManifest(appPath);

      serverlessSyncResult = await this.apiService.syncApplication({
        manifest: manifestWithClient,
        packageJson,
        yarnLock,
      });
    }

    if (serverlessSyncResult.success === false) {
      console.error(
        chalk.red('❌ Serverless functions Sync failed:'),
        serverlessSyncResult.error,
      );
    } else {
      console.log(chalk.green('✅ Serverless functions synced successfully'));
    }

    return serverlessSyncResult;
  }
}