Changeset 3105


Ignore:
Timestamp:
Dec 19, 2016, 2:49:33 PM (2 years ago)
Author:
Juanma
Message:

wip on syslog

Location:
lliurex-store/trunk/fuentes/lliurex-appstore.install/usr/bin
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • lliurex-store/trunk/fuentes/lliurex-appstore.install/usr/bin/plugins/debManager.py

    r3099 r3105  
     1import syslog
    12import gi
    23gi.require_version('PackageKitGlib', '1.0')
     
    2526        #def debug
    2627
     28        def _log(self,msg=None):
     29                if msg:
     30                        syslog.openlog('lliurex-store')
     31                        syslog.syslog(msg)
     32
    2733        def register(self):
    2834                return(self.pluginInfo)
     
    3945                                        self._install_App(app)
    4046                                if action=='remove':
     47                                        self._log("Removing "+appInfo['package'])
     48                                        self._get_App_Dependencies(appInfo,app)
     49                                        self._log("Dependencies to remove"+str(appInfo['depends']))
    4150                                        self._remove_App(app)
    42                                 if action=='pkginfo' and self.count==1:
     51#                               if action=='pkginfo' and self.count==1:
     52                                if action=='pkginfo':
    4353                                        self._get_App_Dependencies(appInfo,app)
    4454#                               if action=='pkginfo':
     
    7282        def _remove_App(self,app):
    7383                try:
    74                         self.installer.remove_packages(False,[app.get_id(),],True,True,None,self._callback,None)
     84                        self.installer.remove_packages(False,[app.get_id(),],True,False,None,self._callback,None)
    7585                        self.result.append({app.get_id():" removed succesfully"})
    7686                except Exception as e:
  • lliurex-store/trunk/fuentes/lliurex-appstore.install/usr/bin/plugins/loadStore.py

    r3099 r3105  
    2727        #def register
    2828
    29         def execute_action(self,action,store):
     29        def execute_action(self,action):
     30                self.store=appstream.Store()
    3031                if action=='load':
    31                         self.load_store(store)
     32                        self.load_store(self.store)
    3233                self.progress=100
    3334                return (self.store)
  • lliurex-store/trunk/fuentes/lliurex-appstore.install/usr/bin/storeManager.py

    r3099 r3105  
     1#!/usr/bin/python3
    12import sys
    2 import gi
    3 import locale
    43import os
    5 import time
    6 gi.require_version('AppStreamGlib', '1.0')
    7 from gi.repository import AppStreamGlib as appstream
    8 from gi.repository import Gio
    94import threading
    10 import plugins
    11 
     5import syslog
     6#Load the plugin dir
     7pluginDir=os.getcwd()+'/plugins' #Path to the dir that stores the plugins
     8oldpwd=os.getcwd()
     9os.chdir(pluginDir)
     10exec ('import ' + os.path.basename(pluginDir))          #DON'T CHANGE!!!
     11os.chdir(oldpwd)
     12del (oldpwd)
     13del (pluginDir)
    1214######
    1315#Ver. 1.0 of storeManager.py
     
    2022class StoreManager:
    2123        def __init__(self,args=()):
    22                 self.store=appstream.Store()
     24                #               self.store=appstream.Store()
     25                self.store=None
    2326                self.relatedActions={
    2427                                        'load':['load'],
     
    2932                                        'remove':['search','info','pkginfo','remove']
    3033                                        }
    31                 if locale.getdefaultlocale()[0]=="es_ES":
    32                         self.locale=['es_ES','es','ca@valencia','ca','ca_ES','C']
    33                 else:
    34                         self.locale=[locale.getlocale()[0],'ca@valencia','ca','es','es_ES','C']
    35                 self.dbg=1
     34                self.dbg=0
    3635                self.threads={}                         #Dict that stores the functions that must execute each action
    3736                self.threadsProgress={}                 #"" "" "" the progress for each launched thread
    3837                self.threadsRunning={}                  #"" "" "" the running threads
    3938                self._define_functions_for_threads()    #Function that loads the dictionary self.threads
    40                 self.pluginDir=os.getcwd()+'/plugins'           #Path to the dir that stores the plugins
     39                self.pluginDir=os.getcwd()+'/plugins' #Path to the dir that stores the plugins
    4140                self.pluginMod=os.path.basename(self.pluginDir) #DON'T CHANGE!!!       
    42                 oldpwd=os.getcwd()
    43                 os.chdir(self.pluginDir)
    44                 exec ('import ' + self.pluginMod)               #DON'T CHANGE!!!
    45                 os.chdir(oldpwd)
    4641                self.registeredPlugins={}               #Dict that have the relation between plugins and actions
    4742                self.registerProcessProgress={}         #Dict that stores the progress for each function/parentAction pair
     
    5146                self.execute_action('load')             #Function that launches the actions
    5247                self.lock=threading.Lock()              #locker for functions related to threads (get_progress, is_action_running...)
     48#               self.log
    5349        #def __init__
    5450
     
    5955                os.chdir(self.pluginDir)
    6056                for mod in os.listdir():
    61                         if not  mod.startswith('_'):
     57                        if not mod.startswith('_'):
    6258                                modName=mod.split('.')[0]
    6359                                strImport='from plugins.'+modName+' import *'
     
    9692        #def _debug
    9793
     94        def _log(self,msg=None):
     95                if msg:
     96                        syslog.openlog('lliurex-store')
     97                        syslog.syslog(msg)
    9898        ####
    9999        #dict of actions/related functions for threading
     
    121121                        self._join_action('load')
    122122                if action in self.threads.keys():
    123 #                       self.action=action
    124123                        if self.is_action_running(action):
    125124                                #join thread if we're performing the same action
     
    154153                        parms="*"
    155154                self._debug("Plugin for "+action+": "+self.registeredPlugins[action][parms])
    156 #               exeFunction=eval(self.pluginDir+'.'+self.registeredPlugins[action][parms]+"()")
    157155                exeFunction=eval(self.pluginMod+'.'+self.registeredPlugins[action][parms]+"()")
    158 #               exeFunction=exec(self.pluginMod+'.'+self.registeredPlugins[action][parms]+"()")
    159156                self._registerProcessProgress(action,exeFunction,launchedby)
    160157                return (exeFunction)
     
    221218                        self.registerProcessProgress[action]=[function]
    222219                if parentAction:
    223                         self._debug("Registered process for Parent Action :"+action+"-"+parentAction+" and function: "+str(function))
     220                        self._debug("Registered process for Parent Action: "+action+"-"+parentAction+" and function: "+str(function))
    224221                        if parentAction in self.threadsProgress.keys():
    225222                                self.threadsProgress[parentAction].update({action:function})
     
    227224                                self.threadsProgress[parentAction]={action:function}
    228225        #def _registerProcessProgress
    229 
    230226
    231227        ####
     
    300296                action='load'
    301297                loadFunction=self._execute_class_method(action)
    302                 self.store=loadFunction.execute_action(action,self.store)
     298                self.store=loadFunction.execute_action(action)
    303299        #def _load_Store
    304300
     
    426422        def _install_remove_App(self,appName,action='install',launchedby=None):
    427423                self._debug("Attempting to "+action +" "+appName)
     424                self._log("Attempting to "+action +" "+appName)
    428425                result={}
    429426                return_msg=False
     
    456453                                        return_msg=True
    457454
     455                self._log("Result "+action +": "+str(self.result[action]))
    458456                return(return_msg)
    459457        #def install_App
     
    462460        #Check the package type
    463461        #Input:
    464         # - AppInfo dict (element of list returned by _get_app_info)
     462        # - AppInfo dict (element of the list returned by _get_app_info)
    465463        #Output:
    466464        # - String with the type (deb, sh, zmd...)
Note: See TracChangeset for help on using the changeset viewer.