#!/usr/bin/env python3 """BECOMINGONE Chat - Simple.""" import asyncio import json from becomingone.llm_integrator import EmissaryLLM # Use just Emissary for now (faster) MODEL = EmissaryLLM(model='llama3.1:8b') async def process(prompt): r = await MODEL.respond(prompt) return {"master": {"response": r.get("response", "")[:500]}, "emissary": {"response": r.get("response", "")[:500]}} HTML = '''BECOMINGONE

🔗 BECOMINGONE

Test Mode: Single Model

''' async def handle(r, w): try: d = await r.read(4096) if not d: return txt = d.decode('utf-8', errors='ignore') ln = txt.split('\n')[0].split() method, path = ln[0], ln[1] if len(ln) > 1 else '/' body = b"" for line in txt.split('\r\n'): if line.lower().startswith('content-length:'): body = await r.read(int(line.split(':')[1].strip())) break if path == '/health': w.write(b'HTTP/1.1 200 OK\r\nContent-Type: application/json\r\nContent-Length: 16\r\n\r\n{"status":"ok"}') elif path == '/c' and method == 'POST': data = json.loads(body.decode()) result = await process(data.get('prompt', 'Hi')) resp = json.dumps(result) w.write(b'HTTP/1.1 200 OK\r\nContent-Type: application/json\r\nContent-Length: ' + str(len(resp)).encode() + b'\r\n\r\n' + resp.encode()) else: w.write(b'HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nContent-Length: ' + str(len(HTML)).encode() + b'\r\n\r\n' + HTML.encode()) except Exception as e: print('Error:', e) finally: w.close() await w.wait_closed() asyncio.run(asyncio.start_server(handle, '0.0.0.0', 8001)) print('Running on http://192.168.1.6:8001')