#!/usr/bin/env python3 """Money -- what the fleet is earning right now. Not in the nav dropdown (link-only page). Everything here is a THEORETICAL earnings model off our live hashrate vs. network difficulty -- it is not pool accounting. Foundry's actual payouts will differ (luck, pool fee, FPPS terms, and our own hashrate undercount on big pods). Model, per unit of hashrate H (TH/s): BTC/day = H * 1e12 * 86400 * block_reward / (difficulty * 2**32) where block_reward = subsidy (3.125 now) + the trailing-144-block average fee. """ import cgi import sys sys.path.insert(0, '/opt/ngon/apps') sys.path.insert(0, '/var/www/html/ngon') from managers.auth_manager import AuthManager, generate_login_page_html _form = cgi.FieldStorage() _auth = AuthManager('money') _auth_required, _should_exit, _headers = _auth.require_auth(_form) if _should_exit: print("Content-Type: application/json") if _headers: print(_headers) print("") print('{"success": false, "error": "Authentication required"}' if _auth_required else '{"success": true}') sys.exit(0) if _auth_required: print("Content-Type: text/html") print("") print(generate_login_page_html("Money")) sys.exit(0) # --------------------------------------------------------------------------- import json import os import time import urllib.request from links import generate_dropdown_html, generate_dropdown_css, generate_dropdown_js STATUS_API = "http://localhost:5050/api/status" REPORTING_CONFIG = "/opt/ngon/config/reporting_config.json" CACHE_FILE = "/var/www/html/ngon/status/caches/btc_network.json" CACHE_TTL = 300 # network stats move slowly; one fetch per 5 min is plenty SPEC_TH = 180 # M60 spec hashrate, TH/s (misc.miner_types is authoritative) SPEC_W = 3500 # M60 spec draw, watts (same source) MINERS_PER_GEN = 90 # the shop rule of thumb; the page also shows the real ratio UA = {"User-Agent": "ngon-money"} MEMPOOL = "https://mempool.space/api" COINGECKO = "https://api.coingecko.com/api/v3/simple/price?ids=bitcoin&vs_currencies=usd" COINBASE_SPOT = "https://api.coinbase.com/v2/prices/BTC-USD/spot" def _get_json(url, timeout=8): req = urllib.request.Request(url, headers=UA) with urllib.request.urlopen(req, timeout=timeout) as resp: return json.loads(resp.read().decode()) def _fetch_network(): """Live difficulty / network hashrate / block reward / BTC price. Every piece is fetched independently so one dead upstream degrades a single field instead of blanking the page. Returns a dict plus an 'errors' list. """ out = {"errors": []} try: hr = _get_json(MEMPOOL + "/v1/mining/hashrate/3d") out["difficulty"] = float(hr["currentDifficulty"]) out["network_hashrate"] = float(hr["currentHashrate"]) # H/s except Exception as exc: out["errors"].append("hashrate/difficulty: %s" % exc) try: out["height"] = int(_get_json(MEMPOOL + "/blocks/tip/height")) except Exception as exc: out["errors"].append("height: %s" % exc) try: adj = _get_json(MEMPOOL + "/v1/difficulty-adjustment") out["retarget"] = { "change_pct": adj.get("difficultyChange"), "remaining_blocks": adj.get("remainingBlocks"), "eta_ms": adj.get("estimatedRetargetDate"), "progress_pct": adj.get("progressPercent"), } except Exception as exc: out["errors"].append("retarget: %s" % exc) try: rw = _get_json(MEMPOOL + "/v1/mining/reward-stats/144") blocks = max(1, int(rw["endBlock"]) - int(rw["startBlock"]) + 1) out["fee_per_block"] = float(rw["totalFee"]) / 1e8 / blocks except Exception as exc: out["fee_per_block"] = 0.0 out["errors"].append("fees: %s" % exc) price = None try: price = float(_get_json(COINGECKO)["bitcoin"]["usd"]) out["price_source"] = "CoinGecko" except Exception: try: price = float(_get_json(COINBASE_SPOT)["data"]["amount"]) out["price_source"] = "Coinbase" except Exception as exc: out["errors"].append("price: %s" % exc) if price: out["price_usd"] = price if "height" in out: # Subsidy halves every 210,000 blocks (3.125 BTC in the current epoch). out["subsidy"] = 50.0 / (2 ** (out["height"] // 210000)) out["fetched"] = time.time() return out def _network_stats(): """Cached network stats. Stale cache beats no data -- age is shown in the UI.""" cached = None try: with open(CACHE_FILE) as fh: cached = json.load(fh) except Exception: pass if cached and (time.time() - cached.get("fetched", 0)) < CACHE_TTL: cached["cached"] = True return cached fresh = _fetch_network() # Only adopt the fetch if the two fields the whole model hangs on came back. if "difficulty" in fresh and "price_usd" in fresh: try: with open(CACHE_FILE, "w") as fh: json.dump(fresh, fh) except Exception: pass fresh["cached"] = False return fresh if cached: cached["cached"] = True cached["errors"] = (cached.get("errors") or []) + fresh.get("errors", []) return cached fresh["cached"] = False return fresh def _gas_rates(): """Gas-cost inputs for the repair-payoff math. Read from reporting_config.json so this page and the report builder price gas off the same number. The shipped $/MCF is still a PLACEHOLDER -- flagged here so the page can say so out loud instead of quietly pricing gas at $0.50/MCF. """ out = {"cuft_per_kwh": 11.0, "usd_per_mcf": 0.5, "placeholder": True} try: with open(REPORTING_CONFIG) as fh: gas = (json.load(fh) or {}).get("gas") or {} out["cuft_per_kwh"] = float(gas.get("cuft_per_kwh") or out["cuft_per_kwh"]) out["usd_per_mcf"] = float(gas.get("usd_per_mcf") or out["usd_per_mcf"]) out["placeholder"] = "PLACEHOLDER" in (gas.get("_usd_per_mcf_note") or "") except Exception: pass return out def _fleet(): """Per-site + fleet rollup straight off the live status API.""" data = _get_json(STATUS_API, timeout=10) excluded = set((((data.get("misc") or {}).get("display") or {}) .get("excludedSites") or [])) spec_th, spec_w = SPEC_TH, SPEC_W try: m60 = (((data.get("misc") or {}).get("miner_types") or {}).get("M60") or {}) spec_th = float(m60.get("spec_hashrate") or SPEC_TH) spec_w = float(m60.get("spec_wattage") or SPEC_W) except Exception: pass sites = [] for name, site in (data.get("sites") or {}).items(): if name in excluded: continue row = {"site": name, "hashrate": 0.0, "hashing": 0, "sleeping": 0, "offline": 0, "zero_hash": 0, "installed": 0, "power_w": 0.0, "gens_running": 0, "gens_total": 0} for group in (site.get("generator_groups") or {}).values(): for gen in (group.get("generators") or {}).values(): row["gens_total"] += 1 if (gen.get("status") or "").lower() == "running": row["gens_running"] += 1 for pod in (group.get("pods") or {}).values(): st = pod.get("stats") or {} row["hashrate"] += st.get("hashrate") or 0 row["hashing"] += st.get("miners_hashing") or 0 row["sleeping"] += st.get("miners_sleeping") or 0 row["offline"] += st.get("miners_offline") or 0 row["zero_hash"] += st.get("miners_zero_hash") or 0 row["installed"] += (st.get("miners_installed") or st.get("total_miners") or 0) # stats.power is average watts PER MINER, not pod total. row["power_w"] += (st.get("power") or 0) * (st.get("total_miners") or 0) if row["installed"] or row["hashrate"]: sites.append(row) sites.sort(key=lambda r: r["hashrate"], reverse=True) total = {k: sum(r[k] for r in sites) for k in ("hashrate", "hashing", "sleeping", "offline", "zero_hash", "installed", "power_w", "gens_running", "gens_total")} total["spec_th"] = spec_th total["spec_w"] = spec_w total["ath_hashrate"] = (data.get("summary") or {}).get("ath_hashrate") total["updated"] = (data.get("metadata") or {}).get("last_updated") return {"sites": sites, "fleet": total} def _payload(): net = _network_stats() out = {"network": net, "miners_per_gen_assumed": MINERS_PER_GEN, "gas": _gas_rates(), "generated": time.time()} try: out.update(_fleet()) except Exception as exc: out["error"] = "status API unreachable: %s" % exc out["sites"] = [] out["fleet"] = {} # The one number everything else is multiplied by: BTC per TH/s per day. diff = net.get("difficulty") reward = (net.get("subsidy") or 3.125) + (net.get("fee_per_block") or 0.0) if diff: out["btc_per_th_day"] = 1e12 * 86400 * reward / (diff * (2 ** 32)) else: out["btc_per_th_day"] = None out["block_reward"] = reward return out if _form.getvalue('ajax') == 'data': print("Content-Type: application/json") print("Cache-Control: no-store") print("") print(json.dumps(_payload())) sys.exit(0) _payload_json = json.dumps(_payload()) _user_access = AuthManager.get_user_access() print("Content-Type: text/html") print("") print(""" Money - NGON

NGON - Money

""") print(generate_dropdown_html(_user_access)) print("""
Theoretical earnings from live hashrate, difficulty and price. Not pool accounting.

Whole operation - right now

--
--
--
per month
--
per year
--
fleet hashrate
--
of network
0 sats earned since you opened this page ($0.00)

Assumptions

Per miner

--
--

Per generator

--
--

Repair payoff - is it worth fixing?

Payoff is on net revenue: mining revenue minus the gas burned to make it. Uptime scales both - drop it below 100% for daytime derate, sleep time or a pod that is down half the month.
Miner repair enter a cost
--
030d90d6mo1yr+
Generator repair enter a cost
--
030d90d6mo1yr+
A gen repair only earns if there are idle miners for it to carry - it pays back at this rate when the gen comes back to a pod with miners waiting, not when it joins a group that is already covering its load.

By site

Site Hashrate Miners Gens run Miners / gen BTC / day $ / day $ / gen / day $ / miner / day

Network

""") print("") print(""" """) # generate_dropdown_js() returns bare JS with no ") print("")