From 1d6c3d1f96243b603dbdbd392dabe09bebfbed7c Mon Sep 17 00:00:00 2001 From: Brian Warner Date: Mon, 23 Nov 2015 16:50:54 -0800 Subject: [PATCH] clients: use "watch" endpoint, not "get" --- src/wormhole/blocking/transcribe.py | 2 +- src/wormhole/twisted/transcribe.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/wormhole/blocking/transcribe.py b/src/wormhole/blocking/transcribe.py index 86f24c2..9a14981 100644 --- a/src/wormhole/blocking/transcribe.py +++ b/src/wormhole/blocking/transcribe.py @@ -92,7 +92,7 @@ class Channel: raise Timeout queryargs = urlencode([("appid", self._appid), ("channelid", self._channelid)]) - f = EventSourceFollower(self._relay_url+"get?%s" % queryargs, + f = EventSourceFollower(self._relay_url+"watch?%s" % queryargs, remaining) # we loop here until the connection is lost, or we see the # message we want diff --git a/src/wormhole/twisted/transcribe.py b/src/wormhole/twisted/transcribe.py index 044d217..db4a154 100644 --- a/src/wormhole/twisted/transcribe.py +++ b/src/wormhole/twisted/transcribe.py @@ -140,7 +140,7 @@ class Channel: # TODO: use agent=self._agent queryargs = urlencode([("appid", self._appid), ("channelid", self._channelid)]) - es = ReconnectingEventSource(self._relay_url+"get?%s" % queryargs, + es = ReconnectingEventSource(self._relay_url+"watch?%s" % queryargs, _handle) es.startService() # TODO: .setServiceParent(self) es.activate()