#!bin/python

from run_local import log

from twisted.internet import reactor, task, defer

from rdflib import URIRef, Literal

from twisted.internet.defer import ensureDeferred

from rdfdb.syncedgraph import SyncedGraph

import time, logging

from light9 import networking, showconfig

from light9.namespaces import L9

class BusyClient:

    def __init__(self, subj, rate):

        self.subj = subj

        self.rate = rate

        self.graph = SyncedGraph(networking.rdfdb.url, "collector")

        self.graph.initiallySynced.addCallback(self.go)

    def go(self, _):

        task.LoopingCall(self.loop).start(1 / self.rate)

    def loop(self):

        self.graph.patchObject(showconfig.showUri() + '/loadTestContext',

                               subject=self.subj,

                          predicate=L9['time'],

                          newObject=Literal(str(time.time())))

def main():

    log.setLevel(logging.INFO)

    clients = [BusyClient(L9['loadTest_%d' % i], 20) for i in range(10)]

    reactor.run()

if __name__ == "__main__":

    main()