Mercurial > code > home > repos > homeauto

comparison service/wifi/wifi.py @ 427:db031d9ec28e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
don't use 'connected' for time and for network. add rdf:type. Ignore-this: 59899796d4785300f40137de2c2c44d5
author drewp@bigasterisk.com
date Thu, 04 Apr 2019 02:19:10 -0700
parents e0703c7824e9
children d0830394bf7b
comparison
equal deleted inserted replaced
426:bfe555dd0c91 427:db031d9ec28e
15 15
16 from cyclone.httpclient import fetch 16 from cyclone.httpclient import fetch
17 from dateutil import tz 17 from dateutil import tz
18 from influxdb import InfluxDBClient 18 from influxdb import InfluxDBClient
19 from pymongo import MongoClient as Connection, DESCENDING 19 from pymongo import MongoClient as Connection, DESCENDING
20 from rdflib import Namespace, Literal, ConjunctiveGraph 20 from rdflib import Namespace, Literal, ConjunctiveGraph, RDF
21 from twisted.internet import reactor, task 21 from twisted.internet import reactor, task
22 from twisted.internet.defer import inlineCallbacks 22 from twisted.internet.defer import inlineCallbacks
23 import ago 23 import ago
24 import cyclone.web 24 import cyclone.web
25 import docopt 25 import docopt
198 raise ValueError("poll data is stale. age=%s" % age) 198 raise ValueError("poll data is stale. age=%s" % age)
199 199
200 for dev in self.lastAddrs: 200 for dev in self.lastAddrs:
201 if not dev.connected: 201 if not dev.connected:
202 continue 202 continue
203 g.add((dev.uri, RDF.type, ROOM['NetworkedDevice'], ctx))
203 g.add((dev.uri, ROOM['macAddress'], Literal(dev.mac), ctx)) 204 g.add((dev.uri, ROOM['macAddress'], Literal(dev.mac), ctx))
204 g.add((dev.uri, ROOM['ipAddress'], Literal(dev.ip), ctx)) 205 g.add((dev.uri, ROOM['ipAddress'], Literal(dev.ip), ctx))
205 206
206 for s,p,o in dev.stmts: 207 for s,p,o in dev.stmts:
207 g.add((s, p, o, ctx)) 208 g.add((s, p, o, ctx))