| 299 | self.echo_flow(f) |
| 300 | |
| 301 | def websocket_message(self, f: http.HTTPFlow): |
| 302 | assert f.websocket is not None # satisfy type checker |
| 303 | if self.match(f): |
| 304 | message = f.websocket.messages[-1] |
| 305 | |
| 306 | direction = "->" if message.from_client else "<-" |
| 307 | self.echo( |
| 308 | f"{human.format_address(f.client_conn.peername)} " |
| 309 | f"{direction} WebSocket {message.type.name.lower()} message " |
| 310 | f"{direction} {human.format_address(f.server_conn.address)}{f.request.path}" |
| 311 | ) |
| 312 | if ctx.options.flow_detail >= 3: |
| 313 | self._echo_message(message, f) |
| 314 | |
| 315 | def websocket_end(self, f: http.HTTPFlow): |
| 316 | assert f.websocket is not None # satisfy type checker |