#!/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('inventory')
_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("Inventory"))
sys.exit(0)
"""
Inventory Display Page
File: /var/www/html/ngon/inventory/index.py
This script displays inventory data with a three-column layout:
- Left: All miners from inventory
- Middle: Container filters (Site Pod combinations)
- Right: Floaters (placeholder for unassigned miners)
"""
import pandas as pd
import json
import csv
import os
import sys
from html import escape
# Import universal navigation
sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
from links import generate_dropdown_html, generate_dropdown_css, generate_dropdown_js
class InventoryManager:
"""Handles loading and processing of inventory data."""
def __init__(self):
self.inventory_data = []
self.containers = set()
self.load_data()
def load_data(self):
"""Loads inventory data from CSV file."""
try:
inventory_file = '/opt/ngon/data/live/miner_inventory.csv'
if os.path.exists(inventory_file):
df = pd.read_csv(inventory_file)
# Process each row
for _, row in df.iterrows():
position = str(row['Position']).strip()
serial = str(row['Serial']).strip()
mac = str(row['MAC']).strip()
site = str(row['Site']).strip()
pod = str(row['Pod']).strip()
# Skip rows with empty essential data
if position == 'nan' or position == '':
continue
container = f"{site} {pod}"
self.containers.add(container)
is_empty = (serial == 'nan' or serial == '') and (mac == 'nan' or mac == '')
self.inventory_data.append({
'position': position,
'serial': serial if serial != 'nan' else 'Unknown',
'mac': mac if mac != 'nan' else 'Unknown',
'site': site,
'pod': pod,
'container': container,
'is_empty': is_empty
})
except Exception:
# Fail silently if file is missing or corrupt
pass
def get_containers(self):
"""Returns sorted list of containers."""
return sorted(list(self.containers))
def get_miners_by_container(self, container):
"""Returns miners for a specific container."""
return [miner for miner in self.inventory_data if miner['container'] == container]
def get_installed_miners_count(self):
"""Returns count of installed miners (higher of MAC or Serial counts)."""
mac_count = 0
serial_count = 0
for miner in self.inventory_data:
# Count valid MACs (not 'Unknown', 'nan', or empty)
if miner['mac'] not in ['Unknown', 'nan', '']:
mac_count += 1
# Count valid Serials (not 'Unknown', 'nan', or empty)
if miner['serial'] not in ['Unknown', 'nan', '']:
serial_count += 1
# Return the higher of the two counts
return max(mac_count, serial_count)
def generate_html_content(inventory_manager):
"""Generates the dynamic HTML sections for the page."""
# Generate miners HTML (left column)
miners_html = []
if not inventory_manager.inventory_data:
miners_html.append('
No inventory data found
')
else:
for miner in inventory_manager.inventory_data:
position = escape(miner['position'])
serial = escape(miner['serial'])
mac = escape(miner['mac'])
site = escape(miner['site'])
pod = escape(miner['pod'])
container = escape(miner['container'])
is_empty_attr = 'true' if miner.get('is_empty', False) else 'false'
miners_html.append(f"""
{position}
{mac}
Serial: {serial}
{site} Pod {pod}
""")
# Generate container filters HTML (middle column)
containers = inventory_manager.get_containers()
container_filters_html = []
for container in containers:
container_safe = escape(container, quote=True)
miner_count = len(inventory_manager.get_miners_by_container(container))
container_filters_html.append(f"""
{miner_count}
""")
return ''.join(miners_html), ''.join(container_filters_html)
def load_miner_moves():
"""Load put and pull CSV data for the miner moves viewer."""
moves = {'put': [], 'pull': []}
put_csv = '/opt/ngon/data/miner_moves/put.csv'
pull_csv = '/opt/ngon/data/miner_moves/pull.csv'
for move_type, csv_path in [('put', put_csv), ('pull', pull_csv)]:
try:
if os.path.exists(csv_path):
with open(csv_path, 'r') as f:
reader = csv.reader(f)
next(reader, None) # Skip header
for row in reader:
if not row or not row[0] or not row[0][0].isdigit():
continue
if move_type == 'put' and len(row) >= 4:
moves['put'].append({
'date': row[0], 'serial': row[1],
'pod': row[2], 'position': row[3],
'user': row[4].strip() if len(row) > 4 else ''
})
elif move_type == 'pull' and len(row) >= 4:
moves['pull'].append({
'date': row[0], 'serial': row[1],
'pod': row[2], 'position': row[3],
'mac': row[5] if len(row) > 5 else '',
'user': row[6].strip() if len(row) > 6 else ''
})
except Exception:
pass
moves['put'].reverse()
moves['pull'].reverse()
return moves
def render_page(inventory_manager):
"""Renders the complete HTML page."""
miners_html, container_filters_html = generate_html_content(inventory_manager)
all_containers_json = json.dumps(inventory_manager.get_containers())
moves_data = load_miner_moves()
moves_json = json.dumps(moves_data)
put_count = len(moves_data['put'])
pull_count = len(moves_data['pull'])
return f"""
Inventory Display