#!/usr/bin/env python3 import cgi import cgitb import json import os import sys # Add the apps directory to Python path for imports sys.path.insert(0, '/opt/ngon/apps') from managers.auth_manager import AuthManager, generate_login_modal_html, generate_access_denied_html # File paths MASTER_CONFIG_FILE = "/opt/ngon/config/master_config.json" # Non-geographic holding sites. Site order everywhere (Site Manager, Generator # Manager, map) is just the key order in master_config.json, so these are kept # pinned to the bottom on every save — the browser appends a newly added site to # the end of window.siteConfig.sites, which would otherwise drop it below them. TRAILING_SITES = ("Spares", "Out of Service", "Out of Service - TX") # Handle form requests form = cgi.FieldStorage() # Initialize authentication auth = AuthManager('site_manager') auth_required, should_exit, headers = auth.require_auth(form) # Handle authentication responses if should_exit: print("Content-Type: application/json") if headers: print(headers) print("") # End headers if auth_required: print('{"success": false, "error": "Authentication required"}') else: print('{"success": true}') sys.exit(0) # Handle logout request if "logout" in form and form.getvalue("logout"): print("Content-Type: text/html") # Clear the authentication cookie import http.cookies cookie = http.cookies.SimpleCookie() cookie['ngon_auth'] = '' cookie['ngon_auth']['path'] = '/' cookie['ngon_auth']['max-age'] = 0 print(cookie.output()) print("") # End headers print("""

Logged Out Successfully

Your authentication session has been cleared.

Return to Site Manager """) sys.exit(0) # Handle AJAX requests IMMEDIATELY - before any HTML headers # Handle miner types save if "ajax_miner_types" in form and form.getvalue("ajax_miner_types"): miner_types_data = form.getvalue("ajax_miner_types") # Send headers immediately print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) # Load existing config with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) # Parse miner types data miner_types = json.loads(miner_types_data) # Update misc section if "misc" not in config: config["misc"] = {} config["misc"]["miner_types"] = miner_types # Update timestamp from datetime import datetime config["last_updated"] = datetime.now().isoformat() # Save updated config with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Error saving miner types: {str(e)}"}}') sys.exit(0) # Handle employees save if "ajax_employees" in form and form.getvalue("ajax_employees"): employees_data = form.getvalue("ajax_employees") # Send headers immediately print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) # Load existing config with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) # Parse employees data employees = json.loads(employees_data) # Update misc section if "misc" not in config: config["misc"] = {} config["misc"]["employees"] = employees # Update timestamp from datetime import datetime config["last_updated"] = datetime.now().isoformat() # Save updated config with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Error saving employees: {str(e)}"}}') sys.exit(0) # Handle generator warning settings save (misc.gen_warnings) # Direct file write (mirrors miner_types/employees). No status_api broadcast # needed: gen_ingest_api re-reads master_config fresh each 5-min sweep via # gen_warnings.load_rules(), so the next sweep picks up the new thresholds. if "ajax_gen_warnings" in form and form.getvalue("ajax_gen_warnings"): gen_warnings_data = form.getvalue("ajax_gen_warnings") print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) gen_warnings_cfg = json.loads(gen_warnings_data) if "misc" not in config: config["misc"] = {} config["misc"]["gen_warnings"] = gen_warnings_cfg from datetime import datetime config["last_updated"] = datetime.now().isoformat() with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Error saving gen warnings: {str(e)}"}}') sys.exit(0) # Handle gen-control engine-action safety toggle (misc.gen_control.enable_engine_actions). # Direct file write (mirrors ajax_gen_warnings). gen_control_api reads master_config # fresh on every request, so this takes effect immediately — no restart/broadcast. # Opening the existing file "w" truncates in place, preserving its ngon:ngon 664 perms. if "ajax_gen_control" in form and form.getvalue("ajax_gen_control"): gc_data = form.getvalue("ajax_gen_control") print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) payload = json.loads(gc_data) config.setdefault("misc", {}).setdefault("gen_control", {})["enable_engine_actions"] = bool( payload.get("enable_engine_actions")) from datetime import datetime config["last_updated"] = datetime.now().isoformat() with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Error saving gen control: {str(e)}"}}') sys.exit(0) # Handle live power-management settings save (misc.power_mgmt). # Direct file write (mirrors ajax_gen_control). generator_monitor calls # config.refresh() every ~5 s cycle, so changes take effect within one cycle # with no restart — including flipping live_control_enabled off (instant kill # switch back to Mesa). Values are clamped to sane ranges server-side. if "ajax_power_mgmt" in form and form.getvalue("ajax_power_mgmt"): pm_data = form.getvalue("ajax_power_mgmt") print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) payload = json.loads(pm_data) def _clamp(v, dflt, lo, hi): try: n = float(v) except (TypeError, ValueError): return dflt return max(lo, min(hi, n)) groups = payload.get("live_control_groups") or [] if not isinstance(groups, list): groups = [] pm = { "live_control_enabled": bool(payload.get("live_control_enabled")), "live_control_groups": [str(g).strip() for g in groups if str(g).strip()], "live_fresh_sec": _clamp(payload.get("live_fresh_sec"), 60, 5, 600), "live_boot_wake_sec": _clamp(payload.get("live_boot_wake_sec"), 120, 0, 3600), "live_wake_lockout_sec": _clamp(payload.get("live_wake_lockout_sec"), 300, 0, 3600), "live_wake_lockout_highload_sec": _clamp(payload.get("live_wake_lockout_highload_sec"), 450, 0, 3600), "live_shed_lockout_sec": _clamp(payload.get("live_shed_lockout_sec"), 15, 0, 600), "deadband_miners": int(_clamp(payload.get("deadband_miners"), 2, 1, 20)), } config.setdefault("misc", {})["power_mgmt"] = pm from datetime import datetime config["last_updated"] = datetime.now().isoformat() with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Error saving power mgmt: {str(e)}"}}') sys.exit(0) # Handle auto-restart gate settings save (misc.auto_restart). Direct file write # (mirrors ajax_power_mgmt). The gen_autostart service calls config.refresh() # every loop (~15 s), so changes take effect within one cycle — no restart. # Values are clamped/validated server-side. if "ajax_auto_restart" in form and form.getvalue("ajax_auto_restart"): ar_data = form.getvalue("ajax_auto_restart") print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) payload = json.loads(ar_data) def _clamp(v, dflt, lo, hi): try: n = float(v) except (TypeError, ValueError): return dflt return max(lo, min(hi, n)) def _hhmm(v, dflt): try: h, m = str(v).split(":") h, m = int(h), int(m) if 0 <= h <= 23 and 0 <= m <= 59: return f"{h:02d}:{m:02d}" except Exception: pass return dflt win = payload.get("window") or {} wu = payload.get("warmup") or {} gas = payload.get("gas") or {} cb = payload.get("circuit_breaker") or {} ex = payload.get("exclude_categories") or [] if not isinstance(ex, list): ex = [] # 'overload' is a cascade victim, never a culprit — refuse to store it. ex = [str(c).strip().lower() for c in ex if str(c).strip() and str(c).strip().lower() != "overload"] flow_min = gas.get("flow_min_mcfd") try: flow_min = float(flow_min) if flow_min not in (None, "", "null") else None except (TypeError, ValueError): flow_min = None ar = { "system_enabled": bool(payload.get("system_enabled")), "window": {"start": _hhmm(win.get("start"), "21:00"), "end": _hhmm(win.get("end"), "05:00")}, "just_ran_minutes": _clamp(payload.get("just_ran_minutes"), 5, 0, 120), "confirm_seconds": _clamp(payload.get("confirm_seconds"), 45, 10, 600), "warmup": { "mode": "temp" if str(wu.get("mode")) == "temp" else "minutes", "minutes": _clamp(wu.get("minutes"), 5, 0, 60), "target_f": _clamp(wu.get("target_f"), 160, 100, 220), "max_minutes": _clamp(wu.get("max_minutes"), 15, 1, 60), }, "exclude_categories": ex, "gas": {"block_on_category_gas": bool(gas.get("block_on_category_gas")), "flow_min_mcfd": flow_min}, "retrip": {"window_minutes": int(_clamp((payload.get("retrip") or {}).get("window_minutes"), 15, 1, 120))}, "circuit_breaker": { "max_attempts": int(_clamp(cb.get("max_attempts"), 3, 1, 20)), "window_minutes": _clamp(cb.get("window_minutes"), 120, 1, 1440), "cooldown_minutes": _clamp(cb.get("cooldown_minutes"), 120, 0, 1440), }, } config.setdefault("misc", {})["auto_restart"] = ar from datetime import datetime config["last_updated"] = datetime.now().isoformat() with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Error saving auto-restart: {str(e)}"}}') sys.exit(0) # Handle chat-command settings (misc.chat_commands). Direct file write, mirroring # ajax_auto_restart. The chat_commands service re-reads these every poll cycle and # gen_history_api reads them per request, so changes take effect without a restart. if "ajax_chat_commands" in form and form.getvalue("ajax_chat_commands"): cc_data = form.getvalue("ajax_chat_commands") print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) payload = json.loads(cc_data) def _cc_clamp(v, dflt, lo, hi): try: n = int(float(v)) except (TypeError, ValueError): return dflt return max(lo, min(hi, n)) # Only real site names, so a stale checkbox can't leave an orphan key that # silently looks like an enabled site. known_sites = set((config.get("sites") or {}).keys()) sites_in = payload.get("sites") or {} sites = {s: True for s in sites_in if s in known_sites and bool(sites_in.get(s))} cc = { "system_enabled": bool(payload.get("system_enabled")), "swap_enabled": bool(payload.get("swap_enabled")), "move_enabled": bool(payload.get("move_enabled")), "order_enabled": bool(payload.get("order_enabled")), "ems_on_shutdown_request": bool(payload.get("ems_on_shutdown_request")), "poll_seconds": _cc_clamp(payload.get("poll_seconds"), 30, 10, 300), "duplicate_window_seconds": _cc_clamp( payload.get("duplicate_window_seconds"), 3600, 60, 86400), "hint_enabled": bool(payload.get("hint_enabled")), "hint_cooldown_seconds": _cc_clamp( payload.get("hint_cooldown_seconds"), 3600, 60, 86400), "all_sites": bool(payload.get("all_sites")), "sites": sites, } config.setdefault("misc", {})["chat_commands"] = cc from datetime import datetime config["last_updated"] = datetime.now().isoformat() with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Error saving chat commands: {str(e)}"}}') sys.exit(0) # Handle per-category alert switches (misc.alerts). Direct file write, mirroring # ajax_auto_restart. notifications_api re-reads master_config on every request, so # a change takes effect on the very next alert with no restart. # # Stored as {category: bool} and only ever written for categories the UI knows # about. Absent == enabled everywhere that reads it, so an un-toggled system and a # category nobody has classified yet both behave exactly as before. if "ajax_alerts" in form and form.getvalue("ajax_alerts"): al_data = form.getvalue("ajax_alerts") print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) payload = json.loads(al_data) if not isinstance(payload, dict): print('{"success": false, "error": "Expected an object of category -> bool"}') sys.exit(0) # Keys come from notifications_api /alert_settings, so accept whatever the # page was rendered with rather than duplicating the catalogue here — but # coerce hard, since this ends up gating whether operators get told things. alerts = {} for k, v in payload.items(): key = str(k).strip() if key: alerts[key] = bool(v) config.setdefault("misc", {})["alerts"] = alerts from datetime import datetime config["last_updated"] = datetime.now().isoformat() with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) off = sorted(k for k, v in alerts.items() if not v) print(json.dumps({"success": True, "disabled": off})) except Exception as e: print(f'{{"success": false, "error": "Error saving alert settings: {str(e)}"}}') sys.exit(0) # Handle gas-pressure hold settings (misc.gas_hold). Direct file write, mirroring # ajax_auto_restart. generator_monitor reads these every reconcile cycle (~15 s) via # config.get_gas_hold_settings(), so changes land without a restart. Only the master # switch and the ORG-WIDE defaults live here; per-group arming and thresholds are on # the status page kW modal. if "ajax_gas_hold" in form and form.getvalue("ajax_gas_hold"): gh_data = form.getvalue("ajax_gas_hold") print("Content-Type: application/json\n") try: if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) payload = json.loads(gh_data) d = (payload.get("defaults") or {}) def _gclamp(v, dflt, lo, hi): try: n = float(v) except (TypeError, ValueError): return dflt return max(lo, min(hi, n)) watch = _gclamp(d.get("watch_psi"), 18.0, 1, 200) hold1 = _gclamp(d.get("hold1_psi"), 16.0, 1, 200) hold2 = _gclamp(d.get("hold2_psi"), 14.0, 1, 200) # A stage that isn't strictly deeper than the one above it is unreachable — # clamp rather than reject so a fat-fingered save can't leave a half-ladder. hold1 = min(hold1, watch) hold2 = min(hold2, hold1) config.setdefault("misc", {})["gas_hold"] = { "system_enabled": bool(payload.get("system_enabled")), "defaults": { "watch_psi": watch, "hold1_psi": hold1, "hold2_psi": hold2, "release_margin_psi": _gclamp(d.get("release_margin_psi"), 1.0, 0, 50), "release_minutes": _gclamp(d.get("release_minutes"), 30.0, 1, 720), "hold1_reserve": int(_gclamp(d.get("hold1_reserve"), 1, 1, 6)), "hold2_reserve": int(_gclamp(d.get("hold2_reserve"), 2, 1, 6)), "confirm_samples": int(_gclamp(d.get("confirm_samples"), 2, 1, 10)), "min_live_gens": int(_gclamp(d.get("min_live_gens"), 2, 1, 10)), "stale_minutes": _gclamp(d.get("stale_minutes"), 45.0, 5, 720), }, } from datetime import datetime config["last_updated"] = datetime.now().isoformat() with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) # Direct file write, so status_api's in-memory copy is now behind. Broadcast # or the status page keeps showing the master switch as OFF and refuses to arm # any group. Best-effort: the save itself already succeeded. try: import urllib.request urllib.request.urlopen( urllib.request.Request("http://localhost:5050/api/config/broadcast", method="POST"), timeout=3).read() except Exception: pass print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Error saving gas hold: {str(e)}"}}') sys.exit(0) # Handle read-only public view links (misc.public_view.views). Direct file write, # mirroring ajax_gas_hold. view.py reads master_config on every request, so a save # takes effect on the next page load with no restart -- which is what makes # "disable" and "delete" immediate revocations rather than eventual ones. # # Tokens are minted HERE, server-side, never sent up from the browser: the client # has no business choosing the secret that guards the link. if "ajax_public_view" in form and form.getvalue("ajax_public_view"): pv_data = form.getvalue("ajax_public_view") print("Content-Type: application/json\n") try: import secrets as _secrets import datetime as _dt if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) payload = json.loads(pv_data) existing = {v.get("id"): v for v in ((config.get("misc", {}) or {}).get("public_view", {}) or {}).get("views", []) if isinstance(v, dict)} known_sites = set((config.get("sites") or {}).keys()) out = [] for row in (payload.get("views") or []): if not isinstance(row, dict): continue vid = str(row.get("id") or "")[:16] or _secrets.token_hex(4) prev = existing.get(vid, {}) # Keep the existing token unless this is new or a regenerate was asked # for. The browser never supplies one. token = prev.get("token") if not token or row.get("regenerate"): token = _secrets.token_urlsafe(24) # Only real site names, so a typo cannot silently widen a view to # nothing-matches (which reads as "all sites" downstream). sites = [x for x in (row.get("sites") or []) if x in known_sites] out.append({ "id": vid, "name": (str(row.get("name") or "").strip() or "Untitled")[:60], "token": token, "sites": sites, "enabled": bool(row.get("enabled")), "created": prev.get("created") or _dt.date.today().isoformat(), }) config.setdefault("misc", {})["public_view"] = { "views": out, "_comment": "Read-only no-login views at /status/view.py?k=. One " "entry per link. sites=[] means every site; otherwise only " "those listed. enabled=false kills that link instantly. " "Delete an entry to revoke it.", } with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) # view.py reads the file directly, so no broadcast is needed for the links # themselves; broadcast anyway so anything holding an in-memory copy agrees. try: import urllib.request urllib.request.urlopen( urllib.request.Request("http://localhost:5050/api/config/broadcast", method="POST"), timeout=3).read() except Exception: pass print(json.dumps({"success": True, "views": out})) except Exception as e: print(json.dumps({"success": False, "error": f"Error saving public views: {e}"})) sys.exit(0) # Handle dead-miner scoring settings (misc.dead_miner). Direct file write, # mirroring ajax_auto_restart. Every reader (the hunter page, the inventory # API) scores from the persisted signal store using these values at read time, # so a save re-scores the whole fleet on the next page load — no re-extraction. if "ajax_dead_miner" in form and form.getvalue("ajax_dead_miner"): dm_data = form.getvalue("ajax_dead_miner") print("Content-Type: application/json\n") try: sys.path.insert(0, '/opt/ngon/apps') from miners.dead_hunter import DEFAULTS as DM_DEFAULTS if not os.path.exists(MASTER_CONFIG_FILE): print('{"success": false, "error": "Config file not found"}') sys.exit(0) with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) payload = json.loads(dm_data) def _dm_clamp(key, lo, hi, as_int=True): dflt = DM_DEFAULTS[key] try: n = float(payload.get(key, dflt)) except (TypeError, ValueError): return dflt n = max(lo, min(hi, n)) return int(round(n)) if as_int else n cats = payload.get("hw_error_cats") if not isinstance(cats, list): cats = DM_DEFAULTS["hw_error_cats"] cats = [str(c).strip().lower() for c in cats if str(c).strip()] dm = { "w_reboots": _dm_clamp("w_reboots", 0, 100), "w_hw_error": _dm_clamp("w_hw_error", 0, 100), "w_zero_hash": _dm_clamp("w_zero_hash", 0, 100), "w_unstable": _dm_clamp("w_unstable", 0, 100), "reboots_full": _dm_clamp("reboots_full", 1, 500), "pull_threshold": _dm_clamp("pull_threshold", 1, 100), "score_floor": _dm_clamp("score_floor", 0, 100), "never_hashed_reboots": _dm_clamp("never_hashed_reboots", 0, 500), "auto_min_days": _dm_clamp("auto_min_days", 1, 30), "hw_error_cats": cats, "no_hash_days": _dm_clamp("no_hash_days", 1, 365), "use_pod_gate": bool(payload.get("use_pod_gate", True)), "pod_active_frac": _dm_clamp("pod_active_frac", 0.0, 1.0, as_int=False), # extract-time knobs "window_days": _dm_clamp("window_days", 1, 90), "min_samples_per_day": _dm_clamp("min_samples_per_day", 1, 200), "short_uptime": _dm_clamp("short_uptime", 60, 86400), "real_hash_th": _dm_clamp("real_hash_th", 1, 500), } # A floor above the pull threshold would make 'suspect' impossible and # silently swallow the amber band. if dm["score_floor"] > dm["pull_threshold"]: dm["score_floor"] = dm["pull_threshold"] config.setdefault("misc", {})["dead_miner"] = dm from datetime import datetime config["last_updated"] = datetime.now().isoformat() with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) print(json.dumps({"success": True, "saved": dm})) except Exception as e: print(json.dumps({"success": False, "error": f"Error saving dead-miner settings: {e}"})) sys.exit(0) # Dead-miner tuning preview: score the persisted signal store against a # CANDIDATE config without saving anything, so an operator can see how many # miners a weight change would put on a truck before committing to it. # Cheap (~70 ms fleet-wide) because the expensive signal extraction already # happened on the cron. if "ajax_dead_preview" in form and form.getvalue("ajax_dead_preview"): dp_data = form.getvalue("ajax_dead_preview") print("Content-Type: application/json\n") try: sys.path.insert(0, '/opt/ngon/apps') from miners.dead_hunter import (DEFAULTS as DM_DEFAULTS, tier_counts, load_config as dm_load_config) payload = json.loads(dp_data) cfg = dm_load_config() candidate = dict(cfg) for k, v in payload.items(): if k in DM_DEFAULTS and v is not None: candidate[k] = v saved = tier_counts(cfg=cfg) preview = tier_counts(cfg=candidate) print(json.dumps({"success": True, "preview": preview, "saved": saved})) except Exception as e: print(json.dumps({"success": False, "error": str(e)})) sys.exit(0) # ajax_groups_data handler removed - now using direct_config_save # Handle direct config save (simplified approach) if "direct_config_save" in form and form.getvalue("direct_config_save"): config_data = form.getvalue("direct_config_save") print("Content-Type: application/json\n") try: new_config = json.loads(config_data) # Read on-disk config once for merges. Even if we can't read it, we can # still save (degraded — missing concurrency protection for this request). existing = None try: with open(MASTER_CONFIG_FILE, 'r') as f: existing = json.load(f) except Exception: existing = None # Merge passwords back into users (browser config has passwords stripped) if 'misc' in new_config and 'users' in new_config['misc']: existing_users = (existing or {}).get('misc', {}).get('users', {}) if existing else {} for uname, udata in new_config['misc']['users'].items(): if 'password' not in udata or not udata.get('password'): udata['password'] = existing_users.get(uname, {}).get('password', '6767') # Preserve `generators` per group from disk. Site Manager has no UI for # adding/moving generators — Generator Manager is the only authority for # that, and it writes via gen_history_api/ConfigManager. Without this, # a Site Manager save with a stale window.siteConfig (e.g. a tab loaded # before someone moved gens via Generator Manager) wholesale-overwrites # the file and silently reverts those moves with no history trail. # Renamed/new groups (key not on disk) keep the browser's data so the # rename flow continues to carry generators forward. # Generator ORDER, however, comes from the browser: drag-to-reorder in Site # Manager is the only way to set it, so taking the disk dict wholesale silently # ate every reorder. Take values from disk, key order from the browser. if existing is not None: existing_sites = existing.get('sites', {}) for site_name, site_data in new_config.get('sites', {}).items(): existing_groups = existing_sites.get(site_name, {}).get('generator_groups', {}) for group_name, group_data in site_data.get('generator_groups', {}).items(): if group_name not in existing_groups: continue # gas_hold_state is runtime state the gas-hold evaluator # owns — live psi, current stage, reserved gens. Site Manager # edits the gas hold SETTINGS (thresholds, per-group arm), not # this, and has no UI for it at all. Left to the browser's # copy, a save made while Fortson sat at stage 1 would write # back whatever that tab loaded and drop a live reserve until # the next evaluation cycle rebuilt it. Same reasoning as # generators below: automation owns it, so it comes from disk. if 'gas_hold_state' in existing_groups[group_name]: group_data['gas_hold_state'] = existing_groups[group_name]['gas_hold_state'] else: group_data.pop('gas_hold_state', None) disk_gens = existing_groups[group_name].get('generators', {}) browser_gens = group_data.get('generators') or {} # browser order first (dropping gens moved away since page load), # then any disk gens the browser hasn't seen yet, at the end ordered = {g: disk_gens[g] for g in browser_gens if g in disk_gens} for g, gdata in disk_gens.items(): ordered.setdefault(g, gdata) group_data['generators'] = ordered # Pin Spares / Out of Service below the real sites, keeping their own # relative order. See TRAILING_SITES above. sites = new_config.get('sites') if isinstance(sites, dict): tail = [s for s in sites if s in TRAILING_SITES] if tail: new_config['sites'] = {k: v for k, v in sites.items() if k not in tail} new_config['sites'].update({k: sites[k] for k in tail}) with open(MASTER_CONFIG_FILE, "w") as f: json.dump(new_config, f, indent=2) print('{"success": true}') except Exception as e: print(f'{{"success": false, "error": "Save failed: {str(e)}"}}') sys.exit(0) # Surgical generator identity save (mac / bridge_mac) via ConfigManager. # NOT direct_config_save: that path preserves `generators` from disk and would # discard these edits. Notes/status/moves remain Generator Manager's job. # (master_config.json must be ngon:ngon 664 so this www-data CGI can write it.) if "save_gen_fields" in form: print("Content-Type: application/json\n") try: gen_id = (form.getvalue("gen_id") or "").strip() site_name = (form.getvalue("site_name") or "").strip() group_name = (form.getvalue("group_name") or "").strip() if not (gen_id and site_name and group_name): print('{"success": false, "error": "gen_id, site_name, group_name required"}') sys.exit(0) from managers.config_manager import ConfigManager cm = ConfigManager() base = ["sites", site_name, "generator_groups", group_name, "generators", gen_id] # values arrive pre-normalized from the browser; '' clears the field changed = False for field in ("mac", "bridge_mac"): if field in form: val = (form.getvalue(field) or "").strip() r = cm.update_value(base + [field], val if val else None, broadcast=False) if not r.get("success"): msg = str(r.get("error")).replace('"', "'") print('{"success": false, "error": "update %s failed: %s"}' % (field, msg)) sys.exit(0) changed = True if changed: cm._broadcast_update() print('{"success": true}') except Exception as e: print('{"success": false, "error": "%s"}' % str(e).replace('"', "'")) sys.exit(0) # Handle session check requests (for automatic logout) if "session_check" in form and form.getvalue("session_check"): print("Content-Type: application/json\n") print('{"success": true}') sys.exit(0) # Disable cgitb for remaining requests to prevent any unwanted output cgitb.enable() # update_gen_note handler removed - now using in-memory system with simplifiedSave() # ajax_action handler removed - now using in-memory system with simplifiedSave() # If not an AJAX request, output HTML header print("Content-Type: text/html\n") def load_sites_with_groups(): """Load sites with their generator groups, pods and generators from master config""" sites = {} unassigned_pods = {} all_generators = set() if os.path.exists(MASTER_CONFIG_FILE): with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) # Extract sites with their groups, pods, and generators for site_name, site_data in config.get("sites", {}).items(): sites[site_name] = { 'site_id': site_data.get('site_id', ''), 'pool1': site_data.get('pool1', ''), 'pool2': site_data.get('pool2', ''), 'pool3': site_data.get('pool3', ''), 'worker_name1': site_data.get('worker_name1', ''), 'worker_name2': site_data.get('worker_name2', ''), 'worker_name3': site_data.get('worker_name3', ''), 'location': site_data.get('location', {}), 'network': site_data.get('network', ''), 'generator_groups': {}, 'peplink': site_data.get('peplink', {}), 'switch_ip': site_data.get('switch_ip', ''), 'webhooks': site_data.get('webhooks', {'alerts': '', 'chat': ''}) } for group_name, group_data in site_data.get("generator_groups", {}).items(): sites[site_name]['generator_groups'][group_name] = { 'pods': {}, 'generators': group_data.get("generators", {}), 'network': group_data.get('network', ''), 'peplink': group_data.get('peplink', {}), 'switch_ip': group_data.get('switch_ip', ''), 'max_gen_kw': group_data.get('max_gen_kw', 330) } # Add generators to master list for gen_id in group_data.get("generators", {}): all_generators.add(gen_id) # Add pods with their settings for pod_name, pod_settings in group_data.get("pods", {}).items(): sites[site_name]['generator_groups'][group_name]['pods'][pod_name] = pod_settings return sites, unassigned_pods, all_generators def load_settings(): """Load pod settings (sleep, reboot, miner counts, miner types, sleep targets) from master config""" settings = { 'sleep_eligible': {}, 'reboot_eligible': {}, 'wake_eligible': {}, 'miner_counts': {}, 'miner_types': {}, } if os.path.exists(MASTER_CONFIG_FILE): with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) # Extract pod settings from all sites for site_name, site_data in config.get("sites", {}).items(): for group_name, group_data in site_data.get("generator_groups", {}).items(): for pod_name, pod_settings in group_data.get("pods", {}).items(): settings['sleep_eligible'][pod_name] = pod_settings.get('auto_sleep_enabled', False) settings['reboot_eligible'][pod_name] = pod_settings.get('auto_reboot_enabled', False) settings['wake_eligible'][pod_name] = pod_settings.get('auto_wake_enabled', False) settings['miner_counts'][pod_name] = pod_settings.get('miner_count', 0) settings['miner_types'][pod_name] = pod_settings.get('miner_type', 'M60') return settings def save_groups_data(groups_data): """Parse and save groups data from the web interface""" if not os.path.exists(MASTER_CONFIG_FILE): return try: # Parse the groups data format: "site_name:group1,group2|site2_name:group3,group4" # Within each site, groups have format: "group_name@pod1,pod2;gen1,gen2" # This preserves both site organization and group order sites_order = [] sites_info = {} if groups_data: # Handle empty data # First pass: parse the data structure for site_data in groups_data.split('||'): if '::' in site_data: site_name, groups_part = site_data.split('::', 1) sites_order.append(site_name) sites_info[site_name] = [] if groups_part: for group_data in groups_part.split('|'): if '@' in group_data: group_name, rest = group_data.split('@', 1) if ';' in rest: pods_part, gens_part = rest.split(';', 1) pods = [p.strip() for p in pods_part.split(',') if p.strip()] generators = [g.strip() for g in gens_part.split(',') if g.strip()] else: pods = [p.strip() for p in rest.split(',') if p.strip()] generators = [] sites_info[site_name].append({ 'name': group_name, 'pods': pods, 'generators': generators }) # Update the master config with open(MASTER_CONFIG_FILE, "r") as f: config = json.load(f) # Create a new sites dictionary with the correct order new_sites = {} # First, add sites in the order they appear in the UI for site_name in sites_order: if site_name in config["sites"]: new_sites[site_name] = config["sites"][site_name] # Then add any remaining sites that weren't in the UI (shouldn't happen, but just in case) for site_name in config["sites"]: if site_name not in new_sites: new_sites[site_name] = config["sites"][site_name] # Replace the sites dictionary with the ordered one config["sites"] = new_sites # Update each site with its groups in the correct order for site_name, groups_list in sites_info.items(): if site_name in config["sites"]: site_data = config["sites"][site_name] # Create new ordered generator_groups new_generator_groups = {} for group_info in groups_list: group_name = group_info['name'] # Preserve existing group data if it exists if group_name in site_data.get("generator_groups", {}): existing_group = site_data["generator_groups"][group_name] # Update generators (preserve existing generator data like notes) new_generators = {} for gen_entry in group_info['generators']: # Parse generator ID and note if present if ':' in gen_entry: gen_id, gen_note = gen_entry.split(':', 1) new_generators[gen_id] = {"notes": gen_note} else: gen_id = gen_entry # Check if this generator exists anywhere with notes found_notes = False for check_site in config["sites"].values(): for check_group in check_site.get("generator_groups", {}).values(): if gen_id in check_group.get("generators", {}): gen_data = check_group["generators"][gen_id] if isinstance(gen_data, dict) and gen_data.get("notes"): new_generators[gen_id] = gen_data found_notes = True break if found_notes: break if not found_notes: new_generators[gen_id] = {} existing_group["generators"] = new_generators # Update pods (preserve existing settings) current_pods = set(existing_group.get("pods", {}).keys()) new_pods = set(group_info['pods']) # Remove pods not in new list for pod_name in current_pods - new_pods: del existing_group["pods"][pod_name] # Add new pods with default settings for pod_name in new_pods - current_pods: existing_group["pods"][pod_name] = { "miner_count": 0, "auto_sleep_enabled": True, "auto_reboot_enabled": True, "auto_wake_enabled": False, "power_target": 0, "miner_type": "M60", "peplink": { "display_children": true } } new_generator_groups[group_name] = existing_group else: # Create new group new_generators = {} for gen_entry in group_info['generators']: # Parse generator ID and note if present if ':' in gen_entry: gen_id, gen_note = gen_entry.split(':', 1) new_generators[gen_id] = {"notes": gen_note} else: gen_id = gen_entry # Check if this generator exists anywhere with notes found_notes = False for check_site in config["sites"].values(): for check_group in check_site.get("generator_groups", {}).values(): if gen_id in check_group.get("generators", {}): gen_data = check_group["generators"][gen_id] if isinstance(gen_data, dict) and gen_data.get("notes"): new_generators[gen_id] = gen_data found_notes = True break if found_notes: break if not found_notes: new_generators[gen_id] = {} new_generator_groups[group_name] = { "pods": {pod: {"miner_count": 0, "auto_sleep_enabled": True, "auto_reboot_enabled": True, "auto_wake_enabled": False, "power_target": 0, "miner_type": "M60"} for pod in group_info['pods']}, "generators": new_generators } # Replace with the ordered version site_data["generator_groups"] = new_generator_groups # Update timestamp from datetime import datetime, timezone new_timestamp = datetime.now(timezone.utc).astimezone().isoformat() config["last_updated"] = new_timestamp with open(MASTER_CONFIG_FILE, "w") as f: json.dump(config, f, indent=2) except Exception as e: # Log error but don't crash import sys print(f"Error saving groups data: {e}", file=sys.stderr) # rename_group function removed - now using in-memory system # rename_pod function removed - now using in-memory system # update_pod_miner_count function removed - now using in-memory system # update_pod_miner_type function removed - now using in-memory system # update_pod_setting function removed - now using in-memory system # rename_site function removed - now using in-memory system # update_generator_note function removed - now using in-memory system # update_site_id function removed - now using in-memory system # create_new_group function removed - now using in-memory system # create_new_site function removed - now using in-memory system # create_new_pod function removed - now using in-memory system # add_generator_to_group function removed - now using in-memory system # add_generator_to_spares function removed - now using in-memory system # update_peplink function removed - now using in-memory system # delete_peplink function removed - now using in-memory system # update_network function removed - now using in-memory system # delete_network function removed - now using in-memory system # delete_site function removed - now using in-memory system # delete_group function removed - now using in-memory system # delete_pod function removed - now using in-memory system def read_config_files(): """Read all existing configuration files""" sites, unassigned_pods, all_generators = load_sites_with_groups() settings = load_settings() config = { 'sites': sites, 'unassigned_pods': unassigned_pods, 'all_generators': list(all_generators), 'sleep_eligible': settings['sleep_eligible'], 'reboot_eligible': settings['reboot_eligible'], 'miner_counts': settings['miner_counts'], 'miner_types': settings['miner_types'], } return config # Old POST handlers removed - all operations now use direct_config_save with in-memory system # Peplink and network handlers removed - now using in-memory system # All remaining handlers removed - using in-memory system only # Read config AFTER all form processing config = read_config_files() # Hash of what a save from this page would overwrite, handed to the browser so # it can tell a collision from the automation traffic that dominates config # writes (20-35 an hour, nearly all of it per-gen fields this page's save # re-reads from disk anyway). Same function status_api uses when it emits # gen_config_changed — one definition, so the two can't drift. try: from managers.config_manager import site_manager_save_digest with open(MASTER_CONFIG_FILE) as _mc: _SM_DIGEST = site_manager_save_digest(json.load(_mc)) except Exception: # No digest -> warn on everything, which is how this page behaved before. _SM_DIGEST = "" sites = config['sites'] unassigned_pods = config['unassigned_pods'] all_generators = config['all_generators'] settings = { 'sleep_eligible': config['sleep_eligible'], 'reboot_eligible': config['reboot_eligible'], 'miner_counts': config['miner_counts'], 'miner_types': config['miner_types'], } print(""" NGON Site Manager
Config changed elsewhere — reload before saving, or your save may revert it.
""") # Show login modal if not authenticated if auth_required: username = auth.is_authenticated() if username: print(generate_access_denied_html("Site Manager")) else: print(generate_login_modal_html("Site Manager")) print("") sys.exit(0) print("""

NGON Site Manager

""") # Output sites for site_name, site_data in sites.items(): print(f'
') print(f'
') print(f'
') print(f'
{site_name}
') # Webhooks - displayed under site name site_webhooks = site_data.get('webhooks', {}) alerts_wh = site_webhooks.get('alerts', '') chat_wh = site_webhooks.get('chat', '') alerts_short = alerts_wh[-20:] if alerts_wh else '' chat_short = chat_wh[-20:] if chat_wh else '' print(f'
') if alerts_wh: print(f'Alerts: ...{alerts_short}') else: print(f'Add Alerts Webhook') if chat_wh: print(f'Chat: ...{chat_short}') else: print(f'Add Chat Webhook') print(f'
') site_id = site_data.get('site_id', '') if site_id: print(f'
Site ID: {site_id}
') else: print(f'
Click to add Site ID
') # Pools and Worker names (side by side) pool1 = site_data.get('pool1', '') pool2 = site_data.get('pool2', '') pool3 = site_data.get('pool3', '') worker_name1 = site_data.get('worker_name1', '') worker_name2 = site_data.get('worker_name2', '') worker_name3 = site_data.get('worker_name3', '') # Pool 1 and Worker 1 print(f'
') if pool1: print(f'
Pool 1: {pool1}
') else: print(f'
Click to add Pool 1
') if worker_name1: print(f'
Worker 1: {worker_name1}
') else: print(f'
Click to add Worker 1
') print(f'
') # Pool 2 and Worker 2 print(f'
') if pool2: print(f'
Pool 2: {pool2}
') else: print(f'
Click to add Pool 2
') if worker_name2: print(f'
Worker 2: {worker_name2}
') else: print(f'
Click to add Worker 2
') print(f'
') # Pool 3 and Worker 3 print(f'
') if pool3: print(f'
Pool 3: {pool3}
') else: print(f'
Click to add Pool 3
') if worker_name3: print(f'
Worker 3: {worker_name3}
') else: print(f'
Click to add Worker 3
') print(f'
') print(f'
') print(f'
') # Peplink site_peplink = site_data.get('peplink', {}) if site_peplink.get('group_id') and site_peplink.get('device_id'): group_id = site_peplink.get('group_id') device_id = site_peplink.get('device_id') router_ip = site_peplink.get('router_ip', '') display_children = str(site_peplink.get('display_children', True)).lower() pep_label = router_ip or f'{group_id}/{device_id}' print(f'{pep_label}') else: print(f'
') # Switch site_switch_ip = site_data.get('switch_ip', '') if site_switch_ip: print(f'{site_switch_ip}') else: print(f'
') # Network site_network = site_data.get('network', '') if site_network: print(f'{site_network}') else: print(f'
') print(f'
') print(f'
') print(f'
') # Output generator groups for this site for group_name, group_data in site_data['generator_groups'].items(): group_pods = group_data['pods'] group_generators = group_data['generators'] print(f'
') print(f'
') print(f'
{group_name}
') print(f'
') # Peplink icon/box group_peplink = group_data.get('peplink', {}) if group_peplink.get('group_id') and group_peplink.get('device_id'): group_id = group_peplink.get('group_id') device_id = group_peplink.get('device_id') router_ip = group_peplink.get('router_ip', '') display_children = str(group_peplink.get('display_children', True)).lower() pep_label = router_ip or f'{group_id}/{device_id}' print(f'{pep_label}') else: print(f'
') # Master switch icon/box group_switch_ip = group_data.get('switch_ip', '') if group_switch_ip: print(f'{group_switch_ip}') else: print(f'
') # Network group_network = group_data.get('network', '') if group_network: print(f'{group_network}') else: print(f'
') # Max gen kW max_gen_kw = group_data.get('max_gen_kw', 330) print(f'{max_gen_kw} kW/gen') print(f'
') print(f'
') # Show generators in this group print(f'
') print(f'
Generators ({len(group_generators)})
') print(f'
') # Display generators in their natural dictionary order (which is preserved in Python 3.7+) for gen_id, gen_data in group_generators.items(): gen_note = gen_data.get('notes', '') if isinstance(gen_data, dict) else '' # Use data attributes to avoid quote escaping issues escaped_note = gen_note.replace('"', '"') print(f'
') print(f'
{gen_id}
') if gen_note: print(f'
{gen_note}
') print(f'
') print(f'
') print(f'
') # Show pods in this group print(f'
') for pod_name, pod_settings in group_pods.items(): miner_count = pod_settings.get('miner_count', 0) miner_type = pod_settings.get('miner_type', 'M60') print(f'
') print(f'
') print(f'

{pod_name}

') print(f'
') # Peplink pod_peplink = pod_settings.get('peplink', {}) if pod_peplink.get('group_id') and pod_peplink.get('device_id'): group_id = pod_peplink.get('group_id') device_id = pod_peplink.get('device_id') router_ip = pod_peplink.get('router_ip', '') display_children = str(pod_peplink.get('display_children', True)).lower() pep_label = router_ip or f'{group_id}/{device_id}' print(f'{pep_label}') else: print(f'
') # Switch pod_switch_ip = pod_settings.get('switch_ip', '') if pod_switch_ip: print(f'{pod_switch_ip}') else: print(f'
') # Network network = pod_settings.get('network', '') if network: print(f'{network}') else: print(f'
') print(f'
') print(f'
') print(f'
{miner_count} miners
') print(f'
Type: {miner_type}
') power_target = pod_settings.get('power_target', 0) power_label = f'{power_target}W' if power_target else 'Off' print(f'
Power Target: {power_label}
') print('
') print(f'
') print('
') print(f'
') # Close groups-wrapper print(f'
') # Close site-container print("""
""") # Show unassigned pods if any if unassigned_pods: print(f'
') print(f'
Unassigned Pods
') print(f'
') for pod_name, pod_settings in unassigned_pods.items(): miner_count = pod_settings.get('miner_count', 0) miner_type = pod_settings.get('miner_type', 'M60') print(f'
') print(f'
') print(f'

{pod_name}

') print(f'
') # Add peplink icon for unassigned pod pod_peplink = pod_settings.get('peplink', {}) if pod_peplink.get('group_id') and pod_peplink.get('device_id'): # Has peplink data - show router icon group_id = pod_peplink.get('group_id') device_id = pod_peplink.get('device_id') display_children = str(pod_peplink.get('display_children', True)).lower() print(f'') else: # No peplink data - show empty box print(f'
') # Add network field for unassigned pod network = pod_settings.get('network', '') if network: # Has network data - show network text print(f'{network}') else: # No network data - show empty box print(f'
') print(f'
') print(f'
') print(f'
{miner_count} miners
') print(f'
Type: {miner_type}
') print('
') print(f'
') print('
') # The alert-category catalogue is owned by notifications_api (ALERT_CATEGORIES) so # there is exactly one list. Fetched here server-side rather than from the browser, # which keeps notifications_api off the public proxy — it is localhost-only and has # no auth of its own. Current on/off state comes from window.configData.misc.alerts, # already in the page, so this only supplies keys and labels. _alert_cats = [] try: import urllib.request as _urlreq with _urlreq.urlopen("http://127.0.0.1:5005/alert_settings", timeout=4) as _r: _alert_cats = (json.loads(_r.read().decode()) or {}).get("categories", []) except Exception: _alert_cats = [] # panel renders an explicit "unavailable" message print(f'') print("""

Create New Site

Create New Group

Create New Pod

Create New Generator

Generator will be added to the selected group

Miner Type Specifications

User Management

Generator Control — Engine Actions

When ON, users with Gen Control access can remotely start generators and close breakers (on load) from the status page — each still gated by on-controller interlocks (manual + alarms-clear + stopped for start) and a type-“yes” confirm for start. Leave OFF unless a field tech is on-site. Manual-mode and Clear-alarms are always allowed regardless of this switch.

Power Management — Live Gen Data Control

When ON, any generator group where every gen is reporting fresh live telemetry is controlled from live data — fast instant-shed on overload, patient 30 s-smoothed wake, with a boot-wake hold once gens come on load (running and breaker closed). Groups missing live data fall back to Mesa automatically. Live and Mesa control stay fully separate. Changes take effect within ~5 s — no restart. Turning this OFF is an instant kill switch back to Mesa for every group.
Fully-live groups today: GN 1–7, Will 1/3/4/5 (others auto-fall-back to Mesa)

Auto-Restart — Gate Settings

Master kill switch. While OFF, the AR toggle on the status page is locked (no group can be armed) and the service actuates nothing. Turn ON only when you're ready to run auto-restart.
Org-wide defaults for the autonomous group auto-restart service. Per-group arming is the AR toggle on the status page (default OFF). On a full group-down, if all gates pass the service clears alarms, restarts the healthy gens, warms them, then asks for load — it does not close breakers. Requires Generator Control → Engine Actions (above) to be ON to actuate. Takes effect within one service cycle (~15 s), no restart. Window uses server-local time.
Exclude causes check a cause to hold a gen carrying it out of auto-restart. Each cause folds in the Mesa no-restart CODES that map to it — click ▸ to see them. 'overload' is a cascade victim and is locked out; gas / manual / e-stop have their own gates.

Chat Commands — Site Spaces

Master kill switch. While OFF the service reads the Spaces but parses nothing and answers nothing — and because it keeps its cursors moving, switching ON starts from now rather than replaying a backlog of old commands.
Watches the 12 per-site chat Spaces (not the alerts Spaces, and not the Mesa tracker — those are already read elsewhere). A command must start with ! — prose is never acted on, because “swap” in a site room is usually a blower motor or a filter. Every !command gets an answer: the result, or why not.
!swap <gen coming out> for <gen going in> — e.g. !swap 588 for 583. No site needed: wherever the outgoing gen is, that's where the incoming one goes.
!move <gen> to <group or OOS> — e.g. !move 588 to OOS, !move 500 to Will 2. For a gen pulled with nothing going back in. “OOS” picks TX or ND from the gen's own site.
!order <group> <gens in order> — e.g. !order Will 2 577 583 565 320 482. Shuffles the group into that line-up; every gen in the group must be listed. # works in place of !.
!help (or just !) lists the commands in-room and marks any that aren't switched on for that site. It isn't gated by the switches below — asking what exists isn't an action — but the master switch above still hides it. A wrong command gets the same list back, so nobody has to ask.
Sites allowed to run commands Pilot one or two first; a site that isn't ticked gets told so rather than ignored.

Alerts — What Reaches Chat

Switch off any category that isn't worth an interruption. Turning one off suppresses the live chat message only — the event still feeds the summary digest and every subsystem keeps logging it, so nothing is lost, it just stops pinging. Takes effect on the very next alert; no restart.
Loading categories…

Read-Only View Links

Shareable links to a view-only site page — no login, no menu, nothing actionable. For temps and partners who need to see what is up and what is down. Each link can be limited to chosen sites (none ticked = every site). Turning one off, or deleting it, revokes it on the next page load.
Anyone holding the link can open it — treat it like a password. It shows fleet status only; it cannot sleep miners, touch generators or reach any other page.

Gas-Pressure Hold — Defaults

Master kill switch. While OFF nothing is evaluated and no group can be armed. Per-group arming and per-group psi thresholds live on the status page → gen group kW modal, because normal NG pressure differs by site.
Sheds mining load before a group's gens starve on gas, and gives it back when supply recovers — the gas analogue of the pre-emptive capacity hold. Thresholds are absolute psi, not percentages: controller trips cluster near 10 psi while per-gen baselines run 19–44 psi, so a relative rule fires constantly on a high-baseline gen and far too late on a low-baseline one. Takes effect within one monitor cycle (~15 s), no restart.

Dead-Miner Scoring — Confidence Weights

Scores every miner 0–100 for dead-confidence. Drives the Dead Miner Hunter page and the dead-miner feed the inventory app reads when a pod is opened. Signals are extracted from history on a cron; the score itself is computed on every read, so a change here re-scores the whole fleet immediately — no re-scan.
The dominant signal is reboots, not zero-hash: a power-parked healthy miner also sits at zero hash. What separates dead from parked is that reboot_zero hammers it and it still won't run. Keep zero-hash weighted below the score floor so it can never surface a parked miner on its own.
Live preview — how many miners these settings would flag, scored against the current signal store:
—
DEAD (pull)
—
SUSPECT
—
below floor / parked
 
 
Judges a miner only on days its own pod was demonstrably able to run — if this share of the pod's miners hashed that day, a silent miner is genuinely broken; if the pod was dark, the day is discarded rather than counted as evidence of death. Uses the pod's other miners as the control group, so it covers gas, gen-down, peplink-down and breaker outages from one data source.
A pod dark for weeks (Osprey) is already immune — it produces no snapshots at all, so its miners are never scored. What this protects is a pod coming back: M60s boot sleeping, and without the gate any with ≥10 reboots would auto-confirm dead within auto-dead min days.
Extraction settings — these change what gets pulled out of history, so they only take effect on the next extraction run (cron, every 2 h). The live preview above will not reflect them until then.

Generator Warning Settings

Thresholds in operator units (°F / psi / V / rpm). These are tunable starter values.
These warnings evaluate off both live telemetry and Mesa data — we prefer live when a gen has a wifi bridge, and fall back to Mesa otherwise (slower, but valid). Every threshold below is available from either source. If we later add data points that only exist on the live feed, we'll designate those individually.

Thresholds (blank = not checked; a field can flag on low and/or high)

OnField Crit LowWarn Low Warn HighCrit High Unit Pre-empt

Controller Status Bits (specific faults the controller flags; DSE Warning is the suppressed fleet-wide rollup)

OnCondition BitSeverity
""")