|
|
@@ -1,101 +1,113 @@ |
|
|
package com.indicee.api.util; |
|
|
package com.indicee.api.examples; |
|
|
|
|
|
import java.io.ByteArrayInputStream; |
|
|
import java.io.File; |
|
|
import java.io.FileInputStream; |
|
|
import java.io.InputStream; |
|
|
import java.io.OutputStream; |
|
|
import java.security.NoSuchAlgorithmException; |
|
|
|
|
|
import javax.net.ssl.SSLContext; |
|
|
import javax.xml.parsers.DocumentBuilderFactory; |
|
|
import javax.xml.transform.OutputKeys; |
|
|
import javax.xml.transform.Result; |
|
|
import javax.xml.transform.Source; |
|
|
import javax.xml.transform.Transformer; |
|
|
import javax.xml.transform.TransformerException; |
|
|
import javax.xml.transform.TransformerFactory; |
|
|
import javax.xml.transform.dom.DOMSource; |
|
|
import javax.xml.transform.stream.StreamResult; |
|
|
|
|
|
import oauth.signpost.basic.DefaultOAuthConsumer; |
|
|
import oauth.signpost.commonshttp.CommonsHttpOAuthConsumer; |
|
|
|
|
|
import org.apache.http.HttpEntity; |
|
|
import org.apache.http.HttpResponse; |
|
|
import org.apache.http.client.methods.HttpPost; |
|
|
import org.apache.http.conn.ClientConnectionManager; |
|
|
import org.apache.http.conn.scheme.PlainSocketFactory; |
|
|
import org.apache.http.conn.scheme.Scheme; |
|
|
import org.apache.http.conn.scheme.SchemeRegistry; |
|
|
import org.apache.http.conn.ssl.SSLSocketFactory; |
|
|
import org.apache.http.entity.mime.MultipartEntity; |
|
|
import org.apache.http.entity.mime.content.ContentBody; |
|
|
import org.apache.http.entity.mime.content.InputStreamBody; |
|
|
import org.apache.http.entity.mime.content.StringBody; |
|
|
import org.apache.http.impl.client.DefaultHttpClient; |
|
|
import org.apache.http.impl.conn.SingleClientConnManager; |
|
|
import org.w3c.dom.Document; |
|
|
|
|
|
public class UploadContribution { |
|
|
private static CommonsHttpOAuthConsumer commonsHttpConsumer; |
|
|
private static final String CONSUMERKEY = ""; |
|
|
private static final String CONSUMERSECRETE = ""; |
|
|
private static final String TOKENKEY = ""; |
|
|
private static final String TOKENSECRETE = ""; |
|
|
private static String host = "https://secure.indicee.com"; |
|
|
|
|
|
public static void main(String args[]) throws Exception { |
|
|
//oauth initialization |
|
|
DefaultOAuthConsumer oconsumer = new DefaultOAuthConsumer(CONSUMERKEY, CONSUMERSECRETE); |
|
|
oconsumer.setTokenWithSecret(TOKENKEY, TOKENSECRETE); |
|
|
|
|
|
commonsHttpConsumer = new CommonsHttpOAuthConsumer(oconsumer.getConsumerKey(), oconsumer.getConsumerSecret()); |
|
|
commonsHttpConsumer.setTokenWithSecret(oconsumer.getToken(), oconsumer.getTokenSecret()); |
|
|
|
|
|
//uploads a datafile |
|
|
File datasetFile = new File("path-to-file"); |
|
|
upload(datasetFile); |
|
|
|
|
|
//uploads data from an inputstream |
|
|
String csvData = "Column1,Column2\nvalue1,value2"; |
|
|
ByteArrayInputStream bs = new ByteArrayInputStream(csvData.getBytes()); |
|
|
upload(bs, "text/csv", "Some Name"); |
|
|
} |
|
|
|
|
|
private static void upload(File data) throws Exception { |
|
|
String url = String.format("%s/api/contributions/upload.xml", host); |
|
|
HttpPost httpPost = new HttpPost(url); |
|
|
// build post data. File upload needs multipart form data. |
|
|
MultipartEntity mentity = new MultipartEntity(); |
|
|
|
|
|
ContentBody fbody = new InputStreamBody(new FileInputStream(data), data.getName()); |
|
|
mentity.addPart("file", fbody); |
|
|
httpPost.setEntity(mentity); |
|
|
|
|
|
// init a http client |
|
|
DefaultHttpClient httpClient = new DefaultHttpClient(); |
|
|
|
|
|
SSLSocketFactory sf = (SSLSocketFactory) httpClient.getConnectionManager().getSchemeRegistry().getScheme( |
|
|
"https").getSocketFactory(); |
|
|
sf.setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); |
|
|
|
|
|
commonsHttpConsumer.sign(httpPost); |
|
|
|
|
|
// send the data to get the response |
|
|
HttpResponse httpResponse = httpClient.execute(httpPost); |
|
|
int status = httpResponse.getStatusLine().getStatusCode(); |
|
|
HttpEntity entity = httpResponse.getEntity(); |
|
|
if (status != 200) { |
|
|
throw new Exception("Error uploading the file"); |
|
|
} |
|
|
} |
|
|
|
|
|
private static void upload(InputStream inputSteam, String mimeType, String fileName) throws Exception { |
|
|
String url = String.format("%s/api/contributions/upload.xml", host); |
|
|
HttpPost httpPost = new HttpPost(url); |
|
|
|
|
|
private static final String HOST = "https://secure.indicee.com"; |
|
|
private static final String CONSUMER_KEY = "XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXXXXXX"; |
|
|
private static final String CONSUMER_SECRET = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX"; |
|
|
private static final String TOKEN_KEY = "XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXXXXXX"; |
|
|
private static final String TOKEN_SECRET = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX"; |
|
|
private static final String DATA_SET_IQN = "iqn.2://indicee.com/{user_id}/{space_id}/dataModel/dataSets/{dataset_name}"; |
|
|
private static final String FILE_PATH = "/path/to/file"; |
|
|
|
|
|
public static void main(String[] args) throws Exception { |
|
|
CommonsHttpOAuthConsumer commonsHttpConsumer = new CommonsHttpOAuthConsumer(CONSUMER_KEY, CONSUMER_SECRET); |
|
|
commonsHttpConsumer.setTokenWithSecret(TOKEN_KEY, TOKEN_SECRET); |
|
|
|
|
|
String path = "/api/contributions/v3/upload.xml"; |
|
|
File file = new File(FILE_PATH); |
|
|
|
|
|
DefaultHttpClient httpClient = createHttpClient(); |
|
|
|
|
|
HttpPost httpPost = new HttpPost(HOST + path); |
|
|
|
|
|
|
|
|
// build post data. File upload needs multipart form data. |
|
|
MultipartEntity mentity = new MultipartEntity(); |
|
|
|
|
|
ContentBody fbody = new InputStreamBody(inputSteam, mimeType, fileName); |
|
|
mentity.addPart("file", fbody); |
|
|
|
|
|
mentity.addPart("file", new InputStreamBody(new FileInputStream(file), file.getName())); |
|
|
mentity.addPart("dataSetQname", new StringBody(DATA_SET_IQN)); |
|
|
httpPost.setEntity(mentity); |
|
|
|
|
|
// init a http client |
|
|
DefaultHttpClient httpClient = new DefaultHttpClient(); |
|
|
|
|
|
SSLSocketFactory sf = (SSLSocketFactory) httpClient.getConnectionManager().getSchemeRegistry().getScheme( |
|
|
"https").getSocketFactory(); |
|
|
sf.setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); |
|
|
|
|
|
|
|
|
|
|
|
commonsHttpConsumer.sign(httpPost); |
|
|
|
|
|
|
|
|
// send the data to get the response |
|
|
HttpResponse httpResponse = httpClient.execute(httpPost); |
|
|
int status = httpResponse.getStatusLine().getStatusCode(); |
|
|
HttpEntity entity = httpResponse.getEntity(); |
|
|
if (status != 200) { |
|
|
throw new Exception("Error uploading the file"); |
|
|
throw new Exception("Error making call: " + path); |
|
|
} |
|
|
} |
|
|
|
|
|
InputStream is = httpResponse.getEntity().getContent(); |
|
|
Document document = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(is); |
|
|
documentToStream(document, System.out); |
|
|
} |
|
|
|
|
|
private static DefaultHttpClient createHttpClient() throws Exception { |
|
|
SchemeRegistry registry = new SchemeRegistry(); |
|
|
|
|
|
registry.register(new Scheme("http", 80, PlainSocketFactory.getSocketFactory())); |
|
|
|
|
|
try { |
|
|
SSLSocketFactory sf = new SSLSocketFactory(SSLContext.getDefault(), |
|
|
SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); |
|
|
registry.register(new Scheme("https", 443, sf)); |
|
|
} catch (NoSuchAlgorithmException e) { |
|
|
throw new Exception("Problem creating ssl connection", e); |
|
|
} |
|
|
|
|
|
ClientConnectionManager conman = new SingleClientConnManager(registry); |
|
|
DefaultHttpClient httpClient = new DefaultHttpClient(conman); |
|
|
return httpClient; |
|
|
} |
|
|
|
|
|
private static void documentToStream(Document document, OutputStream outputStream) { |
|
|
|
|
|
try { |
|
|
Transformer transformer = TransformerFactory.newInstance().newTransformer(); |
|
|
transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8"); |
|
|
transformer.setOutputProperty(OutputKeys.INDENT, "yes"); |
|
|
transformer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", Integer.toString(2)); |
|
|
Result result = new StreamResult(outputStream); |
|
|
Source source = new DOMSource(document); |
|
|
transformer.transform(source, result); |
|
|
} catch (TransformerException e) { |
|
|
throw new RuntimeException(e); |
|
|
} |
|
|
} |
|
|
} |
IndiceeCoder revised this gist