Revert of Add field_specs to all metrics in luci-py

client/third_party/infra_libs/httplib2_utils.py

 # Copyright 2015 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
-import base64
 import collections
 import copy
 import json
 import logging
 import os
 import re
 import socket
 import sys
 import time
 
 import httplib2
 import oauth2client.client
 
 from googleapiclient import errors
 from infra_libs.ts_mon.common import http_metrics
-from oauth2client import util
 
 DEFAULT_SCOPES = ['email']
 
 # default timeout for http requests, in seconds
 DEFAULT_TIMEOUT = 30
 
 # This is part of the API.
 if sys.platform.startswith('win'): # pragma: no cover
   SERVICE_ACCOUNTS_CREDS_ROOT = 'C:\\creds\\service_accounts'
 else:
@@ skipping 125 matching lines @@
     credentials_filename,
     scope=scope,
     service_accounts_creds_root=service_accounts_creds_root)
 
   if http_identifier:
     http = InstrumentedHttp(http_identifier, timeout=timeout)
   else:
     http = httplib2.Http(timeout=timeout)
   return creds.authorize(http)
 
-
-class DelegateServiceAccountCredentials(
-    oauth2client.client.AssertionCredentials):
-  """Authorizes an HTTP client with a service account for which we are an actor.
-
-  This class uses the IAM API to sign a JWT with the private key of another
-  service account for which we have the "Service Account Actor" role.
-  """
-
-  MAX_TOKEN_LIFETIME_SECS = 3600 # 1 hour in seconds
-  _SIGN_BLOB_URL = 'https://iam.googleapis.com/v1/%s:signBlob'
-
-  def __init__(self, http, service_account_email, scopes, project='-'):
-    """
-    Args:
-      http: An httplib2.Http object that is authorized by another
-        oauth2client.client.OAuth2Credentials with credentials that have the
-        service account actor role on the service_account_email.
-      service_account_email: The email address of the service account for which
-        to obtain an access token.
-      scopes: The desired scopes for the token.
-      project: The cloud project to which service_account_email belongs.  The
-        default of '-' makes the IAM API figure it out for us.
-    """
-
-    super(DelegateServiceAccountCredentials, self).__init__(None)
-    self._service_account_email = service_account_email
-    self._scopes = util.scopes_to_string(scopes)
-    self._http = http
-    self._name = 'projects/%s/serviceAccounts/%s' % (
-        project, service_account_email)
-
-  def sign_blob(self, blob):
-    response, content = self._http.request(
-        self._SIGN_BLOB_URL % self._name,
-        method='POST',
-        body=json.dumps({'bytesToSign': base64.b64encode(blob)}),
-        headers={'Content-Type': 'application/json'})
-    if response.status != 200:
-      raise AuthError('Failed to sign blob as %s: %d %s' % (
-          self._service_account_email, response.status, response.reason))
-
-    data = json.loads(content)
-    return data['keyId'], data['signature']
-
-  def _generate_assertion(self):
-    # This is copied with small modifications from
-    # oauth2client.service_account._ServiceAccountCredentials.
-
-    header = {
-        'alg': 'RS256',
-        'typ': 'JWT',
-    }
-
-    now = int(time.time())
-    payload = {
-        'aud': self.token_uri,
-        'scope': self._scopes,
-        'iat': now,
-        'exp': now + self.MAX_TOKEN_LIFETIME_SECS,
-        'iss': self._service_account_email,
-    }
-
-    assertion_input = (
-        self._urlsafe_b64encode(header) + b'.' +
-        self._urlsafe_b64encode(payload))
-
-    # Sign the assertion.
-    _, rsa_bytes = self.sign_blob(assertion_input)
-    signature = rsa_bytes.rstrip(b'=')
-
-    return assertion_input + b'.' + signature
-
-  def _urlsafe_b64encode(self, data):
-    # Copied verbatim from oauth2client.service_account.
-    return base64.urlsafe_b64encode(
-        json.dumps(data, separators=(',', ':')).encode('UTF-8')).rstrip(b'=')
-
-
 class RetriableHttp(object):
   """A httplib2.Http object that retries on failure."""
 
   def __init__(self, http, max_tries=5, backoff_time=1,
                retrying_statuses_fn=None):
     """
     Args:
       http: an httplib2.Http instance
       max_tries: a number of maximum tries
       backoff_time: a number of seconds to sleep between retries
@@ skipping 34 matching lines @@
   def __getattr__(self, name):
     return getattr(self._http, name)
 
   def __setattr__(self, name, value):
     if name in ('request', '_http', '_max_tries', '_backoff_time',
                 '_retrying_statuses_fn'):
       self.__dict__[name] = value
     else:
       setattr(self._http, name, value)
 
-
 class InstrumentedHttp(httplib2.Http):
   """A httplib2.Http object that reports ts_mon metrics about its requests."""
 
   def __init__(self, name, time_fn=time.time, timeout=DEFAULT_TIMEOUT,
                **kwargs):
     """
     Args:
       name: An identifier for the HTTP requests made by this object.
       time_fn: Function returning the current time in seconds. Use for testing
         purposes only.
@@ skipping 82 matching lines @@
     self.requests_made.append(self.HttpCall(uri, method, body, headers))
     headers = None
     body = None
     for candidate in self._uris:
       if candidate[0].match(uri):
         _, headers, body = candidate
         break
     if not headers:
       raise AssertionError("Unexpected request to %s" % uri)
     return httplib2.Response(headers), body