Mercurial > code > home > repos > homeauto
annotate service/wifi/wifi.py @ 1226:7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
Ignore-this: bfecea6f4990d34b36cc6d97cc6c6fa2
darcs-hash:79a3d55bfae5776b2374faa2020b6e27f17eb390
| author | drewp <drewp@bigasterisk.com> |
|---|---|
| date | Sat, 30 Mar 2019 23:38:47 -0700 |
| parents | b8c0daabe5a5 |
| children | ec0db53aa833 |
| rev | line source |
|---|---|
| 1224 | 1 """ |
| 2 scrape the tomato router status pages to see who's connected to the | |
| 3 wifi access points. Includes leases that aren't currently connected. | |
| 4 | |
| 5 Returns: | |
| 6 json listing (for magma page) | |
| 7 rdf graph (for reasoning) | |
| 8 activity stream, when we start saving history | |
| 9 | |
| 10 Todo: this should be the one polling and writing to mongo, not entrancemusic | |
| 11 | |
| 12 """ | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
13 import sys, json, traceback, time, datetime, logging |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
14 from typing import List |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
15 |
| 1223 | 16 from cyclone.httpclient import fetch |
| 1224 | 17 from dateutil import tz |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
18 from influxdb import InfluxDBClient |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
19 from pymongo import MongoClient as Connection, DESCENDING |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
20 from rdflib import Namespace, Literal, ConjunctiveGraph |
| 1224 | 21 from twisted.internet import reactor, task |
| 22 from twisted.internet.defer import inlineCallbacks | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
23 import ago |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
24 import cyclone.web |
| 1224 | 25 import docopt |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
26 import pystache |
| 1224 | 27 |
| 28 from cycloneerr import PrettyErrorHandler | |
| 29 from logsetup import log | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
30 from patchablegraph import PatchableGraph, CycloneGraphEventsHandler, CycloneGraphHandler |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
31 from scrape import Wifi, SeenNode |
| 1224 | 32 |
|
1225
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
33 AST = Namespace("http://bigasterisk.com/") |
| 1224 | 34 DEV = Namespace("http://projects.bigasterisk.com/device/") |
| 35 ROOM = Namespace("http://projects.bigasterisk.com/room/") | |
| 36 reasoning = "http://bang:9071/" | |
| 37 | |
| 38 class Index(PrettyErrorHandler, cyclone.web.RequestHandler): | |
| 39 def get(self): | |
| 40 age = time.time() - self.settings.poller.lastPollTime | |
| 41 if age > 10: | |
| 42 raise ValueError("poll data is stale. age=%s" % age) | |
| 43 | |
| 44 self.set_header("Content-Type", "text/html") | |
| 45 self.write(open("index.html").read()) | |
| 1223 | 46 |
| 1224 | 47 def whenConnected(mongo, macThatIsNowConnected): |
| 48 lastArrive = None | |
| 49 for ev in mongo.find({'address': macThatIsNowConnected.upper()}, | |
| 50 sort=[('created', -1)], | |
| 51 max_scan=100000): | |
| 52 if ev['action'] == 'arrive': | |
| 53 lastArrive = ev | |
| 54 if ev['action'] == 'leave': | |
| 55 break | |
| 56 if lastArrive is None: | |
| 57 raise ValueError("no past arrivals") | |
| 58 | |
| 59 return lastArrive['created'] | |
| 60 | |
| 61 def connectedAgoString(conn): | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
62 return ago.human(conn.astimezone(tz.tzutc()).replace(tzinfo=None)) |
| 1224 | 63 |
| 64 class Table(PrettyErrorHandler, cyclone.web.RequestHandler): | |
| 65 def get(self): | |
| 66 def rowDict(row): | |
| 67 row['cls'] = "signal" if row.get('connected') else "nosignal" | |
| 68 if 'name' not in row: | |
| 69 row['name'] = row.get('clientHostname', '-') | |
| 70 if 'signal' not in row: | |
| 71 row['signal'] = 'yes' if row.get('connected') else 'no' | |
| 1223 | 72 |
| 1224 | 73 try: |
| 74 conn = whenConnected(self.settings.mongo, row.get('mac', '??')) | |
| 75 row['connectedAgo'] = connectedAgoString(conn) | |
| 76 except ValueError: | |
| 77 row['connectedAgo'] = 'yes' if row.get('connected') else '' | |
| 78 row['router'] = row.get('ssid', '') | |
| 79 return row | |
| 80 | |
| 81 self.set_header("Content-Type", "application/xhtml+xml") | |
| 82 self.write(pystache.render( | |
| 83 open("table.mustache").read(), | |
| 84 dict( | |
| 85 rows=sorted(map(rowDict, self.settings.poller.lastAddrs), | |
| 86 key=lambda a: (not a.get('connected'), | |
| 87 a.get('name')))))) | |
| 1223 | 88 |
| 1224 | 89 class Json(PrettyErrorHandler, cyclone.web.RequestHandler): |
| 90 def get(self): | |
| 91 self.set_header("Content-Type", "application/json") | |
| 92 age = time.time() - self.settings.poller.lastPollTime | |
| 93 if age > 10: | |
| 94 raise ValueError("poll data is stale. age=%s" % age) | |
| 95 self.write(json.dumps({"wifi" : self.settings.poller.lastAddrs, | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
96 "dataAge" : age})) |
| 1224 | 97 |
| 98 class Poller(object): | |
| 99 def __init__(self, wifi, mongo): | |
| 100 self.wifi = wifi | |
| 101 self.mongo = mongo | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
102 self.lastAddrs = [] # List[SeenNode] |
| 1224 | 103 self.lastWithSignal = [] |
| 104 self.lastPollTime = 0 | |
| 105 | |
| 106 def assertCurrent(self): | |
| 107 dt = time.time() - self.lastPollTime | |
| 108 assert dt < 10, "last poll was %s sec ago" % dt | |
| 1223 | 109 |
| 110 @inlineCallbacks | |
| 1224 | 111 def poll(self): |
| 112 try: | |
| 113 newAddrs = yield self.wifi.getPresentMacAddrs() | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
114 self.onNodes(newAddrs) |
| 1224 | 115 except Exception as e: |
| 116 log.error("poll error: %r\n%s", e, traceback.format_exc()) | |
| 117 | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
118 def onNodes(self, newAddrs: List[SeenNode]): |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
119 now = int(time.time()) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
120 newWithSignal = [a for a in newAddrs if a.connected] |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
121 |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
122 actions = self.computeActions(newWithSignal) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
123 points = [] |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
124 for action in actions: |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
125 log.info("action: %s", action) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
126 action['created'] = datetime.datetime.now(tz.gettz('UTC')) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
127 mongo.save(action) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
128 points.append( |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
129 self.influxPoint(now, action['address'].lower(), |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
130 1 if action['action'] == 'arrive' else 0)) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
131 if now // 3600 > self.lastPollTime // 3600: |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
132 log.info('hourly writes') |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
133 for addr in newWithSignal: |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
134 points.append(self.influxPoint(now, addr.mac.lower(), 1)) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
135 |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
136 influx.write_points(points, time_precision='s') |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
137 self.lastWithSignal = newWithSignal |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
138 if actions: # this doesn't currently include signal strength changes |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
139 fetch(reasoning + "immediateUpdate", |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
140 method='PUT', |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
141 timeout=2, |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
142 headers={'user-agent': ['wifi']}).addErrback(log.warn) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
143 self.lastAddrs = newAddrs |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
144 self.lastPollTime = now |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
145 |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
146 self.updateGraph(masterGraph) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
147 |
| 1224 | 148 def influxPoint(self, now, address, value): |
| 149 return { | |
| 150 'measurement': 'presence', | |
| 151 'tags': {'sensor': 'wifi', 'address': address,}, | |
| 152 'fields': {'value': value}, | |
| 153 'time': now, | |
| 154 } | |
| 1223 | 155 |
| 1224 | 156 def computeActions(self, newWithSignal): |
| 157 actions = [] | |
| 1223 | 158 |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
159 def makeAction(addr: SeenNode, act: str): |
| 1224 | 160 d = dict(sensor="wifi", |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
161 address=addr.mac.upper(), # mongo data is legacy uppercase |
| 1224 | 162 action=act) |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
163 if act == 'arrive': |
| 1224 | 164 # this won't cover the possible case that you get on |
| 165 # wifi but don't have an ip yet. We'll record an | |
| 166 # action with no ip and then never record your ip. | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
167 d['ip'] = addr.ip |
| 1224 | 168 return d |
| 169 | |
| 170 for addr in newWithSignal: | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
171 if addr.mac not in [r.mac for r in self.lastWithSignal]: |
| 1224 | 172 actions.append(makeAction(addr, 'arrive')) |
| 173 | |
| 174 for addr in self.lastWithSignal: | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
175 if addr.mac not in [r.mac for r in newWithSignal]: |
| 1224 | 176 actions.append(makeAction(addr, 'leave')) |
| 177 | |
| 178 return actions | |
| 1223 | 179 |
| 1224 | 180 def deltaSinceLastArrive(self, name): |
| 181 results = list(self.mongo.find({'name' : name}).sort('created', | |
| 182 DESCENDING).limit(1)) | |
| 183 if not results: | |
| 184 return datetime.timedelta.max | |
| 185 now = datetime.datetime.now(tz.gettz('UTC')) | |
| 186 last = results[0]['created'].replace(tzinfo=tz.gettz('UTC')) | |
| 187 return now - last | |
| 188 | |
| 189 def updateGraph(self, masterGraph): | |
| 190 g = ConjunctiveGraph() | |
| 191 ctx = DEV['wifi'] | |
| 192 | |
| 193 # someday i may also record specific AP and their strength, | |
| 194 # for positioning. But many users just want to know that the | |
| 195 # device is connected to some bigasterisk AP. | |
| 196 age = time.time() - self.lastPollTime | |
| 197 if age > 10: | |
| 198 raise ValueError("poll data is stale. age=%s" % age) | |
| 199 | |
| 200 for dev in self.lastAddrs: | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
201 if not dev.connected: |
| 1224 | 202 continue |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
203 g.add((dev.uri, ROOM['macAddress'], Literal(dev.mac), ctx)) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
204 g.add((dev.uri, ROOM['ipAddress'], Literal(dev.ip), ctx)) |
| 1223 | 205 |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
206 for s,p,o in dev.stmts: |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
207 g.add((s, p, o, ctx)) |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
208 |
| 1224 | 209 try: |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
210 conn = whenConnected(mongo, dev.mac) |
| 1224 | 211 except ValueError: |
| 212 traceback.print_exc() | |
| 213 pass | |
| 214 else: | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
215 g.add((dev.uri, ROOM['connectedAgo'], |
| 1224 | 216 Literal(connectedAgoString(conn)), ctx)) |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
217 g.add((dev.uri, ROOM['connected'], Literal(conn), ctx)) |
| 1224 | 218 masterGraph.setToGraph(g) |
| 1223 | 219 |
| 1224 | 220 |
| 221 if __name__ == '__main__': | |
| 222 args = docopt.docopt(''' | |
| 223 Usage: | |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
224 wifi.py [options] |
| 1223 | 225 |
| 1224 | 226 Options: |
| 227 -v, --verbose more logging | |
| 228 --port=<n> serve on port [default: 9070] | |
| 229 --poll=<freq> poll frequency [default: .2] | |
| 230 ''') | |
| 231 if args['--verbose']: | |
| 232 from twisted.python import log as twlog | |
| 233 twlog.startLogging(sys.stdout) | |
| 234 log.setLevel(10) | |
| 235 log.setLevel(logging.DEBUG) | |
| 236 | |
| 237 mongo = Connection('bang', 27017, tz_aware=True)['visitor']['visitor'] | |
| 238 influx = InfluxDBClient('bang', 9060, 'root', 'root', 'main') | |
| 1223 | 239 |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
240 config = ConjunctiveGraph() |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
241 config.parse(open('private_config.n3'), format='n3') |
|
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
242 |
| 1224 | 243 masterGraph = PatchableGraph() |
|
1226
7de8f0cd3392
very big rewrite. py3; orbi-only for now; n3 config file; delete or move out dead code
drewp <drewp@bigasterisk.com>
parents:
1225
diff
changeset
|
244 wifi = Wifi(config) |
| 1224 | 245 poller = Poller(wifi, mongo) |
| 246 task.LoopingCall(poller.poll).start(1/float(args['--poll'])) | |
| 1223 | 247 |
|
1225
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
248 reactor.listenTCP( |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
249 int(args['--port']), |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
250 cyclone.web.Application( |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
251 [ |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
252 (r"/", Index), |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
253 (r'/json', Json), |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
254 (r'/graph', CycloneGraphHandler, {'masterGraph': masterGraph}), |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
255 (r'/graph/events', CycloneGraphEventsHandler, {'masterGraph': masterGraph}), |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
256 (r'/table', Table), |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
257 #(r'/activity', Activity), |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
258 ], |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
259 wifi=wifi, |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
260 poller=poller, |
|
b8c0daabe5a5
factor out some URI generation
drewp <drewp@bigasterisk.com>
parents:
1224
diff
changeset
|
261 mongo=mongo)) |
| 1224 | 262 reactor.run() |