Lines Matching refs:msg

66 def format_json(msg: str) -> str:
102         msg = json.loads(msg)
103         return str(json.dumps(msg))
105         msg = msg.replace('\n', '')
106         words = msg.split(' ')
155     def add_to_history(self, msg: str, level: Optional[str] = None) -> None:
162         urwid.emit_signal(self, UPDATE_MSG, msg, level)
164     def _cb_outbound(self, msg: Message) -> Message:
173         str_msg = str(msg)
178         return msg
180     def _cb_inbound(self, msg: Message) -> Message:
189         str_msg = str(msg)
194         return msg
196     async def _send_to_server(self, msg: Message) -> None:
207             await self._raw(msg, assign_id='id' not in msg)
227             msg = Message(bytes(raw_msg, encoding='utf-8'))
228             create_task(self._send_to_server(msg))
278     def _set_status(self, msg: str) -> None:
285         self.window.footer.set_text(msg)
450         msg = self.get_edit_text()
451         if key == 'up' and not msg:
476             self.parent.cb_send_to_server(msg)
477             self.history.append(msg)
555     def cb_add_to_history(self, msg: str, level: Optional[str] = None) -> None:
566             msg = f'[{level}]: {msg}'
567             formatted.append((level, msg))
570             for token in lexer.get_tokens(msg):
609         msg = record.getMessage()
610         self.tui.add_to_history(msg, level)