Class EngineService

apps/api/src/engine/engine.service.ts:39–75

 */
@Injectable()
export class EngineService {
  private cache = new Map<string, Engine>();

  constructor(
    private readonly settings: SettingsService,
    private readonly keys: KeysService,
  ) {}

  getForUser(userId: string): Engine {
    let engine = this.cache.get(userId);
    if (!engine) {
      const runtime = settingsToRuntime(this.settings.get(userId));
      const config = resolveConfig({ runtime: runtime as never });
      let overrides = demoOverrides();
      if (!overrides) {
        const env = this.keys.envMap(userId);
        const base = {
          provider: config.llmProvider,
          baseUrl: config.backendUrl ?? undefined,
          env,
        };
        overrides = {
          quick: createLlmClient({ ...base, model: config.quickThinkLlm }),
          deep: createLlmClient({ ...base, model: config.deepThinkLlm }),
        };
      }
      engine = createEngine(config, overrides);
      this.cache.set(userId, engine);
    }
    return engine;
  }

  /** Drop a user's cached engine so their next run picks up new settings/keys. */
  invalidate(userId: string): void {
    this.cache.delete(userId);
  }
}