Compare commits
2 Commits
3dc9b97d1e
...
678c2874a2
| Author | SHA1 | Date |
|---|---|---|
 Flavien
|
678c2874a2 | 1 year ago |
|
Flavien
|
166669c287 | 1 year ago |
@ -0,0 +1,63 @@
|
||||
package fr.sixthemes.beans;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
public class CTConf {
|
||||
|
||||
protected SysConf systemConfiguration;
|
||||
protected NetConf inet4Configuration;
|
||||
protected NetConf6 inet6Configuration;
|
||||
|
||||
|
||||
public CTConf() {
|
||||
this.systemConfiguration = new SysConf();
|
||||
this.inet4Configuration = new NetConf();
|
||||
this.inet6Configuration = new NetConf6();
|
||||
}
|
||||
|
||||
public CTConf(SysConf system, NetConf inet4, NetConf6 inet6) {
|
||||
this.systemConfiguration = system;
|
||||
this.inet4Configuration = inet4;
|
||||
this.inet6Configuration = inet6;
|
||||
}
|
||||
|
||||
public Map<String, String> getParameters() {
|
||||
Map<String, String> parameters = new HashMap<>();
|
||||
|
||||
parameters.put("unprivileged", "1");
|
||||
parameters.put("features", "nesting=1");
|
||||
// TODO : Remove hardcoded password
|
||||
parameters.put("password", "12345");
|
||||
|
||||
parameters.putAll(systemConfiguration.getParameters());
|
||||
parameters.putAll(inet4Configuration.getParameters());
|
||||
|
||||
return parameters;
|
||||
}
|
||||
|
||||
public SysConf getSystemConfiguration() {
|
||||
return this.systemConfiguration;
|
||||
}
|
||||
|
||||
public NetConf getInet4Configuration() {
|
||||
return this.inet4Configuration;
|
||||
}
|
||||
|
||||
public NetConf6 getInet6Configuration() {
|
||||
return this.inet6Configuration;
|
||||
}
|
||||
|
||||
public void setSystemConfiguration(SysConf systemConfiguration) {
|
||||
this.systemConfiguration = systemConfiguration;
|
||||
}
|
||||
|
||||
public void setInet4Configuration(NetConf inet4Configuration) {
|
||||
this.inet4Configuration = inet4Configuration;
|
||||
}
|
||||
|
||||
public void setInet6Configuration(NetConf6 inet6Configuration) {
|
||||
this.inet6Configuration = inet6Configuration;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,66 @@
|
||||
package fr.sixthemes.beans;
|
||||
|
||||
import java.io.UnsupportedEncodingException;
|
||||
import java.net.URI;
|
||||
import java.net.URLEncoder;
|
||||
import java.net.http.HttpClient;
|
||||
import java.net.http.HttpRequest;
|
||||
import java.net.http.HttpResponse;
|
||||
import java.util.Map;
|
||||
|
||||
public class CTCreationRequest {
|
||||
|
||||
protected String targetClusterURL;
|
||||
protected String apiID;
|
||||
protected String apiKey;
|
||||
|
||||
public CTCreationRequest() {
|
||||
// TODO : Get default credentials from user session or docker env
|
||||
this.targetClusterURL = "https://example.com";
|
||||
}
|
||||
|
||||
public CTCreationRequest(String targetClusterURL, String apiID, String apiKey) {
|
||||
this.targetClusterURL = targetClusterURL;
|
||||
this.apiID = apiID;
|
||||
this.apiKey = apiKey;
|
||||
}
|
||||
|
||||
public String sendRequest(CTConf ctConfiguration) {
|
||||
|
||||
try {
|
||||
String postData = this.getPostDataFor(ctConfiguration);
|
||||
// TODO : remove hardcoded parameters
|
||||
postData += "&ostemplate=local%3Avztmpl%2Fdebian-11-standard_11.6-1_amd64.tar.zst&vmid=8000";
|
||||
|
||||
HttpRequest request = HttpRequest.newBuilder()
|
||||
.uri(URI.create(this.targetClusterURL + "?" + postData))
|
||||
.header("Authorization", "PVEAPIToken=" + this.apiID + "=" + this.apiKey)
|
||||
.method("POST", HttpRequest.BodyPublishers.noBody())
|
||||
.build();
|
||||
HttpResponse<String> response = HttpClient.newHttpClient().send(request, HttpResponse.BodyHandlers.ofString());
|
||||
return response.body();
|
||||
}
|
||||
catch(Exception e) {
|
||||
return e.getStackTrace().toString();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public String getPostDataFor(CTConf conf) throws UnsupportedEncodingException {
|
||||
|
||||
StringBuilder builder = new StringBuilder();
|
||||
|
||||
for (Map.Entry<String, String> entry : conf.getParameters().entrySet()) {
|
||||
builder.append(URLEncoder.encode(entry.getKey(), "UTF-8"));
|
||||
builder.append("=");
|
||||
builder.append(URLEncoder.encode(entry.getValue(), "UTF-8"));
|
||||
builder.append("&");
|
||||
}
|
||||
|
||||
String resultString = builder.toString();
|
||||
return resultString.length() > 0
|
||||
? resultString.substring(0, resultString.length() - 1)
|
||||
: resultString;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,40 @@
|
||||
package fr.sixthemes.servlets;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.PrintWriter;
|
||||
|
||||
import javax.servlet.ServletException;
|
||||
import javax.servlet.annotation.WebServlet;
|
||||
import javax.servlet.http.HttpServlet;
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
|
||||
import fr.sixthemes.beans.CTConf;
|
||||
import fr.sixthemes.beans.CTCreationRequest;
|
||||
|
||||
@WebServlet(urlPatterns = "/process")
|
||||
public class RequestProcessor extends HttpServlet {
|
||||
|
||||
@Override
|
||||
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
|
||||
CTConf conf = (CTConf) req.getSession().getAttribute("conf");
|
||||
|
||||
String targetUrl = req.getParameter("target");
|
||||
String tokenID = req.getParameter("tokenid");
|
||||
String tokenKey = req.getParameter("tokenkey");
|
||||
|
||||
CTCreationRequest request = new CTCreationRequest(targetUrl, tokenID, tokenKey);
|
||||
|
||||
String response = request.sendRequest(conf);
|
||||
|
||||
PrintWriter out = resp.getWriter();
|
||||
|
||||
out.println(response);
|
||||
// out.println(request.getPostDataFor(conf));
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue