Add GCP support

closes pulp#3424

CHANGES/3424.feature

@@ -0,0 +1 @@
+Add GCP support

pulpcore/app/settings.py

@@ -315,10 +315,11 @@
     | Validator("DEFAULT_FILE_STORAGE", eq="pulpcore.app.models.storage.FileSystem")
     | Validator("DEFAULT_FILE_STORAGE", eq="storages.backends.azure_storage.AzureStorage")
     | Validator("DEFAULT_FILE_STORAGE", eq="storages.backends.s3boto3.S3Boto3Storage")
+    | Validator("DEFAULT_FILE_STORAGE", eq="storages.backends.gcloud.GoogleCloudStorage")
 )
 storage_validator.messages["combined"] = (
-    "'REDIRECT_TO_OBJECT_STORAGE=True' is only supported with the local file, S3 or Azure storage"
-    "backend configured in DEFAULT_FILE_STORAGE."
+    "'REDIRECT_TO_OBJECT_STORAGE=True' is only supported with the local file, S3, GCP or Azure"
+    "storage backend configured in DEFAULT_FILE_STORAGE."
 )
 
 cache_enabled_validator = Validator("CACHE_ENABLED", eq=True)

pulpcore/app/util.py

@@ -298,6 +298,11 @@ def get_artifact_url(artifact, headers=None, http_method=None):
         if headers and headers.get("Content-Type"):
             parameters["content_type"] = headers.get("Content-Type")
         url = artifact_file.storage.url(artifact_file.name, parameters=parameters)
+    elif settings.DEFAULT_FILE_STORAGE == "storages.backends.gcloud.GoogleCloudStorage":
+        parameters = {"response_disposition": content_disposition}
+        if headers and headers.get("Content-Type"):
+            parameters["content_type"] = headers.get("Content-Type")
+        url = artifact_file.storage.url(artifact_file.name, parameters=parameters)
     else:
         raise NotImplementedError(
             f"The value settings.DEFAULT_FILE_STORAGE={settings.DEFAULT_FILE_STORAGE} "

pulpcore/content/handler.py

@@ -862,6 +862,12 @@ async def _serve_content_artifact(self, content_artifact, headers, request):
                 parameters["content_type"] = headers.get("Content-Type")
             url = URL(artifact_file.storage.url(artifact_name, parameters=parameters), encoded=True)
             raise HTTPFound(url)
+        elif settings.DEFAULT_FILE_STORAGE == "storages.backends.gcloud.GoogleCloudStorage":
+            parameters = {"response_disposition": content_disposition}
+            if headers.get("Content-Type"):
+                parameters["content_type"] = headers.get("Content-Type")
+            url = URL(artifact_file.storage.url(artifact_name, parameters=parameters), encoded=True)
+            raise HTTPFound(url)
         else:
             raise NotImplementedError()
 

setup.py

@@ -22,6 +22,7 @@
     extras_require={
         "sftp": ["django-storages[sftp]"],
         "s3": ["django-storages[boto3]"],
+        "google": ["django-storages[google]>=1.13.2"],
         "azure": ["django-storages[azure]>=1.12.2"],
         "prometheus": ["django-prometheus"],
     },