import {z} from 'zod'

export type GetApiV1OptionsQuotesOptionSymbolArgs = {format?: ('csv' | 'json') | undefined, optionSymbol: string, date?: string | undefined, from?: string | undefined, to?: string | undefined, countback?: number | undefined, dateformat?: ('spreadsheet' | 'timestamp' | 'unix') | undefined, limit?: number | undefined, offset?: number | undefined, headers?: boolean | undefined, columns?: string | undefined, human?: boolean | undefined};

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

export const okStatusEnum = z.literal("ok");

export const optionSideEnum = z.enum(["call", "put"]);

export const nullEnum = z.unknown();

export const optionQuotesResponse = z.object({s: okStatusEnum, optionSymbol: z.array(z.string().nullable()), underlying: z.array(z.string().nullable()), expiration: z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])), side: z.array(z.union([optionSideEnum, nullEnum]).nullable()), strike: z.array(z.number().nullable()), firstTraded: z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])), dte: z.array(z.number().int().nullable()), updated: z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])), bid: z.array(z.number().nullable()), bidSize: z.array(z.number().int().nullable()), mid: z.array(z.number().nullable()), ask: z.array(z.number().nullable()), askSize: z.array(z.number().int().nullable()), last: z.array(z.number().nullable()), openInterest: z.array(z.number().int().nullable()), volume: z.array(z.number().int().nullable()), inTheMoney: z.array(z.boolean().nullable()), intrinsicValue: z.array(z.number().nullable()), extrinsicValue: z.array(z.number().nullable()), underlyingPrice: z.array(z.number().nullable()), iv: z.array(z.number().nullable()), delta: z.array(z.number().nullable()), gamma: z.array(z.number().nullable()), theta: z.array(z.number().nullable()), vega: z.array(z.number().nullable())});

export const optionQuotesCustomResponse = z.object({s: okStatusEnum.optional(), optionSymbol: z.array(z.string().nullable()).optional(), Symbol: z.array(z.string().nullable()).optional(), underlying: z.array(z.string().nullable()).optional(), Underlying: z.array(z.string().nullable()).optional(), expiration: z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])).optional(), "Expiration Date": z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])).optional(), side: z.array(z.union([optionSideEnum, nullEnum]).nullable()).optional(), "Option Side": z.array(z.union([optionSideEnum, nullEnum]).nullable()).optional(), strike: z.array(z.number().nullable()).optional(), Strike: z.array(z.number().nullable()).optional(), firstTraded: z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])).optional(), "First Traded": z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])).optional(), dte: z.array(z.number().int().nullable()).optional(), "Days To Expiration": z.array(z.number().int().nullable()).optional(), updated: z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])).optional(), Date: z.array(z.union([z.number().int().nullable(), z.string().nullable(), z.number().nullable()])).optional(), bid: z.array(z.number().nullable()).optional(), Bid: z.array(z.number().nullable()).optional(), bidSize: z.array(z.number().int().nullable()).optional(), "Bid Size": z.array(z.number().int().nullable()).optional(), mid: z.array(z.number().nullable()).optional(), Mid: z.array(z.number().nullable()).optional(), ask: z.array(z.number().nullable()).optional(), Ask: z.array(z.number().nullable()).optional(), askSize: z.array(z.number().int().nullable()).optional(), "Ask Size": z.array(z.number().int().nullable()).optional(), last: z.array(z.number().nullable()).optional(), Last: z.array(z.number().nullable()).optional(), openInterest: z.array(z.number().int().nullable()).optional(), "Open Interest": z.array(z.number().int().nullable()).optional(), volume: z.array(z.number().int().nullable()).optional(), Volume: z.array(z.number().int().nullable()).optional(), inTheMoney: z.array(z.boolean().nullable()).optional(), "In The Money": z.array(z.boolean().nullable()).optional(), intrinsicValue: z.array(z.number().nullable()).optional(), "Intrinsic Value": z.array(z.number().nullable()).optional(), extrinsicValue: z.array(z.number().nullable()).optional(), "Extrinsic Value": z.array(z.number().nullable()).optional(), underlyingPrice: z.array(z.number().nullable()).optional(), "Underlying Price": z.array(z.number().nullable()).optional(), iv: z.array(z.number().nullable()).optional(), IV: z.array(z.number().nullable()).optional(), delta: z.array(z.number().nullable()).optional(), Delta: z.array(z.number().nullable()).optional(), gamma: z.array(z.number().nullable()).optional(), Gamma: z.array(z.number().nullable()).optional(), theta: z.array(z.number().nullable()).optional(), Theta: z.array(z.number().nullable()).optional(), vega: z.array(z.number().nullable()).optional(), Vega: z.array(z.number().nullable()).optional()});

export const optionQuotesBody = z.union([optionQuotesResponse, optionQuotesCustomResponse]);

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 a current or historical end of day quote for an options contract.
 * 
 * GET /v1/options/quotes/{optionSymbol}/
 * 
 * Also accepts auth: JWT Authentication
 */
export const getApiV1OptionsQuotesOptionSymbol = async (args: GetApiV1OptionsQuotesOptionSymbolArgs, options: GetApiV1OptionsQuotesOptionSymbolOptions) => {
const {baseUrl, fetch: fetchFn = fetch, ApiAuthentication} = options ?? {}

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

if (args.format != null) query.append("format", String(args.format))
if (args.date != null) query.append("date", String(args.date))
if (args.from != null) query.append("from", String(args.from))
if (args.to != null) query.append("to", String(args.to))
if (args.countback != null) query.append("countback", String(args.countback))
if (args.dateformat != null) query.append("dateformat", String(args.dateformat))
if (args.limit != null) query.append("limit", String(args.limit))
if (args.offset != null) query.append("offset", String(args.offset))
if (args.headers != null) query.append("headers", String(args.headers))
if (args.columns != null) query.append("columns", String(args.columns))
if (args.human != null) query.append("human", String(args.human))
if (ApiAuthentication !== undefined) query.set("token", ApiAuthentication)

const url = `${baseUrl.replace(/\/+$/, '')}/v1/options/quotes/${encodeURIComponent(String(args.optionSymbol))}/${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(optionQuotesBody, await res.json())
};