#!/usr/bin/env python3 import cgi, sys sys.path.insert(0, '/opt/ngon/apps') from managers.auth_manager import AuthManager, generate_login_page_html _form = cgi.FieldStorage() _auth = AuthManager('report_builder') _auth_required, _should_exit, _headers = _auth.require_auth(_form) if _should_exit: print("Content-Type: application/json") if _headers: print(_headers) print("") if _auth_required: print('{"success": false, "error": "Authentication required"}') else: print('{"success": true}') sys.exit(0) if _auth_required: print("Content-Type: text/html") print("") print(generate_login_page_html("Report Builder")) sys.exit(0) import json import datetime as dt # ------------------------------------------------------------------ action: run action = _form.getvalue('action', '') if action == 'run': print("Content-Type: application/json\n") try: from reporting.engine import run_report metrics = [m for m in (_form.getvalue('metrics', '') or '').split(',') if m] sites = [s for s in (_form.getvalue('sites', '') or '').split(',') if s] spec = { "start": _form.getvalue('start'), "end": _form.getvalue('end'), "bucket": _form.getvalue('bucket', 'month'), "group_by": _form.getvalue('group_by', 'site'), "metrics": metrics, } if sites: spec["sites"] = sites print(json.dumps({"success": True, "result": run_report(spec)})) except Exception as e: import traceback print(json.dumps({"success": False, "error": str(e), "trace": traceback.format_exc()})) sys.exit(0) REPORTING_CFG_PATH = '/opt/ngon/config/reporting_config.json' if action == 'save_config': print("Content-Type: application/json\n") try: usd_per_mcf = float(_form.getvalue('usd_per_mcf')) cuft_per_kwh = float(_form.getvalue('cuft_per_kwh')) # per-site $/MCF overrides: JSON {site: rate}; blanks already dropped by JS. by_site_in = json.loads(_form.getvalue('usd_per_mcf_by_site', '') or '{}') usd_per_mcf_by_site = {} for _s, _v in by_site_in.items(): if _v is None or str(_v).strip() == '': continue usd_per_mcf_by_site[_s] = float(_v) running_kw_threshold = float(_form.getvalue('running_kw_threshold')) spec_th = float(_form.getvalue('spec_th')) if spec_th <= 0: raise ValueError('miner spec TH/s must be positive') ga_pct = float(_form.getvalue('ga_pct')) / 100.0 ga_base = _form.getvalue('ga_base', 'on_location_service') if ga_base not in ('on_location_service', 'operating_cost', 'revenue', 'no_location_service'): raise ValueError('invalid G&A base') no_loc = [s.strip() for s in (_form.getvalue('no_location_sites', '') or '').split(',') if s.strip()] if not no_loc: raise ValueError('no-location sites cannot be empty') # read-modify-write in place: preserves foundry keys, comments, and file # ownership/mode (do NOT recreate the file or it drifts off ngon:ngon 660). with open(REPORTING_CFG_PATH) as f: cfg = json.load(f) cfg.setdefault('gas', {})['usd_per_mcf'] = usd_per_mcf cfg['gas']['cuft_per_kwh'] = cuft_per_kwh cfg['gas']['usd_per_mcf_by_site'] = usd_per_mcf_by_site cfg.setdefault('gens', {})['running_kw_threshold'] = running_kw_threshold cfg.setdefault('miner', {})['spec_th'] = spec_th cfg.setdefault('ga', {})['pct'] = ga_pct cfg['ga']['base'] = ga_base cfg['ga']['no_location_sites'] = no_loc with open(REPORTING_CFG_PATH, 'w') as f: json.dump(cfg, f, indent=2) print(json.dumps({"success": True})) except Exception as e: print(json.dumps({"success": False, "error": str(e)})) sys.exit(0) # ------------------------------------------------------------------ render page import cgitb cgitb.enable() sys.path.insert(0, '/var/www/html/ngon') from links import generate_dropdown_html, generate_dropdown_css, generate_dropdown_js from reporting.engine import registry_for_ui, gas_site_list # default range: previous 6 whole months up to the start of the current month _today = dt.date.today() _end = _today.replace(day=1) _m = _end.month - 6 _y = _end.year while _m <= 0: _m += 12 _y -= 1 _start = dt.date(_y, _m, 1) # Site Economics tab default range (inclusive months, YYYY-MM) _econ_from = _start.strftime('%Y-%m') _econ_to = (_end - dt.timedelta(days=1)).strftime('%Y-%m') # current config values for the Settings modal with open(REPORTING_CFG_PATH) as _f: _cfg = json.load(_f) _gas, _gens, _ga = _cfg.get('gas', {}), _cfg.get('gens', {}), _cfg.get('ga', {}) _miner = _cfg.get('miner', {}) _gas_sites = gas_site_list() _by_site = _gas.get('usd_per_mcf_by_site', {}) or {} _cfg_js = json.dumps({ 'usd_per_mcf': _gas.get('usd_per_mcf'), 'cuft_per_kwh': _gas.get('cuft_per_kwh'), 'usd_per_mcf_by_site': {s: _by_site.get(s) for s in _gas_sites}, 'gas_sites': _gas_sites, 'running_kw_threshold': _gens.get('running_kw_threshold'), 'spec_th': _miner.get('spec_th', 180), 'ga_pct': round(_ga.get('pct', 0.1) * 100, 4), 'ga_base': _ga.get('base', 'on_location_service'), 'no_location_sites': ', '.join(_ga.get('no_location_sites', [])), }) # metric checkboxes grouped by registry "group" _reg = registry_for_ui() _groups = {} for _mt in _reg: _groups.setdefault(_mt['group'], []).append(_mt) _default_on = {'avg_hashrate', 'theoretical_hashrate', 'revenue_usd', 'gas_mcf', 'gas_cost', 'avg_gens', 'avg_gens_deployed', 'pm_cost', 'sc_cost', 'pm_visits', 'sc_visits', 'ga_cost'} _metric_html = '' for _gname, _items in _groups.items(): _metric_html += f'
{_gname}
' for _it in _items: _lbl = _it['label'] + (f" ({_it['unit']})" if _it['unit'] else '') _chk = 'checked' if _it['key'] in _default_on else '' _metric_html += (f'') _metric_html += '
' print("Content-Type: text/html\n") print(""" NGON Econs by Site Report Builder

Econs by Site Report Builder

""" + generate_dropdown_html(AuthManager.get_user_access()) + """
Live cross-source econ reports — no snapshots, queried on demand
""" + _metric_html + """
Pick a range and metrics, then Run Report.
""")