Plugins

import type { PluginPort, PluginRegistryApi } from "@comis/core";
import type { Result } from "@comis/shared";

export interface PluginPort {
  readonly id: string;
  readonly name: string;
  readonly version?: string;
  register(registry: PluginRegistryApi): Result<void, Error>;
  activate?(): Promise<Result<void, Error>>;
  deactivate?(): Promise<Result<void, Error>>;
}

export interface PluginRegistryApi {
  registerHook<K extends HookName>(
    hookName: K,
    handler: HookHandlerMap[K],
    options?: { priority?: number },
  ): void;
}

import type { PluginPort, PluginRegistryApi } from "@comis/core";
import { ok, type Result } from "@comis/shared";

export const operatorContextPlugin: PluginPort = {
  id: "operator-context",
  name: "Operator Context",

  register(registry: PluginRegistryApi): Result<void, Error> {
    registry.registerHook(
      "before_agent_start",
      (_event, ctx) => {
        if (!ctx.isFirstMessageInSession) return;
        return { prependContext: "Follow the operator runbook for this session." };
      },
      { priority: 20 },
    );

    registry.registerHook("before_delivery", (event) => ({
      text: `${event.text}\n\nSent through Comis`,
    }));

    return ok(undefined);
  },
};

const result = pluginRegistry.register(operatorContextPlugin);
if (!result.ok) return result;