Unit test cases

Author: sujata-m

requirements.txt

@@ -19,3 +19,7 @@ typing_extensions==4.4.0
 uamqp==1.6.3
 urllib3==1.26.14
 pika==1.3.1
+httpx==0.24.1
+coverage==7.2.7
+html_testRunner==1.2.1
+psutil==5.9.5

src/python_ms_core/core/queue/local_queue.py

@@ -36,3 +36,6 @@ def remove(self):
 
     def get_items(self):
         return self.queue
+
+    def empty(self):
+        self.queue = list()

src/python_ms_core/core/queue/models/queue_message.py

@@ -22,14 +22,15 @@ class QueueMessage(Validations):
     data: Union[dict, List[dict]] = dict
     queue = list()
 
-    @staticmethod
     def add(self, data=None):
         if data is not None:
             self.queue.insert(0, json.dumps(data))
             return True
         return False
 
-    @staticmethod
+    def empty(self):
+        self.queue = list()
+
     def remove(self):
         if len(self.queue) > 0:
             self.queue.pop()
@@ -40,7 +41,7 @@ def send(self):
         return True
 
     def get_items(self):
-        return self.queue
+        return [json.loads(item) for item in self.queue]
 
     @ExceptionHandler.decorated
     def data_from(self):

src/python_ms_core/core/queue/queue.py

@@ -32,3 +32,6 @@ def remove(self):
 
     def get_items(self):
         return self.queue
+
+    def empty(self):
+        self.queue = list()

…n_ms_core/core/storage/config/__init__py …_ms_core/core/storage/config/__init__.pysrc/python_ms_core/core/storage/config/__init__py renamed to src/python_ms_core/core/storage/config/__init__.py src/python_ms_core/core/storage/config/__init__py renamed to src/python_ms_core/core/storage/config/__init__.py

@@ -0,0 +1,38 @@
+import unittest
+from unittest.mock import MagicMock
+from src.python_ms_core.core.auth.abstracts.authorizer_abstract import AuthorizerAbstract
+from src.python_ms_core.core.auth.models.permission_request import PermissionRequest
+
+
+class TestAuthorizerAbstract(unittest.TestCase):
+
+    def test_has_permission(self):
+        # Create a mock PermissionRequest object
+        request_params = PermissionRequest(
+            user_id='SOME_USER_ID',
+            org_id='SOME_ORG_ID',
+            should_satisfy_all=False,
+            permissions=['poc']
+        )
+
+        # Implement a concrete subclass for AuthorizerAbstract
+        class AuthorizerImplementation(AuthorizerAbstract):
+            def __init__(self, config=None):
+                super().__init__(config)
+
+            def has_permission(self, request_params: PermissionRequest):
+                # Implement the behavior for the has_permission method
+                return True  # Return True for testing purposes
+
+        # Instantiate the AuthorizerImplementation class
+        authorizer = AuthorizerImplementation()
+
+        # Call the has_permission method with the mock request_params
+        result = authorizer.has_permission(request_params)
+
+        # Assert that the result is True
+        self.assertTrue(result)
+
+
+if __name__ == '__main__':
+    unittest.main()