<filename>srpc/payload.py
from struct import pack, unpack
from srpcDefs import Command

class Payload(object):
    """Basic payload header"""
    def __init__(self, subport = 0, seqNo = 0, command = 0, fnum = 0, nfrags = 0,
                 buffer = None):
        super(Payload, self).__init__()
        self.buffer = buffer
        self.subport = subport
        self.seqNo = seqNo
        self.command = command
        self.fragment = fnum
        self.fragmentCount = nfrags
        if buffer is not None:
            #Unpack subport (host order)
            self.subport = unpack("@I", buffer[0:4])[0]
            #Upack rest (network order)
            (self.seqNo, self.command, self.fragment,
            self.fragmentCount) = unpack(">IHBB", buffer[4:12])

    def pack(self):
        """Pack subport in host order follwed by rest of packet in network order """
        return pack("@I", self.subport) + pack(">IHBB", self.seqNo, self.command,
                             self.fragment, self.fragmentCount)
    def __str__(self):
        return "Payload - Subport: {}\n\tSeqNo: {}\
        \n\tCommand: {}\n\tFragment: {}\n\tFragCount: {}".format(self.subport,
               self.seqNo, self.command, self.fragment, self.fragmentCount)

class ControlPayload(Payload):
    """Payload for issuing commands to RPC host"""
    def __init__(self, subport = 0, seqNo = 0, command = 0, fnum = 0,
                 nfrags = 0, buffer = None):
        super(ControlPayload, self).__init__(subport, seqNo, command, fnum,
                                             nfrags, buffer)

class ConnectPayload(Payload):
    """Payload for sending CONNECT command to a named service"""
    def __init__(self, subport = 0, seqNo = 0, fnum = 0, nfrags = 0,
                 serviceName = None, buffer = None):
        super(ConnectPayload, self).__init__(subport, seqNo, Command.CONNECT,
                                             fnum, nfrags, buffer)
        if buffer is None:
            self.serviceName = serviceName
        else:
            # Calculate string size (buffer - payload size - null end byte)
            ser_len = len(buffer) - 13
            fmt = ">{}sx".format(ser_len)
            self.serviceName = unpack(fmt, buffer[12:])[0]

    def pack(self): #Pack payload and append serviceName
        return super(ConnectPayload, self).pack() + self.serviceName

    def __str__(self):
        return "ConnectPayload:\n\tService: {}\n\t{}".format(
                    self.serviceName, super(ConnectPayload, self))

class DataPayload(Payload):
    """Payload for sending some data/fragments"""
    def __init__(self, subport=0, seqNo=0, command=0, fnum=0, nfrags=0,
                 service=None, data_len=0, frag_len=0, data="", buffer=None):
        super(DataPayload, self).__init__(subport, seqNo, command, fnum, nfrags,
                                          buffer)
        self.data_len = data_len
        self.frag_len = len(data)
        self.data = data
        if buffer is not None: #Unpack a packet 'received'
            #Unpack lengths from network order to host order
            self.data_len, self.frag_len = unpack(">HH", buffer[12:16])
            self.data = buffer[16:]

    def pack(self):
        """Prepend packed payload to packed network ordered lengths and data"""
        return (super(DataPayload, self).pack() +
               pack(">HH", self.data_len, self.frag_len) + self.data)

    def __str__(self):
        return "DataPayload:\n\Data_len: {}\t Frag_len:{}\n\t{}".format(
            self.data_len, self.frag_len, super(DataPayload, self))

<filename>srpc/payload.py
from struct import pack, unpack
from srpcDefs import Command

class Payload(object):
    """Basic payload header"""
    def __init__(self, subport = 0, seqNo = 0, command = 0, fnum = 0, nfrags = 0,
                 buffer = None):
        super(Payload, self).__init__()
        self.buffer = buffer
        self.subport = subport
        self.seqNo = seqNo
        self.command = command
        self.fragment = fnum
        self.fragmentCount = nfrags
        if buffer is not None:
            #Unpack subport (host order)
            self.subport = unpack("@I", buffer[0:4])[0]
            #Upack rest (network order)
            (self.seqNo, self.command, self.fragment,
            self.fragmentCount) = unpack(">IHBB", buffer[4:12])

    def pack(self):
        """Pack subport in host order follwed by rest of packet in network order """
        return pack("@I", self.subport) + pack(">IHBB", self.seqNo, self.command,
                             self.fragment, self.fragmentCount)
    def __str__(self):
        return "Payload - Subport: {}\n\tSeqNo: {}\
        \n\tCommand: {}\n\tFragment: {}\n\tFragCount: {}".format(self.subport,
               self.seqNo, self.command, self.fragment, self.fragmentCount)

class ControlPayload(Payload):
    """Payload for issuing commands to RPC host"""
    def __init__(self, subport = 0, seqNo = 0, command = 0, fnum = 0,
                 nfrags = 0, buffer = None):
        super(ControlPayload, self).__init__(subport, seqNo, command, fnum,
                                             nfrags, buffer)

class ConnectPayload(Payload):
    """Payload for sending CONNECT command to a named service"""
    def __init__(self, subport = 0, seqNo = 0, fnum = 0, nfrags = 0,
                 serviceName = None, buffer = None):
        super(ConnectPayload, self).__init__(subport, seqNo, Command.CONNECT,
                                             fnum, nfrags, buffer)
        if buffer is None:
            self.serviceName = serviceName
        else:
            # Calculate string size (buffer - payload size - null end byte)
            ser_len = len(buffer) - 13
            fmt = ">{}sx".format(ser_len)
            self.serviceName = unpack(fmt, buffer[12:])[0]

    def pack(self): #Pack payload and append serviceName
        return super(ConnectPayload, self).pack() + self.serviceName

    def __str__(self):
        return "ConnectPayload:\n\tService: {}\n\t{}".format(
                    self.serviceName, super(ConnectPayload, self))

class DataPayload(Payload):
    """Payload for sending some data/fragments"""
    def __init__(self, subport=0, seqNo=0, command=0, fnum=0, nfrags=0,
                 service=None, data_len=0, frag_len=0, data="", buffer=None):
        super(DataPayload, self).__init__(subport, seqNo, command, fnum, nfrags,
                                          buffer)
        self.data_len = data_len
        self.frag_len = len(data)
        self.data = data
        if buffer is not None: #Unpack a packet 'received'
            #Unpack lengths from network order to host order
            self.data_len, self.frag_len = unpack(">HH", buffer[12:16])
            self.data = buffer[16:]

    def pack(self):
        """Prepend packed payload to packed network ordered lengths and data"""
        return (super(DataPayload, self).pack() +
               pack(">HH", self.data_len, self.frag_len) + self.data)

    def __str__(self):
        return "DataPayload:\n\Data_len: {}\t Frag_len:{}\n\t{}".format(
            self.data_len, self.frag_len, super(DataPayload, self))

Basic payload header #Unpack subport (host order) #Upack rest (network order) Pack subport in host order follwed by rest of packet in network order Payload for issuing commands to RPC host Payload for sending CONNECT command to a named service # Calculate string size (buffer - payload size - null end byte) #Pack payload and append serviceName Payload for sending some data/fragments #Unpack a packet 'received' #Unpack lengths from network order to host order Prepend packed payload to packed network ordered lengths and data