Send authorization headers when calling Swarming backend.

appengine/swarming/swarming_bot/api/bot.py

 # Copyright 2014 The LUCI Authors. All rights reserved.
 # Use of this source code is governed under the Apache License, Version 2.0
 # that can be found in the LICENSE file.
 
 """Bot interface used in bot_config.py."""
 
 import logging
 import os
 import threading
 import time
 
 import os_utilities
-from utils import net
 from utils import zip_package
 
 THIS_FILE = os.path.abspath(zip_package.get_main_script_path())
 
 # Method could be a function - pylint: disable=R0201
 
 
 class Bot(object):
   def __init__(
-      self, attributes, server, server_version, base_dir, shutdown_hook):
+      self, remote, attributes, server, server_version, base_dir,
+      shutdown_hook):
     # Do not expose attributes  for now, as attributes may be refactored.
     assert server is None or not server.endswith('/'), server
     self._attributes = attributes
     self._base_dir = base_dir
+    self._remote = remote
     self._server = server
     self._server_version = server_version
     self._shutdown_hook = shutdown_hook
     self._timers = []
     self._timers_dying = False
     self._timers_lock = threading.Lock()
 
   @property
   def base_dir(self):
     """Returns the working directory.
@@ skipping 12 matching lines @@
     tasks.
     """
     return self._attributes.get('dimensions', {}).copy()
 
   @property
   def id(self):
     """Returns the bot's ID."""
     return self.dimensions.get('id', ['unknown'])[0]
 
   @property
+  def remote(self):
+    """RemoteClient to talk to the server.
+
+    Should not be normally used by bot_config.py for now.
+    """
+    return self._remote
+
+  @property
   def server(self):
     """URL of the swarming server this bot is connected to.
 
     It includes the https:// prefix but without trailing /, so it looks like
     "https://foo-bar.appspot.com".
     """
     return self._server
 
   @property
   def server_version(self):
@@ skipping 19 matching lines @@
     return swarming_bot.zip since this is the script that must be used when
     starting up.
     """
     return os.path.join(os.path.dirname(THIS_FILE), 'swarming_bot.zip')
 
   def post_event(self, event_type, message):
     """Posts an event to the server."""
     data = self._attributes.copy()
     data['event'] = event_type
     data['message'] = message
-    net.url_read_json(self.server + '/swarming/api/v1/bot/event', data=data)
+    self._remote.url_read_json('/swarming/api/v1/bot/event', data=data)
 
   def post_error(self, message):
     """Posts given string as a failure.
 
     This is used in case of internal code error. It traps exception.
     """
     logging.error('Error: %s\n%s', self._attributes, message)
     try:
       self.post_event('bot_error', message)
     except Exception:
@@ skipping 72 matching lines @@
       if t.isAlive():
         logging.error('Timer thread did not terminate fast enough: %s', t)
 
   def update_dimensions(self, new_dimensions):
     """Called internally to update Bot.dimensions."""
     self._attributes['dimensions'] = new_dimensions
 
   def update_state(self, new_state):
     """Called internally to update Bot.state."""
     self._attributes['state'] = new_state