{"version":3,"sources":["../../gen/fetch.ts"],"sourcesContent":["/**\n * Generated by orval v7.10.0 🍺\n * Do not edit manually.\n * ows-abacus-contract\n * OpenAPI spec version: 1.0.0\n */\nimport type {\n  ContractLifecycleResponse,\n  ContractResponse,\n  ContractsResponse,\n  DataloadContractsResponse,\n  GetContractHeaders,\n  GetContractLifecyclePathParameters,\n  GetContractPathParameters,\n  GetContractsBody,\n  GetHealthHeaders,\n  HealthResponse,\n  ReactivateContractHeaders,\n  ReactivateContractPathParameters,\n  TerminateContractBody,\n  TerminateContractHeaders,\n  TerminateContractPathParameters,\n  UpdateContractBody,\n  UpdateContractHeaders,\n  UpdateContractPathParameters,\n} from \"./types\";\n/**\n * Retrieves contract details\n */\nexport const getGetContractUrl = ({\n  contractId,\n}: GetContractPathParameters) => {\n  return `/contract/${contractId}/`;\n};\n/**\n * Update contract details for a specified contract\n */\nexport const getUpdateContractUrl = ({\n  contractId,\n}: UpdateContractPathParameters) => {\n  return `/contract/${contractId}/`;\n};\n/**\n * Get the contract lifecycle associated to the specified contract\n */\nexport const getGetContractLifecycleUrl = ({\n  contractId,\n}: GetContractLifecyclePathParameters) => {\n  return `/contract/${contractId}/contract-lifecycle/`;\n};\n/**\n * Terminate a contract\n */\nexport const getTerminateContractUrl = ({\n  contractId,\n}: TerminateContractPathParameters) => {\n  return `/contract/${contractId}/terminate/`;\n};\n/**\n * Reactivate a contract\n */\nexport const getReactivateContractUrl = ({\n  contractId,\n}: ReactivateContractPathParameters) => {\n  return `/contract/${contractId}/reactivate/`;\n};\n/**\n * Get a list of contracts by contract_id\n */\nexport const getGetContractsUrl = () => {\n  return `/contracts/`;\n};\n/**\n * Get a list of contracts by contract_id\n */\nexport const getDataloadContractsUrl = () => {\n  return `/contracts/dataloader/`;\n};\n/**\n * Check the health of the application.\n */\nexport const getGetHealthUrl = () => {\n  return `/hello/`;\n};\n/**\n * Generated by @abacus/api-client-generator\n * Do not edit manually.\n */\nimport { type Logger, type HeaderProvider } from \"@abacus/common\";\n\nimport { type Throttler } from \"@abacus/throttlers\";\n\nimport { ApiResponse } from \"./common\";\n\nexport interface ApiConfig {\n  auth?: HeaderProvider;\n  baseUrl?: string;\n  logger?: Logger;\n  throttler?: Throttler;\n}\n\nexport class OwsAbacusContractClient {\n  auth?: HeaderProvider;\n  baseUrl: string;\n  logger?: Logger;\n  throttler?: Throttler;\n\n  constructor(config?: ApiConfig) {\n    this.auth = config?.auth;\n    this.baseUrl = config?.baseUrl ?? `https://localhost:8080`;\n    this.logger = config?.logger;\n    this.throttler = config?.throttler;\n  }\n\n  async _fetch<T>(url: string, options: RequestInit): Promise<ApiResponse<T>> {\n    // On request\n    url = await this._onRequest(url, options);\n    // Make request\n    const response = await fetch(url, options);\n    // Get data\n    const data = await this._getData<T>(response);\n    const headers = Object.fromEntries(response.headers.entries());\n    // Return response\n    return { data, headers, status: response.status };\n  }\n\n  private _getData<T>(res: Response): Promise<T> {\n    const contentType = res.headers.get(\"content-type\");\n    if (contentType) {\n      if (contentType.includes(\"application/json\")) {\n        return res.json() as Promise<T>;\n      }\n      if (contentType && contentType.includes(\"application/pdf\")) {\n        return res.blob() as Promise<T>;\n      }\n    }\n    return res.text() as Promise<T>;\n  }\n\n  private async _getHeaders(\n    headers?: Record<string, string>,\n  ): Promise<Record<string, string>> {\n    return {\n      ...(await this.auth?.getHeaders()),\n      ...headers,\n    };\n  }\n\n  private async _onRequest(url: string, options: RequestInit): Promise<string> {\n    // Throttle the request\n    await this.throttler?.wait();\n    // Get URL\n    url = url = `${this.baseUrl}${url}`;\n    // Add Headers\n    const headers = options.headers as Record<string, string>;\n    options.headers = await this._getHeaders(headers);\n    // Log the request\n    this.logger?.debug(`Requesting ${options.method} ${url}`);\n    return url;\n  }\n\n  async getContract(\n    { contractId }: GetContractPathParameters,\n    headers?: GetContractHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<ContractResponse>(getGetContractUrl({ contractId }), {\n        ...options,\n        method: \"GET\",\n        headers: { ...headers, ...options?.headers },\n      });\n    }\n  }\n\n  async updateContract(\n    { contractId }: UpdateContractPathParameters,\n    updateContractBody: UpdateContractBody,\n    headers?: UpdateContractHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<ContractResponse>(\n        getUpdateContractUrl({ contractId }),\n        {\n          ...options,\n          method: \"PUT\",\n          headers: {\n            \"Content-Type\": \"application/json\",\n            ...headers,\n            ...options?.headers,\n          },\n          body: JSON.stringify(updateContractBody),\n        },\n      );\n    }\n  }\n\n  async getContractLifecycle(\n    { contractId }: GetContractLifecyclePathParameters,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<ContractLifecycleResponse>(\n        getGetContractLifecycleUrl({ contractId }),\n        {\n          ...options,\n          method: \"GET\",\n        },\n      );\n    }\n  }\n\n  async terminateContract(\n    { contractId }: TerminateContractPathParameters,\n    terminateContractBody: TerminateContractBody,\n    headers?: TerminateContractHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<ContractResponse>(\n        getTerminateContractUrl({ contractId }),\n        {\n          ...options,\n          method: \"PUT\",\n          headers: {\n            \"Content-Type\": \"application/json\",\n            ...headers,\n            ...options?.headers,\n          },\n          body: JSON.stringify(terminateContractBody),\n        },\n      );\n    }\n  }\n\n  async reactivateContract(\n    { contractId }: ReactivateContractPathParameters,\n    headers?: ReactivateContractHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<ContractResponse>(\n        getReactivateContractUrl({ contractId }),\n        {\n          ...options,\n          method: \"PUT\",\n          headers: { ...headers, ...options?.headers },\n        },\n      );\n    }\n  }\n\n  async getContracts(\n    getContractsBody: GetContractsBody,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<ContractsResponse>(getGetContractsUrl(), {\n        ...options,\n        method: \"POST\",\n        headers: { \"Content-Type\": \"application/json\", ...options?.headers },\n        body: JSON.stringify(getContractsBody),\n      });\n    }\n  }\n\n  async dataloadContracts(\n    getContractsBody: GetContractsBody,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<DataloadContractsResponse>(getDataloadContractsUrl(), {\n        ...options,\n        method: \"POST\",\n        headers: { \"Content-Type\": \"application/json\", ...options?.headers },\n        body: JSON.stringify(getContractsBody),\n      });\n    }\n  }\n\n  async getHealth(headers?: GetHealthHeaders, options?: RequestInit) {\n    {\n      return this._fetch<HealthResponse>(getGetHealthUrl(), {\n        ...options,\n        method: \"GET\",\n        headers: { ...headers, ...options?.headers },\n      });\n    }\n  }\n}\n"],"mappings":"yaAAA,IAAAA,EAAA,GAAAC,EAAAD,EAAA,6BAAAE,EAAA,4BAAAC,EAAA,+BAAAC,EAAA,sBAAAC,EAAA,uBAAAC,EAAA,oBAAAC,EAAA,6BAAAC,EAAA,4BAAAC,EAAA,yBAAAC,IAAA,eAAAC,EAAAX,GA6BO,IAAMK,EAAoB,CAAC,CAChC,WAAAO,CACF,IACS,aAAaA,CAAU,IAKnBF,EAAuB,CAAC,CACnC,WAAAE,CACF,IACS,aAAaA,CAAU,IAKnBR,EAA6B,CAAC,CACzC,WAAAQ,CACF,IACS,aAAaA,CAAU,uBAKnBH,EAA0B,CAAC,CACtC,WAAAG,CACF,IACS,aAAaA,CAAU,cAKnBJ,EAA2B,CAAC,CACvC,WAAAI,CACF,IACS,aAAaA,CAAU,eAKnBN,EAAqB,IACzB,cAKIH,EAA0B,IAC9B,yBAKII,EAAkB,IACtB,UAmBIL,EAAN,KAA8B,CACnC,KACA,QACA,OACA,UAEA,YAAYW,EAAoB,CAC9B,KAAK,KAAOA,GAAQ,KACpB,KAAK,QAAUA,GAAQ,SAAW,yBAClC,KAAK,OAASA,GAAQ,OACtB,KAAK,UAAYA,GAAQ,SAC3B,CAEA,MAAM,OAAUC,EAAaC,EAA+C,CAE1ED,EAAM,MAAM,KAAK,WAAWA,EAAKC,CAAO,EAExC,IAAMC,EAAW,MAAM,MAAMF,EAAKC,CAAO,EAEnCE,EAAO,MAAM,KAAK,SAAYD,CAAQ,EACtCE,EAAU,OAAO,YAAYF,EAAS,QAAQ,QAAQ,CAAC,EAE7D,MAAO,CAAE,KAAAC,EAAM,QAAAC,EAAS,OAAQF,EAAS,MAAO,CAClD,CAEQ,SAAYG,EAA2B,CAC7C,IAAMC,EAAcD,EAAI,QAAQ,IAAI,cAAc,EAClD,GAAIC,EAAa,CACf,GAAIA,EAAY,SAAS,kBAAkB,EACzC,OAAOD,EAAI,KAAK,EAElB,GAAIC,GAAeA,EAAY,SAAS,iBAAiB,EACvD,OAAOD,EAAI,KAAK,CAEpB,CACA,OAAOA,EAAI,KAAK,CAClB,CAEA,MAAc,YACZD,EACiC,CACjC,MAAO,CACL,GAAI,MAAM,KAAK,MAAM,WAAW,EAChC,GAAGA,CACL,CACF,CAEA,MAAc,WAAWJ,EAAaC,EAAuC,CAE3E,MAAM,KAAK,WAAW,KAAK,EAE3BD,EAAMA,EAAM,GAAG,KAAK,OAAO,GAAGA,CAAG,GAEjC,IAAMI,EAAUH,EAAQ,QACxB,OAAAA,EAAQ,QAAU,MAAM,KAAK,YAAYG,CAAO,EAEhD,KAAK,QAAQ,MAAM,cAAcH,EAAQ,MAAM,IAAID,CAAG,EAAE,EACjDA,CACT,CAEA,MAAM,YACJ,CAAE,WAAAF,CAAW,EACbM,EACAH,EACA,CAEE,OAAO,KAAK,OAAyBV,EAAkB,CAAE,WAAAO,CAAW,CAAC,EAAG,CACtE,GAAGG,EACH,OAAQ,MACR,QAAS,CAAE,GAAGG,EAAS,GAAGH,GAAS,OAAQ,CAC7C,CAAC,CAEL,CAEA,MAAM,eACJ,CAAE,WAAAH,CAAW,EACbS,EACAH,EACAH,EACA,CAEE,OAAO,KAAK,OACVL,EAAqB,CAAE,WAAAE,CAAW,CAAC,EACnC,CACE,GAAGG,EACH,OAAQ,MACR,QAAS,CACP,eAAgB,mBAChB,GAAGG,EACH,GAAGH,GAAS,OACd,EACA,KAAM,KAAK,UAAUM,CAAkB,CACzC,CACF,CAEJ,CAEA,MAAM,qBACJ,CAAE,WAAAT,CAAW,EACbG,EACA,CAEE,OAAO,KAAK,OACVX,EAA2B,CAAE,WAAAQ,CAAW,CAAC,EACzC,CACE,GAAGG,EACH,OAAQ,KACV,CACF,CAEJ,CAEA,MAAM,kBACJ,CAAE,WAAAH,CAAW,EACbU,EACAJ,EACAH,EACA,CAEE,OAAO,KAAK,OACVN,EAAwB,CAAE,WAAAG,CAAW,CAAC,EACtC,CACE,GAAGG,EACH,OAAQ,MACR,QAAS,CACP,eAAgB,mBAChB,GAAGG,EACH,GAAGH,GAAS,OACd,EACA,KAAM,KAAK,UAAUO,CAAqB,CAC5C,CACF,CAEJ,CAEA,MAAM,mBACJ,CAAE,WAAAV,CAAW,EACbM,EACAH,EACA,CAEE,OAAO,KAAK,OACVP,EAAyB,CAAE,WAAAI,CAAW,CAAC,EACvC,CACE,GAAGG,EACH,OAAQ,MACR,QAAS,CAAE,GAAGG,EAAS,GAAGH,GAAS,OAAQ,CAC7C,CACF,CAEJ,CAEA,MAAM,aACJQ,EACAR,EACA,CAEE,OAAO,KAAK,OAA0BT,EAAmB,EAAG,CAC1D,GAAGS,EACH,OAAQ,OACR,QAAS,CAAE,eAAgB,mBAAoB,GAAGA,GAAS,OAAQ,EACnE,KAAM,KAAK,UAAUQ,CAAgB,CACvC,CAAC,CAEL,CAEA,MAAM,kBACJA,EACAR,EACA,CAEE,OAAO,KAAK,OAAkCZ,EAAwB,EAAG,CACvE,GAAGY,EACH,OAAQ,OACR,QAAS,CAAE,eAAgB,mBAAoB,GAAGA,GAAS,OAAQ,EACnE,KAAM,KAAK,UAAUQ,CAAgB,CACvC,CAAC,CAEL,CAEA,MAAM,UAAUL,EAA4BH,EAAuB,CAE/D,OAAO,KAAK,OAAuBR,EAAgB,EAAG,CACpD,GAAGQ,EACH,OAAQ,MACR,QAAS,CAAE,GAAGG,EAAS,GAAGH,GAAS,OAAQ,CAC7C,CAAC,CAEL,CACF","names":["fetch_exports","__export","OwsAbacusContractClient","getDataloadContractsUrl","getGetContractLifecycleUrl","getGetContractUrl","getGetContractsUrl","getGetHealthUrl","getReactivateContractUrl","getTerminateContractUrl","getUpdateContractUrl","__toCommonJS","contractId","config","url","options","response","data","headers","res","contentType","updateContractBody","terminateContractBody","getContractsBody"]}