mirror of
https://github.com/internetarchive/brozzler.git
synced 2025-02-24 00:29:53 -05:00
only reset idle timer on Network.requestWillBeSent instead of all events (otherwise long-running videos keep the browser open unnecessarily)
This commit is contained in:
parent
9d9014c864
commit
a30b5d8dd2
@ -87,10 +87,10 @@ class UmbraWorker:
|
|||||||
routing_key=self.client_id)
|
routing_key=self.client_id)
|
||||||
|
|
||||||
def handle_message(self, websock, message):
|
def handle_message(self, websock, message):
|
||||||
self.logger.debug("handling message from websocket {} - {}".format(websock, message[:95]))
|
# self.logger.debug("handling message from websocket {} - {}".format(websock, message[:95]))
|
||||||
self._reset_idle_timer()
|
|
||||||
message = loads(message)
|
message = loads(message)
|
||||||
if "method" in message.keys() and message["method"] == "Network.requestWillBeSent":
|
if "method" in message.keys() and message["method"] == "Network.requestWillBeSent":
|
||||||
|
self._reset_idle_timer()
|
||||||
self.send_request_to_amqp(message)
|
self.send_request_to_amqp(message)
|
||||||
elif "method" in message.keys() and message["method"] == "Page.loadEventFired":
|
elif "method" in message.keys() and message["method"] == "Page.loadEventFired":
|
||||||
self.logger.debug("got Page.loadEventFired, starting behaviors for {}".format(self.url))
|
self.logger.debug("got Page.loadEventFired, starting behaviors for {}".format(self.url))
|
||||||
|
Loading…
x
Reference in New Issue
Block a user