dynamicserialize.DynamicSerializationManager

Complexity

Total Complexity

6

Size/Duplication

Total Lines	46
Duplicated Lines	63.04 %

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	DynamicSerializationManager.serializeObject()	6	6	1
A	DynamicSerializationManager.__init__()	2	2	1
A	DynamicSerializationManager._deserialize()	2	2	1
A	DynamicSerializationManager._serialize()	2	2	1
A	DynamicSerializationManager._buildSerializationContext()	4	4	1
A	DynamicSerializationManager.deserializeBytes()	6	6	1

#
# A port of the Java DynamicSerializeManager.  Should be used to read/write
# DynamicSerialize binary data.
#
#
#     SOFTWARE HISTORY
#
#    Date            Ticket#       Engineer       Description
#    ------------    ----------    -----------    --------------------------
#    06/09/10                      njensen       Initial Creation.
#

from thrift.transport import TTransport
from . import SelfDescribingBinaryProtocol, ThriftSerializationContext


class DynamicSerializationManager:

This code seems to be duplicated in your project.

    def __init__(self):
        self.transport = None

    def _deserialize(self, ctx):
        return ctx.deserializeMessage()

    def deserializeBytes(self, sbytes):
        ctx = self._buildSerializationContext(sbytes)
        ctx.readMessageStart()
        obj = self._deserialize(ctx)
        ctx.readMessageEnd()
        return obj

    def _buildSerializationContext(self, sbytes=None):
        self.transport = TTransport.TMemoryBuffer(sbytes)
        protocol = SelfDescribingBinaryProtocol.SelfDescribingBinaryProtocol(self.transport)
        return ThriftSerializationContext.ThriftSerializationContext(self, protocol)

    def serializeObject(self, obj):
        ctx = self._buildSerializationContext()
        ctx.writeMessageStart("dynamicSerialize")
        self._serialize(ctx, obj)
        ctx.writeMessageEnd()
        return self.transport.getvalue()

    def _serialize(self, ctx, obj):
        ctx.serializeMessage(obj)