import {z} from 'zod' export type GetApiPartnersReferrersUserIdStatsArgs = {user_id: number}; export type GetApiPartnersReferrersUserIdStatsOptions = {baseUrl: string, APIKeyHeader?: string | undefined, fetch?: typeof fetch | undefined}; export const referrerSummary = z.object({total_referrals: z.number().int(), paid_referrals: z.number().int(), active_referrals: z.number().int(), conversion_to_paid_percent: z.number(), conversion_to_active_percent: z.number(), avg_earnings_per_referral_kopeks: z.number()}); export const earningsByPeriod = z.object({all_time_kopeks: z.number().int(), year_kopeks: z.number().int(), month_kopeks: z.number().int(), week_kopeks: z.number().int(), today_kopeks: z.number().int()}); export const referralsCountByPeriod = z.object({all_time: z.number().int(), year: z.number().int(), month: z.number().int(), week: z.number().int(), today: z.number().int()}); export const referrerDetailedStats = z.object({user_id: z.number().int(), summary: referrerSummary, earnings: earningsByPeriod, referrals_count: referralsCountByPeriod}); 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 Referrer Detailed Stats * * GET /partners/referrers/{user_id}/stats */ export const getApiPartnersReferrersUserIdStats = async (args: GetApiPartnersReferrersUserIdStatsArgs, options: GetApiPartnersReferrersUserIdStatsOptions) => { const {baseUrl, fetch: fetchFn = fetch, APIKeyHeader} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (APIKeyHeader !== undefined) headers.set("X-API-Key", APIKeyHeader) const url = `${baseUrl.replace(/\/+$/, '')}/partners/referrers/${encodeURIComponent(String(args.user_id))}/stats${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(referrerDetailedStats, await res.json()) };