1 | import syslog |
---|
2 | import gi |
---|
3 | gi.require_version('PackageKitGlib', '1.0') |
---|
4 | from gi.repository import PackageKitGlib as packagekit |
---|
5 | class 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.count=0 |
---|
16 | #def __init__ |
---|
17 | |
---|
18 | def set_debug(self,dbg='1'): |
---|
19 | self.dbg=int(dbg) |
---|
20 | self._debug ("Debug enabled") |
---|
21 | #def set_debug |
---|
22 | |
---|
23 | def _debug(self,msg=''): |
---|
24 | if self.dbg==1: |
---|
25 | print ('DEBUG Deb: '+msg) |
---|
26 | #def debug |
---|
27 | |
---|
28 | def _log(self,msg=None): |
---|
29 | if msg: |
---|
30 | syslog.openlog('lliurex-store') |
---|
31 | syslog.syslog(msg) |
---|
32 | |
---|
33 | def register(self): |
---|
34 | return(self.pluginInfo) |
---|
35 | #def register |
---|
36 | |
---|
37 | def execute_action(self,action,applist): |
---|
38 | self.installer=packagekit.Client() |
---|
39 | self.count=len(applist) |
---|
40 | #1.- If the app doesn't exist cancel the action |
---|
41 | for appInfo in applist: |
---|
42 | app=self._resolve_App(appInfo['package']) |
---|
43 | if app: |
---|
44 | if action=='install': |
---|
45 | self._install_App(app) |
---|
46 | 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'])) |
---|
50 | self._remove_App(app) |
---|
51 | # if action=='pkginfo' and self.count==1: |
---|
52 | if action=='pkginfo': |
---|
53 | self._get_App_Dependencies(appInfo,app) |
---|
54 | # if action=='pkginfo': |
---|
55 | # self._get_App_Info(appInfo,app,count) |
---|
56 | self.progress=self.progress+(self.partialProgress/self.count) |
---|
57 | self._debug("Progress: "+str(self.progress)) |
---|
58 | self.progress=100 |
---|
59 | return(self.result) |
---|
60 | |
---|
61 | def _callback(self,status,typ,data=None): |
---|
62 | self.partialProgress=status.get_property('percentage') |
---|
63 | self.progress=self.partialProgress/self.count |
---|
64 | self._debug("Progress"+str(self.partialProgress)) |
---|
65 | |
---|
66 | def initialize_list(self): |
---|
67 | self.pkgList=[] |
---|
68 | #def initialize_list |
---|
69 | |
---|
70 | def _install_App(self,app): |
---|
71 | self.return_msg=False |
---|
72 | self._debug("Installing "+app.get_id()) |
---|
73 | try: |
---|
74 | self.installer.install_packages(False,[app.get_id(),],None,self._callback,None) |
---|
75 | self.result.append({app.get_id():" installed succesfully"}) |
---|
76 | except Exception as e: |
---|
77 | self._debug(e.message) |
---|
78 | self.result.append({app.get_id():e.message}) |
---|
79 | self.partialProgress=100 |
---|
80 | #def _install_App_from_Repo |
---|
81 | |
---|
82 | def _remove_App(self,app): |
---|
83 | try: |
---|
84 | self.installer.remove_packages(False,[app.get_id(),],True,False,None,self._callback,None) |
---|
85 | self.result.append({app.get_id():" removed succesfully"}) |
---|
86 | except Exception as e: |
---|
87 | self._debug(e.message) |
---|
88 | self.result.append({app.get_id():e.message}) |
---|
89 | self.partialProgress=100 |
---|
90 | #def _remove_App |
---|
91 | |
---|
92 | def _get_App_Dependencies(self,appInfo,app): |
---|
93 | self._debug("Getting dependencies for "+app.get_id()) |
---|
94 | pkTask=packagekit.Task() |
---|
95 | results=[] |
---|
96 | dependsList=[] |
---|
97 | try: |
---|
98 | results=pkTask.get_depends(1,[app.get_id(),],True,None,self._callback,None) |
---|
99 | except: |
---|
100 | pass |
---|
101 | if (results): |
---|
102 | for app in results.get_package_array(): |
---|
103 | dependsList.append(app.get_id()) |
---|
104 | appInfo['depends']=dependsList |
---|
105 | # return(dependsList) |
---|
106 | return(appInfo) |
---|
107 | |
---|
108 | def _get_App_Info(self,appInfo,app,appsCount=0): |
---|
109 | info=app.get_info() |
---|
110 | appInfo['status']=info.to_string(info) |
---|
111 | self._debug("Status: "+appInfo['status']) |
---|
112 | #Only search dependencies if there's only one package on the package queue |
---|
113 | if appsCount==1: |
---|
114 | self._debug("loading depends") |
---|
115 | appInfo['depends']=self._get_App_Dependencies(appInfo,app) |
---|
116 | self.partialProgress=100 |
---|
117 | self.result.append(appInfo) |
---|
118 | return(appInfo) |
---|
119 | |
---|
120 | def _resolve_App(self,appName,filters=False): |
---|
121 | self._debug("Resolving "+appName) |
---|
122 | app=None |
---|
123 | applist=[] |
---|
124 | self.return_msg=False |
---|
125 | try: |
---|
126 | result=self.installer.resolve(1,[appName,],None,self._callback, None) |
---|
127 | applist=result.get_package_array() |
---|
128 | if applist: |
---|
129 | self._debug("Application "+applist[0].get_name()+" resolved succesfully") |
---|
130 | app=applist[0] |
---|
131 | except Exception as e: |
---|
132 | self._debug("Couldn't resolve "+appName) |
---|
133 | self._debug("Reason: "+str(e)) |
---|
134 | self.partialProgress=100 |
---|
135 | return(app) |
---|
136 | #def _resolve_App |
---|
137 | |
---|
138 | |
---|