#!/usr/bin/env python3
"""Hermes Web Chat — a lightweight web frontend for Hermes Agent (FIXED VERSION)"""
import http.server
import json
import os
import sys
import urllib.request
import urllib.error
import urllib.parse
import ssl
import threading
from http.server import HTTPServer
HERMES_API_HOST = os.getenv("HERMES_API_HOST", "localhost")
HERMES_API_PORT = int(os.getenv("HERMES_API_PORT", "8642"))
HERMES_API_BASE = f"http://{HERMES_API_HOST}:{HERMES_API_PORT}"
LISTEN_HOST = os.getenv("HERMES_WEB_HOST", "0.0.0.0")
LISTEN_PORT = int(os.getenv("HERMES_WEB_PORT", "8095"))
# Use the gateway's actual API key
API_KEY = "hms_server_806b81a7e1f79ab04ee61f56c9eb357168400ebfe6daf651"
# ─── UI ──→
UI_INDEX = r'''
Iris — Hermes Web Chat
'''
print(f"Generated UI size: {len(UI_INDEX)} bytes")
# ─── Handler ────────────────────
class ChatHandler(http.server.BaseHTTPRequestHandler):
def log_message(self, format, *args):
pass # suppress per-request logs
def _send_json(self, code, data):
body = json.dumps(data).encode()
self.send_response(code)
self.send_header('Content-Type', 'application/json')
self.send_header('Content-Length', str(len(body)))
self.end_headers()
self.wfile.write(body)
def do_GET(self):
if self.path == '/' or self.path == '/index.html':
self.send_response(200)
self.send_header('Content-Type', 'text/html')
self.send_header('Content-Length', str(len(UI_INDEX.encode())))
self.end_headers()
self.wfile.write(UI_INDEX.encode())
elif self.path == '/health':
self._send_json(200, {"status": "ok", "api": f"{HERMES_API_BASE}/v1"})
else:
self.send_error(404)
def do_POST(self):
if self.path == '/api/chat':
self._handle_chat()
elif self.path == '/api/history':
self._handle_history()
else:
self.send_error(404)
def _handle_chat(self):
sess_id = self.headers.get('X-Hermes-Session-Id', '')
sess_key = self.headers.get('X-Hermes-Session-Key', '')
try:
length = int(self.headers.get('Content-Length', 0))
raw_body = self.rfile.read(length)
body = json.loads(raw_body)
except:
self._send_json(400, {"error": "invalid JSON"})
return
# Forward to the actual API server
api_url = f"{HERMES_API_BASE}/v1/chat/completions"
# Build request with proper headers
req = urllib.request.Request(
api_url,
data=raw_body, # Forward the raw JSON as-is, don't re-encode
method='POST'
)
# Add headers
req.add_header('Content-Type', 'application/json')
if sess_id:
req.add_header('X-Hermes-Session-Id', sess_id)
if sess_key:
req.add_header('X-Hermes-Session-Key', sess_key)
if API_KEY:
req.add_header('X-Hermes-API-Key', API_KEY)
try:
with urllib.request.urlopen(req, timeout=300) as resp:
data = json.loads(resp.read())
content = data.get('choices', [{}])[0].get('message', {}).get('content', '')
self._send_json(200, {
"content": content,
"model": data.get('model', 'iris'),
"session_id": sess_id or "new"
})
except urllib.error.HTTPError as e:
err_body = e.read().decode()
self._send_json(e.code, {"error": err_body})
except Exception as e:
self._send_json(502, {"error": f"proxy error: {e}"})
def _handle_history(self):
sess_id = self.headers.get('X-Hermes-Session-Id', '')
api_url = f"{HERMES_API_BASE}/v1/messages"
req = urllib.request.Request(api_url, method='GET')
if sess_id:
req.add_header('X-Hermes-Session-Id', sess_id)
if API_KEY:
req.add_header('X-Hermes-API-Key', API_KEY)
try:
with urllib.request.urlopen(req, timeout=10) as resp:
data = json.loads(resp.read())
self._send_json(200, data)
except Exception:
self._send_json(200, {"messages": []})
# ─── Main ──────────────
def main():
server = HTTPServer((LISTEN_HOST, LISTEN_PORT), ChatHandler)
print(f"{'='*50}")
print(f" Iris Web Chat")
print(f" Access: http://localhost:{LISTEN_PORT}")
print(f" Proxy: {HERMES_API_BASE}")
print(f" API_KEY: {API_KEY[:10]}...")
print(f"{'='*50}")
try:
server.serve_forever()
except KeyboardInterrupt:
server.shutdown()
if __name__ == '__main__':
main()