Create app.py

app.py

@@ -0,0 +1,71 @@
+from aiohttp import web
+import json
+
+# In-memory storage for signaling sessions
+# Format: { "session_id": {"offer": {}, "answer": {}, "candidates": []} }
+sessions = {}
+
+# Cloudflare TURN Credentials
+ICE_CONFIG = {
+    "iceServers": [
+        {"urls": "stun:stun.cloudflare.com:3478"},
+        {
+            "urls": "turn:turn.cloudflare.com:5349",
+            "username": "g08abe68c81a07f098bb5f0914549bb32440e5aad0b216c7fba2b61e76fd62c6",
+            "credential": "aed1a10dd10eba9401ad9d99e5c66036d8a970eab5ba8e6dc9845ab57c771a7d"
+        }
+    ]
+}
+
+async def handle_post(request):
+    """Handles uploading Offers, Answers, and ICE Candidates"""
+    data = await request.json()
+    sid = data.get("id")
+    msg_type = data.get("type")
+    payload = data.get("payload")
+
+    if not sid:
+        return web.json_response({"error": "No ID provided"}, status=400)
+
+    if sid not in sessions:
+        sessions[sid] = {"offer": None, "answer": None, "candidates": []}
+
+    if msg_type == "offer":
+        sessions[sid]["offer"] = payload
+    elif msg_type == "answer":
+        sessions[sid]["answer"] = payload
+    elif msg_type == "candidate":
+        sessions[sid]["candidates"].append(payload)
+
+    return web.json_response({"status": "stored"})
+
+async def handle_get(request):
+    """Handles retrieving session data and TURN config"""
+    sid = request.query.get("id")
+    if not sid or sid not in sessions:
+        return web.json_response({"error": "Session not found"}, status=404)
+    
+    response_data = sessions[sid].copy()
+    response_data["iceConfig"] = ICE_CONFIG
+    return web.json_response(response_data)
+
+# CORS Middleware to allow browsers to talk to this server
+async def cors_middleware(app, handler):
+    async def middleware(request):
+        if request.method == 'OPTIONS':
+            response = web.Response()
+        else:
+            response = await handler(request)
+        response.headers['Access-Control-Allow-Origin'] = '*'
+        response.headers['Access-Control-Allow-Methods'] = 'GET, POST, OPTIONS'
+        response.headers['Access-Control-Allow-Headers'] = 'Content-Type'
+        return response
+    return middleware
+
+app = web.Application(middlewares=[cors_middleware])
+app.router.add_post('/signal', handle_post)
+app.router.add_get('/signal', handle_get)
+
+if __name__ == '__main__':
+    print("WebRTC Broker Server starting on http://0.0.0.0:3000")
+    web.run_app(app, port=3000)