import {z} from 'zod'

export type GetApiDefiV2TokensTopTradersArgs = {'x-chain'?: ('solana' | 'ethereum' | 'arbitrum' | 'avalanche' | 'bsc' | 'optimism' | 'polygon' | 'base' | 'zksync' | 'monad' | 'hyperevm' | 'aptos' | 'fogo' | 'mantle' | 'megaeth' | 'robinhood' | 'sui') | undefined, address: string, time_frame: '30m' | '1h' | '2h' | '4h' | '6h' | '8h' | '12h' | '24h' | '2d' | '3d' | '7d' | '14d' | '30d' | '60d' | '90d' | 'all_time', sort_type: 'desc' | 'asc', sort_by: 'volume' | 'trade' | 'total_pnl' | 'unrealized_pnl' | 'realized_pnl' | 'volume_usd' | 'hold_volume', offset?: number | undefined, limit?: number | undefined, ui_amount_mode?: ('raw' | 'scaled') | undefined, wallet_tags?: (Array<'dev' | 'bundler' | 'sniper' | 'insider' | 'smart_trader'>) | undefined, get_holders_networth?: boolean | undefined};

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

export const defiTokenTopTradedResponse = z.object({success: z.boolean(), data: z.object({items: z.array(z.object({tokenAddress: z.string().optional(), owner: z.string().optional(), tags: z.array(z.unknown()).optional(), type: z.string().optional(), volume: z.number().optional(), trade: z.number().int().optional(), tradeBuy: z.number().int().optional(), tradeSell: z.number().int().optional(), volumeBuy: z.number().optional(), volumeSell: z.number().optional(), volumeBuyUSD: z.number().optional(), volumeSellUSD: z.number().optional(), volumeUsd: z.number().optional(), totalPnl: z.number().optional(), unrealizedPnl: z.number().optional(), realizedPnl: z.number().optional(), holdVolume: z.number().optional(), holdVolumeUsd: z.number().optional(), holdAvgPrice: z.number().optional(), avgBuyPrice: z.number().optional(), avgSellPrice: z.number().optional(), firstTradeUnixTime: z.number().optional(), lastTradeUnixTime: z.number().optional(), netWorth: z.number().optional(), solBalance: z.number().optional(), funding: z.object({funder: z.string().optional(), unixTime: z.number().optional(), amount: z.number().optional(), txHash: z.string().optional()}).optional()})).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
};

/**
 * Token - Top traders
 * 
 * GET /defi/v2/tokens/top_traders
 */
export const getApiDefiV2TokensTopTraders = async (args: GetApiDefiV2TokensTopTradersArgs, options?: GetApiDefiV2TokensTopTradersOptions) => {
const {baseUrl = "https://public-api.birdeye.so", fetch: fetchFn = fetch, apiKeyAuth} = options ?? {}

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

if (args['x-chain'] != null) headers.set("x-chain", String(args['x-chain']))
if (args.address != null) query.append("address", String(args.address))
if (args.time_frame != null) query.append("time_frame", String(args.time_frame))
if (args.sort_type != null) query.append("sort_type", String(args.sort_type))
if (args.sort_by != null) query.append("sort_by", String(args.sort_by))
if (args.offset != null) query.append("offset", String(args.offset))
if (args.limit != null) query.append("limit", String(args.limit))
if (args.ui_amount_mode != null) query.append("ui_amount_mode", String(args.ui_amount_mode))
if (args.wallet_tags != null) query.append("wallet_tags", args.wallet_tags.join(','))
if (args.get_holders_networth != null) query.append("get_holders_networth", String(args.get_holders_networth))
if (apiKeyAuth !== undefined) headers.set("X-API-KEY", apiKeyAuth)

const url = `${baseUrl.replace(/\/+$/, '')}/defi/v2/tokens/top_traders${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(defiTokenTopTradedResponse, await res.json())
};