zenflow/composite-service

import { CompositeServiceConfig } from "./interfaces/CompositeServiceConfig";
import { validateAndNormalizeConfig } from "./validateAndNormalizeConfig";
import { CompositeService } from "./CompositeService";

let started = false;

/**
 * Starts a composite service in the current Node.js process
 */
export function startCompositeService(config: CompositeServiceConfig) {
  if (started) {
    throw new Error("Already started a composite service in this process");
  }
  const normalizedConfig = validateAndNormalizeConfig(config);
  new CompositeService(normalizedConfig);
  started = true;
}