Mercurial > code > home > repos > homeauto

annotate service/environment/environment.py @ 1537:f119ed48194b

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
cors support Ignore-this: 8f628d753d9770b3b9b22be1194f3307 darcs-hash:d277bc36a7c9d5a672bf326f43ece710ec75c6ca
author drewp <drewp@bigasterisk.com>
date Mon, 10 Feb 2020 00:03:11 -0800
parents 13b7e4de3824
children 4167101b816f
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
805
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
1 #!/usr/bin/python
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
2 """
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
3 return some rdf about the environment, e.g. the current time,
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
4 daytime/night, overall modes like 'maintenance mode', etc
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
5
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
6 """
1243
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
7 import sys, datetime, cyclone.web, logging
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
8 from docopt import docopt
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
9 from twisted.internet import reactor, task, defer
805
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
10 from dateutil.tz import tzlocal
876
351292938d7c twilight computation for rules to use
drewp <drewp@bigasterisk.com>
parents: 805
diff changeset
11 from dateutil.relativedelta import relativedelta, FR
805
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
12 from rdflib import Namespace, Literal
1243
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
13 from greplin import scales
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
14 from greplin.scales.cyclonehandler import StatsHandler
1029
4d36cae32a4c refactor /graph and /graph/events handlers to lib/
drewp <drewp@bigasterisk.com>
parents: 1028
diff changeset
15 from patchablegraph import PatchableGraph, CycloneGraphEventsHandler, CycloneGraphHandler
876
351292938d7c twilight computation for rules to use
drewp <drewp@bigasterisk.com>
parents: 805
diff changeset
16 from twilight import isWithinTwilight
1537
f119ed48194b cors support
drewp <drewp@bigasterisk.com>
parents: 1524
diff changeset
17 from standardservice.logsetup import log, verboseLogging
805
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
18
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
19 from rdfdoc import Doc
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
20
805
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
21 ROOM = Namespace("http://projects.bigasterisk.com/room/")
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
22 DEV = Namespace("http://projects.bigasterisk.com/device/")
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
23
1243
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
24 STATS = scales.collection('/root',
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
25 scales.PmfStat('update'),
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
26 )
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
27
1537
f119ed48194b cors support
drewp <drewp@bigasterisk.com>
parents: 1524
diff changeset
28 class CycloneGraphEventsHandlerWithCors(CycloneGraphEventsHandler):
f119ed48194b cors support
drewp <drewp@bigasterisk.com>
parents: 1524
diff changeset
29 def flush(self):
f119ed48194b cors support
drewp <drewp@bigasterisk.com>
parents: 1524
diff changeset
30 self.set_header("Access-Control-Allow-Origin", "*")
f119ed48194b cors support
drewp <drewp@bigasterisk.com>
parents: 1524
diff changeset
31 return CycloneGraphEventsHandler.flush(self)
f119ed48194b cors support
drewp <drewp@bigasterisk.com>
parents: 1524
diff changeset
32
f119ed48194b cors support
drewp <drewp@bigasterisk.com>
parents: 1524
diff changeset
33
1243
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
34 @STATS.update.time()
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
35 def update(masterGraph):
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
36 stmt = lambda s, p, o: masterGraph.patchObject(ROOM.environment, s, p, o)
1524
13b7e4de3824 whitespace
drewp <drewp@bigasterisk.com>
parents: 1523
diff changeset
37
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
38 now = datetime.datetime.now(tzlocal())
805
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
39
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
40 stmt(DEV.environment, ROOM.localHour, Literal(now.hour))
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
41 stmt(DEV.environment, ROOM.localTimeToMinute,
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
42 Literal(now.strftime("%H:%M")))
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
43
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
44 stmt(DEV.environment, ROOM.localTimeToSecond,
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
45 Literal(now.strftime("%H:%M:%S")))
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
46
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
47 stmt(DEV.environment, ROOM.localDayOfWeek,
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
48 Literal(now.strftime("%A")))
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
49 stmt(DEV.environment, ROOM.localMonthDay,
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
50 Literal(now.strftime("%B %e")))
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
51 stmt(DEV.environment, ROOM.localDate,
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
52 Literal(now.strftime("%Y-%m-%d")))
876
351292938d7c twilight computation for rules to use
drewp <drewp@bigasterisk.com>
parents: 805
diff changeset
53
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
54 for offset in range(-12, 7):
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
55 d = now.date() + datetime.timedelta(days=offset)
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
56 if d == d + relativedelta(day=31, weekday=FR(-1)):
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
57 stmt(DEV.calendar, ROOM.daysToLastFridayOfMonth, Literal(offset))
876
351292938d7c twilight computation for rules to use
drewp <drewp@bigasterisk.com>
parents: 805
diff changeset
58
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
59 stmt(DEV.calendar, ROOM.twilight,
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
60 ROOM['withinTwilight'] if isWithinTwilight(now) else ROOM['daytime'])
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
61
1524
13b7e4de3824 whitespace
drewp <drewp@bigasterisk.com>
parents: 1523
diff changeset
62
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
63 def main():
1243
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
64 arg = docopt("""
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
65 Usage: environment.py [options]
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
66
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
67 -v Verbose
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
68 """)
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
69 log.setLevel(logging.INFO)
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
70 if arg['-v']:
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
71 enableTwistedLog()
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
72 log.setLevel(logging.DEBUG)
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
73 defer.setDebugging(True)
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
74
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
75 masterGraph = PatchableGraph()
965
a06d9921c2a3 add more date strings. Accept-header support
drewp <drewp@bigasterisk.com>
parents: 941
diff changeset
76
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
77 class Application(cyclone.web.Application):
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
78 def __init__(self):
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
79 handlers = [
1029
4d36cae32a4c refactor /graph and /graph/events handlers to lib/
drewp <drewp@bigasterisk.com>
parents: 1028
diff changeset
80 (r"/()",
4d36cae32a4c refactor /graph and /graph/events handlers to lib/
drewp <drewp@bigasterisk.com>
parents: 1028
diff changeset
81 cyclone.web.StaticFileHandler,
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
82 {"path": ".", "default_filename": "index.html"}),
1523
0da337780f22 dep updates; graph url renames; and other build updates
drewp <drewp@bigasterisk.com>
parents: 1243
diff changeset
83 (r'/graph/environment',
1029
4d36cae32a4c refactor /graph and /graph/events handlers to lib/
drewp <drewp@bigasterisk.com>
parents: 1028
diff changeset
84 CycloneGraphHandler, {'masterGraph': masterGraph}),
1523
0da337780f22 dep updates; graph url renames; and other build updates
drewp <drewp@bigasterisk.com>
parents: 1243
diff changeset
85 (r'/graph/environment/events',
0da337780f22 dep updates; graph url renames; and other build updates
drewp <drewp@bigasterisk.com>
parents: 1243
diff changeset
86 CycloneGraphEventsHandlerWithCors, {'masterGraph': masterGraph}),
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
87 (r'/doc', Doc), # to be shared
1243
b63c35e13e18 environment graph service standardization
drewp <drewp@bigasterisk.com>
parents: 1029
diff changeset
88 (r'/stats/(.*)', StatsHandler, {'serverName': 'environment'}),
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
89 ]
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
90 cyclone.web.Application.__init__(self, handlers,
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
91 masterGraph=masterGraph)
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
92 task.LoopingCall(update, masterGraph).start(1)
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
93 reactor.listenTCP(9075, Application())
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
94 reactor.run()
805
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
95
Drew Perttula <drewp@bigasterisk.com>
parents:
diff changeset
96 if __name__ == '__main__':
1028
70d52fa8373a add new jsonld/SSE support to environment service as a test
drewp <drewp@bigasterisk.com>
parents: 965
diff changeset
97 main()