'use client' import { useState, useEffect, useCallback } from 'react' import { useLocale } from 'next-intl' import { useWsSubscribe } from '@/lib/wsContext' const API_BASE = '/api/proxy/api' interface SignalAlert { type: 'funding_signal' symbol: string time: string close: number tbr: number vol_mult: number bb_pct: number bb_upper: number btc_trend: string enabled: boolean } function symbolLabel(s: string) { return s.replace('USDT', '') } function timeAgo(iso: string) { const diff = (Date.now() - new Date(iso).getTime()) / 1000 if (diff < 60) return `${Math.round(diff)}s ago` if (diff < 3600) return `${Math.round(diff / 60)}m ago` return `${Math.round(diff / 3600)}h ago` } // ── iOS-style toggle switch ─────────────────────────────────────────────────── function ToggleSwitch({ on, loading, onToggle }: { on: boolean loading: boolean onToggle: () => void }) { return ( ) } // ── Main component ──────────────────────────────────────────────────────────── export default function SignalMonitor() { const locale = useLocale() const isZh = false // i18n shelved — Chinese branches kept as dead code for future revival; see messages/zh.json const [enabled, setEnabledState] = useState(false) const [loading, setLoading] = useState(false) const [backendOk, setBackendOk] = useState(null) const [signals, setSignals] = useState([]) const [btcTrend, setBtcTrend] = useState(null) const [lastScan, setLastScan] = useState(null) // ── Load initial state ─────────────────────────────────────────────────── useEffect(() => { fetch(`${API_BASE}/signal/status`) .then(r => { if (!r.ok) throw new Error(); return r.json() }) .then(d => { setEnabledState(d.enabled); setBackendOk(true) }) .catch(() => setBackendOk(false)) fetch(`${API_BASE}/signal/history?limit=20`) .then(r => r.json()) .then((list: SignalAlert[]) => { if (!Array.isArray(list)) return setSignals(list) if (list.length > 0) { setBtcTrend(list[0].btc_trend) setLastScan(new Date(list[0].time)) } }) .catch(() => {}) }, []) // ── WebSocket listener (shared singleton connection via WsProvider) ───────── useWsSubscribe('funding_signal', (msg) => { const alert = msg as SignalAlert setBtcTrend(alert.btc_trend) setLastScan(new Date(alert.time)) setSignals(prev => [alert, ...prev].slice(0, 50)) }) // ── Toggle ─────────────────────────────────────────────────────────────── const toggle = useCallback(async () => { setLoading(true) try { const next = !enabled const r = await fetch(`${API_BASE}/signal/toggle?enabled=${next}`, { method: 'POST' }) if (!r.ok) throw new Error() const d = await r.json() setEnabledState(d.enabled) setBackendOk(true) } catch { setBackendOk(false) } setLoading(false) }, [enabled]) // ── Render ─────────────────────────────────────────────────────────────── const btcUp = btcTrend?.includes('↑') return (
{/* Header */}
{isZh ? '突破监控' : 'Breakout Monitor'}
{isZh ? 'ETH · LINK · 5 分钟扫描' : 'ETH · LINK · 5m scan'}
{/* Backend offline warning */} {backendOk === false && (
⚠️ {isZh ? '后端离线,开关暂时不可用' : "Backend offline — toggle won't work"}
)} {/* Status row: BTC trend + last scan */}
BTC   {btcTrend ? ( {btcTrend} ) : ( )} {lastScan ? (isZh ? `最近信号 ${timeAgo(lastScan.toISOString())}` : `Last signal ${timeAgo(lastScan.toISOString())}`) : enabled ? (isZh ? '扫描中…' : 'Scanning…') : (isZh ? '已暂停' : 'Paused') }
{/* Signal list */} {signals.length === 0 ? (
{enabled ? (isZh ? '· 正在等待信号…' : '· Watching for signals…') : (isZh ? '· 打开开关后开始监控' : '· Enable the toggle to start watching')}
) : (
{signals.map((s) => (
{/* Top row */}
{symbolLabel(s.symbol)} {!s.enabled && ( silent )}
{timeAgo(s.time)}
{/* Metrics grid */}
{[ { label: isZh ? '价格' : 'Price', value: `$${s.close.toLocaleString(undefined, { maximumFractionDigits: 2 })}`, color: 'var(--ink)' }, { label: isZh ? '主动买入' : 'Taker Buy', value: `${(s.tbr * 100).toFixed(1)}%`, color: '#22c55e' }, { label: isZh ? '成交量倍数' : 'Vol ×', value: `${s.vol_mult}×`, color: '#22c55e' }, ].map(m => (
{m.label}
{m.value}
))}
{/* Footer */}
{isZh ? `BB squeeze 处于第 ${s.bb_pct} 分位` : `BB squeeze ${s.bb_pct}th pct`}  ·  {s.btc_trend}
))}
)}
) }