Method execute

src/tools/api/openapi-digest.ts:46–145

(a: z.infer<typeof Args>, _ctx: ToolContext)

  isReadOnly = true; isDestructive = false; argsSchema = Args;

  async execute(a: z.infer<typeof Args>, _ctx: ToolContext): Promise<ToolResult> {
    let raw: string;
    try {
      if (/^https?:\/\//i.test(a.source)) {
        const res = await proxyFetch(a.source, { redirect: 'follow' });
        if (!res.ok) return { content: `Failed to fetch spec: HTTP ${res.status}`, isError: true };
        raw = await res.text();
      } else {
        raw = await fs.readFile(a.source, 'utf8');
      }
    } catch (e: any) {
      return { content: `Could not read spec source: ${e.message}`, isError: true };
    }

    let spec: any;
    try {
      spec = a.source.trim().endsWith('.json') || raw.trimStart().startsWith('{')
        ? JSON.parse(raw)
        : yaml.load(raw);
    } catch (e: any) {
      return { content: `Spec is not valid JSON/YAML: ${e.message}`, isError: true };
    }

    if (!spec || (!spec.paths && !spec.swagger && !spec.openapi)) {
      return { content: 'This does not look like an OpenAPI/Swagger document (no paths/openapi/swagger fields).', isError: true };
    }

    const version = spec.openapi ?? spec.swagger ?? 'unknown';
    const title = spec.info?.title ?? '(untitled)';
    const servers: string[] = (spec.servers ?? []).map((s: any) => s.url).filter(Boolean);
    const securitySchemes = spec.components?.securitySchemes ?? spec.securityDefinitions ?? {};

    const endpoints: EndpointInfo[] = [];
    const methods = ['get', 'post', 'put', 'patch', 'delete', 'head', 'options'];
    for (const [p, item] of Object.entries<any>(spec.paths ?? {})) {
      if (a.filter && !p.includes(a.filter)) continue;
      for (const m of methods) {
        const op = item?.[m];
        if (!op) continue;
        const params: ParamInfo[] = [...(item.parameters ?? []), ...(op.parameters ?? [])].map((pr: any) => ({
          name: pr.name, in: pr.in, required: !!pr.required,
          type: schemaLabel(pr.schema ?? pr),
        }));
        let body: string | undefined;
        if (op.requestBody) {
          const content = op.requestBody.content ?? {};
          const first = content['application/json'] ?? Object.values(content)[0];
          body = schemaLabel((first as any)?.schema);
        } else if (m === 'post' || m === 'put' || m === 'patch') {
          // Swagger 2.0 carries body in parameters with in:'body'.
          const b = params.find(pr => pr.in === 'body');
          if (b) body = b.type;
        }
        const responses = op.responses ?? {};
        const okKey = Object.keys(responses).find(k => k.startsWith('2')) ?? 'default';
        const okResp = responses[okKey];
        const okContent = okResp?.content?.['application/json'] ?? (okResp?.content ? Object.values(okResp.content)[0] : undefined);
        const success = schemaLabel((okContent as any)?.schema ?? okResp?.schema);