Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Refreshed Code #5

Open
wants to merge 8 commits into
base: master
Choose a base branch
from
Open

Refreshed Code #5

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
fd54a80
Use enumerated endpoints for API
Flo354 Jan 4, 2018
1dfc6b4
Use enumerated endpoints for API
Flo354 Jan 4, 2018
094ec18
Reworked constructor
Flo354 Jan 4, 2018
0e4b97f
Moved sha1 hash to Utils
Flo354 Jan 4, 2018
0487765
Removed endpoint parameter and reworked call method
Flo354 Jan 4, 2018
07d232c
Fixed typos
Flo354 Jan 4, 2018
8417dc7
Call to generate a consumer key
Flo354 Jan 4, 2018
05ffac6
Fix test
Flo354 Jan 4, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
299 changes: 146 additions & 153 deletions src/main/java/com/ovh/api/OvhApi.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,8 @@
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.HashMap;
import java.util.Map;
Expand All @@ -26,212 +24,207 @@
*/
public class OvhApi {

private final String endpoint;
private final OvhApiEndpoints endpoint;
private final String appKey;
private final String appSecret;
private final String consumerKey;

private final static Map<String, String> endpoints;

static {
endpoints = new HashMap<>();
endpoints.put("ovh-eu", "https://eu.api.ovh.com/1.0");
endpoints.put("ovh-ca", "https://ca.api.ovh.com/1.0");
endpoints.put("kimsufi-eu", "https://eu.api.kimsufi.com/1.0");
endpoints.put("kimsufi-ca", "https://ca.api.kimsufi.com/1.0");
endpoints.put("soyoustart-eu", "https://eu.api.soyoustart.com/1.0");
endpoints.put("soyoustart-ca", "https://ca.api.soyoustart.com/1.0");
endpoints.put("runabove", "https://api.runabove.com/1.0");
endpoints.put("runabove-ca", "https://api.runabove.com/1.0");
}


public OvhApi() throws OvhApiException {
super();

Map<String, String> env = System.getenv();
if(env.containsKey("OVH_ENDPOINT") && env.containsKey("OVH_APPLICATION_KEY") && env.containsKey("OVH_APPLICATION_SECRET") && env.containsKey("OVH_CONSUMER_KEY")) {
endpoint = System.getenv("OVH_ENDPOINT");
if (env.containsKey("OVH_ENDPOINT") && env.containsKey("OVH_APPLICATION_KEY") && env.containsKey("OVH_APPLICATION_SECRET") && env.containsKey("OVH_CONSUMER_KEY")) {
endpoint = OvhApiEndpoints.fromString(System.getenv("OVH_ENDPOINT"));
appKey = System.getenv("OVH_APPLICATION_KEY");
appSecret = System.getenv("OVH_APPLICATION_SECRET");
consumerKey = System.getenv("OVH_CONSUMER_KEY");
} else {
// find the config file
File configFile = new File("ovh.conf");
if(!configFile.exists()) {
String userHomePath = System.getProperty("user.home");
configFile = new File(userHomePath+"/ovh.conf");
if(!configFile.exists()) {
configFile = new File("/etc/ovh.conf");
}
}

if(configFile.exists()) {
try {
// read the configuration file
Properties config = new Properties();
config.load(new FileInputStream(configFile));

// get the values
endpoint = config.getProperty("endpoint", null);
appKey = config.getProperty("application_key", null);
appSecret = config.getProperty("application_secret", null);
consumerKey = config.getProperty("consumer_key", null);

} catch (Exception e) {
throw new OvhApiException(e.getMessage(), OvhApiExceptionCause.CONFIG_ERROR);
}
} else {
throw new OvhApiException("environnment variables OVH_ENDPOINT, OVH_APPLICATION_KEY, OVH_APPLICATION_SECRET, OVH_CONSUMER_KEY or configuration files ./ovh.conf, ~/ovh.conf, /etc/ovh.conf were not found", OvhApiExceptionCause.CONFIG_ERROR);
}

assertAllConfigNotNull();
return;
}

// find the config file
File configFile = Utils.getConfigFile("ovh.conf", System.getProperty("user.home") + "/ovh.conf", "/etc/ovh.conf");
if (configFile == null) {
throw new OvhApiException("environment variables OVH_ENDPOINT, OVH_APPLICATION_KEY, OVH_APPLICATION_SECRET, OVH_CONSUMER_KEY or configuration files ./ovh.conf, ~/ovh.conf, /etc/ovh.conf were not found", OvhApiExceptionCause.CONFIG_ERROR);
}

try {
// read the configuration file
Properties config = new Properties();
config.load(new FileInputStream(configFile));

// get the values
endpoint = OvhApiEndpoints.fromString(config.getProperty("endpoint", null));
appKey = config.getProperty("application_key", null);
appSecret = config.getProperty("application_secret", null);
consumerKey = config.getProperty("consumer_key", null);

assertAllConfigNotNull();
} catch (Exception e) {
throw new OvhApiException(e.getMessage(), OvhApiExceptionCause.CONFIG_ERROR);
}

}
public OvhApi(String endpoint, String appKey, String appSecret, String consumerKey) {

public OvhApi(OvhApiEndpoints endpoint, String appKey, String appSecret, String consumerKey) {
this.endpoint = endpoint;
this.appKey = appKey;
this.appSecret = appSecret;
this.consumerKey = consumerKey;

assertAllConfigNotNull();
}
private void assertAllConfigNotNull() throws OvhApiException{
if(endpoint==null || appKey==null || appSecret==null || consumerKey==null) {
throw new OvhApiException("", OvhApiExceptionCause.CONFIG_ERROR);

private void assertAllConfigNotNull() {
if (endpoint == null || appKey == null || appSecret == null || consumerKey == null) {
throw new IllegalArgumentException("Constructor parameters cannot be null");
}
}

public String get(String path) throws OvhApiException {
assertAllConfigNotNull();
return get(path, "", true);
}

public String get(String path, boolean needAuth) throws OvhApiException {
assertAllConfigNotNull();
return get(path, "", needAuth);
}

public String get(String path, String body, boolean needAuth) throws OvhApiException {
assertAllConfigNotNull();
return call("GET", body, appKey, appSecret, consumerKey, endpoint, path, needAuth);
return call("GET", body, path, needAuth);
}

public String put(String path, String body, boolean needAuth) throws OvhApiException {
assertAllConfigNotNull();
return call("PUT", body, appKey, appSecret, consumerKey, endpoint, path, needAuth);
return call("PUT", body, path, needAuth);
}

public String post(String path, String body, boolean needAuth) throws OvhApiException {
assertAllConfigNotNull();
return call("POST", body, appKey, appSecret, consumerKey, endpoint, path, needAuth);
return call("POST", body, path, needAuth);
}

public String delete(String path, String body, boolean needAuth) throws OvhApiException {
assertAllConfigNotNull();
return call("DELETE", body, appKey, appSecret, consumerKey, endpoint, path, needAuth);
return call("DELETE", body, path, needAuth);
}

private String call(String method, String body, String appKey, String appSecret, String consumerKey, String endpoint, String path, boolean needAuth) throws OvhApiException
{

try {
String indexedEndpoint = endpoints.get(endpoint);
endpoint = (indexedEndpoint==null)?endpoint:indexedEndpoint;

URL url = new URL(new StringBuilder(endpoint).append(path).toString());

// prepare
HttpURLConnection request = (HttpURLConnection) url.openConnection();
private String call(String method, String body, String path, boolean needAuth) throws OvhApiException {
String urlStr = endpoint.getUrl() + path;

Map<String, String> headers = new HashMap<>();
headers.put("Content-Type", "application/json");
headers.put("X-Ovh-Application", appKey);

// handle authentication
if (needAuth) {
// get timestamp from local system
long timestamp = System.currentTimeMillis() / 1000;

// build signature
String toSign = appSecret + "+" + consumerKey + "+" + method + "+" + urlStr + "+" + body + "+" + timestamp;
String signature;
try {
signature = "$1$" + Utils.sha1Hex(toSign);
} catch (NoSuchAlgorithmException | IOException e) {
throw new OvhApiException(e.getMessage(), OvhApiExceptionCause.INTERNAL_ERROR);
}

// set HTTP headers for authentication
headers.put("X-Ovh-Consumer", consumerKey);
headers.put("X-Ovh-Signature", signature);
headers.put("X-Ovh-Timestamp", Long.toString(timestamp));
}

return execRequest(method, urlStr, headers, body);
}

public static String generateConsumerKey(OvhApiEndpoints endpoint, String appKey,
boolean get, String pathGet, boolean post, String pathPost,
boolean put, String pathPut, boolean delete, String pathDelete) throws OvhApiException {
if (endpoint == null || appKey == null) {
throw new IllegalArgumentException("Endpoint and appKey cannot be null");
}

if (!get && !post && !put && !delete) {
throw new IllegalArgumentException("At least one method should be allowed");
}

if ((get && pathGet == null) || (post && pathPost == null) || (put && pathPut == null) || (delete && pathDelete == null)) {
throw new IllegalArgumentException("allowed methods must have a path");
}

String body = "{" + "\"accessRules\": [";

if (get) {
body += "{\"method\": \"GET\", \"path\": \"" + pathGet + "\"},";
}

if (post) {
body += "{\"method\": \"POST\", \"path\": \"" + pathPost + "\"},";
}

if (put) {
body += "{\"method\": \"PUT\", \"path\": \"" + pathPut + "\"},";
}

if (delete) {
body += "{\"method\": \"DELETE\", \"path\": \"" + pathDelete + "\"},";
}

body = body.substring(0, body.length() - 1);
body += "]}";

Map<String, String> headers = new HashMap<>();
headers.put("Content-Type", "application/json");
headers.put("X-Ovh-Application", appKey);

return execRequest("GET", endpoint.getUrl() + "/auth/credential", headers, body);
}

private static String execRequest(String method, String urlStr, Map<String, String> headers, String body) throws OvhApiException {
try {
// prepare
HttpURLConnection request = (HttpURLConnection) new URL(urlStr).openConnection();
request.setRequestMethod(method);
request.setReadTimeout(30000);
request.setConnectTimeout(30000);
request.setRequestProperty("Content-Type", "application/json");
request.setRequestProperty("X-Ovh-Application", appKey);
// handle authentification
if(needAuth) {
// get timestamp from local system
long timestamp = System.currentTimeMillis() / 1000;

// build signature
String toSign = new StringBuilder(appSecret)
.append("+")
.append(consumerKey)
.append("+")
.append(method)
.append("+")
.append(url)
.append("+")
.append(body)
.append("+")
.append(timestamp)
.toString();
String signature = new StringBuilder("$1$").append(HashSHA1(toSign)).toString();

// set HTTP headers for authentication
request.setRequestProperty("X-Ovh-Consumer", consumerKey);
request.setRequestProperty("X-Ovh-Signature", signature);
request.setRequestProperty("X-Ovh-Timestamp", Long.toString(timestamp));

if (headers != null) {
for (Map.Entry<String, String> header: headers.entrySet()) {
request.setRequestProperty(header.getKey(), header.getValue());
}
}

if(body != null && !body.isEmpty())
{

if (body != null && !body.isEmpty()) {
request.setDoOutput(true);
DataOutputStream out = new DataOutputStream(request.getOutputStream());
out.writeBytes(body);
out.flush();
out.close();
}


String inputLine;
BufferedReader in;
int responseCode = request.getResponseCode();
if (responseCode == 200) {
in = new BufferedReader(new InputStreamReader(request.getInputStream()));
} else {
in = new BufferedReader(new InputStreamReader(request.getErrorStream()));
DataOutputStream out = new DataOutputStream(request.getOutputStream());
out.writeBytes(body);
out.flush();
out.close();
}


int responseCode = request.getResponseCode();
BufferedReader in = new BufferedReader(new InputStreamReader(responseCode == 200 ? request.getInputStream() : request.getErrorStream()));

// build response
StringBuilder response = new StringBuilder();
while ((inputLine = in.readLine()) != null) {
for (String inputLine; (inputLine = in.readLine()) != null;) {
response.append(inputLine);
}

in.close();
if(responseCode == 200) {

if (responseCode == 200) {
// return the raw JSON result
return response.toString();
} else if(responseCode == 400) {
} else if (responseCode == 400) {
throw new OvhApiException(response.toString(), OvhApiExceptionCause.BAD_PARAMETERS_ERROR);
} else if (responseCode == 403) {
throw new OvhApiException(response.toString(), OvhApiExceptionCause.AUTH_ERROR);
} else if (responseCode == 404) {
throw new OvhApiException(response.toString(), OvhApiExceptionCause.RESSOURCE_NOT_FOUND);
throw new OvhApiException(response.toString(), OvhApiExceptionCause.RESOURCE_NOT_FOUND);
} else if (responseCode == 409) {
throw new OvhApiException(response.toString(), OvhApiExceptionCause.RESSOURCE_CONFLICT_ERROR);
throw new OvhApiException(response.toString(), OvhApiExceptionCause.RESOURCE_CONFLICT_ERROR);
} else {
throw new OvhApiException(response.toString(), OvhApiExceptionCause.API_ERROR);
}

} catch (NoSuchAlgorithmException e) {
throw new OvhApiException(e.getMessage(), OvhApiExceptionCause.INTERNAL_ERROR);
} catch (IOException e) {
throw new OvhApiException(e.getMessage(), OvhApiExceptionCause.INTERNAL_ERROR);
}

}

public static String HashSHA1(String text) throws NoSuchAlgorithmException, UnsupportedEncodingException {
MessageDigest md;
md = MessageDigest.getInstance("SHA-1");
byte[] sha1hash = new byte[40];
md.update(text.getBytes("iso-8859-1"), 0, text.length());
sha1hash = md.digest();
StringBuffer sb = new StringBuffer();
for (int i = 0; i < sha1hash.length; i++) {
sb.append(Integer.toString((sha1hash[i] & 0xff) + 0x100, 16).substring(1));
}
return sb.toString();
}

}
Loading