# HG changeset patch # User drewp # Date 1476046731 25200 # Node ID ae6b5604950d75ffa34835b395241930f5d9712d # Parent d5687ba232795d62ea1db0dbc6dbca41739348e2 new / page Ignore-this: 1319a063da131f3a20e4ea3ded935a99 darcs-hash:7f217dd50d7a19de1e726a6c4820abc35c6f9750 diff -r d5687ba23279 -r ae6b5604950d service/reasoning/sse_collector.py --- a/service/reasoning/sse_collector.py Sun Oct 09 13:57:50 2016 -0700 +++ b/service/reasoning/sse_collector.py Sun Oct 09 13:58:51 2016 -0700 @@ -278,9 +278,13 @@ def addSseHandler(self, handler): log.info('addSseHandler %r %r', handler, handler.streamId) + + # fail early if id doesn't match + sources = self._sourcesForHandler(handler) + self.handlers.add(handler) - for source in self._sourcesForHandler(handler): + for source in sources: if source not in self.clients and source != COLLECTOR: self._localStatements.setSourceState(source, ROOM['connect']) self.clients[source] = ReconnectingPatchSource( @@ -354,6 +358,10 @@ raise self.write(json.dumps({'graphClients': stats}, indent=2)) + +class Root(cyclone.web.RequestHandler): + def get(self): + self.write('sse_collector') if __name__ == '__main__': @@ -375,6 +383,7 @@ 9072, cyclone.web.Application( handlers=[ + (r'/', Root), (r'/stats', Stats), (r'/graph/(.*)', SomeGraph), ],