github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

Updated python DDP client to ddp-pre1

Browse Source
This commit is contained in:
Naomi Seyfer
2012-12-14 16:02:53 -08:00
committed by David Glasser
parent c2e80dbdac
commit 677a43fe19
1 changed files with 27 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
examples/unfinished/python-ddp-client/ddp-client.py
View File

@@ -113,29 +113,34 @@ class DDPClient(WebSocketClient):
log("* ERROR {}".format(msg['error']['reason']))
self.pending.update({'result_acked': True})
elif msg.get('msg') == 'data':
if msg.get('collection'):
if msg.get('set'):
for key, value in msg['set'].items():
log("* SET {} {} {} {}".format(
msg['collection'], msg['id'], key, value))
if msg.get('unset'):
for key in msg['unset']:
log("* UNSET {} {} {}".format(
msg['collection'], msg['id'], key))
if msg.get('methods'):
if self.pending.get('id') in msg['methods']:
log("* UPDATED")
self.pending.update({'data_acked': True})
if msg.get('subs'):
if self.pending.get('id') in msg['subs']:
log("* READY")
self.pending.update({'data_acked': True})
elif msg.get('msg') == 'added':
log("* ADDED {} {}".format(
msg['collection'], msg['id']))
for key, value in msg['fields'].items():
log(" - FIELD {} {}".format(key, value))
elif msg.get('msg') == 'changed':
log("* CHANGED {} {}".format(
msg['collection'], msg['id']))
if 'fields' in msg:
for key, value in msg['fields'].items():
log(" - FIELD {} {}".format(key, value))
if 'cleared' in msg:
for key in msg['cleared']:
log(" - CLEARED {}".format(key));
elif msg.get('msg') == 'removed':
log("* REMOVED {} {}".format(
msg['collection'], ", ".join(msg['ids'])))
elif msg.get('msg') == 'complete':
assert 'subs' in msg
if self.pending.get('id') in msg['subs']:
log("* READY")
self.pending.update({'data_acked': True})
elif msg.get('msg') == 'updated':
if self.pending.get('id') in msg['methods']:
log("* UPDATED")
self.pending.update({'data_acked': True})
elif msg.get('msg') == 'nosub':
log("* NO SUCH SUB")
log("* NOSUB")
self.pending.update({'data_acked': True})
def closed(self, code, reason=None):