import {z} from 'zod' export type OfferTypeQueryParamOfferTypeEnum = 'ONRAMP' | 'OFFRAMP'; export type GetApiExchangeApiOffersBestOfferArgs = {offerType?: OfferTypeQueryParamOfferTypeEnum | undefined, token?: string | undefined, fiat?: string | undefined, tokenAmount?: number | undefined, fiatAmount?: number | undefined, networkId?: string | undefined, paymentChannel?: string | undefined}; export type GetApiExchangeApiOffersBestOfferOptions = {baseUrl?: string | undefined, fetch?: typeof fetch | undefined}; export const offerType = z.enum(["ONRAMP", "OFFRAMP"]); export const offerBehavior = z.enum(["FIXED", "FLEXIBLE"]); export const offerPaymentChannelColor = z.object({bg: z.string(), fg: z.string()}); export const offerPaymentMethod = z.object({channelId: z.string().optional(), channelName: z.string().optional(), channelType: z.string().optional(), color: offerPaymentChannelColor.optional(), id: z.string().optional()}); export const offerPaymentChannel = z.object({channelId: z.string().optional(), channelName: z.string().optional(), channelType: z.string().optional(), color: offerPaymentChannelColor.optional()}); export const offerStatus = z.enum(["PENDING", "ACTIVE", "OFFLINE", "LOW_BALANCE", "LIMIT_REACHED"]); export const partnerStats = z.object({partnerId: z.string().optional(), averageRating: z.number().optional(), totalTransactions: z.number().optional(), tradeCount: z.number().optional(), completionPercentage: z.number().optional(), averageResponseTime: z.number().optional()}); export const tradeMode = z.enum(["P2P", "IP", "OTC"]); export const feeConfig = z.object({tradeType: offerType.optional(), tradeMode: tradeMode.optional(), base: z.number(), tradePercentage: z.number(), cap: z.number().optional(), network: z.string()}); export const tradeCriteria = z.object({verifiedKyc: z.boolean().optional()}); export const fulfillOrderAs = z.enum(["BUSINESS", "PERSONAL"]); export const autoRefillConfig = z.object({threshold: z.number(), amount: z.number()}); export const offerDto = z.object({offerId: z.string(), userId: z.string(), network: z.string(), tokenSymbol: z.string(), fiatSymbol: z.string(), offerType: offerType, behaviour: offerBehavior, totalUnit: z.number(), tradedUnit: z.number(), lockedUnit: z.number(), rate: z.number(), rateCap: z.number().optional(), paymentMethods: z.array(offerPaymentMethod), paymentChannels: z.array(offerPaymentChannel).optional(), flexibleOfferMargin: z.number().optional(), status: offerStatus, partnerDisplayName: z.string(), partnerRating: z.number(), partnerStats: partnerStats.optional(), statusReason: z.string().optional(), tradeMinimumLimit: z.number(), tradeMaximumLimit: z.number(), previewImageUrl: z.string().optional(), maxTimeout: z.object({deposit: z.number().int().optional(), confirmation: z.number().int().optional()}).optional(), feeConfig: feeConfig.optional(), feeConfigs: z.array(feeConfig).optional(), tradeCriteria: tradeCriteria.optional(), autoResponseMessage: z.string().optional(), adNote: z.string().optional(), tradeRequestBroadcastId: z.string().optional(), isPrivate: z.boolean().optional(), isRateHidden: z.boolean().optional(), instantPayEnabled: z.boolean().optional(), instantPayLimit: z.number().optional(), instantPayMinimum: z.number().optional(), instantPayAccountId: z.string().optional(), customPayinProvider: z.string().optional(), createdAt: z.string(), updatedAt: z.string(), editedAt: z.string(), partnerLastActiveAt: z.string(), primaryEscrowAddress: z.string().optional(), fiatTradeMinimumLimit: z.number().optional(), fiatTradeMaximumLimit: z.number().optional(), maxFiatLimit: z.number(), availableUnits: z.number(), fulfillOrderAs: fulfillOrderAs.optional(), autoRefillEnabled: z.boolean().optional(), autoRefillConfig: autoRefillConfig.optional()}); export const bestOfferDTO = z.object({offer: offerDto, orderRequestTradeId: z.string()}); export const getApiExchangeApiOffersBestOfferResponse = z.object({offer: bestOfferDTO, orderRequestTradeId: z.string()}); 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 }; /** * Get best offer using trade parameters * * GET /exchange/api/offers/best-offer */ export const getApiExchangeApiOffersBestOffer = async (args: GetApiExchangeApiOffersBestOfferArgs, options?: GetApiExchangeApiOffersBestOfferOptions) => { const {baseUrl = "https://external.dev.onboardpay.co", fetch: fetchFn = fetch} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (args.offerType != null) query.append("offerType", String(args.offerType)) if (args.token != null) query.append("token", String(args.token)) if (args.fiat != null) query.append("fiat", String(args.fiat)) if (args.tokenAmount != null) query.append("tokenAmount", String(args.tokenAmount)) if (args.fiatAmount != null) query.append("fiatAmount", String(args.fiatAmount)) if (args.networkId != null) query.append("networkId", String(args.networkId)) if (args.paymentChannel != null) query.append("paymentChannel", String(args.paymentChannel)) const url = `${baseUrl.replace(/\/+$/, '')}/exchange/api/offers/best-offer${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(getApiExchangeApiOffersBestOfferResponse, await res.json()) };