Function enumerateAndRegisterTools

src/utils/tool-registry.ts:412–455

(
  manifest: ResolvedManifest,
  selectedWorkflows: WorkflowManifestEntry[],
  ctx: PredicateContext,
)

}

async function enumerateAndRegisterTools(
  manifest: ResolvedManifest,
  selectedWorkflows: WorkflowManifestEntry[],
  ctx: PredicateContext,
): Promise<{ registeredCount: number; desiredWorkflows: Set<string> }> {
  const desiredToolNames = new Set<string>();
  const desiredWorkflows = new Set<string>();
  const catalogTools: ToolDefinition[] = [];
  const moduleCache = new Map<string, ImportedToolModule>();
  const forceExposedToolAliases = getForceExposedToolAliases();

  for (const workflow of selectedWorkflows) {
    desiredWorkflows.add(workflow.id);

    for (const toolId of workflow.tools) {
      const toolManifest = manifest.tools.get(toolId);
      if (!toolManifest) continue;

      if (!shouldExposeTool(toolManifest, ctx, forceExposedToolAliases)) {
        continue;
      }

      const toolModule = await tryImportToolModule(toolManifest, moduleCache);
      if (!toolModule) {
        continue;
      }

      desiredToolNames.add(toolManifest.names.mcp);
      catalogTools.push(toCatalogTool(toolManifest, workflow, toolModule));
      registerToolFromManifest(toolManifest, toolModule);
    }
  }

  registryState.catalog = createToolCatalog(catalogTools);

  for (const [toolName, registeredTool] of registryState.tools.entries()) {
    if (!desiredToolNames.has(toolName)) {
      registeredTool.remove();
      registryState.tools.delete(toolName);
    }
  }

  return { registeredCount: desiredToolNames.size, desiredWorkflows };
}

export async function applyWorkflowSelectionFromManifest(
  requestedWorkflows: string[] | undefined,