import {z} from 'zod'

export type GetApiTwitterUserTweetTimelineArgs = {userId?: unknown | undefined, includeReplies?: boolean | undefined, includeParentTweet?: boolean | undefined, cursor?: unknown | undefined};

export type GetApiTwitterUserTweetTimelineOptions = {baseUrl?: string | undefined, ApiKeyAuth?: string | undefined, fetch?: typeof fetch | undefined};

export const userInfo = z.object({type: z.literal("user").optional(), userName: z.string().optional(), url: z.string().optional(), id: z.string().optional(), name: z.string().optional(), isBlueVerified: z.boolean().optional(), protected: z.boolean().optional(), verifiedType: z.string().optional(), profilePicture: z.string().optional(), coverPicture: z.string().optional(), description: z.string().optional(), location: z.string().optional(), followers: z.number().int().optional(), following: z.number().int().optional(), canDm: z.boolean().optional(), createdAt: z.string().optional(), favouritesCount: z.number().int().optional(), hasCustomTimelines: z.boolean().optional(), isTranslator: z.boolean().optional(), mediaCount: z.number().int().optional(), statusesCount: z.number().int().optional(), withheldInCountries: z.array(z.string()).optional(), affiliatesHighlightedLabel: z.object({}).optional(), possiblySensitive: z.boolean().optional(), pinnedTweetIds: z.array(z.string()).optional(), isAutomated: z.boolean().optional(), automatedBy: z.string().optional(), unavailable: z.boolean().optional(), message: z.string().optional(), unavailableReason: z.string().optional(), profile_bio: z.object({description: z.string().optional(), entities: z.object({description: z.object({urls: z.array(z.object({display_url: z.string().optional(), expanded_url: z.string().optional(), indices: z.array(z.number().int()).optional(), url: z.string().optional()})).optional()}).optional(), url: z.object({urls: z.array(z.object({display_url: z.string().optional(), expanded_url: z.string().optional(), indices: z.array(z.number().int()).optional(), url: z.string().optional()})).optional()}).optional()}).optional()}).optional()});

export const tweetEntities = z.object({hashtags: z.array(z.object({indices: z.array(z.number().int()).optional(), text: z.string().optional()})).optional(), urls: z.array(z.object({display_url: z.string().optional(), expanded_url: z.string().optional(), indices: z.array(z.number().int()).optional(), url: z.string().optional()})).optional(), user_mentions: z.array(z.object({id_str: z.string().optional(), name: z.string().optional(), screen_name: z.string().optional()})).optional()});

export const tweet: z.ZodType<Tweet> = z.object({type: z.literal("tweet").optional(), id: z.string().optional(), url: z.string().optional(), text: z.string().optional(), source: z.string().optional(), retweetCount: z.number().int().optional(), replyCount: z.number().int().optional(), likeCount: z.number().int().optional(), quoteCount: z.number().int().optional(), viewCount: z.number().int().optional(), createdAt: z.string().optional(), lang: z.string().optional(), bookmarkCount: z.number().int().optional(), isReply: z.boolean().optional(), inReplyToId: z.string().optional(), conversationId: z.string().optional(), displayTextRange: z.array(z.number().int()).optional(), inReplyToUserId: z.string().optional(), inReplyToUsername: z.string().optional(), author: userInfo.optional(), entities: tweetEntities.optional(), quoted_tweet: z.lazy(() => tweet.optional()), retweeted_tweet: z.lazy(() => tweet.optional()), isLimitedReply: z.boolean().optional()});

export const getApiTwitterUserTweetTimelineResponse = z.object({tweets: z.array(tweet), has_next_page: z.boolean(), next_cursor: z.string(), status: z.enum(["success", "error"]), message: z.string()});

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
};

/**
 * Retrieve tweets by user id.Sort by created_at. Results are paginated, with each page returning up to 20 tweets.The content you see is in the same order as the tweets on the user's profile in the Twitter app, and filtering by time is not supported.  
 * 
 * GET /twitter/user/tweet_timeline
 */
export const getApiTwitterUserTweetTimeline = async (args: GetApiTwitterUserTweetTimelineArgs, options?: GetApiTwitterUserTweetTimelineOptions) => {
const {baseUrl = "https://api.twitterapi.io", fetch: fetchFn = fetch, ApiKeyAuth} = options ?? {}

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

if (args.userId != null) query.append("userId", String(args.userId))
if (args.includeReplies != null) query.append("includeReplies", String(args.includeReplies))
if (args.includeParentTweet != null) query.append("includeParentTweet", String(args.includeParentTweet))
if (args.cursor != null) query.append("cursor", String(args.cursor))
if (ApiKeyAuth !== undefined) headers.set("X-API-Key", ApiKeyAuth)

const url = `${baseUrl.replace(/\/+$/, '')}/twitter/user/tweet_timeline${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(getApiTwitterUserTweetTimelineResponse, await res.json())
};