mock create channel for control client creation

Author: Mahalaxmibejugam

gcsfs/tests/conftest.py

@@ -126,16 +126,16 @@ def docker_gcs():
     container = "gcsfs_test"
     cmd = (
         "docker run -d -p 4443:4443 --name gcsfs_test fsouza/fake-gcs-server:latest -scheme "
-        "https -public-host 0.0.0.0:4443 -external-url https://localhost:4443 "
+        "http -public-host 0.0.0.0:4443 -external-url http://localhost:4443 "
         "-backend memory"
     )
     stop_docker(container)
     subprocess.check_output(shlex.split(cmd))
-    url = "https://localhost:4443"
+    url = "http://0.0.0.0:4443"
     timeout = 10
     while True:
         try:
-            r = requests.get(url + "/storage/v1/b", verify=False)
+            r = requests.get(url + "/storage/v1/b")
             if r.ok:
                 yield url
                 break
@@ -147,6 +147,20 @@ def docker_gcs():
     stop_docker(container)
 
 
+@pytest.fixture(autouse=True)
+def mock_control_plane_channel():
+    from unittest import mock
+
+    # Mock create_channel to prevent real gRPC channel creation to emulator
+    target = (
+        "google.cloud.storage_control_v2.services.storage_control.transports."
+        "grpc_asyncio.StorageControlGrpcAsyncIOTransport.create_channel"
+    )
+    with mock.patch(target) as mock_create:
+        mock_create.return_value = mock.Mock()  # Return a dummy channel
+        yield mock_create
+
+
 @pytest.fixture(scope="session")
 def gcs_factory(docker_gcs):
     params["endpoint_url"] = docker_gcs