from micropie import App, ConnectionClosed


class MyApp(App):
    async def chat(self):
        """HTTP handler for GET /chat"""
        return "Welcome to MicroPie, this is an HTTP GET route!"

    async def ws_chat(self, ws, room=None):
        """WebSocket handler for ws://localhost:8000/chat"""
        await ws.accept()
        user = self.request.query("user", "anonymous")
        self.request.session["last_room"] = room or "default"
        while True:
            try:
                message = await ws.receive_text()
                response = f"{user} in {room or 'default'}: {message}"
                await ws.send_text(response)
            except ConnectionClosed:
                break


app = MyApp()