Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| b271c15267 | |||
| 3a3d46119a | |||
| 0b16218ce9 | |||
| 248c33ed80 | |||
| 933fa8f257 | |||
| 883ef20ced | |||
| ed4397b21b | |||
| da188ea290 | |||
| 42a50037ab |
+2
-3
@@ -23,6 +23,5 @@ __pycache__/
|
|||||||
.DS_Store
|
.DS_Store
|
||||||
Thumbs.db
|
Thumbs.db
|
||||||
|
|
||||||
# Local config — contains the admin password hash and session secret.
|
# Local config (uncomment if you want to ignore local changes)
|
||||||
# Fresh installs start from config.json.example (see CONFIG.md).
|
# config.json
|
||||||
config.json
|
|
||||||
|
|||||||
@@ -48,15 +48,6 @@ Access at http://localhost:{web_port} (configured in config.json)
|
|||||||
- **admin/** - Admin panel (login + tabbed settings UI)
|
- **admin/** - Admin panel (login + tabbed settings UI)
|
||||||
- Theme management: rename display names, upload per-direction background PNGs, create new themes
|
- Theme management: rename display names, upload per-direction background PNGs, create new themes
|
||||||
- Display names stored in `config.json` `theme_names` map (folder name -> display name)
|
- Display names stored in `config.json` `theme_names` map (folder name -> display name)
|
||||||
- Receivers tab: live per-receiver health (via `GET /api/admin/receiver-status` and `POST /api/admin/test-receivers`), a select → SAVE & APPLY → auto-test flow, selectable scan results, and a per-interface scan selector
|
|
||||||
- Version (from `server.py` `VERSION`) is surfaced via public `GET /api/config` and shown in the admin header
|
|
||||||
- **pixel-editor.js** - In-app Canvas2D pixel editor (Sprites tab "EDIT" button)
|
|
||||||
- Edits sprites at native 500x333; tools: pencil, eraser, color picker, fill bucket, pan, line, rectangle, ellipse (outline/filled), rectangular select
|
|
||||||
- Select & move: marquee + floating layer, drag/arrow-nudge, Ctrl+C/X/V clipboard, Delete, Enter/Esc commit
|
|
||||||
- Zoom/pan, undo/redo (snapshot-per-stroke), grid overlay, brush size & opacity, retro + custom (localStorage) + recent palettes, adjustable reference-image overlay
|
|
||||||
- Exports a 500x333 PNG via `srcCanvas.toBlob` and POSTs to the existing `/api/admin/sprites/{type}` upload endpoint (no new server route)
|
|
||||||
- Keyboard: B/E/I/F/L/R/O/M tools, Space=pan, +/-/0 zoom, Ctrl+Z/Y undo/redo, Ctrl+C/X/V, arrows nudge, G grid, Esc close
|
|
||||||
- **Asset cache-busting:** `admin.html` references `admin.css`/`admin.js`/`pixel-editor.js` with a `?v=YYYYMMDD[x]` query — bump it whenever those files change so browsers reload them
|
|
||||||
|
|
||||||
- **setup/** - First-run setup wizard (multi-step configuration)
|
- **setup/** - First-run setup wizard (multi-step configuration)
|
||||||
|
|
||||||
|
|||||||
@@ -7,16 +7,14 @@ A retro SNES-style side-view flight tracker that displays ADS-B aircraft data wi
|
|||||||
## Features
|
## Features
|
||||||
|
|
||||||
- Real-time aircraft tracking via ADS-B receivers
|
- Real-time aircraft tracking via ADS-B receivers
|
||||||
- Custom pixel art sprites for 9 aircraft types (small prop, regional jet, narrow body, wide body, heavy, helicopter, balloon, glider, UAV)
|
- Custom pixel art sprites for 6 aircraft types (small prop, regional jet, narrow body, wide body, heavy, helicopter)
|
||||||
- Animated sun and moon with accurate astronomical positions
|
- Animated sun and moon with accurate astronomical positions
|
||||||
- Dynamic sky colors based on time of day
|
- Dynamic sky colors based on time of day
|
||||||
- Weather visualization with cloud sprites
|
- Weather visualization with cloud sprites
|
||||||
- Directional view (N/E/S/W) with themed backgrounds
|
- Directional view (N/E/S/W) with themed backgrounds
|
||||||
- Auto-discovery of ADS-B receivers on your network, with per-interface scanning
|
- Auto-discovery of ADS-B receivers on your network
|
||||||
- Canvas-based 10 FPS retro rendering
|
- Canvas-based 10 FPS retro rendering
|
||||||
- Admin panel with password authentication
|
- Admin panel with password authentication
|
||||||
- **In-app pixel editor** — draw and edit sprites in the browser (pencil, shapes, fill, select & move, reference overlay, custom palettes)
|
|
||||||
- **Receiver health dashboard** — live per-receiver status (receiving / no data / unreachable), connection testing, and select → save → apply flow
|
|
||||||
- First-run setup wizard
|
- First-run setup wizard
|
||||||
|
|
||||||
## Quick Start
|
## Quick Start
|
||||||
@@ -104,8 +102,8 @@ ADS-Bit uses a first-run setup wizard to configure your installation. You can al
|
|||||||
"receiver_port": 30003,
|
"receiver_port": 30003,
|
||||||
"location": {
|
"location": {
|
||||||
"name": "My Location",
|
"name": "My Location",
|
||||||
"lat": 0.0,
|
"lat": 36.2788,
|
||||||
"lon": 0.0
|
"lon": -115.2283
|
||||||
},
|
},
|
||||||
"web_port": 2001,
|
"web_port": 2001,
|
||||||
"theme": "desert"
|
"theme": "desert"
|
||||||
|
|||||||
-387
@@ -169,15 +169,6 @@ textarea {
|
|||||||
margin: 0;
|
margin: 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
.admin-version {
|
|
||||||
font-family: 'Courier New', monospace;
|
|
||||||
font-size: 11px;
|
|
||||||
color: #54fc54;
|
|
||||||
text-shadow: none;
|
|
||||||
margin-left: 6px;
|
|
||||||
vertical-align: middle;
|
|
||||||
}
|
|
||||||
|
|
||||||
.header-actions {
|
.header-actions {
|
||||||
display: flex;
|
display: flex;
|
||||||
gap: 8px;
|
gap: 8px;
|
||||||
@@ -601,384 +592,6 @@ textarea {
|
|||||||
font-size: 11px;
|
font-size: 11px;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* ===================================================================
|
|
||||||
Receivers tab — status indicators & selectable scan results
|
|
||||||
=================================================================== */
|
|
||||||
.rx-section-label {
|
|
||||||
font-family: 'Press Start 2P', monospace;
|
|
||||||
font-size: 10px;
|
|
||||||
color: #fcd444;
|
|
||||||
margin: 22px 0 12px;
|
|
||||||
padding-bottom: 6px;
|
|
||||||
border-bottom: 1px solid rgba(92, 148, 252, 0.3);
|
|
||||||
}
|
|
||||||
|
|
||||||
.rx-summary {
|
|
||||||
font-family: 'Courier New', monospace;
|
|
||||||
font-size: 12px;
|
|
||||||
color: #b4d4ec;
|
|
||||||
}
|
|
||||||
|
|
||||||
#receiver-status-list {
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 8px;
|
|
||||||
margin-bottom: 12px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.rx-status-item {
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
gap: 10px;
|
|
||||||
background: rgba(0, 0, 0, 0.3);
|
|
||||||
border: 1px solid rgba(92, 148, 252, 0.4);
|
|
||||||
border-radius: 6px;
|
|
||||||
padding: 8px 12px;
|
|
||||||
font-size: 13px;
|
|
||||||
flex-wrap: wrap;
|
|
||||||
}
|
|
||||||
|
|
||||||
.rx-dot {
|
|
||||||
width: 12px;
|
|
||||||
height: 12px;
|
|
||||||
border-radius: 50%;
|
|
||||||
flex-shrink: 0;
|
|
||||||
box-shadow: 0 0 6px currentColor;
|
|
||||||
}
|
|
||||||
.rx-dot.green { background: #54fc54; color: #54fc54; }
|
|
||||||
.rx-dot.yellow { background: #fcd444; color: #fcd444; }
|
|
||||||
.rx-dot.red { background: #fc5454; color: #fc5454; }
|
|
||||||
.rx-dot.gray { background: #888; color: #888; box-shadow: none; }
|
|
||||||
|
|
||||||
.rx-ip {
|
|
||||||
font-family: 'Courier New', monospace;
|
|
||||||
font-weight: bold;
|
|
||||||
color: #fcfcfc;
|
|
||||||
min-width: 110px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.rx-label {
|
|
||||||
font-family: 'Press Start 2P', monospace;
|
|
||||||
font-size: 8px;
|
|
||||||
}
|
|
||||||
.rx-green { color: #54fc54; }
|
|
||||||
.rx-yellow { color: #fcd444; }
|
|
||||||
.rx-red { color: #fc5454; }
|
|
||||||
.rx-gray { color: #888; }
|
|
||||||
|
|
||||||
.rx-detail {
|
|
||||||
color: #b4d4ec;
|
|
||||||
font-size: 11px;
|
|
||||||
margin-left: auto;
|
|
||||||
}
|
|
||||||
|
|
||||||
.rx-scan-item {
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
gap: 10px;
|
|
||||||
padding: 6px 4px;
|
|
||||||
cursor: pointer;
|
|
||||||
border-bottom: 1px solid rgba(92, 148, 252, 0.2);
|
|
||||||
}
|
|
||||||
|
|
||||||
.rx-scan-item input[type="checkbox"] {
|
|
||||||
width: 16px;
|
|
||||||
height: 16px;
|
|
||||||
accent-color: #fcd444;
|
|
||||||
cursor: pointer;
|
|
||||||
}
|
|
||||||
|
|
||||||
.rx-scan-ip {
|
|
||||||
font-family: 'Courier New', monospace;
|
|
||||||
font-weight: bold;
|
|
||||||
color: #fcfcfc;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* ===================================================================
|
|
||||||
Pixel Editor
|
|
||||||
=================================================================== */
|
|
||||||
.pe-overlay {
|
|
||||||
position: fixed;
|
|
||||||
inset: 0;
|
|
||||||
background: rgba(0, 0, 0, 0.85);
|
|
||||||
z-index: 2000;
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
justify-content: center;
|
|
||||||
padding: 20px;
|
|
||||||
}
|
|
||||||
|
|
||||||
body.pe-open { overflow: hidden; }
|
|
||||||
|
|
||||||
.pe-modal {
|
|
||||||
background: linear-gradient(180deg, #2c3e50 0%, #1a252f 100%);
|
|
||||||
border: 3px solid #fcd444;
|
|
||||||
border-radius: 12px;
|
|
||||||
width: 100%;
|
|
||||||
max-width: 1100px;
|
|
||||||
height: 100%;
|
|
||||||
max-height: 760px;
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
box-shadow: 0 8px 40px rgba(0, 0, 0, 0.6);
|
|
||||||
overflow: hidden;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-header {
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
justify-content: space-between;
|
|
||||||
padding: 12px 16px;
|
|
||||||
background: rgba(0, 0, 0, 0.3);
|
|
||||||
border-bottom: 2px solid #5c94fc;
|
|
||||||
flex-wrap: wrap;
|
|
||||||
gap: 8px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-header .retro-title {
|
|
||||||
font-size: 13px;
|
|
||||||
margin: 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-header-actions {
|
|
||||||
display: flex;
|
|
||||||
gap: 6px;
|
|
||||||
flex-wrap: wrap;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-body {
|
|
||||||
flex: 1;
|
|
||||||
display: grid;
|
|
||||||
grid-template-columns: auto 1fr auto;
|
|
||||||
grid-template-rows: 1fr;
|
|
||||||
min-height: 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Toolbar (left column) */
|
|
||||||
.pe-toolbar {
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 14px;
|
|
||||||
padding: 14px 10px;
|
|
||||||
background: rgba(0, 0, 0, 0.25);
|
|
||||||
border-right: 2px solid #5c94fc;
|
|
||||||
overflow-y: auto;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-tool-group {
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 6px;
|
|
||||||
padding-bottom: 12px;
|
|
||||||
border-bottom: 1px solid rgba(92, 148, 252, 0.25);
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-tool-group:last-child { border-bottom: none; padding-bottom: 0; }
|
|
||||||
|
|
||||||
.pe-tool, .pe-icon-btn {
|
|
||||||
width: 44px;
|
|
||||||
height: 44px;
|
|
||||||
font-size: 20px;
|
|
||||||
line-height: 1;
|
|
||||||
border: 2px solid #5c94fc;
|
|
||||||
border-radius: 6px;
|
|
||||||
background: rgba(92, 148, 252, 0.15);
|
|
||||||
color: #fcfcfc;
|
|
||||||
cursor: pointer;
|
|
||||||
transition: all 0.12s;
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
justify-content: center;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-tool:hover, .pe-icon-btn:hover:not(:disabled) {
|
|
||||||
background: rgba(92, 148, 252, 0.4);
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-tool.active {
|
|
||||||
background: rgba(252, 212, 68, 0.3);
|
|
||||||
border-color: #fcd444;
|
|
||||||
color: #fcd444;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-icon-btn:disabled {
|
|
||||||
opacity: 0.35;
|
|
||||||
cursor: not-allowed;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-tool-label {
|
|
||||||
font-family: 'Press Start 2P', monospace;
|
|
||||||
font-size: 8px;
|
|
||||||
color: #b4d4ec;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-check {
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
gap: 6px;
|
|
||||||
font-family: 'Press Start 2P', monospace;
|
|
||||||
font-size: 8px;
|
|
||||||
color: #b4d4ec;
|
|
||||||
cursor: pointer;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-check input { width: 16px; height: 16px; accent-color: #fcd444; cursor: pointer; }
|
|
||||||
|
|
||||||
.pe-brush-group { align-items: center; }
|
|
||||||
.pe-brush-group input[type="range"] { width: 44px; accent-color: #fcd444; }
|
|
||||||
|
|
||||||
/* Canvas area (center column) */
|
|
||||||
.pe-canvas-wrap {
|
|
||||||
position: relative;
|
|
||||||
min-width: 0;
|
|
||||||
background: #14202b;
|
|
||||||
overflow: hidden;
|
|
||||||
}
|
|
||||||
|
|
||||||
#pe-view {
|
|
||||||
display: block;
|
|
||||||
width: 100%;
|
|
||||||
height: 100%;
|
|
||||||
touch-action: none;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Sidebar (right column) */
|
|
||||||
.pe-sidebar {
|
|
||||||
width: 150px;
|
|
||||||
padding: 14px 12px;
|
|
||||||
background: rgba(0, 0, 0, 0.25);
|
|
||||||
border-left: 2px solid #5c94fc;
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 14px;
|
|
||||||
overflow-y: auto;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-color-current {
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 8px;
|
|
||||||
align-items: center;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-swatch-large {
|
|
||||||
width: 100%;
|
|
||||||
height: 48px;
|
|
||||||
border: 2px solid #fcfcfc;
|
|
||||||
border-radius: 6px;
|
|
||||||
background: #5c94fc;
|
|
||||||
}
|
|
||||||
|
|
||||||
#pe-color-input {
|
|
||||||
width: 100%;
|
|
||||||
height: 32px;
|
|
||||||
padding: 2px;
|
|
||||||
border: 2px solid #5c94fc;
|
|
||||||
border-radius: 6px;
|
|
||||||
background: rgba(0, 0, 0, 0.5);
|
|
||||||
cursor: pointer;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-palette {
|
|
||||||
display: grid;
|
|
||||||
grid-template-columns: repeat(4, 1fr);
|
|
||||||
gap: 4px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-swatch {
|
|
||||||
aspect-ratio: 1;
|
|
||||||
border: 1px solid rgba(255, 255, 255, 0.3);
|
|
||||||
border-radius: 3px;
|
|
||||||
cursor: pointer;
|
|
||||||
padding: 0;
|
|
||||||
transition: transform 0.1s;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-swatch:hover {
|
|
||||||
transform: scale(1.12);
|
|
||||||
border-color: #fcd444;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-readout {
|
|
||||||
margin-top: auto;
|
|
||||||
font-family: 'Press Start 2P', monospace;
|
|
||||||
font-size: 8px;
|
|
||||||
color: #b4d4ec;
|
|
||||||
line-height: 2.2;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-readout span { color: #54fc54; }
|
|
||||||
|
|
||||||
/* Sidebar: opacity, palettes, reference */
|
|
||||||
.pe-opacity-group {
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 4px;
|
|
||||||
}
|
|
||||||
.pe-opacity-group input[type="range"] { width: 100%; accent-color: #fcd444; }
|
|
||||||
|
|
||||||
.pe-subhead {
|
|
||||||
font-family: 'Press Start 2P', monospace;
|
|
||||||
font-size: 7px;
|
|
||||||
color: #b4d4ec;
|
|
||||||
margin-top: 4px;
|
|
||||||
letter-spacing: 1px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-mini-btn {
|
|
||||||
font-family: 'Press Start 2P', monospace;
|
|
||||||
font-size: 7px;
|
|
||||||
padding: 6px 4px;
|
|
||||||
border: 2px solid #5c94fc;
|
|
||||||
border-radius: 5px;
|
|
||||||
background: rgba(92, 148, 252, 0.15);
|
|
||||||
color: #fcfcfc;
|
|
||||||
cursor: pointer;
|
|
||||||
transition: all 0.12s;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
.pe-mini-btn:hover { background: rgba(92, 148, 252, 0.4); }
|
|
||||||
|
|
||||||
#pe-custom-palette:empty::after,
|
|
||||||
#pe-recent-palette:empty::after {
|
|
||||||
content: '—';
|
|
||||||
color: #555;
|
|
||||||
font-size: 11px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.pe-ref-controls {
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 6px;
|
|
||||||
}
|
|
||||||
.pe-ref-row { display: flex; gap: 6px; }
|
|
||||||
.pe-ref-row .pe-mini-btn { flex: 1; }
|
|
||||||
.pe-ref-load { display: inline-block; }
|
|
||||||
.pe-ref-controls input[type="range"] { width: 100%; accent-color: #fcd444; }
|
|
||||||
|
|
||||||
/* Sprite card EDIT button uses primary accent */
|
|
||||||
.sprite-edit-btn { border-color: #fcd444; color: #fcd444; }
|
|
||||||
.sprite-edit-btn:hover { background: rgba(252, 212, 68, 0.3); }
|
|
||||||
|
|
||||||
@media (max-width: 768px) {
|
|
||||||
.pe-modal { max-height: none; border-radius: 0; }
|
|
||||||
.pe-body { grid-template-columns: auto 1fr; }
|
|
||||||
.pe-sidebar {
|
|
||||||
grid-column: 1 / -1;
|
|
||||||
grid-row: 2;
|
|
||||||
width: auto;
|
|
||||||
flex-direction: row;
|
|
||||||
flex-wrap: wrap;
|
|
||||||
align-items: center;
|
|
||||||
border-left: none;
|
|
||||||
border-top: 2px solid #5c94fc;
|
|
||||||
}
|
|
||||||
.pe-body { grid-template-rows: 1fr auto; }
|
|
||||||
.pe-palette { flex: 1; }
|
|
||||||
.pe-readout { margin-top: 0; }
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Mobile */
|
/* Mobile */
|
||||||
@media (max-width: 768px) {
|
@media (max-width: 768px) {
|
||||||
.admin-header {
|
.admin-header {
|
||||||
|
|||||||
+12
-45
@@ -7,7 +7,7 @@
|
|||||||
<link rel="preconnect" href="https://fonts.googleapis.com">
|
<link rel="preconnect" href="https://fonts.googleapis.com">
|
||||||
<link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
|
<link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
|
||||||
<link href="https://fonts.googleapis.com/css2?family=Press+Start+2P&display=swap" rel="stylesheet">
|
<link href="https://fonts.googleapis.com/css2?family=Press+Start+2P&display=swap" rel="stylesheet">
|
||||||
<link rel="stylesheet" href="/admin/admin.css?v=20260609d">
|
<link rel="stylesheet" href="/admin/admin.css">
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<!-- Login Screen -->
|
<!-- Login Screen -->
|
||||||
@@ -27,7 +27,7 @@
|
|||||||
<!-- Admin Panel -->
|
<!-- Admin Panel -->
|
||||||
<div id="admin-panel" class="hidden">
|
<div id="admin-panel" class="hidden">
|
||||||
<header class="admin-header">
|
<header class="admin-header">
|
||||||
<h1 class="retro-title">ADS-Bit Admin <span id="admin-version" class="admin-version"></span></h1>
|
<h1 class="retro-title">ADS-Bit Admin</h1>
|
||||||
<div class="header-actions">
|
<div class="header-actions">
|
||||||
<a href="/" class="btn btn-small">VIEWER</a>
|
<a href="/" class="btn btn-small">VIEWER</a>
|
||||||
<button id="logout-btn" class="btn btn-small btn-danger">LOGOUT</button>
|
<button id="logout-btn" class="btn btn-small btn-danger">LOGOUT</button>
|
||||||
@@ -76,69 +76,37 @@
|
|||||||
<!-- Receivers Tab -->
|
<!-- Receivers Tab -->
|
||||||
<section id="tab-receivers" class="tab-pane hidden">
|
<section id="tab-receivers" class="tab-pane hidden">
|
||||||
<h2>Receiver Configuration</h2>
|
<h2>Receiver Configuration</h2>
|
||||||
|
<div id="network-info-box" class="info-box">
|
||||||
<!-- Live status of the receivers the app is currently using -->
|
<h3>Host Network</h3>
|
||||||
<div id="receiver-status-box" class="info-box">
|
<div id="network-info">Loading...</div>
|
||||||
<h3>Active Receivers <span id="receiver-status-summary" class="rx-summary"></span></h3>
|
|
||||||
<div id="receiver-status-list">Loading...</div>
|
|
||||||
<div class="button-row">
|
|
||||||
<button id="test-receivers-btn" class="btn">TEST CONNECTIONS</button>
|
|
||||||
<button id="restart-receivers-btn" class="btn">RESTART CONNECTIONS</button>
|
|
||||||
</div>
|
|
||||||
<p class="hint">🟢 receiving data 🟡 connected, no data yet 🔴 unreachable</p>
|
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- Step 1: choose how receivers are selected -->
|
|
||||||
<div class="rx-section-label">1. Select Receivers</div>
|
|
||||||
<div class="form-group">
|
<div class="form-group">
|
||||||
<label>Discovery Mode</label>
|
<label>Discovery Mode</label>
|
||||||
<select id="receiver-mode">
|
<select id="receiver-mode">
|
||||||
<option value="AUTO">AUTO (use all receivers found on the network)</option>
|
<option value="AUTO">AUTO (scan network)</option>
|
||||||
<option value="MANUAL">MANUAL (use only the IPs I specify)</option>
|
<option value="MANUAL">MANUAL (specify IPs)</option>
|
||||||
</select>
|
</select>
|
||||||
</div>
|
</div>
|
||||||
<div id="manual-ips-group" class="form-group hidden">
|
<div id="manual-ips-group" class="form-group hidden">
|
||||||
<label>Receiver IPs (one per line)</label>
|
<label>Receiver IPs (one per line)</label>
|
||||||
<textarea id="receiver-ips-input" rows="4" placeholder="192.168.1.100 192.168.1.101"></textarea>
|
<textarea id="receiver-ips-input" rows="4" placeholder="192.168.1.100 192.168.1.101"></textarea>
|
||||||
<span class="hint">The app connects to every IP listed here.</span>
|
|
||||||
</div>
|
</div>
|
||||||
<div class="form-group">
|
<div class="form-group">
|
||||||
<label>Receiver Port</label>
|
<label>Receiver Port</label>
|
||||||
<input type="number" id="receiver-port" value="30003" min="1" max="65535">
|
<input type="number" id="receiver-port" value="30003" min="1" max="65535">
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- Step 2: save + apply -->
|
|
||||||
<div class="rx-section-label">2. Save & Apply</div>
|
|
||||||
<div class="button-row">
|
|
||||||
<button id="save-receivers-btn" class="btn btn-primary">SAVE & APPLY</button>
|
|
||||||
</div>
|
|
||||||
<p class="hint">Saves your selection, reconnects immediately, then re-tests the receivers below.</p>
|
|
||||||
|
|
||||||
<!-- Find receivers on the network -->
|
|
||||||
<div class="rx-section-label">Find Receivers on Network</div>
|
|
||||||
<div class="form-group">
|
<div class="form-group">
|
||||||
<label>Interface / Subnet to Scan</label>
|
<label>Custom Subnet (optional)</label>
|
||||||
<select id="scan-interface"></select>
|
<input type="text" id="scan-subnet" placeholder="e.g. 10.0.0.0/24 (leave empty to scan all local subnets)">
|
||||||
<span class="hint">Pick a network interface to scan, or scan all local subnets.</span>
|
|
||||||
</div>
|
|
||||||
<div class="form-group">
|
|
||||||
<label>Custom Subnet (optional override)</label>
|
|
||||||
<input type="text" id="scan-subnet" placeholder="e.g. 10.0.0.0/24 — overrides the selection above">
|
|
||||||
</div>
|
</div>
|
||||||
<div class="button-row">
|
<div class="button-row">
|
||||||
<button id="scan-receivers-btn" class="btn">SCAN NOW</button>
|
<button id="scan-receivers-btn" class="btn">SCAN NOW</button>
|
||||||
|
<button id="restart-receivers-btn" class="btn">RESTART CONNECTIONS</button>
|
||||||
|
<button id="save-receivers-btn" class="btn btn-primary">SAVE</button>
|
||||||
</div>
|
</div>
|
||||||
<div id="scan-results" class="info-box hidden">
|
<div id="scan-results" class="info-box hidden">
|
||||||
<h3>Scan Results</h3>
|
<h3>Scan Results</h3>
|
||||||
<div id="scan-results-list"></div>
|
<div id="scan-results-list"></div>
|
||||||
<div class="button-row" id="scan-use-row" style="display:none">
|
|
||||||
<button id="use-selected-btn" class="btn btn-primary">USE SELECTED RECEIVERS</button>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div id="network-info-box" class="info-box">
|
|
||||||
<h3>Host Network</h3>
|
|
||||||
<div id="network-info">Loading...</div>
|
|
||||||
</div>
|
</div>
|
||||||
</section>
|
</section>
|
||||||
|
|
||||||
@@ -297,7 +265,6 @@
|
|||||||
<div id="toast" class="toast hidden"></div>
|
<div id="toast" class="toast hidden"></div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<script src="/admin/pixel-editor.js?v=20260609d"></script>
|
<script src="/admin/admin.js"></script>
|
||||||
<script src="/admin/admin.js?v=20260609d"></script>
|
|
||||||
</body>
|
</body>
|
||||||
</html>
|
</html>
|
||||||
|
|||||||
+18
-247
@@ -28,22 +28,10 @@
|
|||||||
loadConfig();
|
loadConfig();
|
||||||
loadThemes();
|
loadThemes();
|
||||||
loadNetworkInfo();
|
loadNetworkInfo();
|
||||||
loadVersion();
|
|
||||||
refreshStatus();
|
refreshStatus();
|
||||||
statusInterval = setInterval(refreshStatus, 5000);
|
statusInterval = setInterval(refreshStatus, 5000);
|
||||||
}
|
}
|
||||||
|
|
||||||
async function loadVersion() {
|
|
||||||
try {
|
|
||||||
const res = await fetch('/api/config');
|
|
||||||
if (!res.ok) return;
|
|
||||||
const data = await res.json();
|
|
||||||
if (data.version) {
|
|
||||||
document.getElementById('admin-version').textContent = 'v' + data.version;
|
|
||||||
}
|
|
||||||
} catch (e) { /* ignore */ }
|
|
||||||
}
|
|
||||||
|
|
||||||
document.getElementById('login-form').addEventListener('submit', async (e) => {
|
document.getElementById('login-form').addEventListener('submit', async (e) => {
|
||||||
e.preventDefault();
|
e.preventDefault();
|
||||||
const pw = document.getElementById('login-password').value;
|
const pw = document.getElementById('login-password').value;
|
||||||
@@ -90,12 +78,6 @@
|
|||||||
themesManagerLoaded = true;
|
themesManagerLoaded = true;
|
||||||
loadThemeManager();
|
loadThemeManager();
|
||||||
}
|
}
|
||||||
// Live receiver health polling only while the Receivers tab is open
|
|
||||||
if (tab.dataset.tab === 'receivers') {
|
|
||||||
startReceiverStatusPolling();
|
|
||||||
} else {
|
|
||||||
stopReceiverStatusPolling();
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -209,44 +191,11 @@
|
|||||||
});
|
});
|
||||||
html += '</table>';
|
html += '</table>';
|
||||||
el.innerHTML = html;
|
el.innerHTML = html;
|
||||||
|
|
||||||
populateScanInterfaces(ifaces);
|
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
el.textContent = 'Error loading network info';
|
el.textContent = 'Error loading network info';
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Build the "Interface / Subnet to Scan" dropdown from the host interfaces.
|
|
||||||
// Subnets larger than /20 (>4094 hosts) are disabled — the server rejects
|
|
||||||
// them anyway, and scanning e.g. a docker /16 is impractically slow.
|
|
||||||
const MAX_SCAN_HOSTS = 4094;
|
|
||||||
function populateScanInterfaces(ifaces) {
|
|
||||||
const sel = document.getElementById('scan-interface');
|
|
||||||
if (!sel) return;
|
|
||||||
sel.innerHTML = '';
|
|
||||||
|
|
||||||
const allOpt = document.createElement('option');
|
|
||||||
allOpt.value = '';
|
|
||||||
allOpt.textContent = 'All local subnets (slower)';
|
|
||||||
sel.appendChild(allOpt);
|
|
||||||
|
|
||||||
let firstScannable = null;
|
|
||||||
ifaces.forEach(i => {
|
|
||||||
const prefix = parseInt((i.network.split('/')[1]) || '0', 10);
|
|
||||||
const hosts = Math.max(0, Math.pow(2, 32 - prefix) - 2);
|
|
||||||
const opt = document.createElement('option');
|
|
||||||
opt.value = i.network;
|
|
||||||
const tooBig = hosts > MAX_SCAN_HOSTS;
|
|
||||||
opt.textContent = `${i.name} — ${i.network} (${hosts} hosts)` + (tooBig ? ' — too large' : '');
|
|
||||||
opt.disabled = tooBig;
|
|
||||||
sel.appendChild(opt);
|
|
||||||
if (!tooBig && firstScannable === null) firstScannable = i.network;
|
|
||||||
});
|
|
||||||
|
|
||||||
// Default to the first reasonably-sized interface for a fast scan.
|
|
||||||
if (firstScannable !== null) sel.value = firstScannable;
|
|
||||||
}
|
|
||||||
|
|
||||||
// ------- Receivers -------
|
// ------- Receivers -------
|
||||||
function toggleManualIps(mode) {
|
function toggleManualIps(mode) {
|
||||||
document.getElementById('manual-ips-group').classList.toggle('hidden', mode === 'AUTO');
|
document.getElementById('manual-ips-group').classList.toggle('hidden', mode === 'AUTO');
|
||||||
@@ -261,10 +210,7 @@
|
|||||||
btn.textContent = 'SCANNING...';
|
btn.textContent = 'SCANNING...';
|
||||||
btn.disabled = true;
|
btn.disabled = true;
|
||||||
try {
|
try {
|
||||||
// Custom subnet text overrides the interface dropdown selection.
|
const subnet = (document.getElementById('scan-subnet').value || '').trim();
|
||||||
const custom = (document.getElementById('scan-subnet').value || '').trim();
|
|
||||||
const iface = document.getElementById('scan-interface').value || '';
|
|
||||||
const subnet = custom || iface;
|
|
||||||
const fetchOpts = { method: 'POST' };
|
const fetchOpts = { method: 'POST' };
|
||||||
if (subnet) {
|
if (subnet) {
|
||||||
fetchOpts.headers = { 'Content-Type': 'application/json' };
|
fetchOpts.headers = { 'Content-Type': 'application/json' };
|
||||||
@@ -272,7 +218,16 @@
|
|||||||
}
|
}
|
||||||
const res = await fetch('/api/admin/scan-receivers', fetchOpts);
|
const res = await fetch('/api/admin/scan-receivers', fetchOpts);
|
||||||
const data = await res.json();
|
const data = await res.json();
|
||||||
renderScanResults(data);
|
const box = document.getElementById('scan-results');
|
||||||
|
const list = document.getElementById('scan-results-list');
|
||||||
|
box.classList.remove('hidden');
|
||||||
|
if (data.error) {
|
||||||
|
list.textContent = data.error;
|
||||||
|
} else if (data.receivers && data.receivers.length) {
|
||||||
|
list.textContent = data.receivers.join(', ');
|
||||||
|
} else {
|
||||||
|
list.textContent = 'No receivers found on network';
|
||||||
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
toast('Scan failed', true);
|
toast('Scan failed', true);
|
||||||
}
|
}
|
||||||
@@ -280,77 +235,17 @@
|
|||||||
btn.disabled = false;
|
btn.disabled = false;
|
||||||
});
|
});
|
||||||
|
|
||||||
// Render scan results as a selectable checklist.
|
|
||||||
function renderScanResults(data) {
|
|
||||||
const box = document.getElementById('scan-results');
|
|
||||||
const list = document.getElementById('scan-results-list');
|
|
||||||
const useRow = document.getElementById('scan-use-row');
|
|
||||||
box.classList.remove('hidden');
|
|
||||||
list.innerHTML = '';
|
|
||||||
|
|
||||||
if (data.error) {
|
|
||||||
list.textContent = data.error;
|
|
||||||
useRow.style.display = 'none';
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const found = data.receivers || [];
|
|
||||||
if (!found.length) {
|
|
||||||
list.textContent = 'No receivers found on network';
|
|
||||||
useRow.style.display = 'none';
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Pre-check IPs already in the manual list.
|
|
||||||
const current = new Set(document.getElementById('receiver-ips-input').value
|
|
||||||
.split('\n').map(s => s.trim()).filter(Boolean));
|
|
||||||
|
|
||||||
found.forEach(ip => {
|
|
||||||
const row = document.createElement('label');
|
|
||||||
row.className = 'rx-scan-item';
|
|
||||||
row.innerHTML = `
|
|
||||||
<input type="checkbox" value="${ip}" ${current.has(ip) ? 'checked' : ''}>
|
|
||||||
<span class="rx-scan-ip">${ip}</span>`;
|
|
||||||
list.appendChild(row);
|
|
||||||
});
|
|
||||||
useRow.style.display = '';
|
|
||||||
}
|
|
||||||
|
|
||||||
// "USE SELECTED" -> switch to MANUAL, populate IPs, save & apply.
|
|
||||||
document.getElementById('use-selected-btn').addEventListener('click', async () => {
|
|
||||||
const checked = Array.from(
|
|
||||||
document.querySelectorAll('#scan-results-list input[type="checkbox"]:checked')
|
|
||||||
).map(cb => cb.value);
|
|
||||||
if (!checked.length) { toast('Select at least one receiver', true); return; }
|
|
||||||
|
|
||||||
document.getElementById('receiver-mode').value = 'MANUAL';
|
|
||||||
toggleManualIps('MANUAL');
|
|
||||||
document.getElementById('receiver-ips-input').value = checked.join('\n');
|
|
||||||
await saveAndApplyReceivers();
|
|
||||||
});
|
|
||||||
|
|
||||||
document.getElementById('restart-receivers-btn').addEventListener('click', async () => {
|
document.getElementById('restart-receivers-btn').addEventListener('click', async () => {
|
||||||
const btn = document.getElementById('restart-receivers-btn');
|
|
||||||
const orig = btn.textContent;
|
|
||||||
btn.textContent = 'RESTARTING…';
|
|
||||||
btn.disabled = true;
|
|
||||||
try {
|
try {
|
||||||
const res = await fetch('/api/admin/restart-receivers', { method: 'POST' });
|
const res = await fetch('/api/admin/restart-receivers', { method: 'POST' });
|
||||||
if (res.ok) { toast('Receivers restarted'); await testReceivers(); }
|
if (res.ok) toast('Receivers restarted');
|
||||||
else toast('Failed to restart', true);
|
else toast('Failed to restart', true);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
toast('Error restarting receivers', true);
|
toast('Error restarting receivers', true);
|
||||||
}
|
}
|
||||||
btn.textContent = orig;
|
|
||||||
btn.disabled = false;
|
|
||||||
});
|
});
|
||||||
|
|
||||||
document.getElementById('save-receivers-btn').addEventListener('click', saveAndApplyReceivers);
|
document.getElementById('save-receivers-btn').addEventListener('click', async () => {
|
||||||
|
|
||||||
// Save the receiver selection, reconnect, then re-test — the full
|
|
||||||
// select -> save -> verify loop in one action.
|
|
||||||
async function saveAndApplyReceivers() {
|
|
||||||
const btn = document.getElementById('save-receivers-btn');
|
|
||||||
const orig = btn.textContent;
|
|
||||||
const mode = document.getElementById('receiver-mode').value;
|
const mode = document.getElementById('receiver-mode').value;
|
||||||
const port = parseInt(document.getElementById('receiver-port').value) || 30003;
|
const port = parseInt(document.getElementById('receiver-port').value) || 30003;
|
||||||
const body = { receiver_port: port };
|
const body = { receiver_port: port };
|
||||||
@@ -360,122 +255,11 @@
|
|||||||
} else {
|
} else {
|
||||||
const ips = document.getElementById('receiver-ips-input').value
|
const ips = document.getElementById('receiver-ips-input').value
|
||||||
.split('\n').map(s => s.trim()).filter(Boolean);
|
.split('\n').map(s => s.trim()).filter(Boolean);
|
||||||
if (!ips.length) { toast('Enter at least one receiver IP', true); return; }
|
body.receivers = ips.length ? ips : 'AUTO';
|
||||||
body.receivers = ips;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
btn.textContent = 'APPLYING…';
|
await saveConfig(body);
|
||||||
btn.disabled = true;
|
});
|
||||||
try {
|
|
||||||
const saved = await saveConfig(body, true);
|
|
||||||
if (saved) {
|
|
||||||
// Apply immediately so the active list reflects the new selection.
|
|
||||||
await fetch('/api/admin/restart-receivers', { method: 'POST' });
|
|
||||||
await testReceivers();
|
|
||||||
toast('Saved & applied — testing connections');
|
|
||||||
}
|
|
||||||
} catch (e) {
|
|
||||||
toast('Failed to apply', true);
|
|
||||||
}
|
|
||||||
btn.textContent = orig;
|
|
||||||
btn.disabled = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
// ------- Receiver status / health -------
|
|
||||||
let receiverStatusInterval = null;
|
|
||||||
|
|
||||||
function startReceiverStatusPolling() {
|
|
||||||
loadReceiverStatus();
|
|
||||||
if (!receiverStatusInterval) {
|
|
||||||
receiverStatusInterval = setInterval(loadReceiverStatus, 4000);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function stopReceiverStatusPolling() {
|
|
||||||
if (receiverStatusInterval) {
|
|
||||||
clearInterval(receiverStatusInterval);
|
|
||||||
receiverStatusInterval = null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async function loadReceiverStatus() {
|
|
||||||
const list = document.getElementById('receiver-status-list');
|
|
||||||
try {
|
|
||||||
const res = await fetch('/api/admin/receiver-status');
|
|
||||||
if (!res.ok) {
|
|
||||||
// 404 here almost always means the server is running an older
|
|
||||||
// build without this endpoint — tell the user instead of
|
|
||||||
// leaving a silent "Loading…".
|
|
||||||
if (res.status === 404) {
|
|
||||||
list.innerHTML = '<span class="no-sprite">Status endpoint not found — ' +
|
|
||||||
'restart the server to load the latest build.</span>';
|
|
||||||
}
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const data = await res.json();
|
|
||||||
renderReceiverStatus(data.receivers || [], data.configured);
|
|
||||||
} catch (e) {
|
|
||||||
// Only replace the initial placeholder; don't clobber good data on
|
|
||||||
// a transient poll failure.
|
|
||||||
if (/Loading/.test(list.textContent)) {
|
|
||||||
list.innerHTML = '<span class="no-sprite">Could not reach server.</span>';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
document.getElementById('test-receivers-btn').addEventListener('click', testReceivers);
|
|
||||||
|
|
||||||
async function testReceivers() {
|
|
||||||
const btn = document.getElementById('test-receivers-btn');
|
|
||||||
const orig = btn.textContent;
|
|
||||||
btn.textContent = 'TESTING…';
|
|
||||||
btn.disabled = true;
|
|
||||||
try {
|
|
||||||
const res = await fetch('/api/admin/test-receivers', { method: 'POST' });
|
|
||||||
if (res.ok) {
|
|
||||||
const data = await res.json();
|
|
||||||
renderReceiverStatus(data.receivers || [], undefined, true);
|
|
||||||
} else {
|
|
||||||
toast('Test failed', true);
|
|
||||||
}
|
|
||||||
} catch (e) {
|
|
||||||
toast('Test error', true);
|
|
||||||
}
|
|
||||||
btn.textContent = orig;
|
|
||||||
btn.disabled = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
function renderReceiverStatus(statuses, configured, tested) {
|
|
||||||
const list = document.getElementById('receiver-status-list');
|
|
||||||
const summary = document.getElementById('receiver-status-summary');
|
|
||||||
|
|
||||||
if (configured !== undefined) {
|
|
||||||
const modeLabel = (configured === 'AUTO') ? 'AUTO' : 'MANUAL';
|
|
||||||
summary.textContent = `(${statuses.length} • ${modeLabel})`;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!statuses.length) {
|
|
||||||
list.innerHTML = '<span class="no-sprite">No receivers configured. ' +
|
|
||||||
'Use AUTO mode or add IPs below, then SAVE & APPLY.</span>';
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
list.innerHTML = '';
|
|
||||||
statuses.forEach(s => {
|
|
||||||
const row = document.createElement('div');
|
|
||||||
row.className = 'rx-status-item';
|
|
||||||
const detail = s.last_msg_age != null
|
|
||||||
? `${s.msg_count} msgs · last ${s.last_msg_age}s ago`
|
|
||||||
: (s.state === 'down' ? (tested ? 'no response on port' : 'not connected')
|
|
||||||
: 'waiting for data…');
|
|
||||||
row.innerHTML = `
|
|
||||||
<span class="rx-dot ${s.color}"></span>
|
|
||||||
<span class="rx-ip">${s.ip}</span>
|
|
||||||
<span class="rx-label rx-${s.color}">${s.label}</span>
|
|
||||||
<span class="rx-detail">${detail}</span>`;
|
|
||||||
list.appendChild(row);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
// ------- Location -------
|
// ------- Location -------
|
||||||
document.getElementById('browser-location-btn').addEventListener('click', () => {
|
document.getElementById('browser-location-btn').addEventListener('click', () => {
|
||||||
@@ -738,7 +522,6 @@
|
|||||||
<div class="sprite-categories">${sprite.categories || ''}</div>
|
<div class="sprite-categories">${sprite.categories || ''}</div>
|
||||||
<div class="sprite-preview">${imgHtml}</div>
|
<div class="sprite-preview">${imgHtml}</div>
|
||||||
<div class="sprite-btn-row">
|
<div class="sprite-btn-row">
|
||||||
<button class="sprite-upload-label sprite-edit-btn" data-type="${sprite.type}">EDIT</button>
|
|
||||||
<label class="sprite-upload-label">
|
<label class="sprite-upload-label">
|
||||||
UPLOAD
|
UPLOAD
|
||||||
<input type="file" class="sprite-upload-input" accept=".png,image/png" data-type="${sprite.type}">
|
<input type="file" class="sprite-upload-input" accept=".png,image/png" data-type="${sprite.type}">
|
||||||
@@ -747,15 +530,6 @@
|
|||||||
</div>
|
</div>
|
||||||
`;
|
`;
|
||||||
|
|
||||||
const editBtn = card.querySelector('.sprite-edit-btn');
|
|
||||||
editBtn.addEventListener('click', () => {
|
|
||||||
if (window.PixelEditor) {
|
|
||||||
window.PixelEditor.open(sprite.type, { onSave: loadSprites });
|
|
||||||
} else {
|
|
||||||
toast('Pixel editor not loaded', true);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
const fileInput = card.querySelector('.sprite-upload-input');
|
const fileInput = card.querySelector('.sprite-upload-input');
|
||||||
fileInput.addEventListener('change', async (e) => {
|
fileInput.addEventListener('change', async (e) => {
|
||||||
const file = e.target.files[0];
|
const file = e.target.files[0];
|
||||||
@@ -796,7 +570,7 @@
|
|||||||
}
|
}
|
||||||
|
|
||||||
// ------- Helpers -------
|
// ------- Helpers -------
|
||||||
async function saveConfig(body, silent) {
|
async function saveConfig(body) {
|
||||||
try {
|
try {
|
||||||
const res = await fetch('/api/admin/config', {
|
const res = await fetch('/api/admin/config', {
|
||||||
method: 'PUT',
|
method: 'PUT',
|
||||||
@@ -804,16 +578,13 @@
|
|||||||
body: JSON.stringify(body)
|
body: JSON.stringify(body)
|
||||||
});
|
});
|
||||||
if (res.ok) {
|
if (res.ok) {
|
||||||
if (!silent) toast('Settings saved');
|
toast('Settings saved');
|
||||||
return true;
|
|
||||||
} else {
|
} else {
|
||||||
const data = await res.json();
|
const data = await res.json();
|
||||||
toast(data.error || 'Save failed', true);
|
toast(data.error || 'Save failed', true);
|
||||||
return false;
|
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
toast('Connection error', true);
|
toast('Connection error', true);
|
||||||
return false;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
Binary file not shown.
|
After Width: | Height: | Size: 264 KiB |
@@ -17,8 +17,6 @@ from aiohttp import web, ClientSession, ClientTimeout
|
|||||||
import netifaces
|
import netifaces
|
||||||
import bcrypt
|
import bcrypt
|
||||||
|
|
||||||
VERSION = "1.1.0"
|
|
||||||
|
|
||||||
WEB_DIR = Path(__file__).parent
|
WEB_DIR = Path(__file__).parent
|
||||||
CONFIG_FILE = WEB_DIR / "config.json"
|
CONFIG_FILE = WEB_DIR / "config.json"
|
||||||
|
|
||||||
@@ -172,69 +170,6 @@ receivers: List[str] = []
|
|||||||
receiver_tasks: List[asyncio.Task] = []
|
receiver_tasks: List[asyncio.Task] = []
|
||||||
emitter_categories: Dict[str, str] = {} # ICAO hex -> ADS-B emitter category (A1, A3, A7, etc.)
|
emitter_categories: Dict[str, str] = {} # ICAO hex -> ADS-B emitter category (A1, A3, A7, etc.)
|
||||||
|
|
||||||
# Live per-receiver connection health, keyed by IP. Each entry:
|
|
||||||
# {"state": "connecting"|"connected"|"down", "last_msg": ts|None,
|
|
||||||
# "msg_count": int, "connected_since": ts|None, "error": str}
|
|
||||||
receiver_status: Dict[str, dict] = {}
|
|
||||||
|
|
||||||
# A receiver is considered "receiving" if it produced a message this recently.
|
|
||||||
RECEIVER_DATA_FRESH_SECONDS = 30
|
|
||||||
|
|
||||||
|
|
||||||
def reset_receiver_status(ips):
|
|
||||||
"""Replace the tracked receiver set, marking each as connecting."""
|
|
||||||
global receiver_status
|
|
||||||
receiver_status = {
|
|
||||||
ip: {"state": "connecting", "last_msg": None,
|
|
||||||
"msg_count": 0, "connected_since": None, "error": ""}
|
|
||||||
for ip in ips
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
def describe_receiver(ip, reachable=None):
|
|
||||||
"""Build a display-friendly status object for one receiver.
|
|
||||||
|
|
||||||
state -> (label, color):
|
|
||||||
down/missing -> DOWN (red)
|
|
||||||
connecting -> CONNECTING (gray)
|
|
||||||
connected + data -> RECEIVING (green)
|
|
||||||
connected, no data -> NO DATA (yellow) (socket up; maybe no aircraft in range)
|
|
||||||
reachable: optional active port-probe result that overrides a stale state.
|
|
||||||
"""
|
|
||||||
st = receiver_status.get(ip)
|
|
||||||
now = time.time()
|
|
||||||
if st is None:
|
|
||||||
state, last_age, msg_count = "down", None, 0
|
|
||||||
else:
|
|
||||||
state = st["state"]
|
|
||||||
last_age = (now - st["last_msg"]) if st["last_msg"] else None
|
|
||||||
msg_count = st["msg_count"]
|
|
||||||
|
|
||||||
# An active probe result is authoritative about reachability.
|
|
||||||
if reachable is False:
|
|
||||||
state = "down"
|
|
||||||
elif reachable is True and state == "down":
|
|
||||||
state = "connected"
|
|
||||||
|
|
||||||
if state == "down":
|
|
||||||
label, color = "DOWN", "red"
|
|
||||||
elif state == "connecting":
|
|
||||||
label, color = "CONNECTING", "gray"
|
|
||||||
elif last_age is not None and last_age <= RECEIVER_DATA_FRESH_SECONDS:
|
|
||||||
label, color = "RECEIVING", "green"
|
|
||||||
else:
|
|
||||||
label, color = "NO DATA", "yellow"
|
|
||||||
|
|
||||||
return {
|
|
||||||
"ip": ip,
|
|
||||||
"state": state,
|
|
||||||
"label": label,
|
|
||||||
"color": color,
|
|
||||||
"msg_count": msg_count,
|
|
||||||
"last_msg_age": round(last_age, 1) if last_age is not None else None,
|
|
||||||
"reachable": reachable,
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
@dataclass
|
@dataclass
|
||||||
class SBSMessage:
|
class SBSMessage:
|
||||||
@@ -311,17 +246,10 @@ async def connect_to_receiver(host: str, port: int = 30003):
|
|||||||
"""Connect to an SBS receiver and process messages"""
|
"""Connect to an SBS receiver and process messages"""
|
||||||
reconnect_delay = config['tuning']['receiver_reconnect_seconds']
|
reconnect_delay = config['tuning']['receiver_reconnect_seconds']
|
||||||
print(f"Connecting to receiver at {host}:{port}...")
|
print(f"Connecting to receiver at {host}:{port}...")
|
||||||
# Ensure a status entry exists even if this task started outside a reset.
|
|
||||||
receiver_status.setdefault(host, {"state": "connecting", "last_msg": None,
|
|
||||||
"msg_count": 0, "connected_since": None, "error": ""})
|
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
receiver_status[host]["state"] = "connecting"
|
|
||||||
reader, writer = await asyncio.open_connection(host, port)
|
reader, writer = await asyncio.open_connection(host, port)
|
||||||
print(f"Connected to {host}:{port}")
|
print(f"Connected to {host}:{port}")
|
||||||
receiver_status[host]["state"] = "connected"
|
|
||||||
receiver_status[host]["connected_since"] = time.time()
|
|
||||||
receiver_status[host]["error"] = ""
|
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
line = await reader.readline()
|
line = await reader.readline()
|
||||||
@@ -331,8 +259,6 @@ async def connect_to_receiver(host: str, port: int = 30003):
|
|||||||
line = line.decode('utf-8', errors='ignore')
|
line = line.decode('utf-8', errors='ignore')
|
||||||
msg = parse_sbs_message(line)
|
msg = parse_sbs_message(line)
|
||||||
if msg and msg.icao:
|
if msg and msg.icao:
|
||||||
receiver_status[host]["last_msg"] = time.time()
|
|
||||||
receiver_status[host]["msg_count"] += 1
|
|
||||||
if msg.icao not in flights:
|
if msg.icao not in flights:
|
||||||
flights[msg.icao] = {
|
flights[msg.icao] = {
|
||||||
'icao': msg.icao,
|
'icao': msg.icao,
|
||||||
@@ -369,14 +295,10 @@ async def connect_to_receiver(host: str, port: int = 30003):
|
|||||||
flight['ground'] = msg.ground
|
flight['ground'] = msg.ground
|
||||||
flight['last_seen'] = time.time()
|
flight['last_seen'] = time.time()
|
||||||
|
|
||||||
# readline returned empty -> peer closed the connection.
|
|
||||||
receiver_status[host]["state"] = "down"
|
|
||||||
writer.close()
|
writer.close()
|
||||||
await writer.wait_closed()
|
await writer.wait_closed()
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print(f"Receiver {host}:{port} error: {e}")
|
print(f"Receiver {host}:{port} error: {e}")
|
||||||
receiver_status[host]["state"] = "down"
|
|
||||||
receiver_status[host]["error"] = str(e)
|
|
||||||
await asyncio.sleep(reconnect_delay)
|
await asyncio.sleep(reconnect_delay)
|
||||||
|
|
||||||
|
|
||||||
@@ -551,7 +473,6 @@ async def handle_receiver_location(request):
|
|||||||
async def handle_config(request):
|
async def handle_config(request):
|
||||||
"""Return client-relevant configuration (public, no secrets)."""
|
"""Return client-relevant configuration (public, no secrets)."""
|
||||||
return web.json_response({
|
return web.json_response({
|
||||||
"version": VERSION,
|
|
||||||
"theme": config.get("theme", "desert"),
|
"theme": config.get("theme", "desert"),
|
||||||
"location": config["location"],
|
"location": config["location"],
|
||||||
"receivers": receivers,
|
"receivers": receivers,
|
||||||
@@ -1071,15 +992,10 @@ async def restart_receiver_connections():
|
|||||||
"""Cancel existing receiver tasks and start new ones."""
|
"""Cancel existing receiver tasks and start new ones."""
|
||||||
global receivers, receiver_tasks
|
global receivers, receiver_tasks
|
||||||
|
|
||||||
# Cancel old tasks and let them unwind cleanly. Awaiting the cancelled
|
# Cancel old tasks
|
||||||
# tasks here (with return_exceptions) absorbs their CancelledError so it
|
for task in receiver_tasks:
|
||||||
# can never propagate into the main event loop.
|
|
||||||
old_tasks = list(receiver_tasks)
|
|
||||||
receiver_tasks.clear()
|
|
||||||
for task in old_tasks:
|
|
||||||
task.cancel()
|
task.cancel()
|
||||||
if old_tasks:
|
receiver_tasks.clear()
|
||||||
await asyncio.gather(*old_tasks, return_exceptions=True)
|
|
||||||
|
|
||||||
# Determine receivers
|
# Determine receivers
|
||||||
receiver_config = config["receivers"]
|
receiver_config = config["receivers"]
|
||||||
@@ -1099,9 +1015,6 @@ async def restart_receiver_connections():
|
|||||||
print(f"Error determining receivers: {e}")
|
print(f"Error determining receivers: {e}")
|
||||||
receivers = []
|
receivers = []
|
||||||
|
|
||||||
# Reset health tracking to the new receiver set.
|
|
||||||
reset_receiver_status(receivers)
|
|
||||||
|
|
||||||
# Start new tasks
|
# Start new tasks
|
||||||
for r in receivers:
|
for r in receivers:
|
||||||
task = asyncio.create_task(connect_to_receiver(r, receiver_port))
|
task = asyncio.create_task(connect_to_receiver(r, receiver_port))
|
||||||
@@ -1117,28 +1030,6 @@ async def handle_admin_restart_receivers(request):
|
|||||||
return web.json_response({"ok": True, "receivers": receivers})
|
return web.json_response({"ok": True, "receivers": receivers})
|
||||||
|
|
||||||
|
|
||||||
@require_auth
|
|
||||||
async def handle_admin_receiver_status(request):
|
|
||||||
"""GET /api/admin/receiver-status - Live health of configured receivers."""
|
|
||||||
statuses = [describe_receiver(ip) for ip in receivers]
|
|
||||||
return web.json_response({
|
|
||||||
"receivers": statuses,
|
|
||||||
"configured": config["receivers"], # "AUTO" or a list of IPs
|
|
||||||
"count": len(receivers),
|
|
||||||
})
|
|
||||||
|
|
||||||
|
|
||||||
@require_auth
|
|
||||||
async def handle_admin_test_receivers(request):
|
|
||||||
"""POST /api/admin/test-receivers - Actively probe each configured receiver
|
|
||||||
and report reachability combined with live data-flow state."""
|
|
||||||
port = config["receiver_port"]
|
|
||||||
probes = await asyncio.gather(*[test_port(ip, port) for ip in receivers])
|
|
||||||
statuses = [describe_receiver(ip, reachable=reachable)
|
|
||||||
for ip, reachable in zip(receivers, probes)]
|
|
||||||
return web.json_response({"receivers": statuses, "count": len(receivers)})
|
|
||||||
|
|
||||||
|
|
||||||
# ---------------------------------------------------------------------------
|
# ---------------------------------------------------------------------------
|
||||||
# Static file serving with setup redirect
|
# Static file serving with setup redirect
|
||||||
# ---------------------------------------------------------------------------
|
# ---------------------------------------------------------------------------
|
||||||
@@ -1212,8 +1103,6 @@ async def start_http_server():
|
|||||||
app.router.add_get('/api/admin/network-info', handle_admin_network_info)
|
app.router.add_get('/api/admin/network-info', handle_admin_network_info)
|
||||||
app.router.add_post('/api/admin/scan-receivers', handle_admin_scan_receivers)
|
app.router.add_post('/api/admin/scan-receivers', handle_admin_scan_receivers)
|
||||||
app.router.add_post('/api/admin/restart-receivers', handle_admin_restart_receivers)
|
app.router.add_post('/api/admin/restart-receivers', handle_admin_restart_receivers)
|
||||||
app.router.add_get('/api/admin/receiver-status', handle_admin_receiver_status)
|
|
||||||
app.router.add_post('/api/admin/test-receivers', handle_admin_test_receivers)
|
|
||||||
app.router.add_get('/api/admin/sprites', handle_admin_sprites)
|
app.router.add_get('/api/admin/sprites', handle_admin_sprites)
|
||||||
app.router.add_post('/api/admin/sprites/{type}', handle_admin_sprite_upload)
|
app.router.add_post('/api/admin/sprites/{type}', handle_admin_sprite_upload)
|
||||||
|
|
||||||
@@ -1234,7 +1123,7 @@ async def main():
|
|||||||
"""Main entry point"""
|
"""Main entry point"""
|
||||||
global receivers, receiver_tasks
|
global receivers, receiver_tasks
|
||||||
|
|
||||||
print(f"ADS-Bit Server v{VERSION} Starting...")
|
print("ADS-Bit Server Starting...")
|
||||||
|
|
||||||
load_config()
|
load_config()
|
||||||
|
|
||||||
@@ -1259,8 +1148,6 @@ async def main():
|
|||||||
else:
|
else:
|
||||||
print(f"Using {len(receivers)} receiver(s)")
|
print(f"Using {len(receivers)} receiver(s)")
|
||||||
|
|
||||||
reset_receiver_status(receivers)
|
|
||||||
|
|
||||||
# Start all tasks
|
# Start all tasks
|
||||||
tasks = [
|
tasks = [
|
||||||
start_http_server(),
|
start_http_server(),
|
||||||
@@ -1269,15 +1156,12 @@ async def main():
|
|||||||
poll_aircraft_json(),
|
poll_aircraft_json(),
|
||||||
]
|
]
|
||||||
|
|
||||||
# Connect to all receivers. These run as independent background tasks and
|
# Connect to all receivers
|
||||||
# are deliberately NOT awaited in the gather below: restarting receivers
|
|
||||||
# cancels them, and a cancelled task inside the main gather would tear down
|
|
||||||
# the whole server. They still run as long as the event loop is alive.
|
|
||||||
for receiver in receivers:
|
for receiver in receivers:
|
||||||
task = asyncio.ensure_future(connect_to_receiver(receiver, receiver_port))
|
task = asyncio.ensure_future(connect_to_receiver(receiver, receiver_port))
|
||||||
receiver_tasks.append(task)
|
receiver_tasks.append(task)
|
||||||
|
tasks.append(task)
|
||||||
|
|
||||||
# Only the core services keep the server alive.
|
|
||||||
await asyncio.gather(*tasks)
|
await asyncio.gather(*tasks)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user