import {z} from 'zod'

export type GetApiV4UserAccountsServerAccountIdPortfolioTransactionsArgs = {accountId: string, server: 'oanda' | 'oanda-demo' | 'otms' | 'v20' | 'v20-demo' | 'oj' | 'oj-demo' | 'opt' | 'ftmo-1', limit?: number | undefined, offset?: number | undefined, type?: (Array<'MARKET_OPEN' | 'MARKET_CLOSE' | 'STOP_LOSS' | 'TAKE_PROFIT' | 'STOP_OUT' | 'SPLIT' | 'INDEX_DIVIDEND' | 'DEPOSIT' | 'WITHDRAWAL' | 'DIVIDEND' | 'SPINOFF_ADJ' | 'TAX' | 'TAX_EQUIVALENT' | 'RIGHTS_ADJ' | 'ACQ_MERG_ADJ' | 'BONUS_ADJ' | 'STOCKDIV_ADJ' | 'CREDIT' | 'CORRECTION' | 'BONUS' | 'COMMISSION' | 'FINANCING' | 'SPLIT_ADJ'>) | undefined, orderId?: string | undefined, instrument?: string | undefined};

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

export const getApiV4UserAccountsServerAccountIdPortfolioTransactionsResponse = z.object({count: z.number(), limit: z.number(), offset: z.number(), data: z.array(z.union([z.object({accountId: z.string(), id: z.string(), creationTime: z.number(), orderId: z.string().optional(), tradeId: z.string().optional(), ref: z.string().optional(), instrument: z.string(), type: z.enum(["MARKET_OPEN", "MARKET_CLOSE", "STOP_LOSS", "TAKE_PROFIT", "STOP_OUT", "SPLIT"]), quantity: z.number().optional(), profit: z.number().optional(), direction: z.enum(["LONG", "SHORT"]), price: z.number().optional(), pricePosition: z.number().optional(), stopLoss: z.number().optional(), takeProfit: z.number().optional(), trailingStop: z.number().optional(), guaranteedStopLoss: z.number().optional(), accountBallance: z.number().optional(), halfSpreadCost: z.number().optional(), commission: z.number().optional(), guaranteedExecutionFee: z.number().optional(), swap: z.number().optional()}), z.object({accountId: z.string(), id: z.string(), creationTime: z.number(), type: z.enum(["INDEX_DIVIDEND", "DEPOSIT", "WITHDRAWAL", "DIVIDEND", "SPINOFF_ADJ", "TAX", "TAX_EQUIVALENT", "RIGHTS_ADJ", "ACQ_MERG_ADJ", "BONUS_ADJ", "STOCKDIV_ADJ", "CREDIT", "CORRECTION", "BONUS", "COMMISSION", "FINANCING", "SPLIT_ADJ"]).optional(), accountBallanceChange: z.number().optional(), accountBallance: z.number(), externalId: z.string().nullable().optional(), gateway: z.string().nullable().optional(), comment: z.string().nullable().optional(), symbol: z.string().nullable().optional(), fee: z.number().nullable().optional(), ref: z.string().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
};

/**
 * GET /v4/user/accounts/{server}/{accountId}/portfolio/transactions
 */
export const getApiV4UserAccountsServerAccountIdPortfolioTransactions = async (args: GetApiV4UserAccountsServerAccountIdPortfolioTransactionsArgs, options: GetApiV4UserAccountsServerAccountIdPortfolioTransactionsOptions) => {
const {baseUrl, fetch: fetchFn = fetch, bearerAuth} = options ?? {}

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

if (args.limit != null) query.append("limit", String(args.limit))
if (args.offset != null) query.append("offset", String(args.offset))
if (args.type != null) query.append("type", args.type.join(','))
if (args.orderId != null) query.append("orderId", String(args.orderId))
if (args.instrument != null) query.append("instrument", String(args.instrument))
if (bearerAuth !== undefined) headers.set('authorization', `Bearer ${bearerAuth}`)

const url = `${baseUrl.replace(/\/+$/, '')}/v4/user/accounts/${encodeURIComponent(String(args.server))}/${encodeURIComponent(String(args.accountId))}/portfolio/transactions${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(getApiV4UserAccountsServerAccountIdPortfolioTransactionsResponse, await res.json())
};