/**
 * Registry access: fetch the curated list from awesome-dsh-plugin.com with an
 * in-memory cache, falling back to the bundled snapshot when offline.
 */

import { readFileSync } from 'node:fs'
import { fileURLToPath } from 'node:url'

export interface RegistryPlugin {
  name: string
  owner: string
  url: string
  category: string
  description: Record<string, string>
  install: string
  added: string
}

export interface Registry {
  updated: string
  count: number
  categories: Record<string, Record<string, string>>
  plugins: RegistryPlugin[]
}

const REGISTRY_URL = 'https://awesome-dsh-plugin.com/plugins.json'
const TTL_MS = 60 * 60 * 1000

let cache: { at: number; data: Registry } | null = null

function snapshot(): Registry {
  const path = fileURLToPath(new URL('../data/registry-snapshot.json', import.meta.url))
  return JSON.parse(readFileSync(path, 'utf8')) as Registry
}

export async function loadRegistry(): Promise<{ registry: Registry; source: 'live' | 'cache' | 'snapshot' }> {
  if (cache && Date.now() - cache.at < TTL_MS) {
    return { registry: cache.data, source: 'cache' }
  }
  try {
    const res = await fetch(REGISTRY_URL, { signal: AbortSignal.timeout(4000) })
    if (!res.ok) throw new Error(`HTTP ${res.status}`)
    const data = (await res.json()) as Registry
    if (!Array.isArray(data.plugins) || data.plugins.length === 0) throw new Error('empty registry')
    cache = { at: Date.now(), data }
    return { registry: data, source: 'live' }
  } catch {
    return { registry: cache?.data ?? snapshot(), source: cache ? 'cache' : 'snapshot' }
  }
}