Class PluginManager

packages/agent-core/src/plugin/manager.ts:37–315

}

export class PluginManager {
  private readonly kimiHomeDir: string;
  private records = new Map<string, PluginRecord>();

  constructor(options: PluginManagerOptions) {
    this.kimiHomeDir = options.kimiHomeDir;
  }

  async load(): Promise<void> {
    const file = await readInstalled(this.kimiHomeDir);
    const next = new Map<string, PluginRecord>();
    for (const entry of file.plugins) {
      next.set(entry.id, await this.materialize(entry));
    }
    this.records = next;
  }

  list(): readonly PluginRecord[] {
    return [...this.records.values()].toSorted((a, b) => a.id.localeCompare(b.id));
  }

  get(id: string): PluginRecord | undefined {
    return this.records.get(normalizePluginId(id));
  }

  async install(source: string): Promise<PluginRecord> {
    const resolved = resolveInstallSource(source);

    let normalizedRoot: string;
    let originalSource: string;
    let sourceType: PluginSource;
    let parsed: ParsedManifestResult;
    let id: string;
    let github: PluginGithubMetadata | undefined;

    if (resolved.kind === 'local-path') {
      const sourceRoot = await normalizeInstallRoot(resolved.path);
      originalSource = resolved.path;
      sourceType = 'local-path';
      parsed = await parseManifest(sourceRoot);
      if (parsed.manifest === undefined) {
        const msg = parsed.diagnostics.find((d) => d.severity === 'error')?.message ?? 'no manifest';
        throw new Error(`Cannot install plugin at ${sourceRoot}: ${msg}`);
      }
      id = normalizePluginId(parsed.manifest.name);
      normalizedRoot = await copyPluginToManagedRoot(this.kimiHomeDir, id, sourceRoot);
      parsed = await parseManifest(normalizedRoot);
    } else {
      let zipUrl: string;
      if (resolved.kind === 'github') {
        const githubResolution = await resolveGithubSource(resolved);
        zipUrl = githubResolution.tarballUrl;
        originalSource = source.trim();
        sourceType = 'github';
        github = {
          owner: resolved.owner,
          repo: resolved.repo,
          ref: githubResolution.ref,