# HG changeset patch # User drewp@bigasterisk.com # Date 1476046731 25200 # Node ID bfc3f246e77e0016b74ed27f8830cb36f5e1d322 # Parent 170dc9b1e7892800e39fdcdc4e525449f9216716 new / page Ignore-this: 1319a063da131f3a20e4ea3ded935a99 diff -r 170dc9b1e789 -r bfc3f246e77e 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), ],