Method read_next_message

remi/server.py:159–205

(self)

        return b

    def read_next_message(self):
        # noinspection PyBroadException
        try:
            decoded = ''
            fin = 0
            while fin == 0:
                head = None
                try:
                    head = self.rfile.read(2)
                except ValueError:
                    # socket was closed, just return without errors
                    return False
                if head is None:
                    return False
                if len(head) < 2:
                    return False
                opcode = head[0] & 0b1111
                fin = head[0] >> 7 & 1
                is_masked = head[1] >> 7 & 1
                length = self.bytetonum(head[1]) & 127

                if length == 126:
                    length = struct.unpack('>H', self.rfile.read(2))[0]
                elif length == 127:
                    length = struct.unpack('>Q', self.rfile.read(8))[0]

                masks = []
                if is_masked:
                    masks = [self.bytetonum(byte) for byte in self.rfile.read(4)]

                frame_data = ''
                for char in self.rfile.read(length):
                    if is_masked:
                        next_data = chr(self.bytetonum(char) ^ masks[len(frame_data) % 4])
                        frame_data += next_data
                    else:
                        frame_data += chr(self.bytetonum(char))

                decoded += frame_data
                self._log.debug('read_message: %s...' % (decoded[:10]))
            self.on_message(from_websocket(decoded))
        except socket.timeout:
            return False
        except Exception:
            self._log.error('Error managing incoming websocket message', exc_info=True)
            return False
        return True

    def send_message(self, message):
        if not self.handshake_done: