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
|
#!/usr/bin/env python
# vim: set expandtab ts=4:
from gi.repository import GLib, Soup
import json
ml = GLib.MainLoop()
def callback(new, old):
try:
import datadiff
if old is None:
return
print datadiff.diff(old, new)
except ImportError:
print 'received longpoll update, datadiff not available'
prevjson = None
LPURL = 'http://beaglebone.local.sublab.org/longpoll'
uri = Soup.URI.new(LPURL)
#
# TODO: add timer that aborts/kills previous requests after a timeout
# for proper error recovery
#
# Note: message.status_code contains HTTP codes _or_ libsoup specific errors
# (status_code < 100 => libsoup)
#
def cb(session, message, cbarg):
global prevjson
def request_next():
uri.set_query(prevjson['ref'])
get = Soup.Message.new_from_uri("GET", uri)
ss.queue_message(get, cb, None)
if message.status_code != 200:
print 'cb error:', message.status_code
if prevjson is None:
print 'first request failed'
ml.quit()
request_next()
return
try:
rdata = message.response_body.flatten().get_data()
if rdata == '':
request_next()
return
njson = json.loads(rdata)
print 'CB OK', njson['ref']
if prevjson is None or njson['ref'] != prevjson['ref']:
callback(njson['data'],
prevjson['data'] if prevjson is not None else None)
prevjson = njson
finally:
request_next()
ss = Soup.SessionAsync.new()
get = Soup.Message.new_from_uri("GET", uri)
ss.queue_message(get, cb, None)
del get
ml.run()
|
