w1cdn/spothole
1
0
Fork 0
mirror of https://git.ianrenton.com/ian/spothole.git synced 2026-02-04 09:14:30 +00:00
Code Issues 13 Packages Projects Releases Wiki Activity

SSE custom headers #3

Browse Source
This commit is contained in:
Ian Renton
2025-12-24 09:44:55 +00:00
parent 2fead92dc5
commit bcc40d1416
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/handlers/api/alerts.py
View File

@@ -53,6 +53,11 @@ class APIAlertsStreamHandler(tornado_eventsource.handler.EventSourceHandler):
self.sse_alert_queues = sse_alert_queues self.sse_alert_queues = sse_alert_queues
self.web_server_metrics = web_server_metrics self.web_server_metrics = web_server_metrics
# Custom headers to avoid e.g. nginx reverse proxy from buffering SSE data
def custom_headers(self):
return {"Cache-Control": "no-store",
"X-Accel-Buffering": "no"}
def open(self): def open(self):
try: try:
# Metrics # Metrics

5
server/handlers/api/spots.py
View File

@@ -54,6 +54,11 @@ class APISpotsStreamHandler(tornado_eventsource.handler.EventSourceHandler):
self.sse_spot_queues = sse_spot_queues self.sse_spot_queues = sse_spot_queues
self.web_server_metrics = web_server_metrics self.web_server_metrics = web_server_metrics
# Custom headers to avoid e.g. nginx reverse proxy from buffering SSE data
def custom_headers(self):
return {"Cache-Control": "no-store",
"X-Accel-Buffering": "no"}
# Called once on the client opening a connection, set things up # Called once on the client opening a connection, set things up
def open(self): def open(self):
try: try: