remote: http: rename http error, refactor test

Author: pared

dvc/exceptions.py

@@ -350,9 +350,8 @@ def __init__(self, path, external_repo_path, external_repo_url):
         )
 
 
-class HTTPErrorStatusCodeException(DvcException):
+class HTTPError(DvcException):
     def __init__(self, code, reason):
-        super(HTTPErrorStatusCodeException, self).__init__(
-            "Server responded with error status code: '{}' and message: "
-            "'{}'".format(code, reason)
+        super(HTTPError, self).__init__(
+            "HTTP error: '{} {}'".format(code, reason)
         )

dvc/remote/http.py

@@ -7,8 +7,7 @@
 
 from dvc.config import Config
 from dvc.config import ConfigError
-from dvc.exceptions import DvcException
-from dvc.exceptions import HTTPErrorStatusCodeException
+from dvc.exceptions import DvcException, HTTPError
 from dvc.progress import Tqdm
 from dvc.remote.base import RemoteBASE
 from dvc.scheme import Schemes
@@ -40,9 +39,7 @@ def __init__(self, repo, config):
     def _download(self, from_info, to_file, name=None, no_progress_bar=False):
         response = self._request("GET", from_info.url, stream=True)
         if response.status_code != 200:
-            raise HTTPErrorStatusCodeException(
-                response.status_code, response.reason
-            )
+            raise HTTPError(response.status_code, response.reason)
         with Tqdm(
             total=None if no_progress_bar else self._content_length(from_info),
             leave=False,

tests/func/test_repro.py

@@ -43,8 +43,7 @@
 from tests.func.test_data_cloud import get_ssh_url
 from tests.func.test_data_cloud import TEST_AWS_REPO_BUCKET
 from tests.func.test_data_cloud import TEST_GCP_REPO_BUCKET
-from tests.utils.httpd import ContentMD5Handler
-from tests.utils.httpd import StaticFileServer
+from tests.utils.httpd import StaticFileServer, ContentMD5Handler
 
 
 class TestRepro(TestDvc):

tests/unit/remote/test_http.py

@@ -1,8 +1,12 @@
+try:
+    from http.server import BaseHTTPRequestHandler
+except ImportError:
+    from BaseHTTPServer import BaseHTTPRequestHandler
+
 import pytest
-from BaseHTTPServer import BaseHTTPRequestHandler
 
 from dvc.config import ConfigError
-from dvc.exceptions import HTTPErrorStatusCodeException
+from dvc.exceptions import HTTPError
 from dvc.path_info import URLInfo
 from dvc.remote.http import RemoteHTTP
 from tests.utils.httpd import StaticFileServer
@@ -19,21 +23,17 @@ def test_no_traverse_compatibility(dvc_repo):
         RemoteHTTP(dvc_repo, config)
 
 
-@pytest.mark.parametrize("response_code", [404, 403, 500])
-def test_download_fails_on_error_code(response_code, dvc_repo):
+def test_download_fails_on_error_code(dvc_repo):
     class ErrorStatusRequestHandler(BaseHTTPRequestHandler):
         def do_GET(self):
-            self.send_response(response_code, message="Error message")
+            self.send_response(404, message="Not found")
             self.end_headers()
 
     with StaticFileServer(ErrorStatusRequestHandler) as httpd:
         url = "http://localhost:{}/".format(httpd.server_port)
         config = {"url": url}
 
         remote = RemoteHTTP(dvc_repo, config)
-        import os
 
-        with pytest.raises(HTTPErrorStatusCodeException):
-            remote._download(
-                URLInfo(os.path.join(url, "file.txt")), "file.txt"
-            )
+        with pytest.raises(HTTPError):
+            remote._download(URLInfo(url) / "file.txt", "file.txt")

tests/utils/httpd.py

@@ -47,7 +47,6 @@ class StaticFileServer:
 
     def __init__(self, handler_class=ETagHandler):
         self._lock.acquire()
-        self.response_handler = handler_class
         self._httpd = HTTPServer(("localhost", 0), handler_class)
         self._thread = None