source: lliurex-store/trunk/fuentes/python3-lliurex-store.install/usr/share/lliurexstore/plugins/debManager.py @ 4920

Last change on this file since 4920 was 4920, checked in by Juanma, 4 years ago

Deactivated errors on packagekit queries
File size: 5.4 KB
Line 
1import syslog
2import gi
3gi.require_version('PackageKitGlib', '1.0')
4from gi.repository import PackageKitGlib as packagekit
5class debmanager:
6        def __init__(self):
7                self.installer=''
8                self.dbg=0
9                self.pkgList=[]
10                self.result=[]
11                self.progress=0
12                self.partialProgress=0
13                #self.pluginInfo=['install','deb','remove','deb','pkginfo','deb','remove','zmd']
14                self.pluginInfo={'install':'deb','remove':'deb','pkginfo':'deb'}
15                self.result={}
16                self.result['data']={}
17                self.result['status']={}
18                self.count=0
19        #def __init__
20
21        def set_debug(self,dbg='1'):
22                self.dbg=int(dbg)
23                self._debug ("Debug enabled")
24        #def set_debug
25
26        def _debug(self,msg=''):
27                if self.dbg==1:
28                        print ('DEBUG Deb: '+str(msg))
29        #def debug
30
31        def _log(self,msg=None):
32                if msg:
33                        syslog.openlog('lliurex-store')
34                        syslog.syslog(msg)
35
36        def register(self):
37                return(self.pluginInfo)
38        #def register
39
40        def execute_action(self,action,applist):
41                self.progress=0
42                self.installer=packagekit.Client()
43                self.count=len(applist)
44                self.result['status']={'status':-1,'msg':''}
45                self.result['data']=[]
46                processedPkg=[]
47                #1.- If the app doesn't exist cancel the action
48                for appInfo in applist:
49                        if appInfo['package'] not in processedPkg:
50                                processedPkg.append(appInfo['package'])
51                                filters=1
52                                if action=='remove':
53                                        filters=2
54                                app=self._resolve_App(appInfo['package'],filters)
55                                if app:
56                                        if action=='install':
57                                                self._log("Installing "+appInfo['package'])
58                                                self._install_App(app)
59                                                self.result['data'].append({'package':appInfo['package']})
60                                        if action=='remove':
61                                                self._log("Removing "+appInfo['package'])
62                                                self._remove_App(app)
63                                                self.result['data'].append({'package':appInfo['package']})
64                                        if action=='pkginfo':
65                                                self.result['data'].append(self._get_App_Extended_Info(appInfo,app))
66                                self.progress=self.progress+(self.partialProgress/self.count)
67                self.progress=100
68                return(self.result)
69        #def execute_action
70
71        def _set_status(self,status,msg=''):
72                self.result['status']={'status':status,'msg':msg}
73
74        def _fake_callback(self,status,typ,data=None):
75                pass
76        #def _fake_callback
77
78        def _callback(self,status,typ,data=None):
79                self.partialProgress=status.props.percentage
80                self.progress=self.partialProgress/self.count
81        #def _callback
82
83        def _install_App(self,app):
84                self.return_msg=False
85                self._debug("Installing "+app.get_id())
86                err=0
87                try:
88                        self.installer.install_packages(True,[app.get_id(),],None,self._callback,None)
89                        err=0
90                except Exception as e:
91                        print(str(e))
92                        self._debug("Install error: "+str(e.code))
93                        err=e.code
94                finally:
95                        self.partialProgress=100
96                self._set_status(err)
97                return err
98        #def _install_App_from_Repo
99                       
100        def _remove_App(self,app):
101                try:
102                        self.installer.remove_packages(True,[app.get_id(),],True,False,None,self._callback,None)
103                        self._set_status(0)
104                except Exception as e:
105                        self._debug("Remove error: " +str(e.code))
106                        self._debug("Remove error: " +str(e))
107                        self._set_status(e.code)
108                finally:
109                        self.partialProgress=100
110        #def _remove_App
111
112        def _get_App_Extended_Info(self,appInfo,app):
113                self._debug("Getting dependencies for "+app.get_id())
114                pkTask=packagekit.Task()
115                results=[]
116                dependsList=[]
117                self._set_status(0)
118                try:
119                        results=pkTask.get_depends(1,[app.get_id(),],True,None,self._fake_callback,None)
120                except Exception as e:
121#                       self._set_status(1)
122                        print (str(e))
123                        pass
124                if (results):
125                        appID=app.get_id()
126                        appInfo['version']=app.get_version()
127                        appInfo['arch']=appID.split(';')[2]
128                        for related_app in results.get_package_array():
129                                dependsList.append(related_app.get_id())
130                        appInfo['depends']=dependsList
131                        #app.get_version()
132                try:
133                        results=pkTask.get_details([app.get_id(),],None,self._fake_callback,None)
134                except Exception as e:
135#                       self._set_status(1)
136                        print (str(e))
137                        pass
138                if(results):
139                        for app_detail in results.get_details_array():
140                                appInfo['size']=str(app_detail.get_size())
141                                break
142                               
143                return(appInfo)
144        #def _get_App_Extended_Info
145
146        def _get_App_Info(self,appInfo,app,appsCount=0): #DEPRECATED
147                try:
148                        info=app.get_info()
149                        appInfo['status']=info.to_string(info)
150                        self._debug("Status: "+appInfo['status'])
151                except:
152                        self._debug("Status: not available")
153                        pass
154                #Only search dependencies if there's only one package on the package queue
155                if appsCount==1:
156                        self._debug("loading extended info")
157                        appInfo=self._get_App_Extended_Info(appInfo,app)
158                self.partialProgress=100
159                self.result.append(appInfo)
160#               self.result['data'].update({appInfo['package']:appInfo})
161                self._set_status(0)
162                return(appInfo)
163        #def _get_App_Info
164
165        def _resolve_App(self,appName,filters=False):
166                self._debug("Resolving "+appName)
167                app=None
168                applist=[]
169                self.return_msg=False
170                if not filters:
171                        filters=1
172                try:
173                        self._debug("Filter for resolver: "+str(filters))
174                        result=self.installer.resolve(filters,[appName,],None,self._fake_callback, None)
175                        applist=result.get_package_array()
176                        resolvedApp=applist[0]
177                        #resolver bug: filters not work so if we want to remove an app first we must get the installed version...
178                        if filters==2:
179                                for app in applist:
180                                        if (str(app.get_info()).find('PK_INFO_ENUM_INSTALLED')!=-1):
181                                                resolvedApp=app
182                        if resolvedApp:
183                                self._debug("Application "+resolvedApp.get_name()+" resolved succesfully")
184                                app=resolvedApp
185                except Exception as e:
186                        self._debug("Couldn't resolve "+appName)
187                        self._debug("Reason: "+str(e))
188                finally:
189                        self.partialProgress=100
190                return(app)
191        #def _resolve_App
192       
Note: See TracBrowser for help on using the repository browser.