Function buildInputSchema

packages/plugins/openapi/src/sdk/extract.ts:410–488

(
  parameters: readonly OperationParameter[],
  requestBody: OperationRequestBody | undefined,
  servers: readonly ServerInfo[],
)

};

export const buildInputSchema = (
  parameters: readonly OperationParameter[],
  requestBody: OperationRequestBody | undefined,
  servers: readonly ServerInfo[],
): Record<string, unknown> | undefined => {
  const properties: Record<string, unknown> = {};
  const required: string[] = [];
  let requiredBodyAlternatives: readonly { readonly required: readonly string[] }[] | undefined;

  for (const param of parameters) {
    properties[param.name] = Option.getOrElse(param.schema, () => ({ type: "string" }));
    if (param.required) required.push(param.name);
  }

  // A path/query parameter named `server` takes precedence over the host input.
  const serverProperty = buildServerInputProperty(servers);
  if (serverProperty && !("server" in properties)) properties.server = serverProperty;

  if (requestBody) {
    // When the spec declares multiple media types for this requestBody,
    // expose `contentType` so the model can pick. Default = first declared.
    // For mixed bodies, `body` schema tracks the default; the model is
    // responsible for supplying a body shape that matches whichever
    // contentType it picks. Octet-only operations use `bodyBase64` instead.
    const contents = Option.getOrUndefined(requestBody.contents);
    const defaultIsOctetStream =
      requestBody.contentType.split(";")[0]?.trim().toLowerCase() === "application/octet-stream";
    const acceptsOctetStream =
      defaultIsOctetStream ||
      contents?.some(
        (content) =>
          content.contentType.split(";")[0]?.trim().toLowerCase() === "application/octet-stream",
      ) === true;
    const acceptsBody =
      !defaultIsOctetStream ||
      contents?.some(
        (content) =>
          content.contentType.split(";")[0]?.trim().toLowerCase() !== "application/octet-stream",
      ) === true;
    if (acceptsBody) {
      properties.body = Option.getOrElse(requestBody.schema, () => ({ type: "object" }));
    }
    if (acceptsOctetStream) {
      properties.bodyBase64 = {
        type: "string",
        contentEncoding: "base64",
        contentMediaType: "application/octet-stream",
        description:
          "Base64-encoded bytes for application/octet-stream request bodies. When contentType is omitted, this selects application/octet-stream.",
      };
    }
    if (requestBody.required) {
      if (acceptsOctetStream && acceptsBody) {
        requiredBodyAlternatives = [{ required: ["body"] }, { required: ["bodyBase64"] }];
      } else {
        required.push(acceptsOctetStream ? "bodyBase64" : "body");
      }
    }