{"version":3,"sources":["../../gen/fetch.ts"],"sourcesContent":["/**\n * Generated by orval v7.10.0 🍺\n * Do not edit manually.\n * ows-abacus-event\n * OpenAPI spec version: 1.0.0\n */\nimport type {\n  AbacusEventResponse,\n  AbacusEventsResponse,\n  CreateAbacusEventBody,\n  CreateAbacusEventHeaders,\n  DataloadAbacusEventsHeaders,\n  DataloadAbacusEventsResponse,\n  GetAbacusEventHeaders,\n  GetAbacusEventPathParameters,\n  GetAbacusEventsBody,\n  GetAbacusEventsByTargetHeaders,\n  GetAbacusEventsByTargetPathParameters,\n  GetHealthHeaders,\n  GetPaymentGroupPaymentApprovalCountHeaders,\n  GetPaymentGroupPaymentApprovalCountPathParameters,\n  HealthResponse,\n  PaymentGroupPaymentApprovalCountResponse,\n  RollbackAbacusEventBody,\n  RollbackAbacusEventHeaders,\n} from \"./types\";\n/**\n * Create an Abacus event\n */\nexport const getCreateAbacusEventUrl = () => {\n  return `/abacus-event/`;\n};\n/**\n * Get an Abacus event by ID\n */\nexport const getGetAbacusEventUrl = ({\n  abacusEventId,\n}: GetAbacusEventPathParameters) => {\n  return `/abacus-event/${abacusEventId}`;\n};\n/**\n * Get all events for a specified target type / id\n */\nexport const getGetAbacusEventsByTargetUrl = ({\n  targetType,\n  targetId,\n}: GetAbacusEventsByTargetPathParameters) => {\n  return `/abacus-event/${targetType}/${targetId}/`;\n};\n/**\n * Dataload Abacus events by Abacus event IDs\n */\nexport const getDataloadAbacusEventsUrl = () => {\n  return `/abacus-event/dataloader`;\n};\n/**\n * Get the number of current approval events for a Payment Group Payment\n */\nexport const getGetPaymentGroupPaymentApprovalCountUrl = ({\n  paymentGroupPaymentId,\n}: GetPaymentGroupPaymentApprovalCountPathParameters) => {\n  return `/abacus-event/payment-group-payment/${paymentGroupPaymentId}/approval-count/`;\n};\n/**\n * @summary Rolls back an Abacus event\n */\nexport const getRollbackAbacusEventUrl = () => {\n  return `/abacus-event/rollback/`;\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 OwsAbacusEventClient {\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 createAbacusEvent(\n    createAbacusEventBody: CreateAbacusEventBody,\n    headers?: CreateAbacusEventHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<AbacusEventResponse>(getCreateAbacusEventUrl(), {\n        ...options,\n        method: \"POST\",\n        headers: {\n          \"Content-Type\": \"application/json\",\n          ...headers,\n          ...options?.headers,\n        },\n        body: JSON.stringify(createAbacusEventBody),\n      });\n    }\n  }\n\n  async getAbacusEvent(\n    { abacusEventId }: GetAbacusEventPathParameters,\n    headers?: GetAbacusEventHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<AbacusEventResponse>(\n        getGetAbacusEventUrl({ abacusEventId }),\n        {\n          ...options,\n          method: \"GET\",\n          headers: { ...headers, ...options?.headers },\n        },\n      );\n    }\n  }\n\n  async getAbacusEventsByTarget(\n    { targetType, targetId }: GetAbacusEventsByTargetPathParameters,\n    headers?: GetAbacusEventsByTargetHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<AbacusEventsResponse>(\n        getGetAbacusEventsByTargetUrl({ targetType, targetId }),\n        {\n          ...options,\n          method: \"GET\",\n          headers: { ...headers, ...options?.headers },\n        },\n      );\n    }\n  }\n\n  async dataloadAbacusEvents(\n    getAbacusEventsBody: GetAbacusEventsBody,\n    headers?: DataloadAbacusEventsHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<DataloadAbacusEventsResponse>(\n        getDataloadAbacusEventsUrl(),\n        {\n          ...options,\n          method: \"POST\",\n          headers: {\n            \"Content-Type\": \"application/json\",\n            ...headers,\n            ...options?.headers,\n          },\n          body: JSON.stringify(getAbacusEventsBody),\n        },\n      );\n    }\n  }\n\n  async getPaymentGroupPaymentApprovalCount(\n    {\n      paymentGroupPaymentId,\n    }: GetPaymentGroupPaymentApprovalCountPathParameters,\n    headers?: GetPaymentGroupPaymentApprovalCountHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<PaymentGroupPaymentApprovalCountResponse>(\n        getGetPaymentGroupPaymentApprovalCountUrl({ paymentGroupPaymentId }),\n        {\n          ...options,\n          method: \"GET\",\n          headers: { ...headers, ...options?.headers },\n        },\n      );\n    }\n  }\n\n  async rollbackAbacusEvent(\n    rollbackAbacusEventBody: RollbackAbacusEventBody,\n    headers?: RollbackAbacusEventHeaders,\n    options?: RequestInit,\n  ) {\n    {\n      return this._fetch<AbacusEventResponse>(getRollbackAbacusEventUrl(), {\n        ...options,\n        method: \"PUT\",\n        headers: {\n          \"Content-Type\": \"application/json\",\n          ...headers,\n          ...options?.headers,\n        },\n        body: JSON.stringify(rollbackAbacusEventBody),\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,0BAAAE,EAAA,4BAAAC,EAAA,+BAAAC,EAAA,yBAAAC,EAAA,kCAAAC,EAAA,oBAAAC,EAAA,8CAAAC,EAAA,8BAAAC,IAAA,eAAAC,EAAAV,GA6BO,IAAMG,EAA0B,IAC9B,iBAKIE,EAAuB,CAAC,CACnC,cAAAM,CACF,IACS,iBAAiBA,CAAa,GAK1BL,EAAgC,CAAC,CAC5C,WAAAM,EACA,SAAAC,CACF,IACS,iBAAiBD,CAAU,IAAIC,CAAQ,IAKnCT,EAA6B,IACjC,2BAKII,EAA4C,CAAC,CACxD,sBAAAM,CACF,IACS,uCAAuCA,CAAqB,mBAKxDL,EAA4B,IAChC,0BAKIF,EAAkB,IACtB,UAmBIL,EAAN,KAA2B,CAChC,KACA,QACA,OACA,UAEA,YAAYa,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,kBACJO,EACAH,EACAH,EACA,CAEE,OAAO,KAAK,OAA4Bd,EAAwB,EAAG,CACjE,GAAGc,EACH,OAAQ,OACR,QAAS,CACP,eAAgB,mBAChB,GAAGG,EACH,GAAGH,GAAS,OACd,EACA,KAAM,KAAK,UAAUM,CAAqB,CAC5C,CAAC,CAEL,CAEA,MAAM,eACJ,CAAE,cAAAZ,CAAc,EAChBS,EACAH,EACA,CAEE,OAAO,KAAK,OACVZ,EAAqB,CAAE,cAAAM,CAAc,CAAC,EACtC,CACE,GAAGM,EACH,OAAQ,MACR,QAAS,CAAE,GAAGG,EAAS,GAAGH,GAAS,OAAQ,CAC7C,CACF,CAEJ,CAEA,MAAM,wBACJ,CAAE,WAAAL,EAAY,SAAAC,CAAS,EACvBO,EACAH,EACA,CAEE,OAAO,KAAK,OACVX,EAA8B,CAAE,WAAAM,EAAY,SAAAC,CAAS,CAAC,EACtD,CACE,GAAGI,EACH,OAAQ,MACR,QAAS,CAAE,GAAGG,EAAS,GAAGH,GAAS,OAAQ,CAC7C,CACF,CAEJ,CAEA,MAAM,qBACJO,EACAJ,EACAH,EACA,CAEE,OAAO,KAAK,OACVb,EAA2B,EAC3B,CACE,GAAGa,EACH,OAAQ,OACR,QAAS,CACP,eAAgB,mBAChB,GAAGG,EACH,GAAGH,GAAS,OACd,EACA,KAAM,KAAK,UAAUO,CAAmB,CAC1C,CACF,CAEJ,CAEA,MAAM,oCACJ,CACE,sBAAAV,CACF,EACAM,EACAH,EACA,CAEE,OAAO,KAAK,OACVT,EAA0C,CAAE,sBAAAM,CAAsB,CAAC,EACnE,CACE,GAAGG,EACH,OAAQ,MACR,QAAS,CAAE,GAAGG,EAAS,GAAGH,GAAS,OAAQ,CAC7C,CACF,CAEJ,CAEA,MAAM,oBACJQ,EACAL,EACAH,EACA,CAEE,OAAO,KAAK,OAA4BR,EAA0B,EAAG,CACnE,GAAGQ,EACH,OAAQ,MACR,QAAS,CACP,eAAgB,mBAChB,GAAGG,EACH,GAAGH,GAAS,OACd,EACA,KAAM,KAAK,UAAUQ,CAAuB,CAC9C,CAAC,CAEL,CAEA,MAAM,UAAUL,EAA4BH,EAAuB,CAE/D,OAAO,KAAK,OAAuBV,EAAgB,EAAG,CACpD,GAAGU,EACH,OAAQ,MACR,QAAS,CAAE,GAAGG,EAAS,GAAGH,GAAS,OAAQ,CAC7C,CAAC,CAEL,CACF","names":["fetch_exports","__export","OwsAbacusEventClient","getCreateAbacusEventUrl","getDataloadAbacusEventsUrl","getGetAbacusEventUrl","getGetAbacusEventsByTargetUrl","getGetHealthUrl","getGetPaymentGroupPaymentApprovalCountUrl","getRollbackAbacusEventUrl","__toCommonJS","abacusEventId","targetType","targetId","paymentGroupPaymentId","config","url","options","response","data","headers","res","contentType","createAbacusEventBody","getAbacusEventsBody","rollbackAbacusEventBody"]}