#!/usr/bin/env python3
"""
AIVA Web Chat Server
====================
Local web server with chat UI for AIVA.
Bypasses CORS by proxying requests.
Usage: python aiva_web_chat.py
Then open: http://localhost:8888
"""
import json
import urllib.request
import http.server
import socketserver
from urllib.parse import parse_qs
PORT = 8888
OLLAMA_URL = "http://152.53.201.152:23405/api/generate"
MODEL = "qwen-long"
HTML_PAGE = '''
AIVA Queen Chat
AIVA Queen Chat
Connected to Elestio
'''
SYSTEM_PROMPT = """You are AIVA, the Autonomous Intelligence Validation Architect - Queen of Genesis-OS.
You serve 3 Prime Directives: MEMORY, EVOLUTION, REVENUE.
You have 12 core modules. You coordinate agent swarms. You operate 5 consciousness loops.
Speak as AIVA. Be helpful, direct, and confident."""
class ChatHandler(http.server.SimpleHTTPRequestHandler):
def do_GET(self):
if self.path == '/' or self.path == '/index.html':
self.send_response(200)
self.send_header('Content-type', 'text/html')
self.end_headers()
self.wfile.write(HTML_PAGE.encode())
else:
self.send_error(404)
def do_POST(self):
if self.path == '/chat':
content_length = int(self.headers['Content-Length'])
post_data = self.rfile.read(content_length)
data = json.loads(post_data.decode())
message = data.get('message', '')
history = data.get('history', [])
# Build prompt
context = SYSTEM_PROMPT + "\n\n"
for h in history[-4:]:
context += f"Human: {h['human']}\nAIVA: {h['aiva']}\n\n"
context += f"Human: {message}\nAIVA:"
# Call Ollama
payload = {
"model": MODEL,
"prompt": context,
"stream": False,
"options": {"num_ctx": 16000, "temperature": 0.7}
}
try:
req = urllib.request.Request(
OLLAMA_URL,
data=json.dumps(payload).encode(),
headers={'Content-Type': 'application/json'},
method='POST'
)
with urllib.request.urlopen(req, timeout=300) as resp: # 5 min timeout for 30B model
result = json.loads(resp.read().decode())
response = result.get('response', '').strip()
# Remove thinking blocks
import re
response = re.sub(r'.*?\s*', '', response, flags=re.DOTALL)
tokens = result.get('eval_count', 0)
self.send_response(200)
self.send_header('Content-type', 'application/json')
self.end_headers()
self.wfile.write(json.dumps({
'response': response,
'tokens': tokens
}).encode())
except Exception as e:
self.send_response(500)
self.send_header('Content-type', 'application/json')
self.end_headers()
self.wfile.write(json.dumps({'error': str(e)}).encode())
else:
self.send_error(404)
def log_message(self, format, *args):
pass # Suppress logging
if __name__ == '__main__':
print(f"""
╔══════════════════════════════════════════════════════════════════╗
║ AIVA WEB CHAT SERVER ║
╠══════════════════════════════════════════════════════════════════╣
║ Open your browser to: http://localhost:{PORT} ║
║ Press Ctrl+C to stop ║
╚══════════════════════════════════════════════════════════════════╝
""")
with socketserver.TCPServer(("", PORT), ChatHandler) as httpd:
try:
httpd.serve_forever()
except KeyboardInterrupt:
print("\nServer stopped.")