Mercurial > code > home > repos > reposync
comparison patch_cyclone_sse.py @ 18:6f38aa08408d
starting over: make a web page that draws a streamed graph from collector, with plans for services to scrape the data that collector will subscribe to
| author | drewp@bigasterisk.com |
|---|---|
| date | Sun, 09 Jan 2022 00:21:41 -0800 |
| parents | |
| children |
comparison
equal
deleted
inserted
replaced
| 17:a4778c56cc03 | 18:6f38aa08408d |
|---|---|
| 1 def patchCycloneSse(): | |
| 2 import cyclone.sse | |
| 3 from cyclone import escape | |
| 4 | |
| 5 def sendEvent(self, message, event=None, eid=None, retry=None): | |
| 6 if isinstance(message, dict): | |
| 7 message = escape.json_encode(message) | |
| 8 if isinstance(message, str): | |
| 9 message = message.encode("utf-8") | |
| 10 assert isinstance(message, bytes) | |
| 11 | |
| 12 if eid: | |
| 13 self.transport.write(b"id: %s\n" % eid) | |
| 14 if event: | |
| 15 self.transport.write(b"event: %s\n" % event) | |
| 16 if retry: | |
| 17 self.transport.write(b"retry: %s\n" % retry) | |
| 18 | |
| 19 self.transport.write(b"data: %s\n\n" % message) | |
| 20 | |
| 21 cyclone.sse.SSEHandler.sendEvent = sendEvent |