move common code to utils

Author: chandra-siri

google/cloud/storage/_experimental/asyncio/_utils.py

@@ -0,0 +1,20 @@
+import google_crc32c
+
+from google.cloud.storage import exceptions
+
+def raise_if_no_fast_crc32c():
+    """Check if the C-accelerated version of google-crc32c is available.
+
+    If not, raise an error to prevent silent performance degradation.
+    
+    raises google.api_core.exceptions.NotFound: If the C extension is not available.
+    returns: True if the C extension is available.
+    rtype: bool
+    
+    """
+    if google_crc32c.implementation != "c":
+        raise exceptions.NotFound(
+            "The google-crc32c package is not installed with C support. "
+            "Bidi reads require the C extension for data integrity checks."
+            "For more information, see https://github.com/googleapis/python-crc32c."
+        )

google/cloud/storage/_experimental/asyncio/async_appendable_object_writer.py

@@ -21,9 +21,13 @@
 if you want to use these Rapid Storage APIs.
 
 """
+import time
 from typing import Optional, Union
+
 from google.api_core import exceptions
-from google_crc32c import Checksum, implementation as crc32c_impl
+from google_crc32c import Checksum
+
+from ._utils import raise_if_no_fast_crc32c
 from google.cloud import _storage_v2
 from google.cloud.storage._experimental.asyncio.async_grpc_client import (
     AsyncGrpcClient,
@@ -102,14 +106,7 @@ def __init__(
         :param write_handle: (Optional) An existing handle for writing the object.
                             If provided, opening the bidi-gRPC connection will be faster.
         """
-        # Verify that the fast, C-accelerated version of crc32c is available.
-        # If not, raise an error to prevent silent performance degradation.
-        if crc32c_impl != "c":
-            raise exceptions.NotFound(
-                "The google-crc32c package is not installed with C support. "
-                "Bidi reads require the C extension for data integrity checks."
-                "For more information, see https://github.com/googleapis/python-crc32c."
-            )
+        raise_if_no_fast_crc32c()
         self.client = client
         self.bucket_name = bucket_name
         self.object_name = object_name

google/cloud/storage/_experimental/asyncio/async_multi_range_downloader.py

@@ -14,12 +14,12 @@
 
 from __future__ import annotations
 import asyncio
-import google_crc32c
+from typing import List, Optional, Tuple
+
 from google.api_core import exceptions
 from google_crc32c import Checksum
 
-from typing import List, Optional, Tuple
-
+from ._utils import raise_if_no_fast_crc32c
 from google.cloud.storage._experimental.asyncio.async_read_object_stream import (
     _AsyncReadObjectStream,
 )
@@ -160,14 +160,7 @@ def __init__(
         :param read_handle: (Optional) An existing read handle.
         """
 
-        # Verify that the fast, C-accelerated version of crc32c is available.
-        # If not, raise an error to prevent silent performance degradation.
-        if google_crc32c.implementation != "c":
-            raise exceptions.NotFound(
-                "The google-crc32c package is not installed with C support. "
-                "Bidi reads require the C extension for data integrity checks."
-                "For more information, see https://github.com/googleapis/python-crc32c."
-            )
+        raise_if_no_fast_crc32c()
 
         self.client = client
         self.bucket_name = bucket_name