#!/usr/bin/env bash
":"; //# comment; exec /usr/bin/env node --input-type=module - "$@" < "$0"

import { readFile, writeFile } from "fs/promises";
import openapi from "openapi-typescript";
// import { resolve } from "path";
// import { cwd } from "process";

const NOTICE = `// This file was auto-generated by @insertish/oapi!\n`;

readFile("OpenAPI.json").then((data) => {
  // Load and patch anything we need to
  let source = data.toString();

  if (process.env.REWRITE_ANYOF) {
    source = source.replace(/"anyOf"/g, '"oneOf"');
  }

  // Parse spec
  const spec = JSON.parse(source);

  // Copy index.ts
  //   readFile(
  //     resolve(cwd(), "node_modules", "@insertish", "oapi", "src", "index.ts")
  //   ).then((data) => writeFile("src/index.ts", data));

  // Generate Schema
  openapi(spec).then((data) => writeFile("src/schema.ts", data));

  // Route Types + Data
  {
    const entries = [
      "import { paths } from './schema';",
      "export type APIRoutes =",
    ];
    const paths = Object.keys(spec.paths);
    const queryData = {};

    for (const path of paths) {
      const data = spec.paths[path];
      const methods = Object.keys(data);

      let template = path.replace(/\{\w+\}/g, "${string}");

      for (const method of methods) {
        const OPERATION = `paths['${path}']['${method}']`;

        const route = data[method];
        const response =
          Object.keys(route["responses"]).find((x) => x !== "default") ||
          "default";
        const contentType = Object.keys(
          route["responses"][response]["content"] || {}
        )[0];
        const RESPONSE =
          response === "204" || !contentType
            ? "undefined"
            : `${OPERATION}['responses']['${response}']['content']['${contentType}']`;

        let queryParams = [];
        let hasBody = false;

        if (route["parameters"]) {
          for (const parameter of route["parameters"]) {
            if (parameter.in === "query") {
              queryParams.push(parameter.name);
            }
          }
        }

        if (route["requestBody"]?.["content"]?.["application/json"]) {
          hasBody = true;
        }

        let params = "undefined";
        if (hasBody || queryParams.length > 0) {
          let entries = [];

          if (queryParams.length > 0) {
            entries.push(`${OPERATION}['parameters']['query']`);
          }

          if (hasBody) {
            entries.push(
              `${OPERATION}['requestBody']['content']['application/json']`
            );
          }

          params = entries.join("|");
        }

        const parts = path.split("").filter((x) => x === "/").length;
        entries.push(
          `| { method: '${method}', path: \`${template}\`, parts: ${parts}, params: ${params}, response: ${RESPONSE} }`
        );

        if (/\{\w+\}/.test(path)) {
          entries.push(
            `| { method: '${method}', path: '-${path}', parts: ${parts}, params: ${params}, response: ${RESPONSE} }`
          );
        }

        queryData[path] = {
          ...queryData[path],
          [method]: queryParams,
        };
      }
    }

    const pathResolve = {};
    for (const path of paths) {
      const segments = path.split("/");
      segments.shift();
      pathResolve[segments.length] = [
        ...(pathResolve[segments.length] || []),
        segments.map((key) => (/\{.*\}/.test(key) ? [key] : key)),
      ];
    }

    writeFile("src/routes.ts", NOTICE + entries.join("\n") + ";");
    writeFile(
      "src/params.ts",
      NOTICE +
        "export const pathResolve = " +
        JSON.stringify(pathResolve) +
        ";\n" +
        "export const queryParams = " +
        JSON.stringify(queryData) +
        ";"
    );
  }

  // Type Exports
  {
    const entries = ["import { components } from './schema';"];
    const schemas = spec.components.schemas;

    for (const schema of Object.keys(schemas)) {
      entries.push(
        `export type ${schema.replace(
          /\s/g,
          "_"
        )} = components['schemas']['${schema}'];`
      );
    }

    writeFile("src/types.ts", NOTICE + entries.join("\n") + ";");
  }

  // Default Base URL
  const baseURL = spec["servers"]?.[0]?.["url"];
  writeFile(
    "src/baseURL.ts",
    NOTICE +
      `export const defaultBaseURL = ${
        baseURL ? '"' + baseURL + '"' : "undefined"
      };`
  );
});