import {z} from 'zod'

export type GetApiApiV4CampaignsArgs = {limit?: number | undefined, offset?: number | undefined, name?: string | undefined, strategy?: ('advanced' | 'simple' | 'predictive_ai' | Array<'advanced' | 'simple' | 'predictive_ai'>) | undefined, status?: ('draft' | 'active' | 'paused' | 'stopping' | 'completed' | 'processing' | 'stopped' | 'auto_paused' | 'pausing' | 'auto_pausing' | 'import_error' | 'deactivating' | Array<'draft' | 'active' | 'paused' | 'stopping' | 'completed' | 'processing' | 'stopped' | 'auto_paused' | 'pausing' | 'auto_pausing' | 'import_error' | 'deactivating'>) | undefined, method?: ('file_import' | 'bitrix_crm' | 'falcon_crm' | 'hubspot_crm' | 'panda_crm' | 'salesforce_crm' | 'zoho_crm' | 'zenoti_crm' | 'leverate_crm' | 'getlogic_crm' | Array<'file_import' | 'bitrix_crm' | 'falcon_crm' | 'hubspot_crm' | 'panda_crm' | 'salesforce_crm' | 'zoho_crm' | 'zenoti_crm' | 'leverate_crm' | 'getlogic_crm'>) | undefined, live?: boolean | undefined};

export type GetApiApiV4CampaignsOptions = {baseUrl: string, StaticKey?: string | undefined, fetch?: typeof fetch | undefined};

export const mediaVoiceMessage = z.object({type: z.literal("voice_message").optional(), name: z.string().optional()});

export const channelProfileShort = z.object({id: z.number().int().optional(), channel: z.enum(["chat", "facebook", "instagram", "telegram", "viber", "whatsapp"]).optional(), identifier: z.string().nullable().optional(), name: z.string().optional()});

export const whatsappTemplateShort = z.object({id: z.string().optional(), name: z.string().optional()});

export const followupActionWhatsapp = z.object({type: z.literal("whatsapp").optional(), channel_profile: channelProfileShort.optional(), whatsapp_template: whatsappTemplateShort.optional()});

export const followupRuleRedial = z.object({type: z.literal("redial").optional(), wait_time: z.number().int().optional(), wait_time_unit: z.enum(["seconds", "minutes", "hours"]).optional(), switch_caller_id_set: z.boolean().optional(), actions: z.array(followupActionWhatsapp).optional()});

export const wrapupCodeShort = z.object({id: z.number().int().optional(), name: z.string().optional(), code: z.string().optional()});

export const followupRuleWrapup = z.object({type: z.literal("redial").optional(), wrapup_code: wrapupCodeShort.optional(), wait_time: z.number().int().optional(), wait_time_unit: z.enum(["seconds", "minutes", "hours"]).optional(), switch_caller_id_set: z.boolean().optional()});

export const campaign = z.object({id: z.number().int().optional(), name: z.string().optional(), status: z.enum(["draft", "active", "paused", "stopping", "completed", "processing", "stopped", "auto_paused", "pausing", "auto_pausing", "import_error", "deactivating"]).optional(), strategy: z.enum(["simple", "predictive_ai"]).optional(), dial_level: z.number().optional(), dial_level_override: z.object({enabled: z.boolean().optional(), value: z.number().optional(), active_agents_threshold: z.number().int().optional()}).optional(), max_dial_time: z.number().int().optional(), max_wait_time: z.number().int().optional(), max_dial_attempts: z.number().int().optional(), voice_message: mediaVoiceMessage.nullable().optional(), amd_voicemail_message: z.object({enabled: z.boolean().optional(), voice_message: mediaVoiceMessage.nullable().optional()}).optional(), amd_enabled: z.boolean().optional(), amd_comfort_noise_enabled: z.boolean().nullable().optional(), live: z.object({enabled: z.boolean().optional(), dialing_order: z.enum(["fifo", "lifo"]).nullable().optional()}).optional(), calling_list: z.object({method: z.enum(["file_import", "bitrix_crm", "falcon_crm", "hubspot_crm", "panda_crm", "salesforce_crm", "zoho_crm", "zenoti_crm", "leverate_crm", "getlogic_crm"]).optional()}).nullable().optional(), caller_id_sets: z.array(z.object({phone_numbers: z.array(z.string()).optional()})).nullable().optional(), use_local_caller_id: z.boolean().optional(), asr_optimization_enabled: z.boolean().optional(), allow_duplicate_numbers: z.boolean().optional(), follow_up_mode: z.enum(["timer", "lowest_attempts"]).nullable().optional(), follow_up_rules: z.object({machine_answered: z.array(followupRuleRedial).optional(), abandoned: z.array(followupRuleRedial).optional(), no_answer: z.array(followupRuleRedial).optional(), rejected: z.array(followupRuleRedial).optional(), failed: z.array(followupRuleRedial).optional(), busy: z.array(followupRuleRedial).optional(), wrapup_code: z.array(followupRuleWrapup).optional()}).optional(), post_call_rating: z.object({enabled: z.boolean().optional(), notification_voice_message: mediaVoiceMessage.nullable().optional(), instructions_voice_message: mediaVoiceMessage.nullable().optional(), complete_voice_message: mediaVoiceMessage.nullable().optional()}).optional(), contact_local_time: z.object({start_time: z.string().optional(), end_time: z.string().optional(), days_of_week: z.array(z.union([z.literal(1), z.literal(2), z.literal(3), z.literal(4), z.literal(5), z.literal(6), z.literal(7)])).optional()}).nullable().optional(), created_at: z.string().optional(), updated_at: z.string().optional()});

export const metadata = z.object({total: z.number().int().optional(), next_cursor: z.string().nullable().optional()});

export const getApiApiV4CampaignsResponse = z.object({campaigns: z.array(campaign).optional(), metadata: metadata.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 list of campaigns
 * 
 * GET /api/v4/campaigns
 */
export const getApiApiV4Campaigns = async (args: GetApiApiV4CampaignsArgs, options: GetApiApiV4CampaignsOptions) => {
const {baseUrl, fetch: fetchFn = fetch, StaticKey} = options ?? {}

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

if (args.limit != null) query.append("limit", String(args.limit))
if (args.offset != null) query.append("offset", String(args.offset))
if (args.name != null) query.append("name", String(args.name))
if (args.strategy != null) query.append("strategy", String(args.strategy))
if (args.status != null) query.append("status", String(args.status))
if (args.method != null) query.append("method", String(args.method))
if (args.live != null) query.append("live", String(args.live))
if (StaticKey !== undefined) headers.set('authorization', `Bearer ${StaticKey}`)

const url = `${baseUrl.replace(/\/+$/, '')}/api/v4/campaigns${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(getApiApiV4CampaignsResponse, await res.json())
};