Compressor Serializers

Data compressor serializer module.

class easynetwork.serializers.wrapper.compressor.BZ2CompressorSerializer

Bases: AbstractCompressorSerializer, Generic

A serializer wrapper to handle bzip2 compressed data, built on top of bz2 module.

__init__(serializer: AbstractPacketSerializer[SentDTOPacket, ReceivedDTOPacket], *, compress_level: int | None = None, debug: bool = False) → None

Parameters:

• serializer (AbstractPacketSerializer[SentDTOPacket, ReceivedDTOPacket]) – The serializer to wrap.

• compress_level (int | None) – bzip2 compression level. Defaults to 9.

• debug (bool) – If True, add information to DeserializeError via the error_info attribute.

final new_compressor_stream() → bz2.BZ2Compressor

See AbstractCompressorSerializer.new_compressor_stream() documentation for details.

Return type:

bz2.BZ2Compressor

final new_decompressor_stream() → bz2.BZ2Decompressor

See AbstractCompressorSerializer.new_decompressor_stream() documentation for details.

Return type:

bz2.BZ2Decompressor

class easynetwork.serializers.wrapper.compressor.ZlibCompressorSerializer

Bases: AbstractCompressorSerializer, Generic

A serializer wrapper to handle zlib compressed data, built on top of zlib module.

__init__(serializer: AbstractPacketSerializer[SentDTOPacket, ReceivedDTOPacket], *, compress_level: int | None = None, debug: bool = False) → None

Parameters:

• serializer (AbstractPacketSerializer[SentDTOPacket, ReceivedDTOPacket]) – The serializer to wrap.

• compress_level (int | None) – bzip2 compression level. Defaults to zlib.Z_BEST_COMPRESSION.

• debug (bool) – If True, add information to DeserializeError via the error_info attribute.

final new_compressor_stream() → zlib.Compress

See AbstractCompressorSerializer.new_compressor_stream() documentation for details.

Return type:

zlib.Compress

final new_decompressor_stream() → zlib.Decompress

See AbstractCompressorSerializer.new_decompressor_stream() documentation for details.

Return type:

zlib.Decompress

Abstract Compressor Interface

class easynetwork.serializers.wrapper.compressor.AbstractCompressorSerializer

Bases: BufferedIncrementalPacketSerializer[SentDTOPacket, ReceivedDTOPacket, memoryview], Generic

A serializer wrapper base class for compressors.

__init__(serializer: AbstractPacketSerializer[SentDTOPacket, ReceivedDTOPacket], expected_decompress_error: type[Exception] | tuple[type[Exception], ...], *, debug: bool = False) → None

Parameters:

• serializer (AbstractPacketSerializer[SentDTOPacket, ReceivedDTOPacket]) – The serializer to wrap.

• expected_decompress_error (type[Exception] | tuple[type[Exception], ...]) – Errors that can be raised by DecompressorInterface.decompress() implementation, which must be considered as deserialization errors.

• debug (bool) – If True, add information to DeserializeError via the error_info attribute.

abstractmethod new_compressor_stream() → CompressorInterface

Returns:

an object suitable for data compression.

Return type:

CompressorInterface

abstractmethod new_decompressor_stream() → DecompressorInterface

Returns:

an object suitable for data decompression.

Return type:

DecompressorInterface

final serialize(packet: SentDTOPacket) → bytes

Serializes packet and returns the compressed data parts.

See AbstractPacketSerializer.serialize() documentation for details.

Return type:

bytes

final incremental_serialize(packet: SentDTOPacket) → Generator[bytes]

Serializes packet and yields the compressed data parts.

See AbstractIncrementalPacketSerializer.incremental_serialize() documentation for details.

Return type:

Generator[bytes]

final deserialize(data: bytes) → ReceivedDTOPacket

Decompresses data and returns the deserialized packet.

See AbstractPacketSerializer.deserialize() documentation for details.

Raises:

• DeserializeError – DecompressorInterface.decompress() does not read until EOF (unused trailing data).

• DeserializeError – DecompressorInterface.decompress() raised an error that matches expected_decompress_error.

• Exception – Any other error raised by DecompressorInterface.decompress() or the underlying serializer.

Return type:

ReceivedDTOPacket

final incremental_deserialize() → Generator[None, bytes, tuple[ReceivedDTOPacket, bytes]]

Yields until data decompression is finished and deserializes the decompressed data using the underlying serializer.

See AbstractIncrementalPacketSerializer.incremental_deserialize() documentation for details.

Raises:

• IncrementalDeserializeError – DecompressorInterface.decompress() raised an error that matches expected_decompress_error.

• Exception – Any other error raised by DecompressorInterface.decompress() or the underlying serializer.

Return type:

Generator[None, bytes, tuple[ReceivedDTOPacket, bytes]]

final create_deserializer_buffer(sizehint: int) → memoryview

See BufferedIncrementalPacketSerializer.create_deserializer_buffer() documentation for details.

Return type:

memoryview

final buffered_incremental_deserialize(buffer: memoryview) → Generator[None, int, tuple[ReceivedDTOPacket, Buffer]]

Yields until data decompression is finished and deserializes the decompressed data using the underlying serializer.

See BufferedIncrementalPacketSerializer.buffered_incremental_deserialize() documentation for details.

Raises:

• IncrementalDeserializeError – DecompressorInterface.decompress() raised an error that matches expected_decompress_error.

• Exception – Any other error raised by DecompressorInterface.decompress() or the underlying serializer.

Return type:

Generator[None, int, tuple[ReceivedDTOPacket, Buffer]]

property debug: bool

The debug mode flag. Read-only attribute.

protocol easynetwork.serializers.wrapper.compressor.CompressorInterface

Bases: Protocol

A compressor object.

Classes that implement this protocol must have the following methods / attributes:

abstractmethod compress(data: Buffer, /) → bytes

Provide data to the compressor object.

Returns:

a chunk of compressed data if possible, or an empty byte string otherwise.

Return type:

bytes

abstractmethod flush() → bytes

Finish the compression process.

The compressor object may not be used after this method has been called.

Returns:

the compressed data left in internal buffers.

Return type:

bytes

protocol easynetwork.serializers.wrapper.compressor.DecompressorInterface

Bases: Protocol

A decompressor object.

Classes that implement this protocol must have the following methods / attributes:

abstractmethod decompress(data: Buffer, /) → bytes

Decompress data (a bytes-like object).

Some of data may be buffered internally, for use in later calls to decompress(). The returned data should be concatenated with the output of any previous calls to decompress().

Returns:

uncompressed data as bytes.

Return type:

bytes

abstract property eof: bool

True if the end-of-stream marker has been reached.

abstract property unused_data: bytes

Data found after the end of the compressed stream.

If this attribute is accessed before the end of the stream has been reached, its value will be b''.