Mercurial > code > home > repos > light9
view bin/collector @ 1350:36f58b2aa8ef
browser syncedgraph sends patches back to server
Ignore-this: eb8d3f018ff97f7389c4af3efa62fd9
author | Drew Perttula <drewp@bigasterisk.com> |
---|---|
date | Sun, 05 Jun 2016 03:21:31 +0000 |
parents | 8863b4485fd4 |
children | f427801da9f6 |
line wrap: on
line source
#!bin/python from __future__ import division from rdflib import Graph, URIRef, Literal from twisted.internet import reactor from twisted.web.server import Site from txzmq import ZmqEndpoint, ZmqFactory, ZmqPullConnection import json import logging import klein from greplin import scales from greplin.scales.twistedweb import StatsResource from run_local import log from light9.collector.output import EnttecDmx, Udmx from light9.collector.collector import Collector from light9.namespaces import L9 from light9 import networking from light9.rdfdb.syncedgraph import SyncedGraph from light9.rdfdb import clientsession class WebServer(object): stats = scales.collection('/webServer', scales.PmfStat('setAttr')) app = klein.Klein() def __init__(self, collector): self.collector = collector @app.route('/attrs', methods=['PUT']) def putAttrs(self, request): with WebServer.stats.setAttr.time(): body = json.load(request.content) settings = [] for device, attr, value in body['settings']: settings.append((URIRef(device), URIRef(attr), Literal(value))) self.collector.setAttrs(body['client'], body['clientSession'], settings) request.setResponseCode(202) @app.route('/stats', methods=['GET']) def getStats(self, request): return StatsResource('collector') def startZmq(port, collector): stats = scales.collection('/zmqServer', scales.PmfStat('setAttr')) zf = ZmqFactory() e = ZmqEndpoint('bind', 'tcp://*:%s' % port) s = ZmqPullConnection(zf, e) def onPull(message): with stats.setAttrZmq.time(): # todo: new compressed protocol where you send all URIs up # front and then use small ints to refer to devices and # attributes in subsequent requests. message[0] collector.setAttrs() s.onPull = onPull def launch(graph): # todo: drive outputs with config files outputs = [EnttecDmx(L9['output/dmx0/'], 100, '/dev/dmx0'), Udmx(L9['output/udmx/'], 100)] c = Collector(graph, outputs) server = WebServer(c) startZmq(networking.collectorZmq.port, c) reactor.listenTCP(networking.collector.port, Site(server.app.resource()), interface='::') log.info('serving http on %s, zmq on %s', networking.collector.port, networking.collectorZmq.port) def main(): log.setLevel(logging.DEBUG) graph = SyncedGraph(networking.rdfdb.url, "collector") graph.initiallySynced.addCallback(lambda _: launch(graph)) reactor.run() if __name__ == '__main__': main()