Function discoverWorkflowScripts

src/node/services/workflows/workflowScriptDiscovery.ts:33–78

(
  input: DiscoverWorkflowScriptsInput
)

 * workflows cover the common case.
 */
export async function discoverWorkflowScripts(
  input: DiscoverWorkflowScriptsInput
): Promise<AvailableWorkflow[]> {
  const skillNames: SkillName[] = [];
  const seen = new Set<string>();
  const addSkill = (descriptor: AgentSkillDescriptor) => {
    if (!seen.has(descriptor.name)) {
      seen.add(descriptor.name);
      skillNames.push(descriptor.name);
    }
  };

  // Built-ins aren't part of discoverAgentSkills' project/global scan, so seed them first;
  // readAgentSkill resolves by precedence (project > global > built-in) when names collide.
  getBuiltInSkillDescriptors().forEach(addSkill);
  try {
    (await discoverAgentSkills(input.runtime, input.workspacePath)).forEach(addSkill);
  } catch (error) {
    log.warn(`Workflow script discovery: failed to enumerate skills: ${getErrorMessage(error)}`);
  }

  const available: AvailableWorkflow[] = [];
  for (const skillName of skillNames) {
    try {
      const resolved = await resolveWorkflowScript({
        scriptPath: `skill://${skillName}/${WORKFLOW_SKILL_ENTRY}`,
        runtime: input.runtime,
        workspacePath: input.workspacePath,
        projectTrusted: input.projectTrusted,
      });
      available.push({
        descriptor: buildWorkflowScriptDescriptor(resolved),
        scriptPath: resolved.canonicalScriptPath,
        args: summarizeWorkflowArgs(parseWorkflowMetadata(resolved.source)) ?? [],
      });
    } catch {
      // Skip non-workflow skills (no workflow.js), untrusted project skills, AND scripts whose
      // arg metadata fails to parse/summarize — keeping the whole body in the per-skill catch so
      // one malformed workflow can't abort discovery and hide every other workflow.
      continue;
    }
  }

  available.sort((a, b) => a.descriptor.name.localeCompare(b.descriptor.name));
  return available;
}