import {z} from 'zod'

export type GetApiPolicyEventsOptions = {baseUrl: string, fetch?: typeof fetch | undefined};

export const accountEventData = z.object({accountLocator: z.string()});

export const accountEvents = z.object({"policy.account.anonymize": accountEventData.optional(), "policy.account.update": accountEventData.optional(), "policy.account.validate": accountEventData.optional(), "policy.account.discard": accountEventData.optional(), "policy.account.create": accountEventData.optional()});

export const quoteEventData = z.object({quoteLocator: z.string()});

export const quoteUnderwrittenEventData = z.object({quoteLocator: z.string(), underwritingStatus: z.enum(["info", "block", "decline", "reject", "approve"])});

export const quoteManuallyUnderwrittenEventData = z.object({quoteLocator: z.string()});

export const quoteEvents = z.object({"policy.quote.issue": quoteEventData.optional(), "policy.quote.staticdata.replace": quoteEventData.optional(), "policy.quote.create": quoteEventData.optional(), "policy.quote.reset": quoteEventData.optional(), "policy.quote.staticdata.anonymize": quoteEventData.optional(), "policy.quote.staticdata.update": quoteEventData.optional(), "policy.quote.refuse": quoteEventData.optional(), "policy.quote.staticdata.add": quoteEventData.optional(), "policy.quote.anonymize": quoteEventData.optional(), "policy.quote.underwrite": quoteUnderwrittenEventData.optional(), "policy.quote.manualunderwrite": quoteManuallyUnderwrittenEventData.optional(), "policy.quote.update": quoteEventData.optional(), "policy.quote.price": quoteEventData.optional(), "policy.quote.validate": quoteEventData.optional(), "policy.quote.discard": quoteEventData.optional(), "policy.quote.accept": quoteEventData.optional()});

export const listPageResponsePolicyStatus = z.object({listCompleted: z.boolean(), items: z.array(z.enum(["pending", "inGap", "expired", "cancelled", "cancelPending", "onRisk", "delinquent", "doNotRenew", "continued", "continuation", "flatCancelled"]))});

export const policyStatusEventData = z.object({policyLocator: z.string(), newStatuses: listPageResponsePolicyStatus, removedStatuses: listPageResponsePolicyStatus});

export const policyStatusEvents = z.object({"policy.status.update": policyStatusEventData.optional()});

export const transactionEventData = z.object({policyLocator: z.string(), transactionLocator: z.string()});

export const transactionUnderwritingEventData = z.object({policyLocator: z.string(), transactionLocator: z.string(), underwritingStatus: z.string()});

export const transactionManualUnderwritingEventData = z.object({policyLocator: z.string(), transactionLocator: z.string()});

export const transactionEvents = z.object({"policy.renewal.accept": transactionEventData.optional(), "policy.cancellation.reset": transactionEventData.optional(), "policy.cancellation.issue": transactionEventData.optional(), "policy.reversal.accept": transactionEventData.optional(), "policy.cancellation.accept": transactionEventData.optional(), "policy.change.discard": transactionEventData.optional(), "policy.continuation.create": transactionEventData.optional(), "policy.change.issue": transactionEventData.optional(), "policy.cancellation.validate": transactionEventData.optional(), "policy.reversal.underwrite": transactionUnderwritingEventData.optional(), "policy.cancellation.price": transactionEventData.optional(), "policy.reversal.update": transactionEventData.optional(), "policy.cancellation.refuse": transactionEventData.optional(), "policy.change.accept": transactionEventData.optional(), "policy.continuation.issue": transactionEventData.optional(), "policy.renewal.refuse": transactionEventData.optional(), "policy.reinstatement.create": transactionEventData.optional(), "policy.reinstatement.reset": transactionEventData.optional(), "policy.renewal.underwrite": transactionUnderwritingEventData.optional(), "policy.reversal.reset": transactionEventData.optional(), "policy.flatCancellation.discard": transactionEventData.optional(), "policy.reversal.validate": transactionEventData.optional(), "policy.change.refuse": transactionEventData.optional(), "policy.reversal.issue": transactionEventData.optional(), "policy.cancellation.update": transactionEventData.optional(), "policy.flatCancellation.issue": transactionEventData.optional(), "policy.change.manualUnderwrite": transactionManualUnderwritingEventData.optional(), "policy.change.create": transactionEventData.optional(), "policy.continuation.validate": transactionEventData.optional(), "policy.flatCancellation.accept": transactionEventData.optional(), "policy.reinstatement.update": transactionEventData.optional(), "policy.renewal.manualUnderwrite": transactionManualUnderwritingEventData.optional(), "policy.reinstatement.discard": transactionEventData.optional(), "policy.renewal.price": transactionEventData.optional(), "policy.reversal.discard": transactionEventData.optional(), "policy.reinstatement.price": transactionEventData.optional(), "policy.flatCancellation.validate": transactionEventData.optional(), "policy.change.validate": transactionEventData.optional(), "policy.continuation.update": transactionEventData.optional(), "policy.continuation.refuse": transactionEventData.optional(), "policy.cancellation.underwrite": transactionUnderwritingEventData.optional(), "policy.continuation.underwrite": transactionUnderwritingEventData.optional(), "policy.change.underwrite": transactionUnderwritingEventData.optional(), "policy.continuation.manualUnderwrite": transactionManualUnderwritingEventData.optional(), "policy.renewal.validate": transactionEventData.optional(), "policy.reinstatement.accept": transactionEventData.optional(), "policy.continuation.discard": transactionEventData.optional(), "policy.reversal.price": transactionEventData.optional(), "policy.cancellation.create": transactionEventData.optional(), "policy.reinstatement.refuse": transactionEventData.optional(), "policy.renewal.create": transactionEventData.optional(), "policy.flatCancellation.update": transactionEventData.optional(), "policy.renewal.reset": transactionEventData.optional(), "policy.flatCancellation.reset": transactionEventData.optional(), "policy.cancellation.manualUnderwrite": transactionManualUnderwritingEventData.optional(), "policy.change.price": transactionEventData.optional(), "policy.cancellation.discard": transactionEventData.optional(), "policy.flatCancellation.price": transactionEventData.optional(), "policy.flatCancellation.refuse": transactionEventData.optional(), "policy.continuation.price": transactionEventData.optional(), "policy.renewal.update": transactionEventData.optional(), "policy.continuation.reset": transactionEventData.optional(), "policy.continuation.accept": transactionEventData.optional(), "policy.renewal.issue": transactionEventData.optional(), "policy.flatCancellation.underwrite": transactionUnderwritingEventData.optional(), "policy.reinstatement.issue": transactionEventData.optional(), "policy.change.reset": transactionEventData.optional(), "policy.reversal.manualUnderwrite": transactionManualUnderwritingEventData.optional(), "policy.reinstatement.underwrite": transactionUnderwritingEventData.optional(), "policy.reinstatement.validate": transactionEventData.optional(), "policy.reinstatement.manualUnderwrite": transactionManualUnderwritingEventData.optional(), "policy.reversal.refuse": transactionEventData.optional(), "policy.flatCancellation.manualUnderwrite": transactionManualUnderwritingEventData.optional(), "policy.renewal.discard": transactionEventData.optional(), "policy.flatCancellation.create": transactionEventData.optional(), "policy.reversal.create": transactionEventData.optional()});

export const policyLocatorData = z.object({policyLocator: z.string()});

export const policyStaticDataEvents = z.object({"policy.staticdata.add": policyLocatorData.optional(), "policy.staticdata.update": policyLocatorData.optional(), "policy.staticdata.anonymize": policyLocatorData.optional(), "policy.staticdata.replace": policyLocatorData.optional()});

export const policyEvents = z.object({"policy.migrateOnRenewal.enable": policyLocatorData.optional(), "policy.migrateOnRenewal.disable": policyLocatorData.optional(), "policy.anonymize": policyLocatorData.optional()});

export const numberingEventData = z.object({entityLocator: z.string()});

export const numberingEvents = z.object({"task.numberAssignmentFailed": numberingEventData.optional()});

export const configMigrationEventPayload = z.object({locator: z.string(), configVersion: z.string()});

export const policyConfigMigrationEventPayload = z.object({policyLocator: z.string(), transactionLocator: z.string(), configVersion: z.string()});

export const configMigrationEvents = z.object({"quote.config.migration.failed": configMigrationEventPayload.optional(), "account.config.migration.failed": configMigrationEventPayload.optional(), "policy.config.migration.failed": policyConfigMigrationEventPayload.optional()});

export const policyServiceEventTypeDefinitions = z.object({accountEvents: accountEvents, quoteEvents: quoteEvents, policyStatusEvents: policyStatusEvents, transactionEvents: transactionEvents, policyStaticDataEvents: policyStaticDataEvents, policyEvents: policyEvents, numberingEvents: numberingEvents, configMigrationEvents: configMigrationEvents});

export const validateResponse = async <Output>(
  schema: {
    readonly '~standard': {
      readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray<PropertyKey | { readonly key: PropertyKey }> | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray<PropertyKey | { readonly key: PropertyKey }> | undefined }> }>
    }
  },
  value: unknown
): Promise<Output> => {
  const result = await schema['~standard'].validate(value)

  if (result.issues !== undefined) {
    const detail = result.issues
      .map(({ message, path }) =>
        path?.length
          ? `${path.map((segment) => String(typeof segment === 'object' ? segment.key : segment)).join('.')}: ${message}`
          : message
      )
      .join('; ')

    throw new Error(`Response does not match the schema: ${detail}`, { cause: { issues: result.issues } })
  }

  return result.value
};

/**
 * GET /policy/events
 */
export const getApiPolicyEvents = async (options: GetApiPolicyEventsOptions) => {
const {baseUrl, fetch: fetchFn = fetch} = options ?? {}

const query = new URLSearchParams()
const headers = new Headers()
headers.set('accept', "application/json")

const url = `${baseUrl.replace(/\/+$/, '')}/policy/events${query.size > 0 ? `?${query}` : ''}`

const res = await fetchFn(url, {method: "GET", headers})

if (!res.ok) throw new Error(`Request failed with status ${res.status}`, {cause: {status: res.status, body: await res.text()}})

return validateResponse(policyServiceEventTypeDefinitions, await res.json())
};