Network tests have been migrated to new cat2.cloud/testing site

Author: FrancescAlted

src/blosc2/c2array.py

@@ -144,11 +144,6 @@ def info(path, urlbase, params=None, headers=None, model=None, auth_token=None):
     return json if model is None else model(**json)
 
 
-def subscribe(root, urlbase, auth_token):
-    url = _sub_url(urlbase, f"api/subscribe/{root}")
-    return _xpost(url, auth_token=auth_token)
-
-
 def fetch_data(path, urlbase, params, auth_token=None, as_blosc2=False):
     url = _sub_url(urlbase, f"api/fetch/{path}")
     response = _xget(url, params=params, auth_token=auth_token)
@@ -237,15 +232,8 @@ def __init__(self, path: str, /, urlbase: str | None = None, auth_token: str | N
         # Try to 'open' the remote path
         try:
             self.meta = info(self.path, self.urlbase, auth_token=self.auth_token)
-        except requests.HTTPError:
-            # Subscribe to root and try again. It is less latency to subscribe directly
-            # than to check for the subscription.
-            root, _ = self.path.split("/", 1)
-            subscribe(root, self.urlbase, self.auth_token)
-            try:
-                self.meta = info(self.path, self.urlbase, auth_token=self.auth_token)
-            except requests.HTTPError as err:
-                raise FileNotFoundError(f"Remote path not found: {path}.\nError was: {err}") from err
+        except requests.HTTPError as err:
+            raise FileNotFoundError(f"Remote path not found: {path}.\nError was: {err}") from err
         cparams = self.meta["schunk"]["cparams"]
         # Remove "filters, meta" from cparams; this is an artifact from the server
         cparams.pop("filters, meta", None)

tests/conftest.py

@@ -20,7 +20,7 @@ def pytest_configure(config):
 def c2sub_context():
     # You may use the URL and credentials for an already existing user
     # in a different Caterva2 subscriber.
-    urlbase = os.environ.get("BLOSC_C2URLBASE", "https://demo.caterva2.net/")
+    urlbase = os.environ.get("BLOSC_C2URLBASE", "https://cat2.cloud/testing/")
     c2params = {"urlbase": urlbase, "username": None, "password": None}
     with blosc2.c2context(**c2params):
         yield c2params

tests/ndarray/test_c2array_expr.py

@@ -16,7 +16,7 @@
 pytestmark = pytest.mark.network
 
 NITEMS_SMALL = 1_000
-ROOT = "b2tests"
+ROOT = "@public"
 DIR = "expr/"
 
 

tests/ndarray/test_c2array_reductions.py

@@ -16,7 +16,7 @@
 pytestmark = pytest.mark.network
 
 NITEMS_SMALL = 1_000
-ROOT = "b2tests"
+ROOT = "@public"
 DIR = "expr/"
 
 

tests/ndarray/test_c2array_udf.py

@@ -12,7 +12,7 @@
 
 import blosc2
 
-ROOT = "b2tests"
+ROOT = "@public"
 DIR = "expr/"
 
 pytestmark = pytest.mark.network

tests/ndarray/test_proxy_c2array.py

@@ -15,7 +15,7 @@
 pytestmark = pytest.mark.network
 
 NITEMS_SMALL = 1_000
-ROOT = "b2tests"
+ROOT = "@public"
 DIR = "expr/"
 
 

tests/ndarray/test_proxy_expr.py

@@ -15,7 +15,7 @@
 
 pytestmark = pytest.mark.network
 
-ROOT = "b2tests"
+ROOT = "@public"
 DIR = "expr/"
 
 

tests/test_open_c2array.py

@@ -18,7 +18,7 @@
 pytestmark = pytest.mark.network
 
 NITEMS_SMALL = 1_000
-ROOT = "b2tests"
+ROOT = "@public"
 DIR = "expr/"
 
 
@@ -71,7 +71,7 @@ def c2sub_user():
     def rand32():
         return random.randint(0, 0x7FFFFFFF)
 
-    urlbase = "https://demo-auth.caterva2.net/"
+    urlbase = "https://cat2.cloud/testing/"
     username = f"user+{rand32():x}@example.com"
     password = hex(rand32())