Merge pull request #11 from mudpi/feature

Get latest changes as per 03/26/2021

Author: yeyeto2788

mudpi/importer.py

@@ -740,23 +740,26 @@ def _install_extension_requirements(mudpi, extension):
         cache[extension.namespace] = extension
         return cache[extension.namespace]
 
+    requirement_cache = mudpi.cache.setdefault('requirement_installed', {})
     for requirement in extension.requirements:
-        if not utils.is_package_installed(requirement):
-            Logger.log_formatted(
-                LOG_LEVEL["info"],
-                f'{FONT_YELLOW}{extension.namespace.title()}{FONT_RESET} requirements', 
-                'Installing', 'notice'
-            )
-            Logger.log(
-                LOG_LEVEL["debug"],
-                f'Installing package {FONT_YELLOW}{requirement}{FONT_RESET}',
-            )
-            if not utils.install_package(requirement):
+        if requirement not in requirement_cache:
+            if not utils.is_package_installed(requirement):
+                Logger.log_formatted(
+                    LOG_LEVEL["info"],
+                    f'{FONT_YELLOW}{extension.namespace.title()}{FONT_RESET} requirements', 
+                    'Installing', 'notice'
+                )
                 Logger.log(
-                    LOG_LEVEL["error"],
-                    f'Error installing <{extension.title()}> requirement: {FONT_YELLOW}{requirement}{FONT_RESET}'
+                    LOG_LEVEL["debug"],
+                    f'Installing package {FONT_YELLOW}{requirement}{FONT_RESET}',
                 )
-                return False
+                if not utils.install_package(requirement):
+                    Logger.log(
+                        LOG_LEVEL["error"],
+                        f'Error installing <{extension.title()}> requirement: {FONT_YELLOW}{requirement}{FONT_RESET}'
+                    )
+                    return False
+                requirement_cache[requirement] = True
     # extension.requirements_installed = True
     cache[extension.namespace] = extension
     return cache[extension.namespace]

mudpi/managers/core_manager.py

@@ -147,6 +147,9 @@ def load_all_extensions(self, config=None):
         #  Import and setup the extensions
         self.load_extensions(extensions_to_load, config)
 
+        # Cache important data like requirements installed
+        self.mudpi.states.cache()
+
         return self.mudpi.extensions.all()
 
     def load_extensions(self, extensions, config):

mudpi/managers/state_manager.py

@@ -111,6 +111,16 @@ def restore_states(self):
                 _state = State.from_json(data)
                 self.states[key] = _state
 
+        # Restore requirement cache
+        _cache = self.redis.get('requirement_installed')
+        if _cache:
+            self.mudpi.cache['requirement_installed'] = json.loads(_cache)
+
+    def cache(self):
+        """ Cache some important states and data for MudPi """
+        if self.mudpi.cache.get('requirement_installed'):
+            self.redis.set('requirement_installed', json.dumps(self.mudpi.cache['requirement_installed']))
+
 
 class State():
     """