1 files changed, 73 insertions, 0 deletions
diff --git a/sdv/docker/sdvstate/tools/result_api/result_api.py b/sdv/docker/sdvstate/tools/result_api/result_api.py
new file mode 100644
index 0000000..95dfd56
--- /dev/null
+++ b/sdv/docker/sdvstate/tools/result_api/result_api.py
@@ -0,0 +1,73 @@
+# Copyright 2020 University Of Delhi.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+
+"""
+Result API
+Main entry point to use results manager
+"""
+
+import logging
+from .storage.storage_api import StorageApi
+
+class ResultApi():
+    """
+    Result API
+    Provides various storage options to use implemented as
+    plugin to storage api
+    """
+
+    def __init__(self):
+        """
+        Initialization function
+        """
+        self._logger = logging.getLogger(__name__)
+        self._storage_handles = []
+
+    def register_storage(self, storage_api):
+        """
+        Registers ``storage_api`` as an active storage option to use.
+        """
+        self._logger.debug("Loading new Storage API...")
+        if not isinstance(storage_api, StorageApi):
+            raise TypeError("incorrect storage type, Required StorageAPI obj")
+
+        storage_api.load_settings()
+        self._storage_handles.append(storage_api)
+        self._logger.info(f'{storage_api.name} api registered')
+
+    def unregister_storage(self, storage_api):
+        """
+        Removes registered ``storage_api`` if exists
+        """
+        while storage_api in self._storage_handles:
+            self._storage_handles.remove(storage_api)
+
+    def unregister_all(self):
+        """
+        Removes all registered storage endpoints
+        """
+        for storage_api in self._storage_handles:
+            self.unregister_storage(storage_api)
+
+    def store(self, data):
+        """
+        Calls all active storage_api and stores ``data`` in all of them
+        """
+        for api in self._storage_handles:
+            api.store(data)
+
+
+# pylint: disable=invalid-name
+result_api = ResultApi()