Function fetch

infrastructure/signaling-server/src/index.ts:19–46

(request: Request, env: Env)

export default {
    async fetch(request: Request, env: Env): Promise<Response> {
        const url = new URL(request.url);

        // Health check endpoint
        if (url.pathname === "/health") {
            return new Response(JSON.stringify({ status: "ok", timestamp: Date.now() }), {
                headers: { "Content-Type": "application/json" }
            });
        }

        // WebSocket upgrade for signaling
        if (url.pathname === "/ws") {
            const upgradeHeader = request.headers.get("Upgrade");
            if (upgradeHeader !== "websocket") {
                return new Response("Expected WebSocket", { status: 426 });
            }

            // Route to a singleton Durable Object that manages all rooms
            const id = env.ROOMS.idFromName("global");
            const room = env.ROOMS.get(id);
            return room.fetch(request);
        }

        // Default response
        return new Response("VisionProTeleop Signaling Server\n\nConnect via WebSocket at /ws", {
            headers: { "Content-Type": "text/plain" }
        });
    }
};

// ============================================================================