Function updateSpec

packages/plugins/openapi/src/sdk/plugin.ts:935–1077

(rawSlug: string, input?: OpenApiUpdateSpecInput)

      // the curated description, connections, and policies are all untouched -
      // this is the "spec changed upstream" path, not a re-add.
      const updateSpec = (rawSlug: string, input?: OpenApiUpdateSpecInput) =>
        Effect.gen(function* () {
          const slug = IntegrationSlug.make(rawSlug);
          const record = yield* ctx.core.integrations.get(slug);
          const current = record ? decodeOpenApiIntegrationConfig(record.config) : null;
          if (!record || !current) {
            return yield* new IntegrationNotFoundError({ slug });
          }

          // The new spec source: explicit input wins; otherwise re-fetch from
          // where the spec originally came from. A pasted-blob integration has
          // no origin, so updating it requires a new input.
          const nextOverrides = input?.specOverrides ?? current.specOverrides ?? [];
          const storedSourceHash = current.sourceSpecHash ?? current.specHash;
          const storedSourceText =
            input?.spec === undefined && !current.specUrl && input?.specOverrides !== undefined
              ? storedSourceHash
                ? yield* ctx.storage.getSpec(storedSourceHash)
                : null
              : null;
          const specInput: OpenApiSpecInput | null =
            input?.spec ??
            (current.specUrl
              ? { kind: "url", url: current.specUrl }
              : storedSourceText
                ? { kind: "blob", value: storedSourceText }
                : null);
          if (specInput === null) {
            return yield* new OpenApiParseError({
              message:
                "This integration's spec was pasted inline and has no source URL to re-fetch. Provide the updated spec content.",
            });
          }

          // Resolve + compile BEFORE the transaction (same Hyperdrive-deadlock
          // rule as addSpec: never hold BEGIN across a network fetch).
          const resolved = yield* resolveSpecForInput(
            {
              spec: specInput,
              specFormat: current.specFormat,
              specOverrides: nextOverrides,
              headers: current.headers,
              queryParams: current.queryParams,
              baseUrl: current.baseUrl,
            },
            httpClientLayer,
          );
          const compiled = resolved.keepPathItem
            ? undefined
            : yield* compileOpenApiSpec(resolved.specText);

          const previousOperations = yield* ctx.storage.listOperations(rawSlug);
          const previousNames = new Set(previousOperations.map((op) => op.toolName));

          // The resolved spec text lives in the plugin blob store keyed by its
          // content hash (`spec/<hash>`); the config carries only the hash. Put
          // the blob outside the transaction - re-puts are idempotent and an
          // aborted config update just leaves an unreferenced blob.