import {z} from 'zod' export type NotificationTypes = 'cuts' | 'game_outcome' | 'game_played' | 'leaderboard_points' | 'user_demotion' | 'user_promotion' | 'user_achievement'; export type GetApiV1NotificationsArgs = {_?: NotificationTypes | undefined, types?: Array | undefined, resetCount?: boolean | undefined, asc?: boolean | undefined, start?: string | undefined, limit?: number | undefined}; export type GetApiV1NotificationsOptions = {baseUrl: string, accessToken?: string | undefined, fetch?: typeof fetch | undefined}; export const notificationTypesDto = z.enum(["cuts", "game_outcome", "game_played", "leaderboard_points", "user_demotion", "user_promotion", "user_achievement"]); export const fundsUpdatedReasons = z.enum(["free_gift", "host_cut", "referrer_cut", "parent_cut", "transaction_voided", "game_played", "game_outcome", "pending_outcome", "purchase", "redeem", "refund", "payout", "admin_update", "distributor_cut", "achievement"]); export const fundType = z.enum(["free", "white", "black", "gray", "coin", "pending_coin", "point"]); export const fund = z.object({type: fundType, amount: z.number()}); export const cutsNotification = z.object({type: fundsUpdatedReasons, gameId: z.string(), blackTickets: z.number(), whiteTickets: z.number(), isFinalResult: z.boolean(), isCanceled: z.boolean(), funds: z.array(fund), creatorId: z.string()}); export const side = z.enum(["A", "B"]); export const ticketType = z.enum(["white", "black", "free"]); export const gameplayStates = z.enum(["waiting_for_match", "matched", "declared_winner", "declared_loser", "won", "lost", "canceled"]); export const gameOutcomeNotification = z.object({side: side, ticketType: ticketType, state: gameplayStates, id: z.string(), gameId: z.string(), quantity: z.number(), matched: z.number(), outcomeChanged: z.boolean(), funds: z.array(fund)}); export const gamePlayedNotification = z.object({side: side, ticketType: ticketType, id: z.string(), gameId: z.string(), quantity: z.number()}); export const leaderboardPointsNotification = z.object({id: z.string(), leaderboardId: z.string(), userId: z.string(), points: z.number()}); export const userDemotionNotification = z.object({userId: z.string()}); export const userPromotionNotification = z.object({userId: z.string(), fromLeague: z.enum(["level1", "level2", "level3", "level4"]), toLeague: z.enum(["level1", "level2", "level3", "level4"])}); export const userAchievementNotification = z.object({userId: z.string(), achievementId: z.string()}); export const notificationDto = z.object({type: notificationTypesDto, notification: z.union([cutsNotification, gameOutcomeNotification, gamePlayedNotification, leaderboardPointsNotification, userDemotionNotification, userPromotionNotification, userAchievementNotification]), id: z.string(), userId: z.string(), createdAt: z.string()}); export const videoUrls = z.object({hls: z.string(), mp4360: z.string(), mp4540: z.string(), mp4720: z.string(), poster: z.string()}); export const gameStates = z.enum(["new", "active", "waiting_for_declaration", "declaring_winner", "winner_declared", "changing_game_result", "processing_payouts", "ended", "canceled", "refunded", "quarantined"]); export const language = z.enum(["en-us", "es-mx"]); export const gameType = z.enum(["POLL", "PREDICTION", "INSTANT_POLL", "TRIVIA", "SURVEY", "THIS_THAT"]); export const orientation = z.enum(["landscape", "portrait"]); export const creator = z.object({avatar: z.string(), id: z.string(), partnerName: z.string(), avatarAssetId: z.string(), profileColor: z.string(), userName: z.string(), createdAt: z.string(), updatedAt: z.string()}); export const category = z.object({language: language, id: z.string(), categoryName: z.string(), createdAt: z.string(), updatedAt: z.string(), deletedAt: z.string(), sticker: z.string().optional(), icon: z.string().optional()}); export const game = z.object({audioUrl: z.string(), videoUrls: videoUrls, questionVideoUrls: videoUrls, landscapeVideoUrls: videoUrls, resultUrls: videoUrls, state: gameStates, language: language, gameType: gameType, orientation: orientation.optional(), correctAnswer: side.optional(), id: z.string(), creatorId: z.string(), creator: creator, startTime: z.string(), endTime: z.string(), lastJoinTime: z.string(), gameTitle: z.string(), sourceUrl: z.string(), sideA: z.string(), sideB: z.string(), videoAssetId: z.string().optional(), questionVideoAssetId: z.string().optional(), landscapeVideoAssetId: z.string().optional(), audioAssetId: z.string().optional(), resultAssetId: z.string().optional(), text: z.string(), categoryId: z.string(), category: category, isAd: z.boolean(), isPrivate: z.boolean().optional(), bingSearch: z.string().optional(), bingSearchClaim: z.string().optional(), metadata: z.object({}).optional(), createdAt: z.string(), updatedAt: z.string(), version: z.number(), urls: z.array(z.string()).optional()}); export const profile = z.object({avatar: z.string(), id: z.string(), username: z.string(), avatarAssetId: z.string().optional(), profileColor: z.string(), createdAt: z.string(), updatedAt: z.string()}); export const notificationsListEntity = z.object({next: z.string().optional(), items: z.array(notificationDto), gameEntities: z.array(game), userEntities: z.array(profile), users: z.array(z.string()), games: z.array(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 /v1/notifications */ export const getApiV1Notifications = async (args: GetApiV1NotificationsArgs, options: GetApiV1NotificationsOptions) => { const {baseUrl, fetch: fetchFn = fetch, accessToken} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (args._ != null) query.append("_", String(args._)) for (const item of args.types ?? []) query.append("types", String(item)) if (args.resetCount != null) query.append("resetCount", String(args.resetCount)) if (args.asc != null) query.append("asc", String(args.asc)) if (args.start != null) query.append("start", String(args.start)) if (args.limit != null) query.append("limit", String(args.limit)) if (accessToken !== undefined) headers.set('authorization', `Bearer ${accessToken}`) const url = `${baseUrl.replace(/\/+$/, '')}/v1/notifications${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(notificationsListEntity, await res.json()) };