view bin/collector @ 1299:02415a3cebb2

requirements.txt filename Ignore-this: 9d7cefc433f3e552f016486b52446fde
author Drew Perttula <drewp@bigasterisk.com>
date Mon, 30 May 2016 08:27:04 +0000
parents 5a4e74f1e36a
children 8863b4485fd4
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

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 main():
    log.setLevel(logging.DEBUG)
    config = Graph()
    # todo: replace with rdfdb's loaded graph, and notice changes
    config.parse('show/dance2016/output.n3', format='n3')

    # todo: drive outputs with config files
    outputs = [EnttecDmx(L9['output/dmx0/'], 100, '/dev/dmx0'),
               Udmx(L9['output/udmx/'], 100)]
    c = Collector(config, 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)
    reactor.run()

if __name__ == '__main__':
    main()