Create app.py

app.py

@@ -0,0 +1,37 @@
+# app.py
+from fastapi import FastAPI, WebSocket, WebSocketDisconnect, Request
+from fastapi.responses import HTMLResponse
+from fastapi.staticfiles import StaticFiles
+from fastrtc import RTCRoom, RTCRoomManager
+from fastapi.templating import Jinja2Templates
+import uuid
+import json
+
+app = FastAPI()
+room_manager = RTCRoomManager()
+
+app.mount("/static", StaticFiles(directory="static"), name="static") # Mount static files
+templates = Jinja2Templates(directory="templates") # Mount templates
+
+@app.get("/", response_class=HTMLResponse)
+async def read_root(request: Request):
+    return templates.TemplateResponse("index.html", {"request": request})
+
+@app.websocket("/ws/{room_id}/{client_id}")
+async def websocket_endpoint(websocket: WebSocket, room_id: str, client_id: str):
+    await websocket.accept()
+    room = room_manager.get_or_create_room(room_id)
+    peer = await room.join(client_id, websocket)
+
+    try:
+        while True:
+            message = await websocket.receive_text()
+            data = json.loads(message)
+            if data["type"] == "offer" or data["type"] == "answer" or data["type"] == "candidate":
+                await peer.handle_sdp(data)
+            else:
+                print(f"Received unknown message: {data}")
+
+    except WebSocketDisconnect:
+        await room.leave(client_id)
+        print(f"Client {client_id} disconnected from room {room_id}")