import {z} from 'zod'

export type GetApiMdSnapshotArgs = {conids: 'conid@exchange:instrType', fields?: string | undefined};

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

export const marketData = z.object({"31": z.string().optional(), "70": z.number().optional(), "71": z.number().optional(), "82": z.string().optional(), "83": z.number().optional(), "84": z.string().optional(), "85": z.string().optional(), "86": z.string().optional(), "87": z.string().optional(), "88": z.string().optional(), "6509": z.string().optional(), "7057": z.string().optional(), "7058": z.string().optional(), "7059": z.number().optional(), "7068": z.string().optional(), "7195": z.string().optional(), "7196": z.string().optional(), "7197": z.string().optional(), "7198": z.string().optional(), "7199": z.string().optional(), "7200": z.string().optional(), "7201": z.string().optional(), "7202": z.string().optional(), "7203": z.string().optional(), "7204": z.string().optional(), "7205": z.string().optional(), "7206": z.string().optional(), "7207": z.string().optional(), "7208": z.string().optional(), "7209": z.string().optional(), "7210": z.string().optional(), "7211": z.string().optional(), "7212": z.string().optional(), "7245": z.string().optional(), "7246": z.string().optional(), "7247": z.string().optional(), "7248": z.string().optional(), "7249": z.string().optional(), "7263": z.string().optional(), "7264": z.string().optional(), "7265": z.string().optional(), "7266": z.string().optional(), "7267": z.string().optional(), "7268": z.string().optional(), "7269": z.string().optional(), "7271": z.string().optional(), "7272": z.string().optional(), "7273": z.string().optional(), "7274": z.string().optional(), "7275": z.string().optional(), "7276": z.string().optional(), "7277": z.string().optional(), "7282": z.string().optional(), "7283": z.string().optional(), "7284": z.string().optional(), "7286": z.number().optional(), "7287": z.string().optional(), "7288": z.string().optional(), "7289": z.string().optional(), "7290": z.string().optional(), "7293": z.string().optional(), "7294": z.string().optional(), "7295": z.number().optional(), "7296": z.number().optional(), "7331": z.string().optional(), "7370": z.string().optional(), "7371": z.string().optional(), "7372": z.string().optional(), "7635": z.string().optional(), "7636": z.number().optional(), "7637": z.string().optional(), "7644": z.string().optional(), "7674": z.string().optional(), "7675": z.string().optional(), "7676": z.string().optional(), "7677": z.string().optional(), "7681": z.string().optional(), "7698": z.string().optional(), "7699": z.string().optional(), "7718": z.string().optional(), "7720": z.string().optional(), "7743": z.string().optional(), "7761": z.string().optional(), "7992": z.string().optional(), "7993": z.string().optional(), "7994": z.string().optional(), "7995": z.string().optional(), conid: z.number().int().optional(), minTick: z.number().optional(), BboExchange: z.string().optional(), HasDelayed: z.boolean().optional(), sizeMinTick: z.number().int().optional(), BestEligible: z.number().int().optional(), BestBidExch: z.number().int().optional(), BestAskExch: z.number().int().optional(), PreOpenBid: z.number().int().optional(), LastAttribs: z.number().int().optional(), TimestampBase: z.number().int().optional(), TimestampDelta: z.number().int().optional(), LastExch: z.number().int().optional(), CloseAttribs: z.number().int().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
};

/**
 * Market Data Snapshot (Beta)
 * 
 * GET /md/snapshot
 */
export const getApiMdSnapshot = async (args: GetApiMdSnapshotArgs, options?: GetApiMdSnapshotOptions) => {
const {baseUrl = "http://localhost:5000/v1/api", fetch: fetchFn = fetch} = options ?? {}

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

if (args.conids != null) query.append("conids", String(args.conids))
if (args.fields != null) query.append("fields", String(args.fields))

const url = `${baseUrl.replace(/\/+$/, '')}/md/snapshot${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(marketData, await res.json())
};