import {z} from 'zod' export type Coin = 'BRLA' | 'USDC' | 'USDT' | 'ETH' | 'GLMR' | 'MATIC' | 'CHZ'; export type Chain = 'Polygon' | 'Ethereum' | 'Moonbeam' | 'Tron' | 'XRP' | 'Chiliz'; export type Markup = string; export type GetApiSuperuserFastQuoteArgs = {operation: 'swap' | 'pix-to-usd' | 'pix-to-token', amount: number, inputCoin: Coin, outputCoin: Coin, chain: Chain, markup?: Markup | undefined, fixOutput?: boolean | undefined}; export type GetApiSuperuserFastQuoteOptions = {baseUrl?: string | undefined, bearerAuth?: string | undefined, fetch?: typeof fetch | undefined}; export const coin = z.enum(["BRLA", "USDC", "USDT", "ETH", "GLMR", "MATIC", "CHZ"]); export const chain = z.enum(["Polygon", "Ethereum", "Moonbeam", "Tron", "XRP", "Chiliz"]); export const fastQuoteOutput = z.object({token: z.string().optional(), basePrice: z.string().optional(), error: z.string().optional(), sub: z.string().optional(), operation: z.string().optional(), amountBrl: z.string().optional(), amountUsd: z.string().optional(), amountToken: z.string().optional(), baseFee: z.string().optional(), gasFee: z.string().optional(), markupFee: z.string().optional(), markupToken: z.string().optional(), inputCoin: coin.optional(), outputCoin: coin.optional(), chain: chain.optional()}); export const validateResponse = async ( schema: { readonly '~standard': { readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }> } }, value: unknown ): Promise => { 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 token conversion * * GET /superuser/fast-quote * * Also accepts auth: apiKeyAuth + apiSignatureAuth + apiTimestampAuth */ export const getApiSuperuserFastQuote = async (args: GetApiSuperuserFastQuoteArgs, options?: GetApiSuperuserFastQuoteOptions) => { const {baseUrl = "https://api.brla.digital:5567/v1", fetch: fetchFn = fetch, bearerAuth} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (args.operation != null) query.append("operation", String(args.operation)) if (args.amount != null) query.append("amount", String(args.amount)) if (args.inputCoin != null) query.append("inputCoin", String(args.inputCoin)) if (args.outputCoin != null) query.append("outputCoin", String(args.outputCoin)) if (args.chain != null) query.append("chain", String(args.chain)) if (args.markup != null) query.append("markup", String(args.markup)) if (args.fixOutput != null) query.append("fixOutput", String(args.fixOutput)) if (bearerAuth !== undefined) headers.set('authorization', `Bearer ${bearerAuth}`) const url = `${baseUrl.replace(/\/+$/, '')}/superuser/fast-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(fastQuoteOutput, await res.json()) };