Mercurial > code > home > repos > homeauto
comparison service/mqtt_to_rdf/patch_cyclone_sse.py @ 1585:c8092f6d70c0
add patch_cyclone_sse
| author | drewp@bigasterisk.com |
|---|---|
| date | Sun, 29 Aug 2021 13:44:05 -0700 |
| parents | |
| children |
comparison
equal
deleted
inserted
replaced
| 1584:0ca3228abade | 1585:c8092f6d70c0 |
|---|---|
| 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 |