contrived example

twisted_application_client.py

class MyClientProtocol(protocol.Protocol):

    def dataTransmit(message):
        self.transport.write(data)

    def dataReceived(self, message):
        self.factory.service.handle_message(message)


class MyClientFactory(protocol.ClientFactory):

    protocol = MyClientProtocol

    def __init__(self, service):
        self.service = service


class MyService(service.Service):

    def startService(self):
    
        self.config = load_config(config_file)

    def handleMessage(self, message):
    
        # do something with data
        decoded_msg = self.decodeMessage(message)
        if decoded_msg['type'] == 'logon_response':
            decoded_msg['result'] == 'good':
                self.doSomthing()
        
        
    
    def sendMessage(self, message)
        ###############################
        # Not sure what to do here without coupling it to the protocol 
        ##############################

    def decodeMessage(self, data):
    
        return json.loads(data)


    def encodeMessage(self, data):
    
        return json.dumps(data)

        
    def logon(self):
    
        logon_message_data = {
            'user': self.config.user,
            'pass': self.config.pass
             }
        msg = self.encodeMessage(logon_message_data)
        self.sendMessage(msg)
        
      
     def doSomthing(self)
        pass