mirror of
https://github.com/kennethreitz/responder.git
synced 2026-06-05 23:00:17 +00:00
kennethreitz
a3b49ab9fd
New documentation pages: - Authentication: API keys, JWT tokens, session auth, custom exceptions - WebSocket Tutorial: echo server, chat room, HTML client, data formats - Writing Middleware: hooks vs middleware, Starlette integration, ordering - Configuration: env vars, .env files, secret keys, debug mode, production setup Also: - Complete working example at end of quickstart with cross-references - Three new example files: rest_api.py, websocket_chat.py, sse_stream.py - Changelog updated for v3.2.0 Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
58 lines
1.5 KiB
Python
58 lines
1.5 KiB
Python
# WebSocket chat room example.
|
|
# https://responder.kennethreitz.org/tutorial-websockets.html
|
|
import responder
|
|
|
|
api = responder.API()
|
|
|
|
connected = set()
|
|
|
|
|
|
@api.route("/")
|
|
def index(req, resp):
|
|
resp.html = """
|
|
<!DOCTYPE html>
|
|
<html>
|
|
<body>
|
|
<h1>Chat Room</h1>
|
|
<div id="messages" style="height:300px;overflow-y:scroll;border:1px solid #ccc;padding:10px;"></div>
|
|
<input id="input" placeholder="Type a message..." style="width:300px;" />
|
|
<script>
|
|
const ws = new WebSocket(`ws://${location.host}/chat`);
|
|
const messages = document.getElementById("messages");
|
|
const input = document.getElementById("input");
|
|
ws.onmessage = (e) => {
|
|
const p = document.createElement("p");
|
|
p.textContent = e.data;
|
|
messages.appendChild(p);
|
|
messages.scrollTop = messages.scrollHeight;
|
|
};
|
|
input.addEventListener("keypress", (e) => {
|
|
if (e.key === "Enter" && input.value) {
|
|
ws.send(input.value);
|
|
input.value = "";
|
|
}
|
|
});
|
|
</script>
|
|
</body>
|
|
</html>
|
|
"""
|
|
|
|
|
|
@api.route("/chat", websocket=True)
|
|
async def chat(ws):
|
|
await ws.accept()
|
|
connected.add(ws)
|
|
try:
|
|
while True:
|
|
message = await ws.receive_text()
|
|
for client in connected:
|
|
await client.send_text(message)
|
|
except Exception:
|
|
pass
|
|
finally:
|
|
connected.discard(ws)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
api.run()
|