import {z} from 'zod'

export type CreateApiV1CustomerFlowFlowIdEdgeCaseEdgeCaseIdPromoteArgs = {flowId: string, edgeCaseId: string};

export type CreateApiV1CustomerFlowFlowIdEdgeCaseEdgeCaseIdPromoteOptions = {baseUrl?: string | undefined, Bearer?: string | undefined, fetch?: typeof fetch | undefined};

export const environmentResponse = z.object({id: z.string(), name: z.string().min(1), description: z.string().nullable().optional(), backgroundNoise: z.enum(["NONE", "AIRPORT", "CHILDREN_PLAYING", "CITY", "COFFEE_SHOP", "CONSTRUCTION", "CRYING_BABY", "DRIVING", "LIBRARY", "OFFICE", "THUNDERSTORM", "TRAIN"]), backgroundNoiseVolume: z.number().gte(0).lte(1), createdAt: z.string(), updatedAt: z.string()});

export const flowExpectation = z.object({id: z.string(), prompt: z.string()});

export const flowStep: z.ZodType<FlowStep> = z.union([z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("AGENT_TURN"), content: z.string().nullable().optional(), offScriptPolicy: z.object({reaction: z.enum(["STAY_SILENT", "REPEAT", "RESPOND", "SAY"]), sayLine: z.string().min(1).max(2000).nullable().optional(), maxAttempts: z.number().int().gte(1).lte(20), then: z.enum(["HANG_UP", "MOVE_ON", "ADAPT", "HANG_UP_INVALIDATE"]), waitSeconds: z.number().int().gte(1).lte(600).nullable().optional()}).nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("CUSTOMER_TURN"), content: z.string().nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("CUSTOMER_FIRST_MESSAGE"), content: z.string().nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("CUSTOMER_VERBATIM_TURN"), content: z.string().nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("CUSTOMER_SILENCE"), silenceDurationSeconds: z.number().int().gt(0).nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("CUSTOMER_AUDIO"), audioClip: z.enum(["HOLD_MUSIC_CLASSICAL_PIANO", "HOLD_MUSIC_CLASSICAL_ORCHESTRA", "HOLD_MUSIC_STRING_QUARTET", "HOLD_MUSIC_AMBIENT", "HOLD_MUSIC_SMOOTH_JAZZ", "HOLD_MUSIC_SOFT_SYNTH", "HOLD_BEEP", "RINGBACK_US", "RINGBACK_UK"]).nullable().optional(), silenceDurationSeconds: z.number().int().gt(0).lte(600).nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("CUSTOMER_DTMF"), dtmfDigits: z.string().nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("AGENT_DTMF"), dtmfDigits: z.string().nullable().optional(), offScriptPolicy: z.object({reaction: z.enum(["STAY_SILENT", "REPEAT", "RESPOND", "SAY"]), sayLine: z.string().min(1).max(2000).nullable().optional(), maxAttempts: z.number().int().gte(1).lte(20), then: z.enum(["HANG_UP", "MOVE_ON", "ADAPT", "HANG_UP_INVALIDATE"]), waitSeconds: z.number().int().gte(1).lte(600).nullable().optional()}).nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("VOICEMAIL")}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("CUSTOMER_HANDOFF"), handoffPersonaId: z.string().nullable().optional()}), z.object({nodeId: z.string().optional(), ref: z.string().min(1).max(64).optional(), steps: z.array(z.lazy(() => flowStep)).optional(), mergeIntoNodeIds: z.array(z.string().min(1)).optional(), stage: z.object({name: z.string().min(1).max(80), required: z.boolean().optional(), analyze: z.boolean().optional()}).nullable().optional(), endsCall: z.boolean().optional(), type: z.literal("SCENARIO_LINK"), linkedCustomerFlowId: z.string().nullable().optional(), linkedCustomerFlowVariantId: z.string().nullable().optional()})]);

export const scriptedFlowVariant = z.object({id: z.string(), title: z.string().min(1), systemKey: z.string().nullable().optional(), openingLine: z.string().nullable().optional(), precededByCustomerFlowId: z.string().nullable(), precededByCustomerFlowVariantId: z.string().nullable(), isGenerated: z.boolean(), includeFlowExpectations: z.boolean(), createdAt: z.string(), updatedAt: z.string(), personaOverride: z.object({id: z.string(), name: z.string(), displayName: z.string().nullable().optional(), description: z.string().nullable().optional(), language: z.enum(["EN", "ES", "DE", "HI", "FR", "NL", "AR", "EL", "IT", "ID", "TH", "JA", "TL", "MS", "ZH", "TR", "PT", "HE"]), secondaryLanguage: z.literal("EN").nullable().optional(), understoodLanguages: z.array(z.enum(["EN", "ES", "DE", "HI", "FR", "NL", "AR", "EL", "IT", "ID", "TH", "JA", "TL", "MS", "ZH", "TR", "PT", "HE"])), accent: z.enum(["US", "US_X_SOUTH", "GB", "ES", "DE", "IN", "FR", "NL", "SA", "GR", "AU", "IT", "ID", "TH", "JP", "NZ", "PH", "SG", "MY", "HK", "TR", "PT", "IL"]), age: z.enum(["CHILD", "TEENAGER", "ADULT", "ELDERLY"]), gender: z.enum(["MALE", "FEMALE"]), backgroundNoise: z.enum(["NONE", "AIRPORT", "CHILDREN_PLAYING", "CITY", "COFFEE_SHOP", "CONSTRUCTION", "CRYING_BABY", "DRIVING", "LIBRARY", "OFFICE", "THUNDERSTORM", "TRAIN"]), speechPace: z.enum(["SUPER_SLOW", "SLOW", "NORMAL", "FAST", "SUPER_FAST"]), speechClarity: z.enum(["CLEAR", "VAGUE", "RAMBLING"]), hasDisfluencies: z.boolean(), baseEmotion: z.enum(["NEUTRAL", "CHEERFUL", "CONFUSED", "FRUSTRATED", "SKEPTICAL", "RUSHED", "DISTRACTED", "ANGRY", "ANXIOUS", "SAD"]), intentClarity: z.enum(["CLEAR", "INDIRECT", "VAGUE"]), confirmationStyle: z.enum(["EXPLICIT", "VAGUE"]), memoryReliability: z.enum(["HIGH", "LOW"]), responseTiming: z.enum(["RELAXED", "NORMAL", "QUICK", "BARGE_IN"]), interruption: z.enum(["OFF", "BACKCHANNEL", "OCCASIONAL", "HEAVY"]), backstoryPrompt: z.string().nullable().optional(), idleMessages: z.array(z.string()).nullable(), idleTimeoutSeconds: z.number().int().gte(5).lte(60), idleMessageMaxSpokenCount: z.number().int().gte(1).lte(10), idleMessageResetCountOnUserSpeechEnabled: z.boolean(), properties: z.record(z.string(), z.unknown()), phoneNumber: z.string().optional(), createdAt: z.string(), updatedAt: z.string()}).nullable(), environment: environmentResponse.nullable(), additionalExpectations: z.array(flowExpectation), type: z.literal("SCRIPTED"), steps: z.array(flowStep)});

export const improvFlowVariant = z.object({id: z.string(), title: z.string().min(1), systemKey: z.string().nullable().optional(), openingLine: z.string().nullable().optional(), precededByCustomerFlowId: z.string().nullable(), precededByCustomerFlowVariantId: z.string().nullable(), isGenerated: z.boolean(), includeFlowExpectations: z.boolean(), createdAt: z.string(), updatedAt: z.string(), personaOverride: z.object({id: z.string(), name: z.string(), displayName: z.string().nullable().optional(), description: z.string().nullable().optional(), language: z.enum(["EN", "ES", "DE", "HI", "FR", "NL", "AR", "EL", "IT", "ID", "TH", "JA", "TL", "MS", "ZH", "TR", "PT", "HE"]), secondaryLanguage: z.literal("EN").nullable().optional(), understoodLanguages: z.array(z.enum(["EN", "ES", "DE", "HI", "FR", "NL", "AR", "EL", "IT", "ID", "TH", "JA", "TL", "MS", "ZH", "TR", "PT", "HE"])), accent: z.enum(["US", "US_X_SOUTH", "GB", "ES", "DE", "IN", "FR", "NL", "SA", "GR", "AU", "IT", "ID", "TH", "JP", "NZ", "PH", "SG", "MY", "HK", "TR", "PT", "IL"]), age: z.enum(["CHILD", "TEENAGER", "ADULT", "ELDERLY"]), gender: z.enum(["MALE", "FEMALE"]), backgroundNoise: z.enum(["NONE", "AIRPORT", "CHILDREN_PLAYING", "CITY", "COFFEE_SHOP", "CONSTRUCTION", "CRYING_BABY", "DRIVING", "LIBRARY", "OFFICE", "THUNDERSTORM", "TRAIN"]), speechPace: z.enum(["SUPER_SLOW", "SLOW", "NORMAL", "FAST", "SUPER_FAST"]), speechClarity: z.enum(["CLEAR", "VAGUE", "RAMBLING"]), hasDisfluencies: z.boolean(), baseEmotion: z.enum(["NEUTRAL", "CHEERFUL", "CONFUSED", "FRUSTRATED", "SKEPTICAL", "RUSHED", "DISTRACTED", "ANGRY", "ANXIOUS", "SAD"]), intentClarity: z.enum(["CLEAR", "INDIRECT", "VAGUE"]), confirmationStyle: z.enum(["EXPLICIT", "VAGUE"]), memoryReliability: z.enum(["HIGH", "LOW"]), responseTiming: z.enum(["RELAXED", "NORMAL", "QUICK", "BARGE_IN"]), interruption: z.enum(["OFF", "BACKCHANNEL", "OCCASIONAL", "HEAVY"]), backstoryPrompt: z.string().nullable().optional(), idleMessages: z.array(z.string()).nullable(), idleTimeoutSeconds: z.number().int().gte(5).lte(60), idleMessageMaxSpokenCount: z.number().int().gte(1).lte(10), idleMessageResetCountOnUserSpeechEnabled: z.boolean(), properties: z.record(z.string(), z.unknown()), phoneNumber: z.string().optional(), createdAt: z.string(), updatedAt: z.string()}).nullable(), environment: environmentResponse.nullable(), additionalExpectations: z.array(flowExpectation), type: z.literal("IMPROV"), prompt: z.string().nullable().optional(), handoffPersonas: z.array(z.object({id: z.string(), name: z.string(), displayName: z.string().nullable().optional(), description: z.string().nullable().optional(), language: z.enum(["EN", "ES", "DE", "HI", "FR", "NL", "AR", "EL", "IT", "ID", "TH", "JA", "TL", "MS", "ZH", "TR", "PT", "HE"]), secondaryLanguage: z.literal("EN").nullable().optional(), understoodLanguages: z.array(z.enum(["EN", "ES", "DE", "HI", "FR", "NL", "AR", "EL", "IT", "ID", "TH", "JA", "TL", "MS", "ZH", "TR", "PT", "HE"])), accent: z.enum(["US", "US_X_SOUTH", "GB", "ES", "DE", "IN", "FR", "NL", "SA", "GR", "AU", "IT", "ID", "TH", "JP", "NZ", "PH", "SG", "MY", "HK", "TR", "PT", "IL"]), age: z.enum(["CHILD", "TEENAGER", "ADULT", "ELDERLY"]), gender: z.enum(["MALE", "FEMALE"]), backgroundNoise: z.enum(["NONE", "AIRPORT", "CHILDREN_PLAYING", "CITY", "COFFEE_SHOP", "CONSTRUCTION", "CRYING_BABY", "DRIVING", "LIBRARY", "OFFICE", "THUNDERSTORM", "TRAIN"]), speechPace: z.enum(["SUPER_SLOW", "SLOW", "NORMAL", "FAST", "SUPER_FAST"]), speechClarity: z.enum(["CLEAR", "VAGUE", "RAMBLING"]), hasDisfluencies: z.boolean(), baseEmotion: z.enum(["NEUTRAL", "CHEERFUL", "CONFUSED", "FRUSTRATED", "SKEPTICAL", "RUSHED", "DISTRACTED", "ANGRY", "ANXIOUS", "SAD"]), intentClarity: z.enum(["CLEAR", "INDIRECT", "VAGUE"]), confirmationStyle: z.enum(["EXPLICIT", "VAGUE"]), memoryReliability: z.enum(["HIGH", "LOW"]), responseTiming: z.enum(["RELAXED", "NORMAL", "QUICK", "BARGE_IN"]), interruption: z.enum(["OFF", "BACKCHANNEL", "OCCASIONAL", "HEAVY"]), backstoryPrompt: z.string().nullable().optional(), idleMessages: z.array(z.string()).nullable(), idleTimeoutSeconds: z.number().int().gte(5).lte(60), idleMessageMaxSpokenCount: z.number().int().gte(1).lte(10), idleMessageResetCountOnUserSpeechEnabled: z.boolean(), properties: z.record(z.string(), z.unknown()), phoneNumber: z.string().optional(), createdAt: z.string(), updatedAt: z.string()}))});

export const voicemailFlowVariant = z.object({id: z.string(), title: z.string().min(1), systemKey: z.string().nullable().optional(), openingLine: z.string().nullable().optional(), precededByCustomerFlowId: z.string().nullable(), precededByCustomerFlowVariantId: z.string().nullable(), isGenerated: z.boolean(), includeFlowExpectations: z.boolean(), createdAt: z.string(), updatedAt: z.string(), personaOverride: z.object({id: z.string(), name: z.string(), displayName: z.string().nullable().optional(), description: z.string().nullable().optional(), language: z.enum(["EN", "ES", "DE", "HI", "FR", "NL", "AR", "EL", "IT", "ID", "TH", "JA", "TL", "MS", "ZH", "TR", "PT", "HE"]), secondaryLanguage: z.literal("EN").nullable().optional(), understoodLanguages: z.array(z.enum(["EN", "ES", "DE", "HI", "FR", "NL", "AR", "EL", "IT", "ID", "TH", "JA", "TL", "MS", "ZH", "TR", "PT", "HE"])), accent: z.enum(["US", "US_X_SOUTH", "GB", "ES", "DE", "IN", "FR", "NL", "SA", "GR", "AU", "IT", "ID", "TH", "JP", "NZ", "PH", "SG", "MY", "HK", "TR", "PT", "IL"]), age: z.enum(["CHILD", "TEENAGER", "ADULT", "ELDERLY"]), gender: z.enum(["MALE", "FEMALE"]), backgroundNoise: z.enum(["NONE", "AIRPORT", "CHILDREN_PLAYING", "CITY", "COFFEE_SHOP", "CONSTRUCTION", "CRYING_BABY", "DRIVING", "LIBRARY", "OFFICE", "THUNDERSTORM", "TRAIN"]), speechPace: z.enum(["SUPER_SLOW", "SLOW", "NORMAL", "FAST", "SUPER_FAST"]), speechClarity: z.enum(["CLEAR", "VAGUE", "RAMBLING"]), hasDisfluencies: z.boolean(), baseEmotion: z.enum(["NEUTRAL", "CHEERFUL", "CONFUSED", "FRUSTRATED", "SKEPTICAL", "RUSHED", "DISTRACTED", "ANGRY", "ANXIOUS", "SAD"]), intentClarity: z.enum(["CLEAR", "INDIRECT", "VAGUE"]), confirmationStyle: z.enum(["EXPLICIT", "VAGUE"]), memoryReliability: z.enum(["HIGH", "LOW"]), responseTiming: z.enum(["RELAXED", "NORMAL", "QUICK", "BARGE_IN"]), interruption: z.enum(["OFF", "BACKCHANNEL", "OCCASIONAL", "HEAVY"]), backstoryPrompt: z.string().nullable().optional(), idleMessages: z.array(z.string()).nullable(), idleTimeoutSeconds: z.number().int().gte(5).lte(60), idleMessageMaxSpokenCount: z.number().int().gte(1).lte(10), idleMessageResetCountOnUserSpeechEnabled: z.boolean(), properties: z.record(z.string(), z.unknown()), phoneNumber: z.string().optional(), createdAt: z.string(), updatedAt: z.string()}).nullable(), environment: environmentResponse.nullable(), additionalExpectations: z.array(flowExpectation), type: z.literal("VOICEMAIL")});

export const flowVariant = z.discriminatedUnion("type", [scriptedFlowVariant, improvFlowVariant, voicemailFlowVariant]);

export const createApiV1CustomerFlowFlowIdEdgeCaseEdgeCaseIdPromoteResponse = z.object({data: flowVariant});

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

/**
 * Promote an edge case to the happy path
 * 
 * POST /v1/customer-flow/{flowId}/edge-case/{edgeCaseId}/promote
 */
export const createApiV1CustomerFlowFlowIdEdgeCaseEdgeCaseIdPromote = async (args: CreateApiV1CustomerFlowFlowIdEdgeCaseEdgeCaseIdPromoteArgs, options?: CreateApiV1CustomerFlowFlowIdEdgeCaseEdgeCaseIdPromoteOptions) => {
const {baseUrl = "https://api.roark.ai", fetch: fetchFn = fetch, Bearer} = options ?? {}

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

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

const url = `${baseUrl.replace(/\/+$/, '')}/v1/customer-flow/${encodeURIComponent(String(args.flowId))}/edge-case/${encodeURIComponent(String(args.edgeCaseId))}/promote${query.size > 0 ? `?${query}` : ''}`

const res = await fetchFn(url, {method: "POST", headers})

if (!res.ok) throw new Error(`Request failed with status ${res.status}`, {cause: {status: res.status, body: await res.text()}})

return validateResponse(createApiV1CustomerFlowFlowIdEdgeCaseEdgeCaseIdPromoteResponse, await res.json())
};