blob: 582d7386b9cc6a7b40ea9cb8a41f64461109d746 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
package org.eclipse.jetty.plugins.impl;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.List;
import org.eclipse.jetty.plugins.MavenService;
import org.eclipse.jetty.plugins.model.Plugin;
import org.eclipse.jetty.plugins.util.RepositoryParser;
import org.eclipse.jetty.plugins.util.StreamUtils;
public class HttpMavenServiceImpl implements MavenService {
private static final String REPOSITORY_URL = "http://repo2.maven.org/maven2/";
private static final String GROUP_ID = "org/eclipse/jetty";
private static final String VERSION = "7.6.0.v20120127"; // TODO: should be
// automatically
// set
private String _repositoryUrl = REPOSITORY_URL;
private String _groupId = GROUP_ID;
private String _version = VERSION;
public List<String> listAvailablePlugins() {
List<String> availablePlugins = new ArrayList<String>();
String moduleListing = fetchDirectoryListingOfJettyModules();
List<String> modules = RepositoryParser
.parseLinksInDirectoryListing(moduleListing);
for (String module : modules) {
String listing = fetchModuleDirectoryListing(module);
if (RepositoryParser.isModuleAPlugin(listing)) {
availablePlugins.add(module);
}
}
return availablePlugins;
}
private String fetchDirectoryListingOfJettyModules() {
try {
URL url = new URL(_repositoryUrl + _groupId);
URLConnection connection = url.openConnection();
InputStream inputStream = connection.getInputStream();
return StreamUtils.inputStreamToString(inputStream);
} catch (MalformedURLException e) {
throw new IllegalStateException(e);
} catch (IOException e) {
throw new IllegalStateException(e);
}
}
private String fetchModuleDirectoryListing(String module) {
try {
URL configJar = new URL(getModuleDirectory(module));
URLConnection connection = configJar.openConnection();
InputStream inputStream = connection.getInputStream();
return StreamUtils.inputStreamToString(inputStream);
} catch (MalformedURLException e) {
throw new IllegalStateException(e);
} catch (IOException e) {
// Honestly, I'm not a friend of ignoring exceptions as it might
// hide something important. In this case however it "usually"
// just means: THIS IS NOT A PLUGIN! However it still might hide
// things. If that'll be the case, I hope I'm not the one who
// has to debug my own code. ;)
return "not a plugin";
}
}
public Plugin getPlugin(String pluginName) {
File configJar = getFile(getModulePrefix(pluginName) + "-plugin.jar");
return new Plugin(pluginName, configJar);
}
private String getModuleDirectory(String pluginName) {
return _repositoryUrl + _groupId + "/" + pluginName + "/" + _version
+ "/";
}
private String getModulePrefix(String pluginName) {
return getModuleDirectory(pluginName) + pluginName + "-" + _version;
}
private File getFile(String urlString) {
String fileName = urlString.substring(urlString.lastIndexOf("/") + 1);
try {
URL url = new URL(urlString);
URLConnection connection = url.openConnection();
InputStream inputStream = connection.getInputStream();
File tempFile = new File(System.getProperty("java.io.tmpdir"),
fileName);
OutputStream out = new FileOutputStream(tempFile);
byte buf[] = new byte[1024];
int len;
while ((len = inputStream.read(buf)) > 0)
out.write(buf, 0, len);
out.close();
inputStream.close();
return tempFile;
} catch (MalformedURLException e) {
throw new IllegalStateException(e);
} catch (IOException e) {
throw new IllegalStateException(e);
}
}
public void setGroupId(String groupId) {
this._groupId = groupId.replace(".", "/");
}
public void setRepositoryUrl(String repositoryUrl) {
this._repositoryUrl = repositoryUrl;
}
public void setVersion(String version) {
this._version = version;
}
}
|
