(self, message, cb=None)
| 157 | |
| 158 | # Encode to json and send message |
| 159 | def send(self, message, cb=None): |
| 160 | message["id"] = self.next_message_id # Add message id to allow response |
| 161 | self.next_message_id += 1 |
| 162 | if cb: # Callback after client responded |
| 163 | self.waiting_cb[message["id"]] = cb |
| 164 | self.send_queue.append(message) |
| 165 | if self.state["sending"]: |
| 166 | return # Already sending |
| 167 | try: |
| 168 | while self.send_queue: |
| 169 | self.state["sending"] = True |
| 170 | message = self.send_queue.pop(0) |
| 171 | self.ws.send(json.dumps(message)) |
| 172 | self.state["sending"] = False |
| 173 | except Exception as err: |
| 174 | self.log.debug("Websocket send error: %s" % Debug.formatException(err)) |
| 175 | self.state["sending"] = False |
| 176 | |
| 177 | def getPermissions(self, req_id): |
| 178 | permissions = self.site.settings["permissions"] |
no outgoing calls
no test coverage detected