core/src/features/init.js

/**
 * Core Feature Database Initialization (CLI)
 *
 * Initializes and drops DB tables for each core feature.
 * Features are discovered from CORE_FEATURES — no manual wiring needed
 * when adding a new feature.
 */

import { CORE_FEATURES } from './features.registry.js';
import { done, fail, info, step } from '@zen/core/shared/logger';

/**
 * Initialize all core feature databases.
 * @returns {Promise<{ created: string[], skipped: string[] }>}
 */
export async function initFeatures() {
  const created = [];
  const skipped = [];

  step('Initializing feature databases...');

  for (const featureName of CORE_FEATURES) {
    try {
      step(`Initializing ${featureName}...`);
      const db = await import(`./${featureName}/db.js`);

      if (typeof db.createTables === 'function') {
        const result = await db.createTables();

        if (result?.created) created.push(...result.created);
        if (result?.skipped) skipped.push(...result.skipped);

        done(`${featureName} initialized`);
      } else {
        info(`${featureName} has no createTables function`);
      }
    } catch (error) {
      fail(`${featureName}: ${error.message}`);
      throw error;
    }
  }

  return { created, skipped };
}

/**
 * Drop all core feature databases in reverse order.
 * @returns {Promise<void>}
 */
export async function dropFeatures() {
  for (const featureName of [...CORE_FEATURES].reverse()) {
    try {
      const db = await import(`./${featureName}/db.js`);

      if (typeof db.dropTables === 'function') {
        await db.dropTables();
      } else {
        info(`${featureName} has no dropTables function`);
      }
    } catch (error) {
      fail(`${featureName}: ${error.message}`);
      throw error;
    }
  }
}