From f943d37efa1ea68f7d6299906ac564d0d61ca381 Mon Sep 17 00:00:00 2001
From: cobycloud <25079070+cobycloud@users.noreply.github.com>
Date: Tue, 14 Jan 2025 06:11:57 -0600
Subject: [PATCH] Update blocking.py

---
 .../crouton_client/crouton_client/blocking.py | 114 +++---------------
 1 file changed, 14 insertions(+), 100 deletions(-)

diff --git a/pkgs/crouton_client/crouton_client/blocking.py b/pkgs/crouton_client/crouton_client/blocking.py
index 6c8a34d..baa613d 100644
--- a/pkgs/crouton_client/crouton_client/blocking.py
+++ b/pkgs/crouton_client/crouton_client/blocking.py
@@ -1,100 +1,14 @@
-import requests as r
-import logging
-from urllib.parse import urlencode
-from typing import Optional, Any, Dict
-from .UUID import UUIDGenerator
-
-# Configure logging
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
-
-class CroutonClient:
-    def __init__(self, API_ROOT: str, ACCESS_STRING: Optional[str] = None):
-        self.API_ROOT = API_ROOT.rstrip('/')  # Ensure no trailing slash
-        self.ACCESS_STRING = ACCESS_STRING
-
-    def _build_url(self, resource: str, item_id: Optional[str] = None, query_params: Optional[Dict[str, Any]] = None) -> str:
-        """
-        Helper method to construct the URL with resource, item_id, and query parameters.
-        """
-        url = f"{self.API_ROOT}/{resource.strip('/')}"
-        
-        # Add item ID if provided
-        if item_id:
-            url += f"/{item_id}"
-
-        # Add query parameters
-        if query_params:
-            query_string = urlencode(query_params)
-            url += f"?{query_string}"
-
-        # Add access string as a query parameter
-        if self.ACCESS_STRING:
-            separator = '&' if '?' in url else '?'
-            url += f"{separator}token={self.ACCESS_STRING.strip('?')}"
-
-        return url
-
-    def get(
-        self, 
-        resource: str, 
-        item_id: Optional[str] = None, 
-        filters: Optional[Dict[str, Any]] = None
-    ) -> dict:
-        """
-        Perform a GET request with optional filters and an item ID.
-        """
-        url = self._build_url(resource, item_id, filters)
-
-        logger.info(f"Performing GET request to {url}")
-        res = r.get(url)
-        if res.status_code == 200:
-            return res.json()
-        else:
-            logger.error(f"GET request failed with status {res.status_code}: {res.text}")
-            raise ValueError(f"GET request failed with status {res.status_code}: {res.text}")
-
-    def post(self, resource: str, data_obj: dict) -> dict:
-        """
-        Perform a POST request to create a resource.
-        """
-        if 'id' not in data_obj:
-            data_obj['id'] = UUIDGenerator().create()
-
-        url = self._build_url(resource)
-
-        logger.info(f"Performing POST request to {url} with data {data_obj}")
-        res = r.post(url, json=data_obj)
-        if res.status_code == 200:
-            return res.json()
-        else:
-            logger.error(f"POST request failed with status {res.status_code}: {res.text}")
-            raise ValueError(f"POST request failed with status {res.status_code}: {res.text}")
-
-    def put(self, resource: str, data_obj: dict, item_id: str) -> dict:
-        """
-        Perform a PUT request to update a resource.
-        """
-        url = self._build_url(resource, item_id)
-
-        logger.info(f"Performing PUT request to {url} with data {data_obj}")
-        res = r.put(url, json=data_obj)
-        if res.status_code == 200:
-            return res.json()
-        else:
-            logger.error(f"PUT request failed with status {res.status_code}: {res.text}")
-            raise ValueError(f"PUT request failed with status {res.status_code}: {res.text}")
-
-    def delete(self, resource: str, item_id: Optional[str] = None) -> dict:
-        """
-        Perform a DELETE request to delete a resource.
-        """
-        url = self._build_url(resource, item_id)
-
-        logger.info(f"Performing DELETE request to {url}")
-        res = r.delete(url)
-        if res.status_code == 200:
-            return res.json()
-        else:
-            logger.error(f"DELETE request failed with status {res.status_code}: {res.text}")
-            raise ValueError(f"DELETE request failed with status {res.status_code}: {res.text}")
+import warnings
+import importlib
+
+warnings.warn(
+    "blocking.py is deprecated. Please use `from crouton_client.client import CroutonClient` instead.",
+    DeprecationWarning,
+    stacklevel=2
+)
+
+def __getattr__(name):
+    if name == "CroutonClient":
+        module = importlib.import_module("crouton_client.client")
+        return getattr(module, "CroutonClient")
+    raise AttributeError(f"module '{__name__}' has no attribute '{name}'")