+ bridge receives request data.

pull/1/head
Ivan Olexyn 5 years ago
parent 7e137ef10c
commit 1555b516db

@ -28,7 +28,7 @@ public class BridgeServlet extends HttpServlet {
String jsonPayload = IOUtils.toString(request.getReader()); String jsonPayload = IOUtils.toString(request.getReader());
if (jsonPayload.contains("LINK")) { if (jsonPayload.contains("REQUEST")) {
Thread handleGetLinkThread = new Thread(() -> { Thread handleGetLinkThread = new Thread(() -> {
try { try {
handleGetRequest(request, response); handleGetRequest(request, response);

@ -18,7 +18,6 @@ public abstract class ActorRunnable implements Runnable {
List<ExchangeMock> exchanges = new ArrayList<>(); List<ExchangeMock> exchanges = new ArrayList<>();
List<HttpServletRequest> requests = new ArrayList<>();
protected MockSet mockSet; protected MockSet mockSet;
@ -33,31 +32,17 @@ public abstract class ActorRunnable implements Runnable {
@Override @Override
public void run() { public void run() {
while (true) { //
if (requests.size() > 0) {
try {
processRequests(requests.remove(0));
} catch (IOException | ServletException e) {
e.printStackTrace();
}
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
} }
public void processRequests(HttpServletRequest request) throws IOException, ServletException { public void processExchange(ExchangeMock exchange) throws IOException, ServletException {
if (request.getMethod().equalsIgnoreCase("GET")) { if (exchange.request.getMethod().equalsIgnoreCase("GET")) {
doGet(request, null); doGet(exchange.request, exchange.response);
} else if (request.getMethod().equalsIgnoreCase("POST")) { } else if (exchange.request.getMethod().equalsIgnoreCase("POST")) {
doPost(request, null); doPost(exchange.request, exchange.response);
} }
} }

@ -1,13 +1,21 @@
package actor; package actor;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import java.net.HttpURLConnection;
import core.ConnectionHelper;
import core.MockSet; import core.MockSet;
import core.Ride;
import core.State;
import exchange.ExchangeMock;
public class UserMock extends ActorRunnable { public class UserMock extends ActorRunnable {
int requestCount = 0;
public UserMock(MockSet mockSet){ public UserMock(MockSet mockSet){
super(mockSet); super(mockSet);
@ -15,7 +23,15 @@ public class UserMock extends ActorRunnable {
@Override @Override
public void run() { public void run() {
while (true){
try {
Thread.sleep(1000);
sendGetRequest();
} catch (IOException | InterruptedException e) {
e.printStackTrace();
}
}
} }
@Override @Override
@ -27,4 +43,35 @@ public class UserMock extends ActorRunnable {
void doPost(HttpServletRequest request, HttpServletResponse response) { void doPost(HttpServletRequest request, HttpServletResponse response) {
} }
/**
* # send GET (Request)
* Generated by Loop
*/
void sendGetRequest() throws IOException, InterruptedException {
// Mock Exchange
ExchangeMock exchange = new ExchangeMock();
exchange.request.setMethod("GET");
exchange.request.setContentType("application/json");
String requestBody = "REQUEST-"+requestCount++;
String jsonString = "{\"request\":\""+requestBody+ "\"}";
exchange.request.setContent(jsonString.getBytes());
synchronized (exchange){
// Mock GET (Request)
exchange.notify();
mockSet.bridgeMock.doGet(exchange.request,exchange.response);
exchange.wait();
// handle OK (Data)
String data = exchange.response.getContentAsString();
System.out.println(data + " of REQUEST-"+requestCount);
}
}
} }

@ -6,8 +6,8 @@ import core.BridgeMock;
import core.ClientMock; import core.ClientMock;
public class MockSet { public class MockSet {
UserMock userMock; public UserMock userMock;
BridgeMock bridgeMock; public BridgeMock bridgeMock;
ClientMock clientMock; public ClientMock clientMock;
AppMock appMock; public AppMock appMock;
} }
Loading…
Cancel
Save