import {z} from 'zod'

export type SessionTerminationReason = 'voicemail_detected' | 'silence_timeout' | 'max_call_duration' | 'participant_left' | 'pipeline_exit' | 'user_requested' | 'agent_initiated' | 'config_rebound' | 'resolved' | 'unresolved' | 'abandoned' | 'escalated' | 'handoff_resolved' | 'transferred' | 'error' | 'unknown' | 'callee_busy' | 'callee_no_answer' | 'callee_unavailable' | 'callee_declined' | 'callee_not_found' | 'sip_failed' | 'unknown_reason' | 'client_initiated' | 'duplicate_identity' | 'server_shutdown' | 'participant_removed' | 'room_deleted' | 'state_mismatch' | 'join_failure' | 'migration' | 'signal_close' | 'room_closed' | 'user_unavailable' | 'user_rejected' | 'sip_trunk_failure' | 'connection_timeout' | 'media_failure' | 'agent_error' | 'dispatch_failed' | 'dispatch_interrupted' | 'dispatch_unacknowledged' | 'dispatch_quarantined' | 'token_mint_failed' | 'sip_dial_failed' | 'dial_unknown_teardown_confirmed' | 'call_ended' | 'ambiguous_no_room_aged' | 'delivery_max_tries_exceeded' | 'missing_lease' | 'missing_conversation' | 'malformed_dispatch_metadata' | 'participant_join_timeout' | 'setup_error' | 'stt_provider_error' | 'tts_provider_error' | 'stale_routing' | 'superseded' | 'duplicate_dispatch' | 'orphaned' | 'agent_absent_orphan' | 'wedged_pipeline_timeout' | 'capacity_rejected' | 'requeued' | 'org_concurrency_limit' | 'global_pipeline_limit' | 'stt_limit' | 'tts_limit' | 'carrier_cps_deferred' | 'call_window_deferred' | 'queue_ttl_expired' | 'outbound_cancelled' | 'inline_dispatch_abandoned' | 'reservation_expired' | 'dial_requeue_exhausted';

export type SessionClose = {reason?: (SessionTerminationReason | string | null) | undefined};

export type CreateApiV1ConversationsConversationIdCloseArgs = {conversation_id: string, body: SessionClose | null};

export type CreateApiV1ConversationsConversationIdCloseOptions = {baseUrl: string, APIKeyHeader?: string | undefined, fetch?: typeof fetch | undefined};

export const sessionEvalSummary = z.object({total: z.number().int().optional(), succeeded: z.number().int().optional(), failed: z.number().int().optional(), pending: z.number().int().optional(), critical_total: z.number().int().optional(), critical_succeeded: z.number().int().optional(), critical_failed: z.number().int().optional(), critical_pending: z.number().int().optional(), eval_status: z.enum(["success", "partial", "failure", "pending", "none"]).optional()});

export const testSessionFeatures = z.object({version: z.literal(1).optional(), identity_resolution: z.boolean(), memory: z.boolean(), summarization: z.boolean(), extraction: z.boolean(), evaluations: z.boolean(), knowledge_gap_analysis: z.boolean()});

export const srcConversationSchemasSessionResponse = z.object({id: z.string(), organization_id: z.string(), end_user_id: z.string(), channel: z.string(), surface: z.string(), external_session_id: z.string().nullable().optional(), status: z.enum(["queued", "ringing", "active", "paused", "waiting_for_human", "transferred", "awaiting_approval", "pending_dispatch", "closed", "expired", "error", "superseded"]), session_type: z.enum(["live", "test", "simulation"]).optional(), priority: z.enum(["low", "normal", "high", "urgent"]), subject: z.string().nullable().optional(), assigned_agent_id: z.string().nullable().optional(), retention_policy_id: z.string().nullable().optional(), summary: z.string().nullable().optional(), metadata: z.record(z.string(), z.unknown()).optional(), context_variables: z.record(z.string(), z.unknown()).optional(), message_count: z.number().int(), first_message_at: z.string().nullable().optional(), last_message_at: z.string().nullable().optional(), started_at: z.string(), ended_at: z.string().nullable().optional(), closed_at: z.string().nullable().optional(), ttl_expires_at: z.string().nullable().optional(), retention_expires_at: z.string().nullable().optional(), archived_at: z.string().nullable().optional(), memory_sync_state: z.enum(["pending", "synced", "skipped", "suppressed"]).optional(), created_at: z.string(), updated_at: z.string(), duration_ms: z.number().int().nullable().optional(), summary_preview: z.string().nullable().optional(), has_recording: z.boolean().optional(), eval_summary: sessionEvalSummary.optional(), test_features: testSessionFeatures.nullable().optional(), revision_id: z.string().nullable().optional(), revision_name: z.string().nullable().optional(), revision_version: z.number().int().nullable().optional(), team_revision_id: z.string().nullable().optional(), team_revision_name: z.string().nullable().optional(), from_number: z.string().nullable().optional(), to_number: z.string().nullable().optional(), email: 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
};

/**
 * Close a v2 conversation
 * 
 * POST /v1/conversations/{conversation_id}/close
 */
export const createApiV1ConversationsConversationIdClose = async (args: CreateApiV1ConversationsConversationIdCloseArgs, options: CreateApiV1ConversationsConversationIdCloseOptions) => {
const {baseUrl, fetch: fetchFn = fetch, APIKeyHeader} = options ?? {}

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

if (APIKeyHeader !== undefined) headers.set("x-api-key", APIKeyHeader)

const url = `${baseUrl.replace(/\/+$/, '')}/v1/conversations/${encodeURIComponent(String(args.conversation_id))}/close${query.size > 0 ? `?${query}` : ''}`

const res = await fetchFn(url, {method: "POST", headers, body: JSON.stringify(args.body)})

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

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