Netpulse_SasS/web/src/hooks/useAlerts.ts

import { useCallback, useEffect, useState } from 'react'
import { api } from '../api/client'
import { session } from '../api/session'
import { isAlertEvent, useLiveRefresh } from './useLiveRefresh'
import type { Alert, AlertCounts } from '../types'

const emptyCounts: AlertCounts = {
  firing: 0,
  acknowledged: 0,
  suppressed: 0,
  disaster: 0,
  high: 0,
}

export interface LiveAlerts {
  alerts: Alert[]
  counts: AlertCounts
  loading: boolean
  error: string | null
  reload: () => Promise<void>
  ack: (id: string) => Promise<void>
  close: (id: string) => Promise<void>
  mute: (deviceID: string, minutes: number) => Promise<void>
}

/**
 * Тримає список активних алертів.
 *
 * Подія по WebSocket не несе всього алерту — лише те, що щось
 * змінилося. Список перечитується цілком: він короткий (десятки рядків),
 * а склеювати його з дельт означало б розходитись зі станом сервера
 * рівно в момент аварії, коли подій найбільше.
 */
export function useAlerts(): LiveAlerts {
  const [alerts, setAlerts] = useState<Alert[]>([])
  const [counts, setCounts] = useState<AlertCounts>(emptyCounts)
  const [loading, setLoading] = useState(true)
  const [error, setError] = useState<string | null>(null)

  const canRead = session.can('alerts:read')

  const reload = useCallback(async () => {
    if (!canRead) {
      setLoading(false)
      return
    }
    try {
      const r = await api.listAlerts()
      setAlerts(r.alerts)
      setCounts(r.counts)
      setError(null)
    } catch (e) {
      setError(e instanceof Error ? e.message : String(e))
    } finally {
      setLoading(false)
    }
  }, [canRead])

  useEffect(() => {
    void reload()
  }, [reload])

  useLiveRefresh(isAlertEvent, () => {
    if (canRead) void reload()
  })

  const ack = useCallback(
    async (id: string) => {
      await api.ackAlert(id)
      await reload()
    },
    [reload],
  )

  const close = useCallback(
    async (id: string) => {
      await api.closeAlert(id)
      await reload()
    },
    [reload],
  )

  const mute = useCallback(
    async (deviceID: string, minutes: number) => {
      await api.muteDevice(deviceID, minutes)
      await reload()
    },
    [reload],
  )

  return { alerts, counts, loading, error, reload, ack, close, mute }
}