feat: Convert cli files to JS

packages/cli/src/commands/start.js

@@ -0,0 +1,96 @@
+import { readFileSync } from 'fs';
+import { Command, Flags } from '@oclif/core';
+import * as dotenv from 'dotenv';
+import process from 'process';
+
+export default class Start extends Command {
+  static description = 'Run automatisch';
+
+  static flags = {
+    env: Flags.string({
+      multiple: true,
+      char: 'e',
+    }),
+    'env-file': Flags.string(),
+  };
+
+  get isProduction() {
+    return process.env.APP_ENV === 'production';
+  }
+
+  async prepareEnvVars() {
+    const { flags } = await this.parse(Start);
+
+    if (flags['env-file']) {
+      const envFile = readFileSync(flags['env-file'], 'utf8');
+      const envConfig = dotenv.parse(envFile);
+
+      for (const key in envConfig) {
+        const value = envConfig[key];
+        process.env[key] = value;
+      }
+    }
+
+    if (flags.env) {
+      for (const env of flags.env) {
+        const [key, value] = env.split('=');
+        process.env[key] = value;
+      }
+    }
+
+    // must serve until more customization is introduced
+    delete process.env.SERVE_WEB_APP_SEPARATELY;
+  }
+
+  async createDatabaseAndUser() {
+    const utils = await import('@automatisch/backend/database-utils');
+
+    await utils.createDatabaseAndUser(
+      process.env.POSTGRES_DATABASE,
+      process.env.POSTGRES_USERNAME
+    );
+  }
+
+  async runMigrationsIfNeeded() {
+    const { logger } = await import('@automatisch/backend/logger');
+    const database = await import('@automatisch/backend/database');
+    const migrator = database.client.migrate;
+
+    const [, pendingMigrations] = await migrator.list();
+    const pendingMigrationsCount = pendingMigrations.length;
+    const needsToMigrate = pendingMigrationsCount > 0;
+
+    if (needsToMigrate) {
+      logger.info(`Processing ${pendingMigrationsCount} migrations.`);
+
+      await migrator.latest();
+      logger.info(`Completed ${pendingMigrationsCount} migrations.`);
+    } else {
+      logger.info('No migrations needed.');
+    }
+  }
+
+  async seedUser() {
+    const utils = await import('@automatisch/backend/database-utils');
+
+    await utils.createUser();
+  }
+
+  async runApp() {
+    await import('@automatisch/backend/server');
+  }
+
+  async run() {
+    await this.prepareEnvVars();
+
+    if (!this.isProduction) {
+      await this.createDatabaseAndUser();
+    }
+
+    await this.runMigrationsIfNeeded();
+
+    await this.seedUser();
+
+    await this.runApp();
+  }
+}