import {z} from 'zod'

export type GetApiAiStatusV1JobsJobIdArgs = {jobId: string};

export type GetApiAiStatusV1JobsJobIdOptions = {baseUrl?: string | undefined, OAuth2?: string | undefined, fetch?: typeof fetch | undefined};

export const summaryTimingsUnit = z.object({confidence: z.number().optional(), value: z.string(), start: z.number().optional(), end: z.number().optional()});

export const summaryOutputUnit = z.object({name: z.enum(["Extractive", "AbstractiveLong", "AbstractiveShort", "All"]).optional(), values: z.array(summaryTimingsUnit).optional()});

export const summaryOutput = z.object({summaries: z.array(summaryOutputUnit).optional()});

export const caiErrorCodeResponse = z.object({errorCode: z.enum(["CAI-101", "CAI-102", "CAI-103", "CAI-104", "CAI-105", "CAI-106", "CAI-107", "CAI-108", "CAI-109", "CAI-110"]), message: z.string(), parameterName: z.string().optional()});

export const caiErrorResponse = z.object({errors: z.array(caiErrorCodeResponse).optional()});

export const summaryApiResponse = z.union([summaryOutput, caiErrorResponse]);

export const punctuateOutput = z.object({texts: z.array(z.string())});

export const punctuateApiResponse = z.union([punctuateOutput, caiErrorResponse]);

export const diarizeSegment = z.object({speakerId: z.string(), start: z.number(), end: z.number(), confidence: z.number().optional()});

export const diarizedObject = z.object({speakerCount: z.number().int(), utterances: z.array(diarizeSegment)});

export const speakerIdentificationObject = z.object({utterances: z.array(diarizeSegment)});

export const wordTimingsUnit = z.object({start: z.number().optional(), end: z.number().optional(), word: z.string().optional()});

export const utteranceObject = z.object({start: z.number(), end: z.number(), text: z.string(), confidence: z.number().optional(), speakerId: z.string().optional(), wordTimings: z.array(wordTimingsUnit).optional()});

export const wordSegment = z.object({speakerId: z.string().optional(), start: z.number(), end: z.number(), confidence: z.number().optional(), word: z.string()});

export const transcribedObject = z.object({speakerCount: z.number().int().optional(), utterances: z.array(utteranceObject).optional(), words: z.array(wordSegment), confidence: z.number().optional(), transcript: z.string()});

export const emotionSegment = z.object({start: z.number(), end: z.number(), emotion: z.enum(["Anger", "Excitement", "Frustration", "Joy", "Sadness", "Neutral"]), confidence: z.number().optional()});

export const emotionObject = z.array(emotionSegment);

export const utteranceInsightsUnit = z.object({name: z.literal("Emotion"), value: z.string(), confidence: z.number().optional()}).and(z.record(z.string(), z.string()));

export const utteranceInsightsObject = z.object({start: z.number(), end: z.number(), text: z.string(), confidence: z.number().optional(), speakerId: z.string().optional(), wordTimings: z.array(wordTimingsUnit).optional(), insights: z.array(utteranceInsightsUnit).optional()});

export const speakerInsightsValuesItems = z.object({speakerId: z.string(), value: z.string()}).and(z.record(z.string(), z.string()));

export const speakerInsightsUnit = z.object({name: z.enum(["Energy", "Pace", "TalkToListenRatio", "QuestionsAsked"]), values: z.array(speakerInsightsValuesItems)});

export const speakerInsightsObject = z.object({speakerCount: z.number().int().optional(), insights: z.array(speakerInsightsUnit).optional()});

export const conversationalInsightsUnitValues = z.object({confidence: z.number().optional(), value: z.string(), start: z.number(), end: z.number(), groupId: z.string().optional(), speakerId: z.string().optional(), assignee: z.string().optional(), category: z.string().optional(), text: z.string().optional(), question: z.string().optional(), answer: z.string().optional()}).and(z.record(z.string(), z.string()));

export const conversationalInsightsUnit = z.object({name: z.enum(["ExtractiveSummary", "AbstractiveSummaryLong", "AbstractiveSummaryShort", "KeyPhrases", "QuestionsAsked", "OverallSentiment", "Topics"]), values: z.array(conversationalInsightsUnitValues)});

export const interactionObject = z.object({utteranceInsights: z.array(utteranceInsightsObject).optional(), speakerInsights: speakerInsightsObject.optional(), conversationalInsights: z.array(conversationalInsightsUnit).optional()});

export const jobStatusResponse = z.union([z.object({jobId: z.string().optional(), creationTime: z.string().optional(), completionTime: z.string().optional(), expirationTime: z.string().optional(), status: z.enum(["Success", "Fail"]).optional(), response: summaryApiResponse.optional()}), z.object({jobId: z.string().optional(), creationTime: z.string().optional(), completionTime: z.string().optional(), expirationTime: z.string().optional(), status: z.enum(["Success", "Fail"]).optional(), response: punctuateApiResponse.optional()}), z.object({jobId: z.string().optional(), creationTime: z.string().optional(), completionTime: z.string().optional(), expirationTime: z.string().optional(), status: z.enum(["Success", "Fail"]).optional(), response: z.union([diarizedObject, caiErrorResponse]).optional()}), z.object({jobId: z.string().optional(), creationTime: z.string().optional(), completionTime: z.string().optional(), expirationTime: z.string().optional(), status: z.enum(["Success", "Fail"]).optional(), response: z.union([speakerIdentificationObject, caiErrorResponse]).optional()}), z.object({jobId: z.string().optional(), creationTime: z.string().optional(), completionTime: z.string().optional(), expirationTime: z.string().optional(), status: z.enum(["Success", "Fail"]).optional(), response: z.union([transcribedObject, caiErrorResponse]).optional()}), z.object({jobId: z.string().optional(), creationTime: z.string().optional(), completionTime: z.string().optional(), expirationTime: z.string().optional(), status: z.enum(["Success", "Fail"]).optional(), response: z.union([emotionObject, caiErrorResponse]).optional()}), z.object({jobId: z.string().optional(), creationTime: z.string().optional(), completionTime: z.string().optional(), expirationTime: z.string().optional(), status: z.enum(["Success", "Fail"]).optional(), response: z.union([interactionObject, caiErrorResponse]).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
};

/**
 * Get Async Task Status
 * 
 * GET /ai/status/v1/jobs/{jobId}
 */
export const getApiAiStatusV1JobsJobId = async (args: GetApiAiStatusV1JobsJobIdArgs, options?: GetApiAiStatusV1JobsJobIdOptions) => {
const {baseUrl = "https://platform.ringcentral.com", fetch: fetchFn = fetch, OAuth2} = options ?? {}

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

if (OAuth2 !== undefined) headers.set('authorization', `Bearer ${OAuth2}`)

const url = `${baseUrl.replace(/\/+$/, '')}/ai/status/v1/jobs/${encodeURIComponent(String(args.jobId))}${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(jobStatusResponse, await res.json())
};