import {z} from 'zod'

export type TradesTradeSymbol = 'BTC' | 'WTGXX' | 'FLTTX' | 'WTSIX' | 'YLDS' | 'USTB';

export type TradesDirection = 'buy' | 'sell';

export type TradesSettlementPreference = 'standard' | 'instant';

export type GetApiMoneyTradesQuoteArgs = {include_approval_preview?: boolean | undefined, symbol: TradesTradeSymbol, direction: TradesDirection, input_amount: string, settlement_preference?: TradesSettlementPreference | undefined};

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

export const moneyfmtFormattedMoneyAmountView = z.object({compact: z.string(), currency_sign: z.string(), currency_sign_position: z.string(), full: z.string()});

export const moneyfmtMoneyAmountView = z.object({float: z.number(), formatted: moneyfmtFormattedMoneyAmountView, precise: z.string(), symbol: z.string(), zero: z.boolean()});

export const moneyMovementsApprovalRequirementKind = z.enum(["ordinary_quorum", "additional_named", "selected_member"]);

export const moneyMovementsApprovalRequirementSource = z.enum(["business", "member"]);

export const moneyMovementsApprovalClauseView = z.object({approvals_received: z.number().int().gte(0).optional(), count: z.number().int().gte(1).optional(), excluded_individual_ids: z.array(z.string()).optional(), individual_id: z.string().optional(), individual_name: z.string().optional(), kind: moneyMovementsApprovalRequirementKind.optional(), progress_available: z.boolean().optional(), satisfied: z.boolean().optional(), source: moneyMovementsApprovalRequirementSource.optional()});

export const moneyMovementsApprovalValuationStatus = z.enum(["valued", "unavailable"]);

export const moneyMovementsApprovalPolicyValuationView = z.object({amount_usd: z.string().nullable().optional(), amount_usd_view: z.union([moneyfmtMoneyAmountView, z.unknown()]).optional(), status: moneyMovementsApprovalValuationStatus.optional()});

export const moneyMovementsApprovalPolicyView = z.object({action_allowed: z.boolean().optional(), business_policy_revision: z.string().nullable().optional(), permission_allowed: z.boolean().optional(), requirements: z.array(moneyMovementsApprovalClauseView).nullable().optional(), revision: z.string().optional(), valuation: moneyMovementsApprovalPolicyValuationView.optional()});

export const tradesBuyApprovalPreview = z.object({policy: moneyMovementsApprovalPolicyView.optional(), required: z.boolean()});

export const moneyMovementsMovementExecution = z.literal("after_funding");

export const tradesExpressBuyFeeDisclosure = z.object({fee_usd_view: moneyfmtMoneyAmountView.optional(), net_quantity_view: moneyfmtMoneyAmountView.optional(), rate_bps: z.number().int(), rate_label: z.string()});

export const tradesExpressBuyQuote = z.object({available: z.boolean(), fee: tradesExpressBuyFeeDisclosure.optional(), max_order_usd: z.string().optional(), max_order_usd_view: moneyfmtMoneyAmountView.optional(), settlement_estimate_seconds: z.number().int().optional()});

export const tradesInstantSellQuote = z.object({available: z.boolean(), max_order_usd: z.string().optional(), max_order_usd_view: moneyfmtMoneyAmountView.optional()});

export const tradesBuySubmissionRefusal = z.object({code: z.string().optional(), message: z.string()});

export const tradesGetTradeQuoteOutput = z.object({amount_usd: z.string().optional(), amount_usd_view: moneyfmtMoneyAmountView.optional(), approval_preview: tradesBuyApprovalPreview.optional(), estimated_execution_ts: z.string().optional(), estimated_quantity: z.string().optional(), estimated_quantity_view: moneyfmtMoneyAmountView.optional(), execution: moneyMovementsMovementExecution.optional(), expires_ts: z.string().optional(), express_buy: tradesExpressBuyQuote.optional(), instant_sell: tradesInstantSellQuote.optional(), price_per_unit: z.string().optional(), price_per_unit_view: moneyfmtMoneyAmountView.optional(), settlement_duration_minutes: z.number().int().gte(1).nullable().optional(), settlement_trading_days: z.number().int().nullable().optional(), settlement_ts: z.string().optional(), submission_refusal: tradesBuySubmissionRefusal.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
};

/**
 * Quote a member trade
 * 
 * GET /money/trades/quote
 */
export const getApiMoneyTradesQuote = async (args: GetApiMoneyTradesQuoteArgs, options: GetApiMoneyTradesQuoteOptions) => {
const {baseUrl, fetch: fetchFn = fetch} = options ?? {}

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

if (args.include_approval_preview != null) query.append("include_approval_preview", String(args.include_approval_preview))
if (args.symbol != null) query.append("symbol", String(args.symbol))
if (args.direction != null) query.append("direction", String(args.direction))
if (args.input_amount != null) query.append("input_amount", String(args.input_amount))
if (args.settlement_preference != null) query.append("settlement_preference", String(args.settlement_preference))

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