Eliminate uses of requests library in src/azul/service/drs_controller.py (#7633)

Author: achave11-ucsc

src/azul/service/drs_controller.py

@@ -28,7 +28,6 @@
 from more_itertools import (
     one,
 )
-import requests
 
 from azul import (
     CatalogName,
@@ -47,6 +46,9 @@
     drs_object_uri,
     drs_object_url_path,
 )
+from azul.http import (
+    HasCachedHttpClient,
+)
 from azul.openapi import (
     responses,
     schema,
@@ -66,7 +68,7 @@
 )
 
 
-class DRSController(ServiceAppController):
+class DRSController(ServiceAppController, HasCachedHttpClient):
 
     @cached_property
     def service(self) -> RepositoryService:
@@ -149,7 +151,9 @@ def dss_get_file(self, file_uuid, replica, **kwargs):
             **kwargs
         }
         url = self.dss_file_url(file_uuid)
-        return requests.get(str(url), params=dss_params, allow_redirects=False)
+        return self._http_client.request('GET', str(url),
+                                         fields=dss_params,
+                                         redirect=False)
 
     @classmethod
     def dss_file_url(cls, file_uuid: str) -> mutable_furl:
@@ -177,7 +181,9 @@ def _dos_gs_url(self, file_uuid, version) -> mutable_furl:
                       replica='gcp')
         while True:
             if self.lambda_context.get_remaining_time_in_millis() / 1000 > 3:
-                dss_response = requests.get(url, params=params, allow_redirects=False)
+                dss_response = self._http_client.request('GET', url,
+                                                         fields=params,
+                                                         redirect=False)
                 if dss_response.status_code == 302:
                     url = furl(dss_response.next.url)
                     assert url.scheme == 'gs', R('Expected a gs:// URL', url)
@@ -238,7 +244,7 @@ class GatewayTimeoutError(ChaliceViewError):
 
 
 @dataclass
-class DRSObject:
+class DRSObject(HasCachedHttpClient):
     """"
     Used to build up a https://ga4gh.github.io/data-repository-service-schemas/docs/#_drsobject
     """
@@ -264,7 +270,7 @@ def add_access_method(self,
     def to_json(self) -> JSON:
         args = adict(replica='aws', version=self.version)
         url = DRSController.dss_file_url(self.uuid).add(args=args)
-        headers = requests.head(url).headers
+        headers = self._http_client.request('HEAD', url).headers
         version = headers['x-dss-version']
         if self.version is not None:
             assert version == self.version