view bin/clientdemo @ 1436:d0d5900a8031

collector run the blocking dmx output calls in another thread, so they don't add delay to our http server Ignore-this: b5385085b654e1ac0b8018e6813f36e
author drewp@bigasterisk.com
date Sat, 11 Jun 2016 20:30:34 +0000
parents a38955ba6f40
children 6fa4288da8a6
line wrap: on
line source

#!bin/python

import os, sys
sys.path.append(".")
from twisted.internet import reactor
import cyclone.web, cyclone.httpclient, logging
from rdflib import Namespace, Literal, URIRef
from light9 import networking
from light9.rdfdb.patch import Patch
from light9.rdfdb.syncedgraph import SyncedGraph

if __name__ == "__main__":
    logging.basicConfig(level=logging.DEBUG)
    log = logging.getLogger()

    g = SyncedGraph(networking.rdfdb.url, "clientdemo")

    from light9.Submaster import PersistentSubmaster
    sub = PersistentSubmaster(graph=g, uri=URIRef("http://light9.bigasterisk.com/sub/bcools"))

    #get sub to show its updating name, then push that all the way into KC gui so we can see just names refresh in there


    L9 = Namespace("http://light9.bigasterisk.com/")
    def updateDemoValue():
        v = list(g.objects(L9['demo'], L9['is']))
        print "demo value is %r" % v

    g.addHandler(updateDemoValue)

    def adj():
        g.patch(Patch(addQuads=[(L9['demo'], L9['is'], Literal(os.getpid()),
                                 L9['clientdemo'])],
                      delQuads=[]))
    reactor.callLater(2, adj)
    reactor.run()