Added unit test cases and updated README.md

Author: sujata-m

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Change log
 
+
+### 0.0.17
+- Added Unit Test Cases
+
 ### 0.0.16
 - Removed extra logs
 

src/python_ms_core/__init__.py

@@ -7,7 +7,7 @@
 from .core.storage.providers.local.local_storage_client import LocalStorageClient
 from .core.auth.provider.hosted.hosted_authorizer import HostedAuthorizer
 from .core.auth.provider.simulated.simulated_authorizer import SimulatedAuthorizer
-from .core.config.config import CoreConfig, LocalConfig, AuthConfig
+from .core.config.config import CoreConfig, LocalConfig, AuthConfig, UnknownConfig
 
 LOCAL_ENV = 'LOCAL'
 AZURE_ENV = 'AZURE'
@@ -17,11 +17,18 @@
 
 class Core:
     def __init__(self, config=None):
-        if config is not None and config.upper() == LOCAL_ENV:
-            self.config = LocalConfig()
+        if config is not None:
+            if config.upper() == LOCAL_ENV:
+                self.config = LocalConfig()
+            elif config.upper() == LOCAL_ENV:
+                self.config = CoreConfig()
+                self.__check_health()
+            else:
+                self.config = UnknownConfig(provider=config)
+                logging.error(f'Failed to initialization core.get_logger for provider: {config}')
         else:
             self.config = CoreConfig()
-        self.__check_health()
+            self.__check_health()
 
     def get_logger(self):
         logger_config = self.config.logger()
@@ -39,7 +46,7 @@ def get_topic(self, topic_name: str):
         elif topic_config.provider.upper() == AZURE_ENV:
             return Topic(config=topic_config, topic_name=topic_name)
         else:
-            logging.error(f'Failed to  initialization core.get_topic for provider: {topic_config.provider}')
+            logging.error(f'Failed to initialization core.get_topic for provider: {topic_config.provider}')
 
     def get_storage_client(self):
         storage_config = self.config.storage()
@@ -48,7 +55,7 @@ def get_storage_client(self):
         elif storage_config.provider.upper() == AZURE_ENV:
             return AzureStorageClient(storage_config)
         else:
-            logging.error(f'Failed to  initialization core.get_storage_client for provider: {storage_config.provider}')
+            logging.error(f'Failed to initialization core.get_storage_client for provider: {storage_config.provider}')
 
     def get_authorizer(self, config: dict = None):
         if config is None:
@@ -62,7 +69,7 @@ def get_authorizer(self, config: dict = None):
         elif auth_config.provider.upper() == HOSTED_ENV:
             return HostedAuthorizer(config=auth_config)
         else:
-            logging.error(f'Failed to  initialization core.get_authorizer for provider: {auth_config.provider}')
+            logging.error(f'Failed to initialization core.get_authorizer for provider: {auth_config.provider}')
 
     def __check_health(self):
         print('\x1b[32m ------------------------- \x1b[0m')

src/python_ms_core/core/config/config.py

@@ -116,3 +116,44 @@ def auth(self):
         return AuthConfig(
             provider='Simulated'
         )
+
+
+class UnknownConfig:
+    def __init__(self, provider: str):
+        self.provider = provider
+        self.queue_connection = None
+        self.queue_name = None
+        self.topic_connection = None
+        self.storage_connection = None
+
+    def logger(self):
+        return LogerConfig(
+            provider=self.provider,
+            con_string=self.queue_connection,
+            queue_name=self.queue_name
+        )
+
+    def queue(self):
+        return QueueConfig(
+            provider=self.provider,
+            con_string=self.queue_connection,
+            queue_name=self.queue_name
+        )
+
+    def topic(self):
+        return TopicConfig(
+            provider=self.provider,
+            con_string=self.topic_connection
+        )
+
+    def storage(self):
+        return StorageConfig(
+            provider=self.provider,
+            con_string=self.storage_connection
+        )
+
+    def auth(self):
+        return AuthConfig(
+            provider='Simulated'
+        )
+

src/python_ms_core/core/topic/local_topic.py

@@ -26,7 +26,6 @@ def __init__(self, config=None, topic_name=None):
         self.topic = topic_name
         self.config = config
         self.client = Config(config=config, topic_name=topic_name)
-        print(self.client.connection_string)
         params = pika.URLParameters(self.client.connection_string)
         self.connection = pika.BlockingConnection(params)
         self.channel = self.connection.channel()