update tools

Author: lgguzman

build/lib/sbxpy/QueryBuilder.py

@@ -12,7 +12,7 @@ def __init__(self):
             "GROUP": []
         }
         self.OP = ["in", "IN", "not in", "NOT IN", "is", "IS", "is not", "IS NOT", "<>", "!=", "=", "<", "<=", ">=", ">",
-              "like", "LIKE"]
+              "like", "LIKE", "not like", "NOT LIKE"]
 
     def set_domain(self, domain_id):
         self.q['domain'] = domain_id

build/lib/sbxpy/__init__.py

@@ -92,6 +92,11 @@ def and_where_contains(self, field, value):
         self.query.add_condition(self.lastANDOR, field, 'LIKE', '%' + value + '%')
         return self
 
+    def and_where_not_contains(self, field, value):
+        self.lastANDOR = 'AND'
+        self.query.add_condition(self.lastANDOR, field, 'NOT LIKE', '%' + value + '%')
+        return self
+
     def and_where_in(self, field, value):
         self.lastANDOR = 'AND'
         self.query.add_condition(self.lastANDOR, field, 'IN', value)
@@ -157,6 +162,11 @@ def or_where_contains(self, field, value):
         self.query.add_condition(self.lastANDOR, field, 'LIKE', '%' + value + '%')
         return self
 
+    def or_where_not_contains(self, field, value):
+        self.lastANDOR = 'AND' if (self.lastANDOR is None) else 'OR'
+        self.query.add_condition(self.lastANDOR, field, 'NOT LIKE', '%' + value + '%')
+        return self
+
     def or_where_in(self, field, value):
         self.lastANDOR = 'AND' if (self.lastANDOR is None) else 'OR'
         self.query.add_condition(self.lastANDOR, field, 'IN', value)

build/lib/sbxpy/service/__init__.py

@@ -24,19 +24,18 @@ async def get(
         cache_key = f"sbx:{result_type.get_model()}:{key}"
         cached_keys: Set[str] = set()
         model_instance = None
-        try:
-
-            await redis_service.get_connection()
-            cached_keys: Set[str] = set(
-                await redis_service.get_keys_index(keys_idx) or []
-            )
-            if use_cache and key in cached_keys:
-                model_instance = await redis_service.get_object(cache_key, result_type)
-                if model_instance:
-                    return model_instance
-        except Exception as e:
-            logger.exception(f"An error occurred while retrieving data: {e}")
-
+        await redis_service.get_connection()
+        if use_cache:
+            try:
+                cached_keys: Set[str] = set(
+                    await redis_service.get_keys_index(keys_idx) or []
+                )
+                if key in cached_keys:
+                    model_instance = await redis_service.get_object(cache_key, result_type)
+                    if model_instance:
+                        return model_instance
+            except Exception as e:
+                logger.exception(f"An error occurred while retrieving data: {e}")
         try:
             query = SBXCachedService.find(result_type.get_model())
             query.where_with_keys([key])

dist/sbxpy-0.6.7-py3-none-any.whl

@@ -1,4 +1,4 @@
-Metadata-Version: 2.1
+Metadata-Version: 2.2
 Name: sbxpy
 Version: 0.6.8
 Summary: This is the module  create all request used to communicate with SbxCloud
@@ -10,5 +10,17 @@ Classifier: License :: OSI Approved :: MIT License
 Classifier: Operating System :: OS Independent
 Description-Content-Type: text/markdown
 License-File: LICENSE
+Requires-Dist: aiohttp>=3.7.3
+Requires-Dist: redis>=4.5.2
+Requires-Dist: pydantic>2.1.0
+Requires-Dist: deepmerge>=1.1.0
+Dynamic: author
+Dynamic: author-email
+Dynamic: classifier
+Dynamic: description
+Dynamic: description-content-type
+Dynamic: home-page
+Dynamic: requires-dist
+Dynamic: summary
 
 This is the module  create all request used to communicate with SbxCloud