minecraft packet dissector

mcdissect.py

    @handler('read', channel=channel_upstream)
    def read(self, data):
        offset = 0

        while True:
            shift = 0
            size = 0

            while True
                if offset >= len(data):
                    data = yield SPECIAL_VALUE
                    offset = 0

                byte = indexbytes(data, offset)
                offset += 1

                size |= (byte & 0x7F) << shift
                if not (byte & 0x80):
                    break

                shift += 7

            buffer = bytearray()

            while True
                end = offset + size - len(buffer)
                buffer.extend(data[offset:end])

                if len(buffer) >= size:
                    offset = end
                    break
                
                data = yield SPECIAL_VALUE
                offset = 0

            self.fire(read(buffer), self.channel_downstream)
            yield # normal yield without waiting for a new read event