mia/bumper
1
0
Fork 0
Code Issues 47 Pull requests 11 Projects Releases Packages Wiki Activity Actions

Forward client-to-client pings

Browse source
This commit is contained in:
Torbjörn Axelsson 2017-12-18 12:59:16 -08:00
parent c764c20ae7
commit b74f76fb45
1 changed files with 11 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

13
bumper/xmppserver.py
View file

@ -104,6 +104,16 @@ class Client(threading.Thread):
data = data.encode() data = data.encode()
client.send(data.decode('utf-8')) client.send(data.decode('utf-8'))
def _handle_ping(self, xml, data):
if(xml.get('to').find('@') == -1):
# Ping to server - respond
self.send('<iq type="result" id="{}" from="{}" />'.format(xml.get('id'), xml.get('to')))
else:
for client in XMPPServer.clients:
if client.address != self.address and client.state == client.READY:
client.send(data.decode('utf-8'))
def _handle_result(self, data): def _handle_result(self, data):
# forward # forward
for client in XMPPServer.clients: for client in XMPPServer.clients:
@ -144,8 +154,7 @@ class Client(threading.Thread):
elif child == 'query': elif child == 'query':
self._handle_ctl(xml, data) self._handle_ctl(xml, data)
elif child == 'ping': elif child == 'ping':
# respond to ping request self._handle_ping(xml, data)
res = '<iq type="result" id="{}" from="{}" />'.format(last_id, xml.get('to'))
elif xml.get('type') == 'result': elif xml.get('type') == 'result':
self._handle_result(data) self._handle_result(data)
if res: if res: