import {z} from 'zod'

export type GetApiV1MessagesGroupArgs = {internal_id: string, from_date?: number | undefined, to_date?: number | undefined, short_info?: boolean | undefined, cursor?: string | undefined};

export type GetApiV1MessagesGroupOptions = {baseUrl?: string | undefined, apiKey?: string | undefined, fetch?: typeof fetch | undefined};

export const typePeer = z.union([z.object({channel_id: z.string(), _: z.literal("PeerChannel")}), z.object({chat_id: z.string(), _: z.literal("PeerChat")}), z.object({user_id: z.string(), _: z.literal("PeerUser")})]);

export const forwardedFrom = z.object({peer: typePeer.nullable().optional(), channel_post: z.number().int().gte(0).nullable().optional(), date: z.string()});

export const messageEntity = z.object({type: z.string(), offset: z.number().int().gte(0), length: z.number().int().gte(0), url: z.string().nullable().optional(), user: z.string().nullable().optional(), language: z.string().nullable().optional(), custom_emoji_id: z.string().nullable().optional()});

export const mediaPhoto = z.object({id: z.number().int(), size: z.number().int().gte(0).nullable().optional(), url: z.string().nullable().optional(), thumb_url: z.string().nullable().optional(), width: z.number().int().gte(0).nullable().optional(), height: z.number().int().gte(0).nullable().optional(), date: z.string().nullable().optional()});

export const mediaGeo = z.object({long: z.number(), lat: z.number(), accuracy_radius: z.number().int().nullable().optional()});

export const mediaGeoLive = z.object({long: z.number(), lat: z.number(), accuracy_radius: z.number().int().nullable().optional(), period: z.number().int()});

export const mediaContact = z.object({phone_number: z.string(), first_name: z.string(), last_name: z.string(), vcard: z.string(), user_id: z.number().int()});

export const mediaDice = z.object({value: z.number().int(), emoticon: z.string()});

export const documentAttributeAudio = z.object({voice: z.boolean(), duration: z.number().int(), title: z.string().nullable().optional(), performer: z.string().nullable().optional()});

export const documentAttributeCustomEmoji = z.object({free: z.boolean(), text_color: z.boolean(), alt: z.string(), stickerset: z.unknown()});

export const documentAttributeVideo = z.object({round_message: z.boolean(), supports_streaming: z.boolean(), duration: z.number(), w: z.number().int(), h: z.number().int()});

export const documentAttributeSticker = z.object({mask: z.boolean(), alt: z.string(), stickerset: z.unknown(), mask_coords: z.unknown()});

export const mediaDocument = z.object({id: z.number().int(), size: z.number().int().gte(0).nullable().optional(), mime_type: z.string(), file_name: z.string(), url: z.string().nullable().optional(), animated: z.boolean(), has_stickers: z.boolean(), audio: documentAttributeAudio.nullable().optional(), custom_emoji: documentAttributeCustomEmoji.nullable().optional(), video: documentAttributeVideo.nullable().optional(), sticker: documentAttributeSticker.nullable().optional()});

export const mediaWebPage = z.object({url: z.string(), type: z.string(), site_name: z.string(), title: z.string(), description: z.string(), author: z.string()});

export const mediaVenue = z.object({geo: mediaGeo, title: z.string(), address: z.string(), provider: z.string(), venue_id: z.string(), venue_type: z.string()});

export const mediaGame = z.object({id: z.number().int(), short_name: z.string(), title: z.string(), description: z.string()});

export const mediaInvoice = z.object({test: z.boolean(), title: z.string(), description: z.string(), receipt_msg_id: z.number().int().nullable().optional(), currency: z.string(), total_amount: z.number().int(), start_param: z.string()});

export const textWithEntities = z.object({text: z.string(), entities: z.array(messageEntity)});

export const poll = z.object({id: z.number().int(), closed: z.boolean(), public_voters: z.boolean(), multiple_choice: z.boolean(), quiz: z.boolean(), question: textWithEntities, answers: z.array(textWithEntities), close_period: z.number().int().nullable().optional(), close_date: z.string().nullable().optional()});

export const pollAnswerVoters = z.object({chosen: z.boolean(), correct: z.boolean(), voters: z.number().int()});

export const pollResults = z.object({min: z.boolean(), results: z.array(pollAnswerVoters).nullable().optional(), total_voters: z.number().int().nullable().optional(), solution: z.string().nullable().optional(), solution_entities: z.array(messageEntity).nullable().optional()});

export const mediaPoll = z.object({poll: poll, results: pollResults});

export const storyItem = z.object({public: z.boolean(), edited: z.boolean(), id: z.number().int(), date: z.string(), expire_date: z.string(), caption: z.string().nullable().optional(), entities: z.array(messageEntity).nullable().optional()});

export const mediaStory = z.object({via_mention: z.boolean(), peer: typePeer, id: z.number().int(), story: storyItem.nullable().optional()});

export const mediaGiveaway = z.object({only_new_subscribers: z.boolean(), channels: z.array(z.number().int()), countries_iso2: z.array(z.string()).nullable().optional(), quantity: z.number().int(), months: z.number().int().nullable().optional(), stars: z.number().int().nullable().optional(), until_date: z.string()});

export const mediaGiveawayResults = z.object({only_new_subscribers: z.boolean(), refunded: z.boolean(), channel_id: z.number().int(), additional_peers_count: z.number().int().nullable().optional(), launch_msg_id: z.number().int(), winners_count: z.number().int(), unclaimed_count: z.number().int(), winners: z.array(z.number().int()), months: z.number().int().nullable().optional(), stars: z.number().int().nullable().optional(), prize_description: z.string().nullable().optional(), until_date: z.string()});

export const mediaPaidMedia = z.object({stars_amount: z.number().int()});

export const messageMedia = z.union([z.object({Photo: mediaPhoto}), z.object({Geo: mediaGeo}), z.object({GeoLive: mediaGeoLive}), z.object({Contact: mediaContact}), z.object({Dice: mediaDice}), z.object({Document: mediaDocument}), z.object({WebPage: mediaWebPage}), z.object({Venue: mediaVenue}), z.object({Game: mediaGame}), z.object({Invoice: mediaInvoice}), z.object({Poll: mediaPoll}), z.object({Story: mediaStory}), z.object({Giveaway: mediaGiveaway}), z.object({GiveawayResults: mediaGiveawayResults}), z.object({PaidMedia: mediaPaidMedia}), z.object({Other: z.string()})]);

export const replyMarkupButton = z.object({kind: z.string(), text: z.string(), url: z.string().nullable().optional()});

export const messageReplyMarkupRow = z.object({buttons: z.array(replyMarkupButton).optional()});

export const messageReplyMarkup = z.object({rows: z.array(messageReplyMarkupRow).optional()});

export const groupMessage = z.object({peer_id: z.string(), from_peer: typePeer.nullable().optional(), is_premium: z.boolean().nullable().optional(), is_bot: z.boolean().nullable().optional(), message_id: z.number().int().gte(0), fwd_from: forwardedFrom.nullable().optional(), date: z.string(), text: z.string(), entities: z.array(messageEntity).optional(), media: messageMedia.nullable().optional(), keyboard: messageReplyMarkup.nullable().optional(), grouped_id: z.number().int().nullable().optional()});

export const peerType = z.enum(["Group", "Channel"]);

export const chatShort = z.object({internal_id: z.string(), peer: peerType, title: z.string(), photo_url: z.string().nullable().optional(), country: z.string().nullable().optional(), language: z.string().nullable().optional(), category: z.string().nullable().optional(), members_count: z.number().int().gte(0), verified: z.boolean()});

export const groupMessagesResponse = z.object({messages: z.array(groupMessage), chats: z.array(chatShort), cursor: z.string().nullable().optional()});

export const validateResponse = async <Output>(
  schema: {
    readonly '~standard': {
      readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray<PropertyKey | { readonly key: PropertyKey }> | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray<PropertyKey | { readonly key: PropertyKey }> | undefined }> }>
    }
  },
  value: unknown
): Promise<Output> => {
  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
};

/**
 * Group Messages
 * 
 * GET /v1/messages/group
 */
export const getApiV1MessagesGroup = async (args: GetApiV1MessagesGroupArgs, options?: GetApiV1MessagesGroupOptions) => {
const {baseUrl = "https://api.tlmtr.io", fetch: fetchFn = fetch, apiKey} = options ?? {}

const query = new URLSearchParams()
const headers = new Headers()
headers.set('accept', "application/json")

if (args.internal_id != null) query.append("internal_id", String(args.internal_id))
if (args.from_date != null) query.append("from_date", String(args.from_date))
if (args.to_date != null) query.append("to_date", String(args.to_date))
if (args.short_info != null) query.append("short_info", String(args.short_info))
if (args.cursor != null) query.append("cursor", String(args.cursor))
if (apiKey !== undefined) headers.set("x-api-key", apiKey)

const url = `${baseUrl.replace(/\/+$/, '')}/v1/messages/group${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(groupMessagesResponse, await res.json())
};