Files
@ 90ef6e3128f2
Branch filter:
Location: libtransport.git/backends/template/template_backend.py - annotation
90ef6e3128f2
2.7 KiB
text/x-python
Fix HAVE_SWIFTEN_3 definition to work also in gcc. Fix the tests to work with swiften3 and also with swiften2.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 | 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d 8bd3dfd3a28d | #!/usr/bin/python
import asyncore, argparse, protocol_pb2, socket, logging
from NetworkPlugin import NetworkPlugin
np = None
logger = logging.getLogger('Template Backend')
logger.setLevel(logging.DEBUG)
ch = logging.StreamHandler()
ch.setLevel(logging.DEBUG)
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
ch.setFormatter(formatter)
logger.addHandler(ch)
def handleTransportData(data):
"""
This function is called when data is received from the NetworkPlugin server
"""
np.handleDataRead(data)
class SpectrumPlugin(NetworkPlugin):
global logger
def __init__(self, iochannel):
NetworkPlugin.__init__(self)
self.iochannel = iochannel
logger.info("Starting plugin.")
def sendData(self, string):
"""
NetworkPlugin uses this method to send the data to networkplugin server
"""
self.iochannel.sendData(string)
logger.info("Starting plugin.")
def handleLoginRequest(self, user, legacyName, password):
self.handleConnected(user)
logger.info("Added Echo Buddy")
self.handleBuddyChanged(user, "echo", "Echo", [], protocol_pb2.STATUS_ONLINE)
def handleLogoutRequest(self, user, legacyName):
pass
def handleMessageSendRequest(self, user, legacyName, message, xhtml = ""):
logger.info("Message sent from " + user + ' to ' + legacyName)
if(legacyName == "echo"):
logger.info("Message Echoed: " + message)
self.handleMessage(user, legacyName, message)
def handleBuddyUpdatedRequest(self, user, buddyName, alias, groups):
logger.info("Added Buddy " + buddyName)
self.handleBuddyChanged(user, buddyName, alias, groups, protocol_pb2.STATUS_ONLINE)
def handleBuddyRemovedRequest(self, user, buddyName, groups):
pass
class IOChannel(asyncore.dispatcher):
def __init__(self, host, port, readCallBack):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.connect((host, port))
self.handleReceivedData = readCallBack
self.send_buffer = ""
def sendData(self, data):
self.send_buffer += data
def handle_connect(self):
pass
def handle_close(self):
self.close()
def handle_read(self):
data = self.recv(65536)
self.handleReceivedData(data)
def handle_write(self):
sent = self.send(self.send_buffer)
self.send_buffer = self.send_buffer[sent:]
def writable(self):
return (len(self.send_buffer) > 0)
def readable(self):
return True
if __name__ == "__main__":
parser = argparse.ArgumentParser()
parser.add_argument('--host', type=str, required=True)
parser.add_argument('--port', type=int, required=True)
parser.add_argument('config_file', type=str)
args = parser.parse_args()
io = IOChannel(args.host, args.port, handleTransportData)
np = SpectrumPlugin(io)
asyncore.loop()
|