Changeset 3646 for lliurex-store/trunk/fuentes/python3-lliurex-store.install/usr/share/lliurexstore/storeManager.py

Timestamp:

Feb 15, 2017, 6:27:03 PM (4 years ago)

Author:

Juanma

Message:

WIP on CLI

File:

• lliurex-store/trunk/fuentes/python3-lliurex-store.install/usr/share/lliurexstore/storeManager.py (modified) (5 diffs)

lliurex-store/trunk/fuentes/python3-lliurex-store.install/usr/share/lliurexstore/storeManager.py

@@ -27 +27 @@
                                         }
                 self.dbg=0
+                if args:
+                        self.dbg=args
                 self.threads={}                         #Dict that stores the functions that must execute each action
                 self.threadsProgress={}                 #"" "" "" the progress for each launched thread
                 self.threadsRunning={}                  #"" "" "" the running threads
-                self._define_functions_for_threads()    #Function that loads the dictionary self.threads
                 self.registeredPlugins={}               #Dict that have the relation between plugins and actions 
                 self.registerProcessProgress={}         #Dict that stores the progress for each function/parentAction pair
-                self.__init_plugins__()                 #Function that loads the plugins
                 self.progressActions={}                 #Progress of global actions based on average progress of individual processes
                 self.result={}                          #Result of the actions
-                self.execute_action('load')             #Function that launches the actions
                 self.lock=threading.Lock()              #locker for functions related to threads (get_progress, is_action_running...)
-#               self.log
+                self.main()
         #def __init__
+
+        def main(self):
+                self._define_functions_for_threads()    #Function that loads the dictionary self.threads
+                self.__init_plugins__()                 #Function that loads the plugins
+                self.execute_action('load')             #Initial load of the store
+        #def main
 
         ####
@@ -148 +153 @@
                 if action in self.registeredPlugins:
                         self._debug("Plugin for "+action+": "+self.registeredPlugins[action][parms])
-#                       exeFunction=eval(self.pluginMod+'.'+self.registeredPlugins[action][parms]+"()")
                         exeFunction=eval(self.registeredPlugins[action][parms]+"()")
+                        if self.dbg:
+                                exeFunction.set_debug(1)
                         self._registerProcessProgress(action,exeFunction,launchedby)
                 else:
@@ -211 +217 @@
         def _registerProcessProgress(self,action,function,parentAction=None):
                 if action in self.registerProcessProgress.keys():
-                        self._debug("Appended process for action :"+action +" and function: "+str(function))
+                        self._debug("Appended process for action: "+action +" and function: "+str(function))
                         self.registerProcessProgress[action].append(function)
                 else:
-                        self._debug("Registered process for action :"+action+" and function: "+str(function))
+                        self._debug("Registered process for action: "+action+" and function: "+str(function))
                         self.registerProcessProgress[action]=[function]
                 if parentAction:
@@ -370 +376 @@
                 if action=='list_sections':
                         searchItem=''
-                if (searchItem in self.registeredPlugins[action]):
-                        self._debug("Plugin for search "+ searchItem +": "+self.registeredPlugins[action][searchItem])
-                        finder=self.registeredPlugins[action][searchItem]
-                else:
-                        self._debug("Plugin for generic search: "+self.registeredPlugins[action]['*'])
-                        finder=self.registeredPlugins[action][('*')]
-                searchFunction=eval(finder+"()")
                 if not launchedby:
                         launchedby=action
-                self._registerProcessProgress(action,searchFunction,launchedby)
+
+                searchFunction=self._execute_class_method(action,'*',launchedby)
                 aux_applist=searchFunction.execute_action(self.store,action,searchItem)
-                #1.- Get appstream metadata (faster)
-                partialAction='info'
-                applist=self._get_App_Info(aux_applist,launchedby)
-                self._debug("Add result for "+partialAction)
-                self.result[partialAction]=applist
-                #2.- Get rest of metadata (slower)
-                partialAction='pkginfo'
-                applist=self._get_Extended_App_Info(applist,launchedby,fullsearch)
-                realAction=action
-                if launchedby:
-                        realAction=launchedby
-                        self._debug("Assigned results of "+action+" to "+realAction)
-                if (len(applist)):
-                        self.result[realAction]=applist
-                        return_msg=True
-                else:
-                        notfound=''
-                        for item in searchItem:
-                                notfound=' '.join(searchItem)
-                        self.result[realAction]=[{notfound:" not found"}]
+                if len(aux_applist):
+                        #1.- Get appstream metadata (faster)
+                        partialAction='info'
+                        applist=self._get_App_Info(aux_applist,launchedby)
+                        self._debug("Add result for "+partialAction)
+                        self.result[partialAction]=applist
+                        #2.- Get rest of metadata (slower)
+                        partialAction='pkginfo'
+                        applist=self._get_Extended_App_Info(applist,launchedby,fullsearch)
+                        realAction=action
+                        if launchedby:
+                                realAction=launchedby
+                                self._debug("Assigned results of "+action+" to "+realAction)
+                        if (len(applist)):
+                                self.result[realAction]=applist
+                                return_msg=True
+                        else:
+                                notfound=''
+                                self.result[realAction]=[{searchItem:2}]
+                                return_msg=False
+                else:
+                        self.result[launchedby]=[{searchItem:1}]
                         return_msg=False
                 return(return_msg)
@@ -424 +426 @@
                                 if (action=='install' and appInfo['status']=='installed') or (action=='remove' and appInfo['status']=='available'):
                                         if action=='remove':
-                                                self.result[action]=[{appInfo['package']:"Package not installed"}]
+                                                self.result[action]=[{appInfo['package']:3}]
                                         else:
-                                                self.result[action]=[{appInfo['package']:"Package already installed"}]
+                                                self.result[action]=[{appInfo['package']:4}]
                                         return_msg=False
                                         typeDict={}