pull/1/head
Ivan Olexyn 5 years ago
parent 9ebe5575fa
commit 2f6e088480

@ -8,7 +8,7 @@
<orderEntry type="inheritedJdk" /> <orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" /> <orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="module" module-name="misphelper" /> <orderEntry type="module" module-name="misphelper" />
<orderEntry type="module" module-name="mispclient" />
<orderEntry type="library" name="org.eclipse.jetty.orbit:javax.servlet:3.0.0.v201112011016" level="project" /> <orderEntry type="library" name="org.eclipse.jetty.orbit:javax.servlet:3.0.0.v201112011016" level="project" />
<orderEntry type="library" name="org.json:json:20190722" level="project" />
</component> </component>
</module> </module>

@ -1,12 +1,11 @@
package com.olexyn.mispl.adapter; package com.olexyn.misp.adapter;
import com.olexyn.misp.client.ConnectionHelper;
import com.olexyn.misp.helper.Ride; import com.olexyn.misp.helper.Ride;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import java.io.PrintWriter;
import java.net.HttpURLConnection; import java.net.HttpURLConnection;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
@ -15,7 +14,7 @@ import java.util.Map;
public class Adapter { public class Adapter {
protected static final String MISP_BRIDGE_URL = "http://localhost:9090/mispbridge/core"; protected static final String MISP_BRIDGE_URL = "http://localhost:9090/mispbridge/core";
protected static final String APP_URL = "http://localhost:9090/mispclient"; protected static final String APP_URL = "http://localhost:9090/mirror/core";
public static final int AVAILABLE_RIDES_OVERHEAD_TRIGGER = 2; public static final int AVAILABLE_RIDES_OVERHEAD_TRIGGER = 2;
public static final int AVAILABLE_RIDES_OVERHEAD = 4; public static final int AVAILABLE_RIDES_OVERHEAD = 4;

@ -1,4 +1,4 @@
package com.olexyn.misp.client; package com.olexyn.misp.adapter;
import com.olexyn.misp.helper.Ride; import com.olexyn.misp.helper.Ride;
@ -7,6 +7,7 @@ import java.io.IOException;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.net.HttpURLConnection; import java.net.HttpURLConnection;
import java.net.URL; import java.net.URL;
import org.json.JSONObject;
public class ConnectionHelper { public class ConnectionHelper {

@ -1,4 +1,4 @@
package com.olexyn.mispl.adapter; package com.olexyn.misp.adapter;
public class Main { public class Main {

@ -1,9 +1,8 @@
package com.olexyn.misp.mock; package com.olexyn.misp.mock;
import com.olexyn.misp.client.ClientServlet;
import com.olexyn.misp.helper.Ride; import com.olexyn.misp.helper.Ride;
import com.olexyn.misp.mock.exchange.ExchangeMock; import com.olexyn.misp.mock.exchange.ExchangeMock;
import com.olexyn.mispl.adapter.Adapter; import com.olexyn.misp.adapter.Adapter;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import java.io.IOException; import java.io.IOException;

@ -1,100 +0,0 @@
package com.olexyn.misp.mock;
import com.olexyn.misp.client.ClientServlet;
import com.olexyn.misp.helper.Ride;
import com.olexyn.misp.mock.exchange.ExchangeMock;
import javax.servlet.ServletException;
import java.io.IOException;
/**
* Wraps a ClientServlet so it can be debugged easily, i.e. without running Tomcat.
*/
public class ClientMock extends ClientServlet {
private MockSet mockSet;
public ClientMock(MockSet mockSet) {
super();
mockSet.clientMock = this;
this.mockSet = mockSet;
}
/**
* Send POST (Ride).
* Parse response.
*/
@Override
protected Ride doSendPostRide(Ride ride) throws IOException, ServletException, InterruptedException {
// Mock Exchange
final ExchangeMock exchange = new ExchangeMock();
exchange.request.setMethod("POST");
exchange.request.setContentType("application/json");
exchange.request.setContent(ride.json().getBytes());
synchronized (exchange) {
// Mock POST (Ride)
exchange.notify();
mockSet.bridgeMock.doPost(exchange.request, exchange.response);
exchange.wait();
exchange.notify();
}
// handle OK (Ride)(Request)
return new Ride(exchange.response.getContentAsString());
}
/**
* Send GET (Request) to App.
* Parse response.
*/
@Override
protected String doSendGetRequest(String request) throws IOException, InterruptedException {
// Mock Exchange
final ExchangeMock exchange = new ExchangeMock();
exchange.request.setMethod("GET");
exchange.request.setContent(request.getBytes());
synchronized (exchange) {
// Mock GET (Request)
exchange.notify();
mockSet.appMock.doGet(exchange.request, exchange.response);
// handle OK (Data)
exchange.notify();
}
return exchange.response.getContentAsString();
}
/**
* Send GET (Ride)(Request)(Data).
* Parse response.
*/
@Override
protected void doSendGetRideRequest(Ride ride) throws IOException, InterruptedException {
// Mock Exchange
final ExchangeMock exchange = new ExchangeMock();
exchange.request.setMethod("GET");
exchange.request.setContentType("application/json");
exchange.request.setContent(ride.json().getBytes());
synchronized (exchange) {
// Mock GET (Ride)(Request)(Data)
exchange.notify();
mockSet.bridgeMock.doGet(exchange.request, exchange.response);
exchange.wait();
exchange.notify();
}
}
}

@ -1,20 +0,0 @@
package com.olexyn.misp.mock;
/**
* Pass the MockSet.
* Provide a Runnable.
*/
public class ClientRunnable implements Runnable {
private MockSet mockSet;
public ClientRunnable(MockSet mockSet){
super();
this.mockSet = mockSet;
}
@Override
public void run() {
new ClientMock(mockSet);
}
}

@ -7,6 +7,5 @@ public class MockSet {
public UserMock userMock; public UserMock userMock;
public BridgeMock bridgeMock; public BridgeMock bridgeMock;
public AdapterMock adapterMock; public AdapterMock adapterMock;
public ClientMock clientMock;
public AppMock appMock; public AppMock appMock;
} }
Loading…
Cancel
Save