1 |
|
|
2 |
|
|
3 |
|
|
4 |
|
|
5 |
|
|
6 |
|
|
7 |
|
|
8 |
|
|
9 |
|
|
10 |
|
|
11 |
|
|
12 |
|
|
13 |
|
|
14 |
|
|
15 |
|
|
16 |
|
|
17 |
|
|
18 |
|
|
19 |
|
|
20 |
|
package org.xwiki.extension.xar.internal.job; |
21 |
|
|
22 |
|
import java.util.Collection; |
23 |
|
import java.util.Collections; |
24 |
|
import java.util.Map; |
25 |
|
|
26 |
|
import javax.inject.Inject; |
27 |
|
import javax.inject.Named; |
28 |
|
|
29 |
|
import org.xwiki.component.annotation.Component; |
30 |
|
import org.xwiki.extension.Extension; |
31 |
|
import org.xwiki.extension.ExtensionDependency; |
32 |
|
import org.xwiki.extension.ExtensionId; |
33 |
|
import org.xwiki.extension.InstallException; |
34 |
|
import org.xwiki.extension.InstalledExtension; |
35 |
|
import org.xwiki.extension.LocalExtension; |
36 |
|
import org.xwiki.extension.ResolveException; |
37 |
|
import org.xwiki.extension.event.ExtensionInstalledEvent; |
38 |
|
import org.xwiki.extension.internal.ExtensionUtils; |
39 |
|
import org.xwiki.extension.job.InstallRequest; |
40 |
|
import org.xwiki.extension.job.internal.AbstractExtensionJob; |
41 |
|
import org.xwiki.extension.repository.CoreExtensionRepository; |
42 |
|
import org.xwiki.extension.repository.ExtensionRepositoryManager; |
43 |
|
import org.xwiki.extension.repository.InstalledExtensionRepository; |
44 |
|
import org.xwiki.extension.repository.LocalExtensionRepository; |
45 |
|
import org.xwiki.extension.repository.LocalExtensionRepositoryException; |
46 |
|
import org.xwiki.extension.xar.internal.handler.XarExtensionHandler; |
47 |
|
import org.xwiki.job.DefaultJobStatus; |
48 |
|
import org.xwiki.job.Request; |
49 |
|
import org.xwiki.logging.marker.BeginTranslationMarker; |
50 |
|
import org.xwiki.logging.marker.EndTranslationMarker; |
51 |
|
|
52 |
|
|
53 |
|
|
54 |
|
|
55 |
|
@version |
56 |
|
@since |
57 |
|
|
58 |
|
@Component |
59 |
|
@Named(RepairXarJob.JOBTYPE) |
|
|
| 83.6% |
Uncovered Elements: 18 (110) |
Complexity: 24 |
Complexity Density: 0.32 |
|
60 |
|
public class RepairXarJob extends AbstractExtensionJob<InstallRequest, DefaultJobStatus<InstallRequest>> |
61 |
|
{ |
62 |
|
|
63 |
|
|
64 |
|
|
65 |
|
public static final String JOBTYPE = "repairxar"; |
66 |
|
|
67 |
|
private static final BeginTranslationMarker LOG_REPAIR_BEGIN = |
68 |
|
new BeginTranslationMarker("extension.xar.log.repair.begin"); |
69 |
|
|
70 |
|
private static final BeginTranslationMarker LOG_REPAIR_NAMESPACE_BEGIN = |
71 |
|
new BeginTranslationMarker("extension.xar.log.repair.begin.namespace"); |
72 |
|
|
73 |
|
private static final EndTranslationMarker LOG_REPAIR_END = new EndTranslationMarker("extension.xar.log.repair.end"); |
74 |
|
|
75 |
|
private static final EndTranslationMarker LOG_REPAIR_END_NAMESPACE = |
76 |
|
new EndTranslationMarker("extension.xar.log.repair.end.namespace"); |
77 |
|
|
78 |
|
|
79 |
|
|
80 |
|
|
81 |
|
@Inject |
82 |
|
protected ExtensionRepositoryManager repositoryManager; |
83 |
|
|
84 |
|
|
85 |
|
|
86 |
|
|
87 |
|
@Inject |
88 |
|
private InstalledExtensionRepository installedRepository; |
89 |
|
|
90 |
|
|
91 |
|
|
92 |
|
|
93 |
|
@Inject |
94 |
|
private LocalExtensionRepository localRepository; |
95 |
|
|
96 |
|
@Inject |
97 |
|
private CoreExtensionRepository coreRepository; |
98 |
|
|
|
|
| 100% |
Uncovered Elements: 0 (1) |
Complexity: 1 |
Complexity Density: 1 |
|
99 |
15 |
@Override... |
100 |
|
public String getType() |
101 |
|
{ |
102 |
15 |
return JOBTYPE; |
103 |
|
} |
104 |
|
|
|
|
| 71.4% |
Uncovered Elements: 2 (7) |
Complexity: 2 |
Complexity Density: 0.4 |
|
105 |
3 |
@Override... |
106 |
|
protected InstallRequest castRequest(Request request) |
107 |
|
{ |
108 |
3 |
InstallRequest installRequest; |
109 |
3 |
if (request instanceof InstallRequest) { |
110 |
3 |
installRequest = (InstallRequest) request; |
111 |
|
} else { |
112 |
0 |
installRequest = new InstallRequest(request); |
113 |
|
} |
114 |
|
|
115 |
3 |
return installRequest; |
116 |
|
} |
117 |
|
|
|
|
| 100% |
Uncovered Elements: 0 (15) |
Complexity: 2 |
Complexity Density: 0.15 |
|
118 |
3 |
@Override... |
119 |
|
protected void runInternal() throws Exception |
120 |
|
{ |
121 |
3 |
this.progressManager.pushLevelProgress(getRequest().getExtensions().size(), this); |
122 |
|
|
123 |
3 |
try { |
124 |
3 |
for (ExtensionId extensionId : getRequest().getExtensions()) { |
125 |
3 |
this.progressManager.startStep(this); |
126 |
|
|
127 |
3 |
if (getRequest().getNamespaces() != null) { |
128 |
1 |
this.progressManager.pushLevelProgress(getRequest().getNamespaces().size(), this); |
129 |
|
|
130 |
1 |
try { |
131 |
1 |
for (String namespace : getRequest().getNamespaces()) { |
132 |
1 |
this.progressManager.startStep(this); |
133 |
|
|
134 |
1 |
repairExtension(extensionId, namespace, false, Collections.emptyMap()); |
135 |
|
} |
136 |
|
} finally { |
137 |
1 |
this.progressManager.popLevelProgress(this); |
138 |
|
} |
139 |
|
} else { |
140 |
2 |
repairExtension(extensionId, null, false, Collections.emptyMap()); |
141 |
|
} |
142 |
|
} |
143 |
|
} finally { |
144 |
3 |
this.progressManager.popLevelProgress(this); |
145 |
|
} |
146 |
|
} |
147 |
|
|
148 |
|
|
149 |
|
@param |
150 |
|
@return |
151 |
|
@throws |
152 |
|
|
|
|
| 66.7% |
Uncovered Elements: 7 (21) |
Complexity: 6 |
Complexity Density: 0.4 |
|
153 |
6 |
private LocalExtension getLocalXARExtension(ExtensionId extensionId) throws InstallException... |
154 |
|
{ |
155 |
6 |
LocalExtension localExtension = this.localRepository.getLocalExtension(extensionId); |
156 |
|
|
157 |
6 |
if (localExtension == null) { |
158 |
6 |
this.progressManager.pushLevelProgress(2, this); |
159 |
|
|
160 |
6 |
try { |
161 |
6 |
this.progressManager.startStep(this); |
162 |
|
|
163 |
6 |
Extension extension = this.repositoryManager.resolve(extensionId); |
164 |
|
|
165 |
5 |
this.progressManager.startStep(this); |
166 |
|
|
167 |
5 |
if (extension.getType().equals(XarExtensionHandler.TYPE)) { |
168 |
5 |
localExtension = this.localExtensionRepository.storeExtension(extension); |
169 |
|
} |
170 |
|
} catch (ResolveException e) { |
171 |
1 |
throw new InstallException("Failed to find extension", e); |
172 |
|
} catch (LocalExtensionRepositoryException e) { |
173 |
0 |
throw new InstallException("Failed save extension in local repository", e); |
174 |
|
} finally { |
175 |
6 |
this.progressManager.popLevelProgress(this); |
176 |
|
} |
177 |
0 |
} else if (!localExtension.getType().equals(XarExtensionHandler.TYPE)) { |
178 |
0 |
localExtension = null; |
179 |
|
} |
180 |
|
|
181 |
5 |
return localExtension; |
182 |
|
} |
183 |
|
|
184 |
|
|
185 |
|
@param |
186 |
|
@param |
187 |
|
@param |
188 |
|
@param |
189 |
|
@throws |
190 |
|
|
|
|
| 80.6% |
Uncovered Elements: 6 (31) |
Complexity: 7 |
Complexity Density: 0.37 |
|
191 |
6 |
private void repairExtension(ExtensionId extensionId, String namespace, boolean dependency,... |
192 |
|
Map<String, ExtensionDependency> managedDependencies) throws InstallException |
193 |
|
{ |
194 |
6 |
if (this.installedRepository.getInstalledExtension(extensionId.getId(), namespace) != null) { |
195 |
0 |
this.logger.debug("Extension [{}] already installed on namespace [{}]", extensionId.getId(), namespace); |
196 |
|
|
197 |
0 |
return; |
198 |
|
} |
199 |
|
|
200 |
6 |
if (getRequest().isVerbose()) { |
201 |
6 |
if (namespace != null) { |
202 |
2 |
this.logger.info(LOG_REPAIR_NAMESPACE_BEGIN, "Repairing XAR extension [{}] on namespace [{}]", |
203 |
|
extensionId, namespace); |
204 |
|
} else { |
205 |
4 |
this.logger.info(LOG_REPAIR_BEGIN, "Repairing XAR extension [{}] on all namespaces", extensionId, |
206 |
|
namespace); |
207 |
|
} |
208 |
|
} |
209 |
|
|
210 |
6 |
this.progressManager.pushLevelProgress(2, this); |
211 |
|
|
212 |
6 |
try { |
213 |
6 |
this.progressManager.startStep(this); |
214 |
|
|
215 |
6 |
LocalExtension localExtension = getLocalXARExtension(extensionId); |
216 |
|
|
217 |
5 |
this.progressManager.startStep(this); |
218 |
|
|
219 |
5 |
if (localExtension != null) { |
220 |
5 |
repairExtension(localExtension, namespace, dependency, managedDependencies); |
221 |
|
} |
222 |
|
} finally { |
223 |
6 |
if (getRequest().isVerbose()) { |
224 |
6 |
if (namespace != null) { |
225 |
2 |
this.logger.info(LOG_REPAIR_END_NAMESPACE, "Done repairing XAR extension [{}] on namespace [{}]", |
226 |
|
extensionId, namespace); |
227 |
|
} else { |
228 |
4 |
this.logger.info(LOG_REPAIR_END, "Done repairing XAR extension [{}] on all namespaces", extensionId, |
229 |
|
namespace); |
230 |
|
} |
231 |
|
} |
232 |
|
|
233 |
6 |
this.progressManager.popLevelProgress(this); |
234 |
|
} |
235 |
|
} |
236 |
|
|
237 |
|
|
238 |
|
@param |
239 |
|
@param |
240 |
|
@param |
241 |
|
@param |
242 |
|
@throws |
243 |
|
|
|
|
| 100% |
Uncovered Elements: 0 (18) |
Complexity: 2 |
Complexity Density: 0.12 |
|
244 |
5 |
private void repairExtension(LocalExtension localExtension, String namespace, boolean dependency,... |
245 |
|
Map<String, ExtensionDependency> managedDependencies) throws InstallException |
246 |
|
{ |
247 |
5 |
this.progressManager.pushLevelProgress(2, this); |
248 |
|
|
249 |
5 |
try { |
250 |
5 |
this.progressManager.startStep(this); |
251 |
|
|
252 |
5 |
Collection<? extends ExtensionDependency> dependencies = localExtension.getDependencies(); |
253 |
|
|
254 |
5 |
if (!dependencies.isEmpty()) { |
255 |
3 |
this.progressManager.pushLevelProgress(dependencies.size(), this); |
256 |
|
|
257 |
3 |
try { |
258 |
3 |
for (ExtensionDependency extensionDependency : dependencies) { |
259 |
3 |
this.progressManager.startStep(this); |
260 |
|
|
261 |
|
|
262 |
3 |
ExtensionDependency resolvedDependency = |
263 |
|
ExtensionUtils.getDependency(extensionDependency, managedDependencies, localExtension); |
264 |
|
|
265 |
3 |
repairDependency(resolvedDependency, namespace, |
266 |
|
ExtensionUtils.append(managedDependencies, localExtension)); |
267 |
|
} |
268 |
|
} finally { |
269 |
3 |
this.progressManager.popLevelProgress(this); |
270 |
|
} |
271 |
|
} |
272 |
|
|
273 |
5 |
this.progressManager.startStep(this); |
274 |
|
|
275 |
5 |
InstalledExtension installedExtension = |
276 |
|
this.installedRepository.installExtension(localExtension, namespace, dependency); |
277 |
|
|
278 |
5 |
this.observationManager.notify(new ExtensionInstalledEvent(installedExtension.getId(), namespace), |
279 |
|
installedExtension); |
280 |
|
} finally { |
281 |
5 |
this.progressManager.popLevelProgress(this); |
282 |
|
} |
283 |
|
} |
284 |
|
|
285 |
|
|
286 |
|
@param |
287 |
|
@param |
288 |
|
@param |
289 |
|
|
|
|
| 70% |
Uncovered Elements: 3 (10) |
Complexity: 4 |
Complexity Density: 0.67 |
|
290 |
3 |
private void repairDependency(ExtensionDependency extensionDependency, String namespace,... |
291 |
|
Map<String, ExtensionDependency> managedDependencies) |
292 |
|
{ |
293 |
|
|
294 |
3 |
if (this.coreRepository.getCoreExtension(extensionDependency.getId()) == null) { |
295 |
|
|
296 |
3 |
if (extensionDependency.getVersionConstraint().getVersion() == null) { |
297 |
0 |
this.logger.warn( |
298 |
|
"Can't repair extension dependency [{}] with version range ([{}])" |
299 |
|
+ " since there is no way to know what has been installed", |
300 |
|
extensionDependency.getId(), extensionDependency.getVersionConstraint()); |
301 |
|
|
302 |
|
} else { |
303 |
3 |
try { |
304 |
3 |
repairExtension( |
305 |
|
new ExtensionId(extensionDependency.getId(), |
306 |
|
extensionDependency.getVersionConstraint().getVersion()), |
307 |
|
namespace, true, managedDependencies); |
308 |
|
} catch (InstallException e) { |
309 |
1 |
this.logger.warn("Failed to repair dependency [{}]", extensionDependency, e); |
310 |
|
} |
311 |
|
} |
312 |
|
} |
313 |
|
} |
314 |
|
} |