o ЅjK @sNddlZddlZddlZddlZddlmZejddddlmZe dddl m Z m Z m Z mZddZdd d Zd d Zdd dZddZddZddZddZz1ddlZejddZejeZeddgdZeswddiZ neeZ e ej!e ddWdSe"yZ#ze ej!de$e#iddWYdZ#[#dSdZ#[#ww)N)datetimez/opt/ngon/apps)configzContent-Type: application/json )load_inventory load_minersload_sleeping_minersget_miner_colorc Csdd|D}|s tSzPddl}|jdddd}|}t}t|}tdt|d D])}|||d }d d t|}|d |d || dd| Dq,| |WSt y}} zt d| dtjdt|WYd} ~ Sd} ~ ww)uReturn the subset of `macs` that have EVER recorded hs_rt > 0, via the maintained miner_lifecycle.ever_hashed flag (instant indexed lookup — the flag is set monotonically by get_hashrate_and_status.py on each snapshot). MACs are normalized to uppercase (how the DB stores them). On ANY DB error we fail safe by returning the full input set (treat all as having hashed), so a DB hiccup never floods the problem list with false "never hashed" flags.cSsh|]}|r|qSupper.0mrr3/var/www/html/ngon/status/status_site_detail_cgi.py z'get_ever_hashed_macs..rNz,file:/opt/ngon/data/miner_history.db?mode=roT)uritimeouti,?zBSELECT mac FROM miner_lifecycle WHERE ever_hashed = 1 AND mac IN ()css$|] }|dr|dVqdS)rNr )r rrrr /s"z'get_ever_hashed_macs..z$WARNING: ever-hashed lookup failed (z); treating all as hashedfile)setsqlite3connectcursorlistrangelenjoinexecuteupdatefetchallclose Exceptionprintsysstderr) macsrconncurevermac_listichunkpherrrget_ever_hashed_macss8  r4cCst}t}||vr$||D]}|||||D]} || qq||vrB||D]}|||||D]} || q9q,|rF|sKgddSt|t|} } t|t|} } g| | | | d}t| | dD]}|gd}t| | dD]}t|||||||}||||d}||vr|||vr||||vr||||}|dd}||v}d}||vr|||vr||||vr||||d }t|d uo|o| |v}|r|d pd d krd }| |d|d |d|d|d|d|d||||dd nS||vr`|||vr`||||vr`||||}|dp4d}t|d uoH|doH|oH| |v}| |d |d||drZdnddnd|d<|d |q{|d |ql|S)z5Generate data structure for a single pod's miner gridzNo data)rowsmessage)r5min_rowmax_rowmin_posmax_pos)row_num positions)pos_numcolorrowposmacserialNhashraterF miner_typepower error_codestemp fan_speeduptimeonline) rFrErGrHrIrJrKrBrD is_sleeping never_hashedstatus installedofflineempty)rDrBrNrOrOr=r5) raddminmaxr rgetlowerboolr r$append)pod_key inventoryminerssleeping_minersminer_type_specsever_hashed_macsall_rows all_positionsr<r>r7r8r9r: grid_datar@row_datarAr? position_dataminerrBrMrDrNinventory_dataomacrrrgenerate_pod_grid_data7s        *$  *  rhc Csi}zotdd_}t|}|D]M}|dd}|sq||vr%g||<|||ddt|ddp:dt|ddpCd|d d|d d|d dd qWd W|S1sjwYW|Sty}zt d|t j dWYd }~|Sd }~ww)zLoad all miners grouped by pod field from miner_status.csv. Returns dict of pod_name -> list of miner dicts (includes miners not in inventory).z$/opt/ngon/data/live/miner_status.csvrpodrCrBhs_rtrrGrFrH mining_state)rBrErGrFrHrkNz!Error loading all miners by pod: r) opencsv DictReaderrVstriprYrWfloatr'r(r)r*)podsfreaderr@rir3rrrload_all_miners_by_pods8     rtcCsj|r||vrtdd||DSd}||vr3||D]}|||D]}|||||d7}q#q|S)zCalculate total hashrate for a pod. Uses all_miners_by_pod (from pod field) for accurate totals that include miners not in inventory. Falls back to inventory-matched miners only.css|]}|dVqdS)rENrr rrrrsz)calculate_pod_hashrate..rrE)sum)rZr[r\all_miners_by_podtotalr<r>rrrcalculate_pod_hashrates  rxc Cs|r||vrdSt}||vr4||D] }|||D]}||||dd}|r2||qqd}d}||D]} | drR| d|vrR|d7}|| d7}q<||fS)z8Count miners in a pod that aren't in the inventory grid.)rrBrCrryr;rE)rrVrWrS) rZr\rvpositioned_macsr<r>rBcountrEr rrrcount_unpositioned_minerss&     r|cCsz'ddl}|jjddd}t|}Wdn1s!wYWn ty2iYSwi}|dp;i D] }|dpFi D]}|dpQi D]\}}|||<qTqIq>|S) a{unit_id: gen} from status_api, for gens the Mesa feed doesn't carry. status_api is the authority the rest of the status page renders from, so asking it here keeps this modal agreeing with the generator columns instead of quietly disagreeing. Best-effort by design: on any failure we return {} and resolve_generator() still emits the gen, just without a run status. A generator that is missing is a bug; one showing an unknown state is not. rNz http://localhost:5050/api/status)rsitesgenerator_groups generators) urllib.requestrequesturlopenjsonloadsreaddecoder'rVvaluesitems)urllibrdataoutsitegroupgen_idgenrrrload_live_gen_indexs"   rcCs2||}|r |S||pi}||dddS)a3Always return a renderable generator entry for a configured gen. Prefers the full Mesa record when there is one. Otherwise synthesises the two fields the modal actually reads (unit_id, run_status) from status_api. Never returns None: if a gen is mapped to a pod in master_config it belongs on screen, and an unknown-state dot beats a missing generator. run_status here is the non-live branch of the frontend's genEffectiveRunStatus() -- status_api's `status`, i.e. what Mesa last said. The live-telemetry branch is deliberately NOT reimplemented: duplicating that freshness rule in a second place is how the two drift apart. A gen running on our own DSE feed with no Mesa record would read offline here; no gen is in that state today, and the modal's dot is binary anyway. rOT)unit_id run_statusno_provider_datarV)r mesa_by_unit live_by_unitgen_dataliverrrresolve_generators rc' s6zt\}}t|}t}t}zt}Wni}Ygt}fdd|Dt}D]N} | |vr\|| D]} || | D]} || | |  d} | rZ| | qFq>| |vr|| D]} || | D]} || | |  d} | r| | qlqdq4t |} z t }t }Wni}i}Yg}d}tj|rt|d }t|}Wdn1swYdd|D}t}d ggid }D]}t||||}|d |7<qt}|D]\}}|d r|d d d }n|ksdvr|dvr|}nqfdd|D}|r|gd}|D]:}t||||}t|||||| }t|||\}} |||d}!|d krR||!d<| |!d<|d|!| |q%g}"t}#|D]%}||vr||D]}$|$|#vr|"t|$|||# |$qrnqg|"|d<|d|qD]S}||vrt||||}t|||||| }t|||\}} g}%||vr||D] }$|%t|$||q||||%d}!|d kr||!d<| |!d<|d|!qtd|d<|WSt y}&zt!|&tddWYd}&~&Sd}&~&ww)z4Get comprehensive site detail data for modal displaycs&g|]}|ds|kr|qS) ) startswithr ri) site_namerr s&z(get_site_detail_data..rBz'/opt/ngon/data/live/generator_data.jsonrNcSs"i|] }|dr|d|qS)rr)r grrr Ds"z(get_site_detail_data..r)rtotal_hashrate pod_groupsstandalone_podsrr_r;)Out of ServiceSpares)rzAvailable Sparescsg|]}|vr|qSrrr) site_podsrrrer) group_namerq)rZrErbunpositioned_countunpositioned_hashraterqrr)rZrErbrrz %m/%d %H:%M updated_atz%m/%d %H:%M:%S)errorrr)"rrrrtrget_miner_type_specsget_pod_miner_countskeysrrVrSr4get_generator_groupsget_generator_to_pod_mappingospathexistsrlrloadrrxrrsplitrhr|rYrrnowstrftimer'str)'rr[mac_to_locationr\r]rvr^all_pods site_macspkrpr r_r pod_to_gensgenerator_datagenerator_data_pathrrrr site_detailrZ pod_hashrate grouped_podsr pod_namesgroup_display_name pods_in_group group_datapod_grid unpos_countunpos_hashrate pod_entrygroup_generators seen_gen_idsrpod_generatorsr3r)rrrget_site_detail_datas                          r QUERY_STRINGrCrrzMissing site parameterr})indent)N)%rr)rrmrrinsertmanagers.config_managerrr(miners.miner_gridrrrrr4rhrtrxr|rrr urllib.parserenvironrV query_stringparseparse_qsparamsrrdumpsr'r3rrrrrs>   d 1  (