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.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
-import java.io.BufferedInputStream;
import java.util.List;
-import java.security.cert.CertificateFactory;
-import java.security.cert.Certificate;
-import java.security.cert.X509Certificate;
-import java.security.KeyStore;
/**
* Created by xubin on 4/26/16.
public class Helper {
private static final int Driver_port = 8000;
private static final String Tag = "http";
- private static final String KEYEXT = ".pem";
HttpClient httpclient;
//Set up
- void setConnection(String destIP) {
-
- httpclient = createClient(destIP);
+ void setConnection() {
+ httpclient = createClient();
}
-
- HttpClient createClient(String destIP) {
+ HttpClient createClient() {
HttpParams params = new BasicHttpParams();
params.setParameter(CoreProtocolPNames.PROTOCOL_VERSION, HttpVersion.HTTP_1_1);
params.setParameter(CoreProtocolPNames.HTTP_CONTENT_CHARSET, HTTP.DEFAULT_CONTENT_CHARSET);
SchemeRegistry schReg = new SchemeRegistry();
schReg.register(new Scheme("http", PlainSocketFactory.getSocketFactory(), Driver_port));
- schReg.register(new Scheme("https", newSslSocketFactory(destIP), 443));
+ //schReg.register(new Scheme("https", SSLSocketFactory.getSocketFactory(), 443));
ClientConnectionManager conMgr = new ThreadSafeClientConnManager(params, schReg);
return new DefaultHttpClient(conMgr, params);
}
-
//Make http request
public void makeRequest(String destIP, List<Object> paramObjects, String methodName) {
- String url = "https://"+ destIP + ":"+Driver_port+ "/"+methodName;
- System.out.println("URL: " + url);
+ String url = "http://"+ destIP + ":"+Driver_port+ "/"+methodName;
InputStream inputStream = null;
String result = "";
try {
HttpPost httpPost = new HttpPost(url);
JSONArray params = new JSONArray();
+
JSONObject parent = new JSONObject();
for (int i = 0; i < paramObjects.size(); i++) {
JSONObject content = new JSONObject();
ex.printStackTrace();
}
}
-
- private SSLSocketFactory newSslSocketFactory(String destIP) {
- try {
- // Load CAs from an InputStream
- CertificateFactory cf = CertificateFactory.getInstance("X.509");
- InputStream caInput = new
- BufferedInputStream(MainActivity.context.getAssets().open(destIP + KEYEXT));
- Certificate ca;
- try {
- ca = cf.generateCertificate(caInput);
- System.out.println("ca=" + ((X509Certificate) ca).getSubjectDN());
- } finally {
- caInput.close();
- }
- String keyStoreType = KeyStore.getDefaultType();
- KeyStore keyStore = KeyStore.getInstance(keyStoreType);
- keyStore.load(null, null);
- keyStore.setCertificateEntry("ca", ca);
- SSLSocketFactory socketFactory = new SSLSocketFactory(keyStore);
- return socketFactory;
- } catch (Exception e) {
- throw new AssertionError(e);
- }
- }
-
private static String convertInputStreamToString(InputStream inputStream) throws IOException {
BufferedReader bufferedReader = new BufferedReader( new InputStreamReader(inputStream));
String line = "";