96 lines
3.1 KiB
Java
96 lines
3.1 KiB
Java
package uulm.teamname.marvelous.gamelibrary.gamelogic;
|
|
|
|
import org.junit.jupiter.api.BeforeAll;
|
|
import org.junit.jupiter.api.Test;
|
|
import uulm.teamname.marvelous.gamelibrary.ai.AIClient;
|
|
import uulm.teamname.marvelous.gamelibrary.entities.EntityType;
|
|
import uulm.teamname.marvelous.gamelibrary.events.Event;
|
|
import uulm.teamname.marvelous.gamelibrary.json.JSON;
|
|
import uulm.teamname.marvelous.gamelibrary.messages.*;
|
|
import uulm.teamname.marvelous.gamelibrary.messages.client.*;
|
|
import uulm.teamname.marvelous.gamelibrary.messages.server.*;
|
|
import uulm.teamname.marvelous.gamelibrary.requests.*;
|
|
|
|
import java.util.List;
|
|
import java.util.Optional;
|
|
import java.util.concurrent.*;
|
|
|
|
class AITest extends BaseGameLogicTest {
|
|
private static JSON json;
|
|
private static ExecutorService executor;
|
|
|
|
private static GameInstance server;
|
|
private static AIClient clientA;
|
|
private static AIClient clientB;
|
|
|
|
@BeforeAll
|
|
static void setUp() {
|
|
generate();
|
|
|
|
json = new JSON(characterConfig);
|
|
executor = new SimpleErrorSensitiveThreadPoolExecutor();
|
|
|
|
server = new GameInstance(partyConfig, characterConfig, scenarioConfig);
|
|
clientA = new AIClient(EntityType.P1, partyConfig, characterConfig, scenarioConfig);
|
|
clientB = new AIClient(EntityType.P2, partyConfig, characterConfig, scenarioConfig);
|
|
}
|
|
|
|
@Test
|
|
void main() throws InterruptedException {
|
|
serverSend(server.startGame(player1Selection, player2Selection).toArray(new Event[0]));
|
|
|
|
Thread.sleep(2000);
|
|
}
|
|
|
|
private void clientSend(Request[] requests) {
|
|
RequestMessage message = new RequestMessage();
|
|
message.messages = requests;
|
|
|
|
Optional<String> data = json.stringify(message);
|
|
|
|
if(data.isPresent()) {
|
|
executor.submit(() -> serverReceive(data.get()));
|
|
}
|
|
}
|
|
|
|
private void clientReceive(String data) {
|
|
Optional<BasicMessage> message = json.parse(data);
|
|
|
|
if(message.isPresent()) {
|
|
Optional<List<Request>> resultA = clientA.handle(((EventMessage)message.get()).messages);
|
|
Optional<List<Request>> resultB = clientB.handle(((EventMessage)message.get()).messages);
|
|
|
|
if(resultA.isPresent()) {
|
|
executor.submit(() -> clientSend(resultA.get().toArray(new Request[0])));
|
|
}
|
|
|
|
if(resultB.isPresent()) {
|
|
executor.submit(() -> clientSend(resultB.get().toArray(new Request[0])));
|
|
}
|
|
}
|
|
}
|
|
|
|
private void serverSend(Event[] events) {
|
|
EventMessage message = new EventMessage();
|
|
message.messages = events;
|
|
|
|
Optional<String> data = json.stringify(message);
|
|
|
|
if(data.isPresent()) {
|
|
executor.submit(() -> clientReceive(data.get()));
|
|
}
|
|
}
|
|
|
|
private void serverReceive(String data) {
|
|
Optional<BasicMessage> message = json.parse(data);
|
|
|
|
if(message.isPresent()) {
|
|
Optional<List<Event>> result = server.checkRequestsAndApply(((RequestMessage)message.get()).messages);
|
|
|
|
if(result.isPresent()) {
|
|
executor.submit(() -> serverSend(result.get().toArray(new Event[0])));
|
|
}
|
|
}
|
|
}
|
|
}
|