/**
 * История диалога per-agent per-day. Файлы в /data/voice-history/{agent}-{date}.json.
 * /data — это volume контейнера (на хосте /opt/digital-home/smart-home-tablet-data/).
 *
 * Fallback: если /data не существует (локальная разработка) — пишем в /tmp/voice-history.
 *
 * Формат обновлён под Groq/OpenAI: role может быть 'user' | 'assistant' | 'tool'.
 */
import { promises as fs } from 'node:fs'
import { existsSync } from 'node:fs'
import path from 'node:path'

const PRIMARY_DIR = process.env.VOICE_HISTORY_DIR || '/data/voice-history'
const DATA_DIR = (() => {
  const parent = path.dirname(PRIMARY_DIR)
  return existsSync(parent) ? PRIMARY_DIR : '/tmp/voice-history'
})()
const MAX_HISTORY = parseInt(process.env.VOICE_MAX_HISTORY || '40', 10)

export type HistoryMessage = {
  role: 'user' | 'assistant' | 'tool'
  content: any
  tool_calls?: any[]
  tool_call_id?: string
}

function todayIso(): string {
  return new Date().toISOString().slice(0, 10)
}

function historyPath(agent: string): string {
  return path.join(DATA_DIR, `${agent}-${todayIso()}.json`)
}

export async function loadHistory(agent: string): Promise<HistoryMessage[]> {
  try {
    const raw = await fs.readFile(historyPath(agent), 'utf-8')
    const parsed = JSON.parse(raw)
    return Array.isArray(parsed) ? parsed : []
  } catch (e: any) {
    if (e?.code === 'ENOENT') return []
    console.warn('[voice/history] read failed:', e?.message || e)
    return []
  }
}

export async function saveHistory(agent: string, history: HistoryMessage[]): Promise<void> {
  try {
    await fs.mkdir(DATA_DIR, { recursive: true })
    const trimmed = history.slice(-MAX_HISTORY)
    await fs.writeFile(historyPath(agent), JSON.stringify(trimmed, null, 2), 'utf-8')
  } catch (e: any) {
    console.warn('[voice/history] write failed:', e?.message || e)
  }
}

export async function resetHistory(agent: string): Promise<void> {
  try {
    await fs.unlink(historyPath(agent))
  } catch (e: any) {
    if (e?.code !== 'ENOENT') console.warn('[voice/history] reset failed:', e?.message || e)
  }
}

/**
 * Заглушка для обратной совместимости — убирает cache_control из блоков.
 * В Groq-режиме cache_control не используется, функция — no-op.
 */
export function stripCacheControl(content: any): any {
  if (Array.isArray(content)) {
    return content.map((b) => {
      if (b && typeof b === 'object' && 'cache_control' in b) {
        const { cache_control: _ignore, ...rest } = b
        return rest
      }
      return b
    })
  }
  return content
}

/**
 * Заглушка для обратной совместимости.
 * В Groq-режиме prompt-кеширование не используется — просто возвращаем историю как есть.
 */
export function buildMessagesWithCache(history: HistoryMessage[], _cacheTailUncached = 2): HistoryMessage[] {
  return history.map((m) => ({ role: m.role, content: m.content }))
}