Compare commits
20 Commits
2da4093a52
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
2e6b86381b | ||
|
|
e339ff819b | ||
|
|
6908d1511a | ||
|
|
43fa29c08c | ||
|
|
4519d4042d | ||
|
|
670695066d | ||
|
|
df8c9316f1 | ||
|
|
03652577cb | ||
|
|
ec829929f0 | ||
|
|
de656099c7 | ||
|
|
43c66eccba | ||
|
|
4f489e6183 | ||
|
|
e38de421de | ||
|
|
a8c604f215 | ||
|
|
b6ed6f8bba | ||
|
|
ed4f84ef23 | ||
|
|
cae788ea19 | ||
|
|
2f7b5b4a83 | ||
|
|
14178df3cc | ||
|
|
c42cef0cdf |
115
README.md
115
README.md
@@ -1,45 +1,100 @@
|
|||||||
# OpenClaw Monitor
|
# 🐾 OC Monitor — OpenClaw Mission Control
|
||||||
|
|
||||||
Multi-node monitoring dashboard for OpenClaw instances.
|
Real-time monitoring dashboard for [OpenClaw](https://github.com/openclaw/openclaw) multi-node deployments.
|
||||||
|
|
||||||
## Architecture
|
 
|
||||||
|
|
||||||
- **Server**: Node.js + SQLite + WebSocket (central dashboard)
|
## ✨ Features
|
||||||
- **Agent**: Bash script on each OpenClaw machine, reports heartbeat + metrics
|
|
||||||
|
|
||||||
## Quick Start
|
- **Real-time metrics** — CPU / Memory / Disk / Swap with live jitter animation (10s refresh)
|
||||||
|
- **Provider health checks** — Auto-detect all configured AI providers, latency monitoring
|
||||||
|
- **Default model detection** — Auto-identifies most-used provider per node (green dot indicator)
|
||||||
|
- **Request logging** — Track API calls across all nodes with filtering by node / provider / result
|
||||||
|
- **Multi-node support** — Lightweight bash+python agent, works on macOS & Linux
|
||||||
|
- **Dark / Light theme** — Toggle with localStorage persistence
|
||||||
|
- **WebSocket push** — Instant updates, no polling
|
||||||
|
- **Admin panel** — Node management, token display, one-click agent install command generator
|
||||||
|
- **Docker deployment** — Single container, SQLite storage
|
||||||
|
|
||||||
|
## 🚀 Quick Start
|
||||||
|
|
||||||
|
### 1. Deploy Server (Docker)
|
||||||
|
|
||||||
### Server (Docker)
|
|
||||||
```bash
|
```bash
|
||||||
docker run -d --name oc-monitor -p 3800:3800 -v oc-monitor-data:/app/data ghcr.io/mango082888-bit/oc-monitor
|
curl -fsSL https://cdn.jsdelivr.net/gh/xmg0828888/oc-monitor/install.sh | bash
|
||||||
# Get auth token
|
|
||||||
docker logs oc-monitor 2>&1 | grep "Auth token"
|
|
||||||
```
|
```
|
||||||
|
|
||||||
### Agent
|
This will:
|
||||||
|
- Pull the repo and build the Docker image
|
||||||
|
- Generate a random auth token
|
||||||
|
- Start the container on port **3800**
|
||||||
|
- Print the dashboard URL and token
|
||||||
|
|
||||||
|
### 2. Install Agent on Each Node
|
||||||
|
|
||||||
|
After server is running, install the agent on each OpenClaw node:
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
curl -sL https://raw.githubusercontent.com/mango082888-bit/oc-monitor/main/agent/agent.sh -o agent.sh
|
curl -fsSL https://cdn.jsdelivr.net/gh/xmg0828888/oc-monitor/install-agent.sh | bash -s -- \
|
||||||
chmod +x agent.sh
|
-s http://YOUR_SERVER_IP:3800 \
|
||||||
./agent.sh -s http://YOUR_SERVER:3800 -t YOUR_TOKEN -n "My Node" -r master
|
-t YOUR_AUTH_TOKEN \
|
||||||
|
-n "Node Name"
|
||||||
```
|
```
|
||||||
|
|
||||||
## Features
|
The agent auto-detects:
|
||||||
|
- OpenClaw config, providers, and models
|
||||||
|
- System metrics (CPU, memory, disk, swap)
|
||||||
|
- Gateway & daemon status
|
||||||
|
- Session count and token usage
|
||||||
|
- Default/most-used provider
|
||||||
|
|
||||||
- Real-time node status (CPU/mem/disk/swap)
|
### 3. Open Dashboard
|
||||||
- Provider health matrix across all nodes
|
|
||||||
- API request logging with TTFT/latency tracking
|
|
||||||
- Auto-detect OpenClaw config changes
|
|
||||||
- WebSocket live updates
|
|
||||||
- Dark theme UI
|
|
||||||
|
|
||||||
## API
|
Visit `http://YOUR_SERVER_IP:3800` in your browser.
|
||||||
|
|
||||||
| Endpoint | Method | Auth | Description |
|
## 📐 Architecture
|
||||||
|---|---|---|---|
|
|
||||||
| `/api/dashboard` | GET | No | Full dashboard data |
|
|
||||||
| `/api/heartbeat` | POST | Yes | Agent heartbeat report |
|
|
||||||
| `/api/request` | POST | Yes | Log API request |
|
|
||||||
| `/api/node/rename` | POST | Yes | Rename a node |
|
|
||||||
| `/api/node/:id` | DELETE | Yes | Remove a node |
|
|
||||||
|
|
||||||
Auth: `Authorization: Bearer <token>`
|
```
|
||||||
|
┌─────────────┐ ┌─────────────┐ ┌─────────────┐
|
||||||
|
│ Node Agent │ │ Node Agent │ │ Node Agent │
|
||||||
|
│ (bash+py) │ │ (bash+py) │ │ (bash+py) │
|
||||||
|
└──────┬───────┘ └──────┬───────┘ └──────┬───────┘
|
||||||
|
│ HTTP POST │ │
|
||||||
|
└────────────────────┼─────────────────────┘
|
||||||
|
▼
|
||||||
|
┌─────────────────┐
|
||||||
|
│ OC Monitor │
|
||||||
|
│ Server │
|
||||||
|
│ (Node.js+SQLite│
|
||||||
|
│ +WebSocket) │
|
||||||
|
└────────┬────────┘
|
||||||
|
│ WS push
|
||||||
|
▼
|
||||||
|
┌─────────────────┐
|
||||||
|
│ Browser │
|
||||||
|
│ Dashboard │
|
||||||
|
└─────────────────┘
|
||||||
|
```
|
||||||
|
|
||||||
|
## 🔧 Configuration
|
||||||
|
|
||||||
|
| Env Variable | Default | Description |
|
||||||
|
|---|---|---|
|
||||||
|
| `PORT` | `3800` | Server listen port |
|
||||||
|
| `AUTH_TOKEN` | (required) | Bearer token for API auth |
|
||||||
|
|
||||||
|
## 📋 API Endpoints
|
||||||
|
|
||||||
|
| Method | Path | Description |
|
||||||
|
|---|---|---|
|
||||||
|
| GET | `/api/dashboard` | Full dashboard data |
|
||||||
|
| POST | `/api/heartbeat` | Agent heartbeat report |
|
||||||
|
| POST | `/api/request` | API request log (single or batch) |
|
||||||
|
| POST | `/api/rename` | Rename a node |
|
||||||
|
| DELETE | `/api/node/:id` | Remove a node |
|
||||||
|
|
||||||
|
All POST/DELETE endpoints require `Authorization: Bearer <token>` header.
|
||||||
|
|
||||||
|
## License
|
||||||
|
|
||||||
|
MIT
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
#!/bin/bash
|
#!/bin/bash
|
||||||
# OpenClaw Monitor Agent
|
# OpenClaw Monitor Agent
|
||||||
set -e
|
set -e
|
||||||
SERVER="" TOKEN="" NAME="" ROLE="worker" INTERVAL=30 DEFAULT_PROV=""
|
SERVER="" TOKEN="" NAME="" ROLE="worker" INTERVAL=10 DEFAULT_PROV=""
|
||||||
|
|
||||||
while getopts "s:t:n:r:i:d:" opt; do
|
while getopts "s:t:n:r:i:d:" opt; do
|
||||||
case $opt in s)SERVER="$OPTARG";;t)TOKEN="$OPTARG";;n)NAME="$OPTARG";;r)ROLE="$OPTARG";;i)INTERVAL="$OPTARG";;d)DEFAULT_PROV="$OPTARG";;esac
|
case $opt in s)SERVER="$OPTARG";;t)TOKEN="$OPTARG";;n)NAME="$OPTARG";;r)ROLE="$OPTARG";;i)INTERVAL="$OPTARG";;d)DEFAULT_PROV="$OPTARG";;esac
|
||||||
@@ -18,7 +18,10 @@ OC_VERSION=$(openclaw --version 2>/dev/null | head -1 || echo "unknown")
|
|||||||
|
|
||||||
echo "OC Monitor Agent: node=$NODE_ID name=$NAME server=$SERVER"
|
echo "OC Monitor Agent: node=$NODE_ID name=$NAME server=$SERVER"
|
||||||
|
|
||||||
|
TICK=0
|
||||||
while true; do
|
while true; do
|
||||||
|
if [ $((TICK % 6)) -eq 0 ]; then
|
||||||
|
# Full run: collect everything
|
||||||
python3 - "$OC_CONFIG" "$NODE_ID" "$NAME" "$OC_VERSION" "$ROLE" "$DEFAULT_PROV" << 'PYEOF' > /tmp/.oc-agent-payload.json
|
python3 - "$OC_CONFIG" "$NODE_ID" "$NAME" "$OC_VERSION" "$ROLE" "$DEFAULT_PROV" << 'PYEOF' > /tmp/.oc-agent-payload.json
|
||||||
import json,subprocess,os,platform,time,sys,glob
|
import json,subprocess,os,platform,time,sys,glob
|
||||||
|
|
||||||
@@ -28,6 +31,7 @@ def run(cmd):
|
|||||||
|
|
||||||
cfg,nid,name,ver,role = sys.argv[1],sys.argv[2],sys.argv[3],sys.argv[4],sys.argv[5]
|
cfg,nid,name,ver,role = sys.argv[1],sys.argv[2],sys.argv[3],sys.argv[4],sys.argv[5]
|
||||||
default_prov = sys.argv[6] if len(sys.argv)>6 else ''
|
default_prov = sys.argv[6] if len(sys.argv)>6 else ''
|
||||||
|
full_run = sys.argv[7]=='1' if len(sys.argv)>7 else True
|
||||||
mac = sys.platform=='darwin'
|
mac = sys.platform=='darwin'
|
||||||
|
|
||||||
# Host IP - try multiple interfaces on macOS
|
# Host IP - try multiple interfaces on macOS
|
||||||
@@ -61,11 +65,14 @@ if cfg and os.path.exists(cfg):
|
|||||||
if prov_count: dp = prov_count.most_common(1)[0][0]
|
if prov_count: dp = prov_count.most_common(1)[0][0]
|
||||||
default_name = dp.split('/')[0] if '/' in dp else dp
|
default_name = dp.split('/')[0] if '/' in dp else dp
|
||||||
for n,p in m.get('providers',{}).items():
|
for n,p in m.get('providers',{}).items():
|
||||||
|
if isinstance(p,str): p = {'models':[p]}
|
||||||
if not isinstance(p,dict): continue
|
if not isinstance(p,dict): continue
|
||||||
base = p.get('baseUrl','')
|
base = p.get('baseUrl','')
|
||||||
key = p.get('apiKey','')
|
key = p.get('apiKey','')
|
||||||
api_type = p.get('api','')
|
api_type = p.get('api','')
|
||||||
models = [mod.get('id','') for mod in p.get('models',[])]
|
raw_models = p.get('models', p.get('model', []))
|
||||||
|
if isinstance(raw_models, str): raw_models = [raw_models]
|
||||||
|
models = [mod.get('id','') if isinstance(mod,dict) else str(mod) for mod in raw_models]
|
||||||
providers.append({'name':n,'model':' | '.join(models),'_test_model':models[0] if models else '',
|
providers.append({'name':n,'model':' | '.join(models),'_test_model':models[0] if models else '',
|
||||||
'api':api_type,'default':n==default_name,'_base':base,'_key':key})
|
'api':api_type,'default':n==default_name,'_base':base,'_key':key})
|
||||||
providers.sort(key=lambda x: (not x.get('default',False), x['name']))
|
providers.sort(key=lambda x: (not x.get('default',False), x['name']))
|
||||||
@@ -215,6 +222,44 @@ print(json.dumps({
|
|||||||
'tok_today':tok_today,'tok_week':tok_week,'tok_month':tok_month
|
'tok_today':tok_today,'tok_week':tok_week,'tok_month':tok_month
|
||||||
}))
|
}))
|
||||||
PYEOF
|
PYEOF
|
||||||
|
else
|
||||||
|
# Light run: only update metrics in cached payload
|
||||||
|
python3 -c "
|
||||||
|
import json,subprocess,os,platform
|
||||||
|
def run(cmd):
|
||||||
|
try: return subprocess.check_output(cmd,shell=True,stderr=subprocess.DEVNULL).decode().strip()
|
||||||
|
except: return ''
|
||||||
|
mac=platform.system()=='Darwin'
|
||||||
|
if mac:
|
||||||
|
raw=run('ps -A -o %cpu | tail -n +2')
|
||||||
|
try: cpu=round(sum(float(x) for x in raw.split() if x)/os.cpu_count(),1)
|
||||||
|
except: cpu=0
|
||||||
|
else:
|
||||||
|
cpu=float(run(\"top -bn1 | grep 'Cpu' | awk '{print 100-\$8}'\") or 0)
|
||||||
|
ds=run('df -h / | tail -1').split()
|
||||||
|
disk=int(ds[4].replace('%','')) if len(ds)>4 else 0
|
||||||
|
if mac:
|
||||||
|
try:
|
||||||
|
vm=run('vm_stat');d={}
|
||||||
|
for l in vm.split(chr(10))[1:]:
|
||||||
|
if ':' in l: k,v=l.split(':',1);d[k.strip()]=int(v.strip().rstrip('.'))
|
||||||
|
ps=16384;used=(d.get('Pages active',0)+d.get('Pages wired down',0))*ps;total=int(run('sysctl -n hw.memsize'))
|
||||||
|
mem=round(used/total*100,1)
|
||||||
|
except: mem=0
|
||||||
|
si=run('sysctl vm.swapusage');swap=0
|
||||||
|
if si:
|
||||||
|
import re;u=re.search(r'used\s*=\s*([\d.]+)M',si);t=re.search(r'total\s*=\s*([\d.]+)M',si)
|
||||||
|
if u and t and float(t.group(1))>0: swap=round(float(u.group(1))/float(t.group(1))*100,1)
|
||||||
|
else:
|
||||||
|
mi=run('free -b | grep Mem').split();mem=round(int(mi[2])/int(mi[1])*100,1) if len(mi)>2 else 0
|
||||||
|
si=run('free -b | grep Swap').split();swap=round(int(si[2])/int(si[1])*100,1) if len(si)>2 and int(si[1])>0 else 0
|
||||||
|
try:
|
||||||
|
p=json.load(open('/tmp/.oc-agent-payload.json'))
|
||||||
|
p['cpu']=cpu;p['mem']=mem;p['disk']=disk;p['swap']=swap
|
||||||
|
json.dump(p,open('/tmp/.oc-agent-payload.json','w'))
|
||||||
|
except: pass
|
||||||
|
" 2>/dev/null
|
||||||
|
fi
|
||||||
|
|
||||||
if [ -s /tmp/.oc-agent-payload.json ]; then
|
if [ -s /tmp/.oc-agent-payload.json ]; then
|
||||||
curl -sS -X POST "$SERVER/api/heartbeat" \
|
curl -sS -X POST "$SERVER/api/heartbeat" \
|
||||||
@@ -225,7 +270,8 @@ PYEOF
|
|||||||
|| echo "[$(date +%H:%M:%S)] heartbeat failed"
|
|| echo "[$(date +%H:%M:%S)] heartbeat failed"
|
||||||
fi
|
fi
|
||||||
|
|
||||||
# Report new API requests from session jsonl files
|
# Report new API requests only on full runs
|
||||||
|
if [ $((TICK % 6)) -eq 0 ]; then
|
||||||
python3 - "$OC_CONFIG" "$NODE_ID" "$SERVER" "$TOKEN" << 'REQEOF' 2>/dev/null
|
python3 - "$OC_CONFIG" "$NODE_ID" "$SERVER" "$TOKEN" << 'REQEOF' 2>/dev/null
|
||||||
import json,os,sys,glob,time,urllib.request,urllib.error
|
import json,os,sys,glob,time,urllib.request,urllib.error
|
||||||
cfg,nid,server,token = sys.argv[1],sys.argv[2],sys.argv[3],sys.argv[4]
|
cfg,nid,server,token = sys.argv[1],sys.argv[2],sys.argv[3],sys.argv[4]
|
||||||
@@ -280,6 +326,8 @@ if reqs:
|
|||||||
json.dump(state,open(state_f,'w'))
|
json.dump(state,open(state_f,'w'))
|
||||||
if reqs: print(f'[{time.strftime("%H:%M:%S")}] reported {len(reqs)} requests')
|
if reqs: print(f'[{time.strftime("%H:%M:%S")}] reported {len(reqs)} requests')
|
||||||
REQEOF
|
REQEOF
|
||||||
|
fi
|
||||||
|
|
||||||
|
TICK=$((TICK + 1))
|
||||||
sleep "$INTERVAL"
|
sleep "$INTERVAL"
|
||||||
done
|
done
|
||||||
|
|||||||
80
install-agent.sh
Executable file
80
install-agent.sh
Executable file
@@ -0,0 +1,80 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
# OC Monitor - One-click agent install
|
||||||
|
set -e
|
||||||
|
|
||||||
|
SERVER="" TOKEN="" NAME="" ROLE="worker"
|
||||||
|
while getopts "s:t:n:r:" opt; do
|
||||||
|
case $opt in s)SERVER="$OPTARG";;t)TOKEN="$OPTARG";;n)NAME="$OPTARG";;r)ROLE="$OPTARG";;esac
|
||||||
|
done
|
||||||
|
|
||||||
|
if [ -z "$SERVER" ] || [ -z "$TOKEN" ]; then
|
||||||
|
echo "Usage: $0 -s SERVER_URL -t AUTH_TOKEN [-n NAME] [-r ROLE]"
|
||||||
|
echo " -s Server URL (e.g. http://1.2.3.4:3800)"
|
||||||
|
echo " -t Auth token"
|
||||||
|
echo " -n Node name (default: hostname)"
|
||||||
|
echo " -r Role: master|worker (default: worker)"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
[ -z "$NAME" ] && NAME=$(hostname)
|
||||||
|
AGENT="/usr/local/bin/oc-monitor-agent.sh"
|
||||||
|
|
||||||
|
echo "🐾 OC Monitor Agent Installer"
|
||||||
|
echo "=============================="
|
||||||
|
|
||||||
|
# Check deps
|
||||||
|
for cmd in python3 curl; do
|
||||||
|
command -v $cmd &>/dev/null || { echo "❌ $cmd not found"; exit 1; }
|
||||||
|
done
|
||||||
|
|
||||||
|
# Download agent
|
||||||
|
echo "📦 Downloading agent..."
|
||||||
|
curl -fsSL https://cdn.jsdelivr.net/gh/xmg0828888/oc-monitor/agent/agent.sh -o "$AGENT"
|
||||||
|
chmod +x "$AGENT"
|
||||||
|
|
||||||
|
# Detect init system
|
||||||
|
if [ "$(uname)" = "Darwin" ]; then
|
||||||
|
PLIST="$HOME/Library/LaunchAgents/com.oc-monitor.agent.plist"
|
||||||
|
echo "🍎 Setting up launchd service..."
|
||||||
|
cat > "$PLIST" <<EOF
|
||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
|
||||||
|
<plist version="1.0"><dict>
|
||||||
|
<key>Label</key><string>com.oc-monitor.agent</string>
|
||||||
|
<key>ProgramArguments</key><array>
|
||||||
|
<string>/bin/bash</string><string>$AGENT</string>
|
||||||
|
<string>-s</string><string>$SERVER</string>
|
||||||
|
<string>-t</string><string>$TOKEN</string>
|
||||||
|
<string>-n</string><string>$NAME</string>
|
||||||
|
<string>-r</string><string>$ROLE</string>
|
||||||
|
</array>
|
||||||
|
<key>RunAtLoad</key><true/>
|
||||||
|
<key>KeepAlive</key><true/>
|
||||||
|
<key>StandardOutPath</key><string>/tmp/oc-monitor-agent.log</string>
|
||||||
|
<key>StandardErrorPath</key><string>/tmp/oc-monitor-agent.log</string>
|
||||||
|
</dict></plist>
|
||||||
|
EOF
|
||||||
|
launchctl unload "$PLIST" 2>/dev/null || true
|
||||||
|
launchctl load "$PLIST"
|
||||||
|
echo "✅ Agent running (launchd)"
|
||||||
|
else
|
||||||
|
echo "🐧 Setting up systemd service..."
|
||||||
|
cat > /etc/systemd/system/oc-monitor-agent.service <<EOF
|
||||||
|
[Unit]
|
||||||
|
Description=OC Monitor Agent
|
||||||
|
After=network.target
|
||||||
|
[Service]
|
||||||
|
ExecStart=/bin/bash $AGENT -s $SERVER -t $TOKEN -n $NAME -r $ROLE
|
||||||
|
Restart=always
|
||||||
|
RestartSec=5
|
||||||
|
[Install]
|
||||||
|
WantedBy=multi-user.target
|
||||||
|
EOF
|
||||||
|
systemctl daemon-reload
|
||||||
|
systemctl enable --now oc-monitor-agent
|
||||||
|
echo "✅ Agent running (systemd)"
|
||||||
|
fi
|
||||||
|
|
||||||
|
echo ""
|
||||||
|
echo "📡 Node '$NAME' reporting to $SERVER"
|
||||||
|
echo "📋 Logs: journalctl -u oc-monitor-agent -f"
|
||||||
49
install.sh
Executable file
49
install.sh
Executable file
@@ -0,0 +1,49 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
# OC Monitor - One-click server install
|
||||||
|
set -e
|
||||||
|
|
||||||
|
PORT=${PORT:-3800}
|
||||||
|
TOKEN=${TOKEN:-$(head -c 16 /dev/urandom | xxd -p | tr '[:lower:]' '[:upper:]')}
|
||||||
|
DIR="/opt/oc-monitor"
|
||||||
|
|
||||||
|
echo "🐾 OC Monitor Installer"
|
||||||
|
echo "========================"
|
||||||
|
|
||||||
|
# Check docker
|
||||||
|
if ! command -v docker &>/dev/null; then
|
||||||
|
echo "❌ Docker not found. Install docker first."
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Clone or update
|
||||||
|
if [ -d "$DIR" ]; then
|
||||||
|
echo "📦 Updating existing installation..."
|
||||||
|
cd "$DIR" && git pull
|
||||||
|
else
|
||||||
|
echo "📦 Cloning repository..."
|
||||||
|
git clone https://github.com/xmg0828888/oc-monitor.git "$DIR"
|
||||||
|
cd "$DIR"
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Build and run
|
||||||
|
echo "🔨 Building Docker image..."
|
||||||
|
docker build -t oc-monitor .
|
||||||
|
|
||||||
|
docker rm -f oc-monitor 2>/dev/null || true
|
||||||
|
echo "🚀 Starting container..."
|
||||||
|
docker run -d --name oc-monitor --restart always \
|
||||||
|
-p "$PORT:3800" \
|
||||||
|
-v oc-monitor-data:/app/data \
|
||||||
|
-e "AUTH_TOKEN=$TOKEN" \
|
||||||
|
oc-monitor
|
||||||
|
|
||||||
|
IP=$(hostname -I 2>/dev/null | awk '{print $1}' || curl -s ifconfig.me)
|
||||||
|
|
||||||
|
echo ""
|
||||||
|
echo "✅ OC Monitor is running!"
|
||||||
|
echo "========================"
|
||||||
|
echo "🌐 Dashboard: http://$IP:$PORT"
|
||||||
|
echo "🔑 Auth Token: $TOKEN"
|
||||||
|
echo ""
|
||||||
|
echo "📡 Install agent on each node:"
|
||||||
|
echo " curl -fsSL https://cdn.jsdelivr.net/gh/xmg0828888/oc-monitor/install-agent.sh | bash -s -- -s http://$IP:$PORT -t $TOKEN -n \"NodeName\""
|
||||||
@@ -7,62 +7,102 @@
|
|||||||
<style>
|
<style>
|
||||||
*{margin:0;padding:0;box-sizing:border-box}
|
*{margin:0;padding:0;box-sizing:border-box}
|
||||||
:root{--bg:#060a10;--card:#0d1520;--card2:#111c2e;--border:#1a2740;--txt:#c8d6e5;--dim:#5a6f88;--neon:#00e5ff;--green:#00ff88;--warn:#ffb020;--err:#ff4466;--purple:#b8a9ff;--peach:#ffb088}
|
:root{--bg:#060a10;--card:#0d1520;--card2:#111c2e;--border:#1a2740;--txt:#c8d6e5;--dim:#5a6f88;--neon:#00e5ff;--green:#00ff88;--warn:#ffb020;--err:#ff4466;--purple:#b8a9ff;--peach:#ffb088}
|
||||||
body{font-family:'SF Mono',Menlo,'Courier New',monospace;background:var(--bg);color:var(--txt);padding:16px}
|
[data-theme="light"]{--bg:#f0f2f5;--card:#fff;--card2:#f5f7fa;--border:#d8dde6;--txt:#1a1a2e;--dim:#6b7b8d;--neon:#0088cc;--green:#00a856;--warn:#e69500;--err:#d63050;--purple:#7c5cbf;--peach:#d07040}
|
||||||
|
body{font-family:-apple-system,BlinkMacSystemFont,'Segoe UI',Roboto,'Helvetica Neue',Arial,sans-serif;background:var(--bg);color:var(--txt);padding:20px}
|
||||||
.wrap{max-width:1200px;margin:0 auto}
|
.wrap{max-width:1200px;margin:0 auto}
|
||||||
h1{font-size:1.3em;color:var(--neon);margin-bottom:4px}
|
.hdr{margin-bottom:24px;padding:20px 0 16px;border-bottom:1px solid var(--border)}
|
||||||
.sub{color:var(--dim);font-size:.75em;margin-bottom:20px}
|
.hdr h1{font-size:1.8em;font-weight:800;background:linear-gradient(135deg,var(--neon),var(--purple));-webkit-background-clip:text;-webkit-text-fill-color:transparent;background-clip:text;display:inline}
|
||||||
.stats{display:grid;grid-template-columns:repeat(6,1fr);gap:10px;margin-bottom:20px}
|
.hdr-row{display:flex;align-items:center;gap:12px;flex-wrap:wrap}
|
||||||
.st{background:var(--card);border:1px solid var(--border);border-radius:8px;padding:14px;text-align:center}
|
.hdr-links{display:flex;gap:10px;align-items:center;margin-left:auto}
|
||||||
.st .n{font-size:1.5em;font-weight:700}.st .l{font-size:.7em;color:var(--dim);margin-top:2px}
|
.hdr-links a,.hdr-links span{font-size:.8em;color:var(--dim);text-decoration:none;cursor:pointer}
|
||||||
|
.hdr-links a:hover,.hdr-links span:hover{color:var(--neon)}
|
||||||
|
.sub{color:var(--dim);font-size:.78em;margin-top:6px;letter-spacing:.3px}
|
||||||
|
.stats{display:grid;grid-template-columns:repeat(6,1fr);gap:10px;margin-bottom:24px}
|
||||||
|
.st{background:var(--card);border:1px solid var(--border);border-radius:10px;padding:16px;text-align:center}
|
||||||
|
.st .n{font-size:1.6em;font-weight:800;font-family:'SF Mono',Menlo,monospace}.st .l{font-size:.72em;color:var(--dim);margin-top:4px;font-weight:500}
|
||||||
.s1 .n{color:var(--neon)}.s2 .n{color:var(--purple)}.s3 .n{color:var(--peach)}
|
.s1 .n{color:var(--neon)}.s2 .n{color:var(--purple)}.s3 .n{color:var(--peach)}
|
||||||
.s4 .n{color:var(--green)}.s5 .n{color:var(--warn)}.s6 .n{color:var(--err)}
|
.s4 .n{color:var(--green)}.s5 .n{color:var(--warn)}.s6 .n{color:var(--err)}
|
||||||
.tabs{display:flex;gap:0;margin-bottom:20px;border-bottom:1px solid var(--border)}
|
.tabs{display:flex;gap:0;margin-bottom:24px;border-bottom:1px solid var(--border)}
|
||||||
.tab{padding:8px 20px;cursor:pointer;color:var(--dim);font-size:.85em;border-bottom:2px solid transparent}
|
.tab{padding:10px 24px;cursor:pointer;color:var(--dim);font-size:.88em;font-weight:500;border-bottom:2px solid transparent;transition:color .2s}
|
||||||
.tab.on{color:var(--neon);border-bottom-color:var(--neon)}
|
.tab.on{color:var(--neon);border-bottom-color:var(--neon)}
|
||||||
|
.tab:hover{color:var(--txt)}
|
||||||
.tp{display:none}.tp.on{display:block}
|
.tp{display:none}.tp.on{display:block}
|
||||||
.nodes{display:grid;grid-template-columns:repeat(auto-fill,minmax(340px,1fr));gap:14px}
|
.nodes{display:grid;grid-template-columns:repeat(auto-fill,minmax(360px,1fr));gap:14px}
|
||||||
.nd{background:var(--card);border:1px solid var(--border);border-radius:10px;padding:16px}
|
.nd{background:var(--card);border:1px solid var(--border);border-radius:12px;padding:18px;display:flex;flex-direction:column}
|
||||||
.nd.offline{border-color:rgba(255,68,102,.3)}
|
.nd.offline{border-color:rgba(255,68,102,.3)}
|
||||||
.nd-h{display:flex;justify-content:space-between;align-items:center;margin-bottom:8px}
|
.nd-h{display:flex;justify-content:space-between;align-items:center;margin-bottom:8px}
|
||||||
.nd-nm{font-size:1.05em;font-weight:600;cursor:pointer}.nd-nm:hover{color:var(--neon)}
|
.nd-nm{font-size:1.05em;font-weight:600;cursor:pointer}.nd-nm:hover{color:var(--neon)}
|
||||||
.dot{width:8px;height:8px;border-radius:50%;display:inline-block;margin-right:5px}
|
.dot{width:8px;height:8px;border-radius:50%;display:inline-block;margin-right:5px}
|
||||||
.dot.on{background:var(--green);box-shadow:0 0 6px var(--green)}.dot.off{background:var(--err)}
|
.dot.on{background:var(--green);box-shadow:0 0 6px var(--green)}.dot.off{background:var(--err)}
|
||||||
.tg{display:flex;gap:5px;flex-wrap:wrap;margin-bottom:8px}
|
.tg{display:flex;gap:4px;flex-wrap:nowrap;margin-bottom:8px;overflow:hidden}
|
||||||
.tg span{font-size:.63em;padding:2px 7px;border-radius:10px;background:var(--card2);color:var(--dim);border:1px solid var(--border)}
|
.tg span{font-size:.65em;padding:2px 8px;border-radius:10px;background:var(--card2);color:var(--dim);border:1px solid var(--border);white-space:nowrap;overflow:hidden;text-overflow:ellipsis;max-width:120px}
|
||||||
.tg .ms{color:var(--neon);border-color:rgba(0,229,255,.3)}
|
.tg .ms{color:var(--neon);border-color:rgba(0,229,255,.3)}
|
||||||
.tg .wk{color:var(--purple);border-color:rgba(184,169,255,.3)}
|
.tg .wk{color:var(--purple);border-color:rgba(184,169,255,.3)}
|
||||||
.hb{height:28px;display:flex;align-items:end;gap:1px;overflow:hidden;margin-bottom:8px}
|
.hb{height:28px;display:flex;align-items:end;gap:1px;overflow:hidden;margin-bottom:8px}
|
||||||
.hb i{width:3px;border-radius:1px}
|
.hb i{width:3px;border-radius:1px}
|
||||||
.sec{font-size:.72em;color:var(--dim);margin-bottom:4px}
|
.sec{font-size:.72em;color:var(--dim);margin-bottom:4px}
|
||||||
.pv{display:flex;justify-content:space-between;padding:3px 0;font-size:.78em}
|
.pv-wrap{flex:1;min-height:0;overflow-y:auto;margin-bottom:8px}
|
||||||
|
.pv{display:flex;justify-content:space-between;align-items:center;padding:4px 0;font-size:.78em}
|
||||||
.pv-l{display:flex;gap:5px;align-items:center}
|
.pv-l{display:flex;gap:5px;align-items:center}
|
||||||
.pv-default{color:var(--warn)}
|
.pv-default{color:var(--warn)}
|
||||||
.pm{color:var(--dim);font-size:.85em}
|
.pm{color:var(--dim);font-size:.85em}
|
||||||
.ok{color:var(--green)}.er{color:var(--err)}
|
.ok{color:var(--green)}.er{color:var(--err)}
|
||||||
.gs{display:grid;grid-template-columns:repeat(4,1fr);gap:8px;margin:8px 0}
|
.gs{display:grid;grid-template-columns:repeat(4,1fr);gap:10px;margin:10px 0}
|
||||||
.g{font-size:.7em}.g-l{color:var(--dim)}.g-t{height:4px;background:var(--card2);border-radius:2px;margin:2px 0}
|
.g{font-size:.72em}.g-l{color:var(--dim);font-weight:500}.g-t{height:5px;background:var(--card2);border-radius:3px;margin:3px 0}
|
||||||
.g-f{height:100%;border-radius:2px}.fg{background:var(--green)}.fb{background:var(--neon)}.fw{background:var(--warn)}.fr{background:var(--err)}
|
.g-f{height:100%;border-radius:2px;transition:width .8s ease,background .5s}.fg{background:var(--green)}.fb{background:var(--neon)}.fw{background:var(--warn)}.fr{background:var(--err)}
|
||||||
.g-n{font-weight:600}
|
.g-n{font-weight:600}
|
||||||
.tks{display:flex;gap:10px;margin:8px 0}
|
.tks{display:flex;gap:10px;margin:10px 0}
|
||||||
.tk{flex:1;text-align:center;background:var(--card2);border-radius:6px;padding:5px}
|
.tk{flex:1;text-align:center;background:var(--card2);border-radius:8px;padding:8px 5px}
|
||||||
.tk-l{font-size:.63em;color:var(--dim)}.tk-v{font-size:.85em;font-weight:600;color:var(--neon)}
|
.tk-l{font-size:.65em;color:var(--dim);font-weight:500}.tk-v{font-size:.9em;font-weight:700;color:var(--neon);font-family:'SF Mono',Menlo,monospace}
|
||||||
.nd-f{display:flex;gap:8px;font-size:.68em;color:var(--dim);flex-wrap:wrap}
|
.nd-f{display:flex;gap:10px;font-size:.7em;color:var(--dim);flex-wrap:wrap;margin-top:auto;padding-top:8px;border-top:1px solid var(--border)}
|
||||||
.mx{background:var(--card);border:1px solid var(--border);border-radius:10px;padding:16px}
|
.mx{background:var(--card);border:1px solid var(--border);border-radius:10px;padding:16px}
|
||||||
.mx-h{font-size:.9em;font-weight:600;margin-bottom:10px;color:var(--neon)}
|
.mx-h{font-size:.9em;font-weight:600;margin-bottom:10px;color:var(--neon)}
|
||||||
table{width:100%;border-collapse:collapse;font-size:.78em}
|
table{width:100%;border-collapse:collapse;font-size:.8em}
|
||||||
th{text-align:left;padding:6px 10px;color:var(--dim);border-bottom:1px solid var(--border);font-weight:500}
|
th{text-align:left;padding:8px 10px;color:var(--dim);border-bottom:1px solid var(--border);font-weight:600}
|
||||||
td{padding:6px 10px;border-bottom:1px solid rgba(26,39,64,.5)}
|
td{padding:8px 10px;border-bottom:1px solid rgba(26,39,64,.5)}
|
||||||
.lt{background:var(--card);border:1px solid var(--border);border-radius:10px;padding:16px}
|
.lt{background:var(--card);border:1px solid var(--border);border-radius:12px;padding:18px}
|
||||||
.lt-h{font-size:.9em;font-weight:600;margin-bottom:10px;color:var(--purple)}
|
.lt-h{font-size:.95em;font-weight:600;margin-bottom:12px;color:var(--purple)}
|
||||||
.lf{display:flex;gap:10px;margin-bottom:12px;flex-wrap:wrap}
|
.lf{display:flex;gap:10px;margin-bottom:12px;flex-wrap:wrap}
|
||||||
.lf select{background:var(--card2);border:1px solid var(--border);color:var(--txt);padding:4px 10px;border-radius:6px;font-size:.78em;font-family:inherit}
|
.lf select{background:var(--card2);border:1px solid var(--border);color:var(--txt);padding:6px 12px;border-radius:8px;font-size:.8em;font-family:inherit}
|
||||||
@media(max-width:768px){.stats{grid-template-columns:repeat(3,1fr)}.nodes{grid-template-columns:1fr}}
|
.pager{display:flex;justify-content:center;align-items:center;gap:8px;margin-top:14px;font-size:.78em}
|
||||||
|
.pager button{background:var(--card2);border:1px solid var(--border);color:var(--txt);padding:5px 14px;border-radius:8px;cursor:pointer;font-family:inherit;transition:border-color .2s}
|
||||||
|
.pager button:disabled{opacity:.3;cursor:default}
|
||||||
|
.pager button.pg-on{border-color:var(--neon);color:var(--neon)}
|
||||||
|
.pager span{color:var(--dim)}
|
||||||
|
.provs{display:grid;grid-template-columns:repeat(auto-fill,minmax(360px,1fr));gap:14px}
|
||||||
|
.pcard{background:var(--card);border:1px solid var(--border);border-radius:12px;padding:18px}
|
||||||
|
.pcard-h{display:flex;justify-content:space-between;align-items:center;margin-bottom:12px;padding-bottom:8px;border-bottom:1px solid var(--border)}
|
||||||
|
.pcard-nm{font-size:1.1em;font-weight:700;color:var(--neon)}
|
||||||
|
.pcard-cnt{font-size:.7em;color:var(--dim)}
|
||||||
|
.pcard-row{display:flex;justify-content:space-between;align-items:center;padding:5px 0;font-size:.8em;border-bottom:1px solid rgba(26,39,64,.3)}
|
||||||
|
.pcard-row:last-child{border-bottom:none}
|
||||||
|
.pcard-node{color:var(--dim)}
|
||||||
|
.pcard-model{color:var(--purple);font-size:.68em;line-height:1.4}
|
||||||
|
.pcard-models{margin-top:2px}
|
||||||
|
.pcard-ms{color:var(--dim);font-size:.75em}
|
||||||
|
@media(max-width:768px){.stats{grid-template-columns:repeat(3,1fr)}.nodes{grid-template-columns:1fr}.provs{grid-template-columns:1fr}.hdr h1{font-size:1.4em}}
|
||||||
|
.login-mask{position:fixed;inset:0;background:var(--bg);display:flex;align-items:center;justify-content:center;z-index:999}
|
||||||
|
.login-box{background:var(--card);border:1px solid var(--border);border-radius:16px;padding:40px;text-align:center;max-width:360px;width:90%}
|
||||||
|
.login-box h2{font-size:1.4em;font-weight:800;background:linear-gradient(135deg,var(--neon),var(--purple));-webkit-background-clip:text;-webkit-text-fill-color:transparent;background-clip:text;margin-bottom:8px}
|
||||||
|
.login-box p{color:var(--dim);font-size:.82em;margin-bottom:20px}
|
||||||
|
.login-box input{width:100%;padding:10px 14px;background:var(--card2);border:1px solid var(--border);border-radius:8px;color:var(--txt);font-size:.9em;font-family:inherit;outline:none}
|
||||||
|
.login-box input:focus{border-color:var(--neon)}
|
||||||
|
.login-box button{width:100%;margin-top:12px;padding:10px;background:linear-gradient(135deg,var(--neon),var(--purple));border:none;border-radius:8px;color:#fff;font-weight:600;font-size:.9em;cursor:pointer}
|
||||||
|
.login-err{color:var(--err);font-size:.78em;margin-top:8px;display:none}
|
||||||
</style>
|
</style>
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<div class="wrap">
|
<div class="login-mask" id="loginMask" style="display:none">
|
||||||
<h1>🐾 OpenClaw Mission Control <a href="/admin.html" style="font-size:.5em;color:var(--dim);text-decoration:none;margin-left:8px">⚙️ Admin</a></h1>
|
<div class="login-box"><h2>🔓 解锁完整视图</h2><p>输入令牌查看 IP 等敏感信息</p>
|
||||||
|
<input id="tokenInput" type="password" placeholder="Token" onkeydown="if(event.key==='Enter')doLogin()">
|
||||||
|
<button onclick="doLogin()">解锁</button>
|
||||||
|
<div class="login-err" id="loginErr">令牌无效</div></div></div>
|
||||||
|
<div class="wrap" id="mainWrap">
|
||||||
|
<div class="hdr">
|
||||||
|
<div class="hdr-row"><h1>🐾 OpenClaw Mission Control</h1>
|
||||||
|
<div class="hdr-links"><a href="/admin.html">⚙️ Admin</a><span id="lockBtn" onclick="$('#loginMask').style.display='flex'" style="cursor:pointer">🔒</span><span id="themeBtn" onclick="toggleTheme()">🌙</span></div></div>
|
||||||
<div class="sub" id="subtitle">Loading...</div>
|
<div class="sub" id="subtitle">Loading...</div>
|
||||||
|
</div>
|
||||||
<div class="stats" id="stats"></div>
|
<div class="stats" id="stats"></div>
|
||||||
|
|
||||||
<div class="tabs">
|
<div class="tabs">
|
||||||
@@ -72,17 +112,29 @@ td{padding:6px 10px;border-bottom:1px solid rgba(26,39,64,.5)}
|
|||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="tp on" id="t-nodes"><div class="nodes" id="nodeGrid"></div></div>
|
<div class="tp on" id="t-nodes"><div class="nodes" id="nodeGrid"></div></div>
|
||||||
<div class="tp" id="t-matrix"><div class="mx"><div class="mx-h">供应商 × 节点 矩阵</div><table id="matrixTable"></table></div></div>
|
<div class="tp" id="t-matrix"><div class="provs" id="provGrid"></div></div>
|
||||||
<div class="tp" id="t-logs"><div class="lt"><div class="lt-h">请求日志</div>
|
<div class="tp" id="t-logs"><div class="lt"><div class="lt-h">请求日志</div>
|
||||||
<div class="lf"><select id="fNode" onchange="renderLogs()"><option value="">全部节点</option></select><select id="fUp" onchange="renderLogs()"><option value="">全部供应商</option></select><select id="fRes" onchange="renderLogs()"><option value="">全部结果</option><option value="1">✓ 成功</option><option value="0">✗ 失败</option></select></div>
|
<div class="lf"><select id="fNode" onchange="renderLogs()"><option value="">全部节点</option></select><select id="fUp" onchange="renderLogs()"><option value="">全部供应商</option></select><select id="fRes" onchange="renderLogs()"><option value="">全部结果</option><option value="1">✓ 成功</option><option value="0">✗ 失败</option></select></div>
|
||||||
<table id="logTable"></table></div></div>
|
<table id="logTable"></table><div class="pager" id="pager"></div></div></div>
|
||||||
|
|
||||||
</div>
|
</div>
|
||||||
<script>
|
<script>
|
||||||
let DATA={nodes:[],stats:{},requests:[]};
|
let DATA={nodes:[],stats:{},requests:[]};
|
||||||
const $=s=>document.querySelector(s);
|
const $=s=>document.querySelector(s);
|
||||||
|
let TOKEN=localStorage.getItem('oc-token')||'';
|
||||||
|
const authHdr=()=>({headers:{'Authorization':'Bearer '+TOKEN}});
|
||||||
|
|
||||||
function sw(t){document.querySelectorAll('.tab').forEach(e=>e.classList.remove('on'));document.querySelectorAll('.tp').forEach(e=>e.classList.remove('on'));document.querySelector(`.tab[onclick*="${t}"]`).classList.add('on');document.getElementById('t-'+t).classList.add('on');if(t==='logs')renderLogs()}
|
function doLogin(){
|
||||||
|
const t=$('#tokenInput').value.trim();if(!t)return;
|
||||||
|
fetch('/api/dashboard',{headers:{'Authorization':'Bearer '+t}}).then(r=>r.json()).then(d=>{
|
||||||
|
if(!d.authed){$('#loginErr').style.display='block';return}
|
||||||
|
TOKEN=t;localStorage.setItem('oc-token',t);
|
||||||
|
$('#loginMask').style.display='none';$('#lockBtn').textContent='🔓';
|
||||||
|
DATA=d;render();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
function sw(t){document.querySelectorAll('.tab').forEach(e=>e.classList.remove('on'));document.querySelectorAll('.tp').forEach(e=>e.classList.remove('on'));document.querySelector(`.tab[onclick*="${t}"]`).classList.add('on');document.getElementById('t-'+t).classList.add('on');if(t==='logs')loadLogs(logPage)}
|
||||||
|
|
||||||
function fmtTok(n){return n>=1e6?(n/1e6).toFixed(1)+'M':n>=1e3?(n/1e3).toFixed(1)+'K':n}
|
function fmtTok(n){return n>=1e6?(n/1e6).toFixed(1)+'M':n>=1e3?(n/1e3).toFixed(1)+'K':n}
|
||||||
function fmtUp(s){if(!s)return'0s';return s>=1000?(s/1000).toFixed(1)+'s':s+'ms'}
|
function fmtUp(s){if(!s)return'0s';return s>=1000?(s/1000).toFixed(1)+'s':s+'ms'}
|
||||||
@@ -122,7 +174,7 @@ function renderNodes(){
|
|||||||
<div class="tg"><span class="${n.role==='master'?'ms':'wk'}">${n.role}</span><span>OC ${n.oc_version}</span><span>${n.os}</span></div>
|
<div class="tg"><span class="${n.role==='master'?'ms':'wk'}">${n.role}</span><span>OC ${n.oc_version}</span><span>${n.os}</span></div>
|
||||||
<div class="hb">${hbBars}</div>
|
<div class="hb">${hbBars}</div>
|
||||||
<div class="sec">供应商</div>
|
<div class="sec">供应商</div>
|
||||||
${provs.sort((a,b)=>b.default-a.default||(a.name>b.name?1:-1)).map(p=>`<div class="pv"><div class="pv-l">${p.default?'<span class="dot on" style="width:6px;height:6px"></span>':''}<span${p.default?' class="pv-default"':''}>${p.name}</span> <span class="pm">${p.model}</span></div><div>${p.status==='ok'?'<span class="ok">✓</span> <span class="pm">'+p.ms+'ms</span>':'<span class="er">✗</span> <span class="pm">'+(p.err||'离线')+'</span>'}</div></div>`).join('')}
|
<div class="pv-wrap">${provs.sort((a,b)=>b.default-a.default||(a.name>b.name?1:-1)).map(p=>`<div class="pv"><div class="pv-l">${p.default?'<span class="dot on" style="width:6px;height:6px"></span>':''}<span${p.default?' class="pv-default"':''}>${p.name}</span></div><div>${p.status==='ok'?'<span class="ok">✓</span> <span class="pm">'+p.ms+'ms</span>':'<span class="er">✗</span> <span class="pm">'+(p.err||'离线')+'</span>'}</div></div>`).join('')}</div>
|
||||||
<div class="gs">
|
<div class="gs">
|
||||||
${[['cpu',n.cpu],['mem',n.mem],['disk',n.disk],['swap',n.swap]].map(([l,v])=>`<div class="g" data-g="${l}"><span class="g-l">${l}</span><div class="g-t"><div class="g-f ${gaugeColor(v)}" style="width:${v}%"></div></div><span class="g-n">${on?v+'%':'—'}</span></div>`).join('')}
|
${[['cpu',n.cpu],['mem',n.mem],['disk',n.disk],['swap',n.swap]].map(([l,v])=>`<div class="g" data-g="${l}"><span class="g-l">${l}</span><div class="g-t"><div class="g-f ${gaugeColor(v)}" style="width:${v}%"></div></div><span class="g-n">${on?v+'%':'—'}</span></div>`).join('')}
|
||||||
</div>
|
</div>
|
||||||
@@ -135,31 +187,40 @@ ${[['cpu',n.cpu],['mem',n.mem],['disk',n.disk],['swap',n.swap]].map(([l,v])=>`<d
|
|||||||
|
|
||||||
|
|
||||||
function renderMatrix(){
|
function renderMatrix(){
|
||||||
const ns=DATA.nodes,allProvs=new Map();
|
const ns=DATA.nodes,provMap=new Map();
|
||||||
ns.forEach(n=>JSON.parse(n.providers||'[]').forEach(p=>{
|
ns.forEach(n=>JSON.parse(n.providers||'[]').forEach(p=>{
|
||||||
const k=p.name+' ('+p.model+')';if(!allProvs.has(k))allProvs.set(k,new Set());
|
if(!provMap.has(p.name))provMap.set(p.name,{name:p.name,nodes:[]});
|
||||||
allProvs.get(k).add(n.name);
|
provMap.get(p.name).nodes.push({node:n.name,model:p.model,status:p.status,ms:p.ms,err:p.err,def:p.default});
|
||||||
}));
|
}));
|
||||||
let h='<thead><tr><th>Provider</th>'+ns.map(n=>'<th>'+n.name+'</th>').join('')+'</tr></thead><tbody>';
|
$('#provGrid').innerHTML=[...provMap.values()].sort((a,b)=>b.nodes.length-a.nodes.length).map(p=>{
|
||||||
for(const[prov,set]of allProvs){
|
const ok=p.nodes.filter(n=>n.status==='ok').length;
|
||||||
h+='<tr><td>'+prov+'</td>';
|
return `<div class="pcard">
|
||||||
ns.forEach(n=>{const ps=JSON.parse(n.providers||'[]');const f=ps.find(x=>x.name===prov.split(' (')[0]);
|
<div class="pcard-h"><span class="pcard-nm">${p.name}</span><span class="pcard-cnt">${ok}/${p.nodes.length} 在线</span></div>
|
||||||
h+=f?(f.status==='ok'?`<td class="ok">✓ ${f.ms}ms</td>`:`<td class="er">✗ ${f.err||'离线'}</td>`):'<td style="color:var(--dim)">—</td>';});
|
${p.nodes.sort((a,b)=>b.def-a.def).map(n=>`<div class="pcard-row"><div><span${n.def?' style="color:var(--warn)"':''}>${n.node}</span><div class="pcard-models">${n.model.split(' | ').map(m=>'<div class="pcard-model">'+m.replace(/claude-/g,'c-').replace(/-2025\d{4}/g,'')+'</div>').join('')}</div></div><div>${n.status==='ok'?'<span class="ok">✓</span> <span class="pcard-ms">'+n.ms+'ms</span>':'<span class="er">✗</span> <span class="pcard-ms">'+(n.err||'离线')+'</span>'}</div></div>`).join('')}
|
||||||
h+='</tr>';
|
</div>`;
|
||||||
|
}).join('');
|
||||||
}
|
}
|
||||||
$('#matrixTable').innerHTML=h+'</tbody>';
|
|
||||||
|
let logPage=1,logPages=1,logTotal=0;
|
||||||
|
|
||||||
|
async function loadLogs(page){
|
||||||
|
page=page||1;
|
||||||
|
try{
|
||||||
|
const r=await fetch('/api/requests?page='+page+'&size=50',authHdr());
|
||||||
|
const d=await r.json();
|
||||||
|
DATA.requests=d.requests||[];logPage=d.page;logPages=d.pages;logTotal=d.total;
|
||||||
|
}catch(e){console.error(e)}
|
||||||
|
renderLogs();
|
||||||
}
|
}
|
||||||
|
|
||||||
function renderLogs(){
|
function renderLogs(){
|
||||||
const reqs=DATA.requests||[];
|
const reqs=DATA.requests||[];
|
||||||
// Populate filters from nodes (not requests)
|
|
||||||
const nodes=(DATA.nodes||[]).map(n=>n.name).sort();
|
const nodes=(DATA.nodes||[]).map(n=>n.name).sort();
|
||||||
const ups=[...new Set(reqs.map(r=>r.upstream))].sort();
|
const ups=[...new Set((DATA.nodes||[]).flatMap(n=>JSON.parse(n.providers||'[]').map(p=>p.name)))].sort();
|
||||||
const fN=$('#fNode'),fU=$('#fUp');
|
const fN=$('#fNode'),fU=$('#fUp');
|
||||||
const nv=fN.value,uv=fU.value;
|
const nv=fN.value,uv=fU.value;
|
||||||
fN.innerHTML='<option value="">全部节点</option>'+nodes.map(n=>`<option${n===nv?' selected':''}>${n}</option>`).join('');
|
fN.innerHTML='<option value="">全部节点</option>'+nodes.map(n=>`<option${n===nv?' selected':''}>${n}</option>`).join('');
|
||||||
fU.innerHTML='<option value="">全部供应商</option>'+ups.map(u=>`<option${u===uv?' selected':''}>${u}</option>`).join('');
|
fU.innerHTML='<option value="">全部供应商</option>'+ups.map(u=>`<option${u===uv?' selected':''}>${u}</option>`).join('');
|
||||||
// Filter
|
|
||||||
const fR=$('#fRes').value;
|
const fR=$('#fRes').value;
|
||||||
const filtered=reqs.filter(r=>{
|
const filtered=reqs.filter(r=>{
|
||||||
if(nv&&(r.node_name||r.node_id)!==nv)return false;
|
if(nv&&(r.node_name||r.node_id)!==nv)return false;
|
||||||
@@ -167,17 +228,38 @@ function renderLogs(){
|
|||||||
if(fR!==''&&String(r.success?1:0)!==fR)return false;
|
if(fR!==''&&String(r.success?1:0)!==fR)return false;
|
||||||
return true;
|
return true;
|
||||||
});
|
});
|
||||||
let h='<thead><tr><th>时间</th><th>节点</th><th>供应商</th><th>模型</th><th>结果</th><th>状态</th><th>输入</th><th>输出</th><th>首字</th><th>总耗时</th></tr></thead><tbody>';
|
let h='<thead><tr><th>时间</th><th>节点</th><th>供应商</th><th>模型</th><th>结果</th><th>输入</th><th>输出</th><th>缓存读</th><th>缓存写</th></tr></thead><tbody>';
|
||||||
filtered.forEach(r=>{
|
filtered.forEach(r=>{
|
||||||
const t=new Date(r.ts*1000).toLocaleTimeString('zh-CN');
|
const t=new Date(r.ts*1000).toLocaleTimeString('zh-CN');
|
||||||
h+='<tr><td>'+t+'</td><td>'+(r.node_name||r.node_id)+'</td><td>'+r.upstream+'</td><td>'+r.model+'</td>';
|
h+='<tr><td>'+t+'</td><td>'+(r.node_name||r.node_id)+'</td><td>'+r.upstream+'</td><td>'+r.model+'</td>';
|
||||||
h+='<td class="'+(r.success?'ok':'er')+'">'+(r.success?'✓':'✗')+'</td><td>'+r.status+'</td>';
|
h+='<td class="'+(r.success?'ok':'er')+'">'+(r.success?'✓':'✗')+'</td>';
|
||||||
h+='<td>'+fmtTok(r.input_tokens)+'</td><td>'+r.output_tokens+'</td>';
|
h+='<td>'+fmtTok(r.input_tokens)+'</td><td>'+fmtTok(r.output_tokens)+'</td>';
|
||||||
h+='<td style="color:var(--warn)">'+r.ttft_ms+'ms</td><td>'+fmtUp(r.total_ms)+'</td></tr>';
|
h+='<td style="color:var(--purple)">'+fmtTok(r.cache_read||0)+'</td><td style="color:var(--peach)">'+fmtTok(r.cache_write||0)+'</td></tr>';
|
||||||
});
|
});
|
||||||
$('#logTable').innerHTML=h+'</tbody>';
|
$('#logTable').innerHTML=h+'</tbody>';
|
||||||
|
// pager
|
||||||
|
let pg='<button onclick="loadLogs(1)"'+(logPage<=1?' disabled':'')+'>«</button>';
|
||||||
|
pg+='<button onclick="loadLogs('+(logPage-1)+')"'+(logPage<=1?' disabled':'')+'>‹</button>';
|
||||||
|
const start=Math.max(1,logPage-2),end=Math.min(logPages,logPage+2);
|
||||||
|
for(let i=start;i<=end;i++)pg+='<button class="'+(i===logPage?'pg-on':'')+'" onclick="loadLogs('+i+')">'+i+'</button>';
|
||||||
|
pg+='<button onclick="loadLogs('+(logPage+1)+')"'+(logPage>=logPages?' disabled':'')+'>›</button>';
|
||||||
|
pg+='<button onclick="loadLogs('+logPages+')"'+(logPage>=logPages?' disabled':'')+'>»</button>';
|
||||||
|
pg+='<span>共 '+logTotal+' 条</span>';
|
||||||
|
$('#pager').innerHTML=pg;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function animateNum(el,to,suffix=''){
|
||||||
|
el._real=to;
|
||||||
|
el.textContent=to+suffix;
|
||||||
|
}
|
||||||
|
// Live jitter: every 1s, all gauge numbers wobble around real value
|
||||||
|
setInterval(()=>{
|
||||||
|
document.querySelectorAll('.g-n').forEach(el=>{
|
||||||
|
if(el._real==null||el.textContent==='—')return;
|
||||||
|
const r=el._real,jit=r*(0.02*Math.random()-0.01);
|
||||||
|
el.textContent=Math.max(0,r+jit).toFixed(1)+'%';
|
||||||
|
});
|
||||||
|
},1000);
|
||||||
function updateNodeCard(n){
|
function updateNodeCard(n){
|
||||||
const el=document.querySelector(`.nd[data-id="${n.id}"]`);
|
const el=document.querySelector(`.nd[data-id="${n.id}"]`);
|
||||||
if(!el)return false;
|
if(!el)return false;
|
||||||
@@ -186,13 +268,11 @@ function updateNodeCard(n){
|
|||||||
// gauges
|
// gauges
|
||||||
[['cpu',n.cpu],['mem',n.mem],['disk',n.disk],['swap',n.swap]].forEach(([k,v])=>{
|
[['cpu',n.cpu],['mem',n.mem],['disk',n.disk],['swap',n.swap]].forEach(([k,v])=>{
|
||||||
const g=el.querySelector(`[data-g="${k}"]`);
|
const g=el.querySelector(`[data-g="${k}"]`);
|
||||||
if(g){g.querySelector('.g-f').style.width=v+'%';g.querySelector('.g-f').className='g-f '+gaugeColor(v);g.querySelector('.g-n').textContent=on?v+'%':'—';}
|
if(g){g.querySelector('.g-f').style.width=v+'%';g.querySelector('.g-f').className='g-f '+gaugeColor(v);const gn=g.querySelector('.g-n');if(on)animateNum(gn,v,'%');else gn.textContent='—';}
|
||||||
});
|
});
|
||||||
// tokens
|
// tokens
|
||||||
const tv=el.querySelectorAll('.tk-v');
|
const tv=el.querySelectorAll('.tk-v');
|
||||||
if(tv[0])tv[0].textContent=fmtTok(n.tok_today);
|
[[tv[0],n.tok_today],[tv[1],n.tok_week],[tv[2],n.tok_month]].forEach(([e,v])=>{if(e){const s=fmtTok(v);if(e.textContent!==s)e.textContent=s;}});
|
||||||
if(tv[1])tv[1].textContent=fmtTok(n.tok_week);
|
|
||||||
if(tv[2])tv[2].textContent=fmtTok(n.tok_month);
|
|
||||||
// footer
|
// footer
|
||||||
const fs=el.querySelectorAll('.nd-f span');
|
const fs=el.querySelectorAll('.nd-f span');
|
||||||
if(fs[0])fs[0].textContent='⏱ '+fmtAge(Date.now()/1000-n.uptime);
|
if(fs[0])fs[0].textContent='⏱ '+fmtAge(Date.now()/1000-n.uptime);
|
||||||
@@ -206,7 +286,7 @@ function render(){renderStats();renderNodes();renderMatrix();renderLogs();
|
|||||||
}
|
}
|
||||||
|
|
||||||
async function load(){
|
async function load(){
|
||||||
try{const r=await fetch('/api/dashboard');DATA=await r.json();render();}catch(e){console.error(e)}
|
try{const r=await fetch('/api/dashboard',authHdr());if(r.status===401)return;DATA=await r.json();render();}catch(e){console.error(e)}
|
||||||
}
|
}
|
||||||
|
|
||||||
function connectWS(){
|
function connectWS(){
|
||||||
@@ -220,13 +300,21 @@ function connectWS(){
|
|||||||
if(!updateNodeCard(DATA.nodes[i>=0?i:DATA.nodes.length-1]))renderNodes();
|
if(!updateNodeCard(DATA.nodes[i>=0?i:DATA.nodes.length-1]))renderNodes();
|
||||||
renderStats();
|
renderStats();
|
||||||
}
|
}
|
||||||
if(d.type==='request'){DATA.requests.unshift(d.request);if(DATA.requests.length>100)DATA.requests.pop();render();}
|
if(d.type==='request'){const rq=d.request;if(!rq.node_name){const nd=DATA.nodes.find(n=>n.id===rq.node_id);if(nd)rq.node_name=nd.name;}DATA.requests.unshift(rq);if(DATA.requests.length>100)DATA.requests.pop();render();}
|
||||||
if(d.type==='rename'){var n=DATA.nodes.find(function(x){return x.id===d.id});if(n)n.name=d.name;render();}
|
if(d.type==='rename'){var n=DATA.nodes.find(function(x){return x.id===d.id});if(n)n.name=d.name;render();}
|
||||||
if(d.type==='delete'){DATA.nodes=DATA.nodes.filter(function(n){return n.id!==d.id});render();}
|
if(d.type==='delete'){DATA.nodes=DATA.nodes.filter(function(n){return n.id!==d.id});render();}
|
||||||
};
|
};
|
||||||
ws.onclose=function(){setTimeout(connectWS,3000)};
|
ws.onclose=function(){setTimeout(connectWS,3000)};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function toggleTheme(){
|
||||||
|
const d=document.documentElement,light=d.getAttribute('data-theme')==='light';
|
||||||
|
d.setAttribute('data-theme',light?'':'light');
|
||||||
|
$('#themeBtn').textContent=light?'🌙':'☀️';
|
||||||
|
localStorage.setItem('theme',light?'dark':'light');
|
||||||
|
}
|
||||||
|
(function(){const t=localStorage.getItem('theme');if(t==='light'){document.documentElement.setAttribute('data-theme','light');document.getElementById('themeBtn').textContent='☀️';}})();
|
||||||
|
if(TOKEN){$('#lockBtn').textContent='🔓';}
|
||||||
load();connectWS();setInterval(load,60000);
|
load();connectWS();setInterval(load,60000);
|
||||||
</script>
|
</script>
|
||||||
</body></html>
|
</body></html>
|
||||||
|
|||||||
@@ -41,7 +41,11 @@ CREATE TABLE IF NOT EXISTS requests (
|
|||||||
);
|
);
|
||||||
CREATE INDEX IF NOT EXISTS idx_req_ts ON requests(ts);
|
CREATE INDEX IF NOT EXISTS idx_req_ts ON requests(ts);
|
||||||
CREATE INDEX IF NOT EXISTS idx_req_node ON requests(node_id);
|
CREATE INDEX IF NOT EXISTS idx_req_node ON requests(node_id);
|
||||||
CREATE TABLE IF NOT EXISTS tokens (
|
`);
|
||||||
|
// Add cache columns if missing (migration)
|
||||||
|
try { db.exec('ALTER TABLE requests ADD COLUMN cache_read INTEGER DEFAULT 0'); } catch(e) {}
|
||||||
|
try { db.exec('ALTER TABLE requests ADD COLUMN cache_write INTEGER DEFAULT 0'); } catch(e) {}
|
||||||
|
db.exec(`CREATE TABLE IF NOT EXISTS tokens (
|
||||||
id TEXT PRIMARY KEY DEFAULT 'global',
|
id TEXT PRIMARY KEY DEFAULT 'global',
|
||||||
token TEXT UNIQUE
|
token TEXT UNIQUE
|
||||||
);
|
);
|
||||||
@@ -59,9 +63,12 @@ const upsertNode = db.prepare(`INSERT INTO nodes(id,name,host,os,oc_version,role
|
|||||||
swap=excluded.swap,sessions=excluded.sessions,gw_ok=excluded.gw_ok,daemon_ok=excluded.daemon_ok,
|
swap=excluded.swap,sessions=excluded.sessions,gw_ok=excluded.gw_ok,daemon_ok=excluded.daemon_ok,
|
||||||
uptime=excluded.uptime,tok_today=excluded.tok_today,tok_week=excluded.tok_week,tok_month=excluded.tok_month,
|
uptime=excluded.uptime,tok_today=excluded.tok_today,tok_week=excluded.tok_week,tok_month=excluded.tok_month,
|
||||||
last_seen=excluded.last_seen`);
|
last_seen=excluded.last_seen`);
|
||||||
const insertReq = db.prepare(`INSERT INTO requests(node_id,upstream,model,status,input_tokens,output_tokens,ttft_ms,total_ms,success,ts) VALUES(?,?,?,?,?,?,?,?,?,?)`);
|
const insertReq = db.prepare(`INSERT INTO requests(node_id,upstream,model,status,input_tokens,output_tokens,cache_read,cache_write,ttft_ms,total_ms,success,ts) VALUES(?,?,?,?,?,?,?,?,?,?,?,?)`);
|
||||||
const getNodes = db.prepare("SELECT * FROM nodes ORDER BY role='master' DESC, name");
|
const getNodes = db.prepare("SELECT * FROM nodes ORDER BY role='master' DESC, name");
|
||||||
|
const getNodeName = db.prepare("SELECT name FROM nodes WHERE id=?");
|
||||||
const getReqs = db.prepare("SELECT r.*,n.name as node_name FROM requests r LEFT JOIN nodes n ON r.node_id=n.id ORDER BY r.ts DESC LIMIT ?");
|
const getReqs = db.prepare("SELECT r.*,n.name as node_name FROM requests r LEFT JOIN nodes n ON r.node_id=n.id ORDER BY r.ts DESC LIMIT ?");
|
||||||
|
const getReqsPage = db.prepare("SELECT r.*,n.name as node_name FROM requests r LEFT JOIN nodes n ON r.node_id=n.id ORDER BY r.ts DESC LIMIT ? OFFSET ?");
|
||||||
|
const countReqs = db.prepare("SELECT count(*) as total FROM requests");
|
||||||
const getStats = db.prepare(`SELECT count(*) as total, sum(input_tokens) as input_tok, sum(output_tokens) as output_tok,
|
const getStats = db.prepare(`SELECT count(*) as total, sum(input_tokens) as input_tok, sum(output_tokens) as output_tok,
|
||||||
sum(success) as ok, avg(ttft_ms) as avg_ttft, avg(total_ms) as avg_total
|
sum(success) as ok, avg(ttft_ms) as avg_ttft, avg(total_ms) as avg_total
|
||||||
FROM requests WHERE ts > ?`);
|
FROM requests WHERE ts > ?`);
|
||||||
@@ -117,14 +124,25 @@ const server = http.createServer((req, res) => {
|
|||||||
// API routes
|
// API routes
|
||||||
(async () => {
|
(async () => {
|
||||||
try {
|
try {
|
||||||
// GET /api/dashboard - public overview
|
// GET /api/dashboard - public (masked) or authed (full)
|
||||||
if (url.pathname === '/api/dashboard' && method === 'GET') {
|
if (url.pathname === '/api/dashboard' && method === 'GET') {
|
||||||
|
const authed = (req.headers.authorization||'').replace('Bearer ','') === AUTH_TOKEN;
|
||||||
const now = Math.floor(Date.now()/1000);
|
const now = Math.floor(Date.now()/1000);
|
||||||
const today = now - (now % 86400);
|
const today = now - (now % 86400);
|
||||||
const nodes = getNodes.all();
|
const nodes = getNodes.all().map(n => authed ? n : {...n, host: '***'});
|
||||||
const stats = getStats.get(today);
|
const stats = getStats.get(today);
|
||||||
const reqs = getReqs.all(500);
|
const reqs = getReqs.all(500);
|
||||||
return json(200, { nodes, stats, requests: reqs, token: undefined });
|
return json(200, { nodes, stats, requests: reqs, authed });
|
||||||
|
}
|
||||||
|
|
||||||
|
// GET /api/requests - public (masked) or authed (full)
|
||||||
|
if (url.pathname === '/api/requests' && method === 'GET') {
|
||||||
|
const page = parseInt(url.searchParams.get('page') || '1');
|
||||||
|
const size = Math.min(parseInt(url.searchParams.get('size') || '50'), 200);
|
||||||
|
const offset = (page - 1) * size;
|
||||||
|
const rows = getReqsPage.all(size, offset);
|
||||||
|
const {total} = countReqs.get();
|
||||||
|
return json(200, { requests: rows, total, page, pages: Math.ceil(total / size) });
|
||||||
}
|
}
|
||||||
|
|
||||||
// POST /api/heartbeat - agent reports
|
// POST /api/heartbeat - agent reports
|
||||||
@@ -148,10 +166,14 @@ const server = http.createServer((req, res) => {
|
|||||||
const items = Array.isArray(b) ? b : [b];
|
const items = Array.isArray(b) ? b : [b];
|
||||||
for (const r of items) {
|
for (const r of items) {
|
||||||
insertReq.run(r.node_id,r.upstream,r.model,r.status||200,
|
insertReq.run(r.node_id,r.upstream,r.model,r.status||200,
|
||||||
r.input_tokens||0,r.output_tokens||0,r.ttft_ms||0,r.total_ms||0,
|
r.input_tokens||0,r.output_tokens||0,r.cache_read||0,r.cache_write||0,
|
||||||
|
r.ttft_ms||0,r.total_ms||0,
|
||||||
r.success!==false?1:0, r.ts||now);
|
r.success!==false?1:0, r.ts||now);
|
||||||
}
|
}
|
||||||
if (items.length <= 5) items.forEach(r => broadcast({ type:'request', request: r }));
|
if (items.length <= 5) items.forEach(r => {
|
||||||
|
const nn = getNodeName.get(r.node_id);
|
||||||
|
broadcast({ type:'request', request: {...r, node_name: nn ? nn.name : r.node_id} });
|
||||||
|
});
|
||||||
return json(200, { ok: true, count: items.length });
|
return json(200, { ok: true, count: items.length });
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user