import {z} from 'zod'

export type GetApi10KbBundlesBundleIdArgs = {bundleId: string, audit?: ('FULL' | 'MINIMAL' | 'NONE') | undefined};

export type GetApi10KbBundlesBundleIdOptions = {baseUrl: string, basicAuth?: {username: string, password: string} | undefined, fetch?: typeof fetch | undefined};

export const entity = z.object({id: z.string().optional(), updatedDate: z.string().optional(), createdDate: z.string().optional()});

export const auditLog = z.object({changeType: z.string().optional(), changeDate: z.string().optional(), objectType: z.enum(["ACCOUNT", "ACCOUNT_EMAIL", "BLOCKING_STATES", "BUNDLE", "CUSTOM_FIELD", "INVOICE", "PAYMENT", "TRANSACTION", "INVOICE_ITEM", "INVOICE_PAYMENT", "SUBSCRIPTION", "SUBSCRIPTION_EVENT", "SERVICE_BROADCAST", "PAYMENT_ATTEMPT", "PAYMENT_METHOD", "TAG", "TAG_DEFINITION", "TENANT", "TENANT_KVS"]).optional(), objectId: z.string().optional(), changedBy: z.string().optional(), reasonCode: z.string().optional(), comments: z.string().optional(), userToken: z.string().optional(), history: entity.optional()});

export const eventSubscription = z.object({eventId: z.string().optional(), billingPeriod: z.enum(["DAILY", "WEEKLY", "BIWEEKLY", "THIRTY_DAYS", "SIXTY_DAYS", "NINETY_DAYS", "MONTHLY", "BIMESTRIAL", "QUARTERLY", "TRIANNUAL", "BIANNUAL", "ANNUAL", "BIENNIAL", "NO_BILLING_PERIOD"]).optional(), effectiveDate: z.string().optional(), plan: z.string().optional(), product: z.string().optional(), priceList: z.string().optional(), eventType: z.enum(["START_ENTITLEMENT", "START_BILLING", "PAUSE_ENTITLEMENT", "PAUSE_BILLING", "RESUME_ENTITLEMENT", "RESUME_BILLING", "PHASE", "CHANGE", "STOP_ENTITLEMENT", "STOP_BILLING", "SERVICE_STATE_CHANGE"]).optional(), isBlockedBilling: z.boolean().optional(), isBlockedEntitlement: z.boolean().optional(), serviceName: z.string().optional(), serviceStateName: z.string().optional(), phase: z.string().optional(), auditLogs: z.array(auditLog).optional()});

export const blockPrice = z.object({unitName: z.string().optional(), size: z.number().optional(), price: z.number().optional(), max: z.number().optional()});

export const tierPrice = z.object({blockPrices: z.array(blockPrice).optional()});

export const usagePrice = z.object({usageName: z.string().optional(), usageType: z.enum(["CAPACITY", "CONSUMABLE"]).optional(), billingMode: z.enum(["IN_ADVANCE", "IN_ARREAR"]).optional(), tierBlockPolicy: z.enum(["ALL_TIERS", "TOP_TIER"]).optional(), tierPrices: z.array(tierPrice).optional()});

export const phasePrice = z.object({planName: z.string().optional(), phaseName: z.string().optional(), phaseType: z.string().optional(), fixedPrice: z.number().optional(), recurringPrice: z.number().optional(), usagePrices: z.array(usagePrice).optional()});

export const subscription = z.object({accountId: z.string().optional(), bundleId: z.string().optional(), bundleExternalKey: z.string().optional(), subscriptionId: z.string().optional(), externalKey: z.string().optional(), startDate: z.string().optional(), productName: z.string(), productCategory: z.enum(["BASE", "ADD_ON", "STANDALONE"]).optional(), billingPeriod: z.enum(["DAILY", "WEEKLY", "BIWEEKLY", "THIRTY_DAYS", "SIXTY_DAYS", "NINETY_DAYS", "MONTHLY", "BIMESTRIAL", "QUARTERLY", "TRIANNUAL", "BIANNUAL", "ANNUAL", "BIENNIAL", "NO_BILLING_PERIOD"]), phaseType: z.enum(["TRIAL", "DISCOUNT", "FIXEDTERM", "EVERGREEN"]).optional(), priceList: z.string(), planName: z.string(), state: z.enum(["PENDING", "ACTIVE", "BLOCKED", "CANCELLED", "EXPIRED"]).optional(), sourceType: z.enum(["NATIVE", "MIGRATED", "TRANSFERRED"]).optional(), cancelledDate: z.string().optional(), chargedThroughDate: z.string().optional(), billingStartDate: z.string().optional(), billingEndDate: z.string().optional(), billCycleDayLocal: z.number().int().optional(), events: z.array(eventSubscription).optional(), priceOverrides: z.array(phasePrice).optional(), prices: z.array(phasePrice).optional(), auditLogs: z.array(auditLog).optional()});

export const bundleTimeline = z.object({accountId: z.string().optional(), bundleId: z.string().optional(), externalKey: z.string().optional(), events: z.array(eventSubscription).optional(), auditLogs: z.array(auditLog).optional()});

export const bundle = z.object({accountId: z.string(), bundleId: z.string().optional(), externalKey: z.string().optional(), subscriptions: z.array(subscription).optional(), timeline: bundleTimeline.optional(), auditLogs: z.array(auditLog).optional()});

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
};

/**
 * Retrieve a bundle by id
 * 
 * GET /1.0/kb/bundles/{bundleId}
 * 
 * Also accepts auth: Killbill_Api_Key, Killbill_Api_Secret
 */
export const getApi10KbBundlesBundleId = async (args: GetApi10KbBundlesBundleIdArgs, options: GetApi10KbBundlesBundleIdOptions) => {
const {baseUrl, fetch: fetchFn = fetch, basicAuth} = options ?? {}

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

if (args.audit != null) query.append("audit", String(args.audit))
if (basicAuth !== undefined) headers.set('authorization', `Basic ${btoa(`${basicAuth.username}:${basicAuth.password}`)}`)

const url = `${baseUrl.replace(/\/+$/, '')}/1.0/kb/bundles/${encodeURIComponent(String(args.bundleId))}${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(bundle, await res.json())
};