import {z} from 'zod' export type GetApiSpacesArgs = {id?: string | undefined, link?: string | undefined}; export type GetApiSpacesOptions = {baseUrl?: string | undefined, ApiKeyAuth?: string | undefined, fetch?: typeof fetch | undefined}; export const commonUser = z.object({bio_urls: z.array(z.string()).optional(), can_dm: z.boolean().optional(), created_at: z.string().optional(), description: z.string().optional(), display_name: z.string().optional(), favourites_count: z.number().int().optional(), followers_count: z.number().int().optional(), followings_count: z.number().int().optional(), id: z.string().optional(), location: z.string().optional(), media_count: z.number().int().optional(), pinned_tweet_ids: z.array(z.string()).optional(), possibly_sensitive: z.boolean().optional(), profile_background_image_url: z.string().optional(), profile_image_url: z.string().optional(), protected: z.boolean().optional(), tweets_count: z.number().int().optional(), username: z.string().optional(), verified: z.boolean().optional()}); export const commonPlaceParticipant = z.object({avatar: z.string().optional(), id: z.string().optional(), is_muted_by_admin: z.boolean().optional(), is_muted_by_guest: z.boolean().optional(), is_verified: z.boolean().optional(), name: z.string().optional(), periscope_user_id: z.string().optional(), start: z.number().int().optional(), username: z.string().optional()}); export const commonPlaceParticipants = z.object({admins: z.array(commonPlaceParticipant).optional(), listeners: z.array(commonPlaceParticipant).optional(), speakers: z.array(commonPlaceParticipant).optional(), total: z.number().int().optional()}); export const commonPlaceSettings = z.object({conversation_controls: z.number().int().optional(), disallow_join: z.boolean().optional(), is_employee_only: z.boolean().optional(), is_locked: z.boolean().optional(), is_muted: z.boolean().optional(), is_space_available_for_clipping: z.boolean().optional(), is_space_available_for_replay: z.boolean().optional(), max_admin_capacity: z.number().int().optional(), max_guest_sessions: z.number().int().optional(), narrow_cast_space_type: z.number().int().optional(), no_incognito: z.boolean().optional()}); export const commonPlaceStats = z.object({total_live_listeners: z.number().int().optional(), total_participants: z.number().int().optional(), total_replay_watched: z.number().int().optional()}); export const commonPlace = z.object({created_at: z.number().int().optional(), creator: commonUser.optional(), id: z.string().optional(), is_subscribed: z.boolean().optional(), media_key: z.string().optional(), participants: commonPlaceParticipants.optional(), scheduled_start: z.number().int().optional(), settings: commonPlaceSettings.optional(), state: z.string().optional(), stats: commonPlaceStats.optional(), title: z.string().optional(), updated_at: z.number().int().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 }; /** * Spaces Information * * GET /spaces */ export const getApiSpaces = async (args: GetApiSpacesArgs, options?: GetApiSpacesOptions) => { const {baseUrl = "https://api.sorsa.io/v3", fetch: fetchFn = fetch, ApiKeyAuth} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (args.id != null) query.append("id", String(args.id)) if (args.link != null) query.append("link", String(args.link)) if (ApiKeyAuth !== undefined) headers.set("ApiKey", ApiKeyAuth) const url = `${baseUrl.replace(/\/+$/, '')}/spaces${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(commonPlace, await res.json()) };