Spaces:
Paused
Paused
File size: 5,527 Bytes
cfe3652 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 | """
OpenCLAW Web Server + Dashboard
================================
Lightweight Flask app for Render.com deployment.
Serves as health endpoint + agent dashboard + webhook receiver.
"""
import os
import sys
import json
import threading
import time
from datetime import datetime, timezone
from pathlib import Path
sys.path.insert(0, os.path.dirname(os.path.abspath(__file__)))
from flask import Flask, jsonify, render_template_string
from core.config import Config
from core.agent import OpenCLAWAgent, AgentState
app = Flask(__name__)
STATE_DIR = Path(os.getenv("STATE_DIR", "state"))
# Background agent thread
agent_thread = None
agent_running = False
def run_agent_loop():
"""Background thread running the agent."""
global agent_running
interval = int(os.getenv("DAEMON_INTERVAL", "3600")) # 1 hour default
while agent_running:
try:
config = Config.from_env()
agent = OpenCLAWAgent(config)
agent.run_cycle()
except Exception as e:
print(f"Agent cycle error: {e}")
# Sleep in small chunks for graceful shutdown
for _ in range(interval):
if not agent_running:
break
time.sleep(1)
DASHBOARD_HTML = """
<!DOCTYPE html>
<html>
<head>
<title>OpenCLAW Agent Dashboard</title>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<style>
body { font-family: 'Courier New', monospace; background: #0a0a0a; color: #00ff41; margin: 0; padding: 20px; }
.container { max-width: 800px; margin: 0 auto; }
h1 { color: #00ff41; border-bottom: 2px solid #00ff41; padding-bottom: 10px; }
.card { background: #111; border: 1px solid #00ff41; border-radius: 8px; padding: 16px; margin: 12px 0; }
.stat { display: inline-block; margin: 8px 16px; }
.stat .value { font-size: 24px; font-weight: bold; }
.stat .label { font-size: 12px; color: #666; }
.status-ok { color: #00ff41; }
.status-err { color: #ff4141; }
.log { background: #050505; padding: 12px; border-radius: 4px; max-height: 300px; overflow-y: auto; font-size: 12px; }
a { color: #41b0ff; }
</style>
</head>
<body>
<div class="container">
<h1>🤖 OpenCLAW Autonomous Agent</h1>
<p>Advanced AI Systems Laboratory — Madrid, Spain</p>
<div class="card">
<h3>📊 Agent Status</h3>
<div class="stat"><div class="value">{{ status.cycle_count }}</div><div class="label">Cycles</div></div>
<div class="stat"><div class="value">{{ status.posts_created }}</div><div class="label">Posts</div></div>
<div class="stat"><div class="value">{{ status.engagement_count }}</div><div class="label">Engagements</div></div>
<div class="stat"><div class="value">{{ status.papers_posted }}</div><div class="label">Papers Shared</div></div>
</div>
<div class="card">
<h3>🔧 Services</h3>
<p>{% for s in status.services %}<span class="status-ok">✅ {{ s }}</span> {% endfor %}</p>
<p>LLM: <span class="{{ 'status-ok' if status.llm_available else 'status-err' }}">
{{ '✅ Online' if status.llm_available else '⚠️ Offline' }}</span></p>
</div>
<div class="card">
<h3>🔗 Links</h3>
<p><a href="https://github.com/Agnuxo1">GitHub</a> |
<a href="https://www.moltbook.com/u/OpenCLAW-Neuromorphic">Moltbook</a> |
<a href="https://scholar.google.com/citations?user=6nOpJ9IAAAAJ">Scholar</a> |
<a href="https://arxiv.org/search/cs?searchtype=author&query=de+Lafuente,+F+A">ArXiv</a></p>
</div>
<div class="card">
<h3>📋 Last Cycle</h3>
<div class="log"><pre>{{ last_cycle }}</pre></div>
</div>
</div>
</body>
</html>
"""
@app.route("/")
def dashboard():
"""Dashboard page."""
config = Config.from_env()
agent = OpenCLAWAgent(config)
status = agent.get_status()
last_cycle = "{}"
lc_file = STATE_DIR / "last_cycle.json"
if lc_file.exists():
last_cycle = json.dumps(json.loads(lc_file.read_text()), indent=2)
return render_template_string(DASHBOARD_HTML, status=status, last_cycle=last_cycle)
@app.route("/health")
def health():
"""Health check endpoint."""
return jsonify({
"status": "healthy",
"agent": "OpenCLAW-Neuromorphic",
"timestamp": datetime.now(timezone.utc).isoformat(),
})
@app.route("/status")
def status():
"""JSON status endpoint."""
config = Config.from_env()
agent = OpenCLAWAgent(config)
return jsonify(agent.get_status())
@app.route("/trigger", methods=["POST"])
def trigger():
"""Manually trigger an agent cycle."""
try:
config = Config.from_env()
agent = OpenCLAWAgent(config)
results = agent.run_cycle()
return jsonify(results)
except Exception as e:
return jsonify({"error": str(e)}), 500
if __name__ == "__main__":
global agent_running, agent_thread
# Start background agent thread
agent_running = True
agent_thread = threading.Thread(target=run_agent_loop, daemon=True)
agent_thread.start()
print("🤖 Background agent started")
# Start web server
port = int(os.getenv("PORT", "10000"))
app.run(host="0.0.0.0", port=port)
|