.factorypath

@@ -1,14 +0,0 @@
-<factorypath>
-    <factorypathentry kind="VARJAR" id="M2_REPO/com/epita/given/4.0-SNAPSHOT/given-4.0-SNAPSHOT.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/org/projectlombok/lombok/1.18.42/lombok-1.18.42.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/org/slf4j/slf4j-api/2.0.17/slf4j-api-2.0.17.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/ch/qos/logback/logback-classic/1.5.23/logback-classic-1.5.23.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/ch/qos/logback/logback-core/1.5.23/logback-core-1.5.23.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/com/fasterxml/jackson/core/jackson-databind/2.20.1/jackson-databind-2.20.1.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/com/fasterxml/jackson/core/jackson-annotations/2.20/jackson-annotations-2.20.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/com/fasterxml/jackson/core/jackson-core/2.20.1/jackson-core-2.20.1.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/com/konghq/unirest-java-core/4.7.0/unirest-java-core-4.7.0.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/com/konghq/unirest-objectmapper-jackson/4.2.9/unirest-objectmapper-jackson-4.2.9.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/com/fasterxml/jackson/datatype/jackson-datatype-jsr310/2.15.2/jackson-datatype-jsr310-2.15.2.jar" enabled="true" runInBatchMode="false"/>
-    <factorypathentry kind="VARJAR" id="M2_REPO/javax/validation/validation-api/2.0.1.Final/validation-api-2.0.1.Final.jar" enabled="true" runInBatchMode="false"/>
-</factorypath>

.settings/org.eclipse.core.resources.prefs

@@ -1,3 +0,0 @@
-eclipse.preferences.version=1
-encoding//src/main/java=UTF-8
-encoding/<project>=UTF-8

.settings/org.eclipse.jdt.apt.core.prefs

@@ -1,4 +0,0 @@
-eclipse.preferences.version=1
-org.eclipse.jdt.apt.aptEnabled=true
-org.eclipse.jdt.apt.genSrcDir=target/generated-sources/annotations
-org.eclipse.jdt.apt.genTestSrcDir=target/generated-test-sources/test-annotations

.settings/org.eclipse.jdt.core.prefs

@@ -1,9 +0,0 @@
-eclipse.preferences.version=1
-org.eclipse.jdt.core.compiler.codegen.targetPlatform=21
-org.eclipse.jdt.core.compiler.compliance=21
-org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
-org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
-org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
-org.eclipse.jdt.core.compiler.processAnnotations=enabled
-org.eclipse.jdt.core.compiler.release=enabled
-org.eclipse.jdt.core.compiler.source=21

.settings/org.eclipse.m2e.core.prefs

@@ -1,4 +0,0 @@
-activeProfiles=
-eclipse.preferences.version=1
-resolveWorkspaceProjects=true
-version=1

src/main/java/com/epita/creeps/AsyncExec.java

@@ -1,44 +0,0 @@
-package com.epita.creeps;
-
-
-import kong.unirest.core.HttpResponse;
-import kong.unirest.core.JsonNode;
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-import lombok.Setter;
-
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.TimeUnit;
-import java.util.function.Function;
-import java.util.function.Supplier;
-
-// Handles server operations to respect commands delays
-@NoArgsConstructor
-public class AsyncExec<T> {
-
-
-    private static float ticksPerSecond = 1;
-//    private CompletableFuture<T> task;
-
-
-    public static void setTicksPerSecond(float ticksPerSecond) {
-        AsyncExec.ticksPerSecond = ticksPerSecond;
-    }
-
-    public static long ticksToTime(long ticks) {
-        return Math.ceilDiv(ticks, (long)Math.ceil(ticksPerSecond));
-    }
-
-    public static <T> CompletableFuture<T> asyncExec(Supplier<T> supplier, long time) {
-        return CompletableFuture.supplyAsync(supplier).thenApplyAsync(x -> x,
-                CompletableFuture.delayedExecutor(ticksToTime(time), TimeUnit.SECONDS));
-    }
-    public static <T, R> CompletableFuture<R> thenAsyncExec(CompletableFuture<T> base, Function<T, R> f, long time) {
-        return base.thenApplyAsync(f, CompletableFuture.delayedExecutor(time, TimeUnit.SECONDS));
-    }
-
-    public static void justWait(long time) {
-        CompletableFuture.supplyAsync(() -> 0, CompletableFuture.delayedExecutor(time, TimeUnit.SECONDS)).join();
-    }
-
-}

src/main/java/com/epita/creeps/Program.java

@@ -1,83 +1,8 @@
 package com.epita.creeps;
 
-import com.epita.creeps.commands.Basics;
-import com.epita.creeps.given.extra.Cartographer;
-import com.epita.creeps.given.vo.geometry.Direction;
-import com.epita.creeps.given.vo.geometry.Point;
-import com.epita.creeps.given.vo.response.CommandResponse;
-import com.epita.creeps.given.vo.response.InitResponse;
-import com.epita.creeps.given.vo.response.StatisticsResponse;
-import com.epita.creeps.units.*;
-import kong.unirest.core.HttpResponse;
-import kong.unirest.core.JsonNode;
-import kong.unirest.core.Unirest;
-import kong.unirest.core.UnirestException;
-import lombok.Getter;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.ArrayList;
-import java.util.List;
-
 public class Program {
 
-    private static String srvUrl;
-    private static Logger logger;
-    @Getter
-    private static String login;
-
     public static void main(String[] args) {
-
+        System.out.println("Hello World!");
-        //Initialization
-
-        // Default Vars
-        srvUrl = "http://localhost:1664";
-        login = "marion.mavie";
-
-        // Arguments
-        boolean default_values = true;
-        if (args.length == 3) {
-            srvUrl = "http://" + args[0] + ":" +  args[1];
-            login = args[2];
-        } else {
-            default_values = false;
     }
-
-        // Classes
-        logger = LoggerFactory.getLogger(Program.class);
-        logger.info("Initializing");
-        Basics.setSrvUrl(srvUrl);
-        Citizen.srvUrl = srvUrl;
-        logger.debug("Using server " + srvUrl + " with player " + login);
-
-        if (default_values)
-            logger.warn("No given args: using the default values");
-
-        // Test
-        HttpResponse<JsonNode> response;
-        try {
-            response = Unirest.get(srvUrl + "/status").asJson();
-        } catch (UnirestException e) {
-            logger.error("Cannot connect to the server. Aborting...");
-            throw e;
-        }
-
-        // Create account and get init infos
-        logger.info("Creating account");
-        InitResponse initResponse = Basics.connectAccount(login);
-
-        login = initResponse.login; // Just in case
-        AsyncExec.setTicksPerSecond((float) initResponse.setup.ticksPerSeconds);
-        Citizen citizen1 = new Citizen(login, initResponse.citizen1Id, initResponse.householdCoordinates);
-        Citizen citizen2 = new Citizen(login, initResponse.citizen2Id, initResponse.householdCoordinates);
-        Unit.getUnits().add(citizen1);
-        Unit.getUnits().add(citizen2);
-
-        // Et voilà, machtou pichtou
-
-
-        logger.info("Done");
-    }
-
-
 }

src/main/java/com/epita/creeps/ServerReponseException.java

@@ -1,7 +0,0 @@
-package com.epita.creeps;
-
-public class ServerReponseException extends RuntimeException {
-    public ServerReponseException(String message) {
-        super(message);
-    }
-}

src/main/java/com/epita/creeps/commands/Basics.java

@@ -1,129 +0,0 @@
-package com.epita.creeps.commands;
-
-import com.epita.creeps.AsyncExec;
-import com.epita.creeps.Program;
-import com.epita.creeps.given.exception.NoReportException;
-import com.epita.creeps.given.extra.Cartographer;
-import com.epita.creeps.given.json.Json;
-import com.epita.creeps.given.vo.report.*;
-import com.epita.creeps.given.vo.response.InitResponse;
-import com.epita.creeps.given.vo.response.StatisticsResponse;
-import com.epita.creeps.units.BomberBot;
-import com.epita.creeps.units.Turret;
-import com.epita.creeps.units.Unit;
-import kong.unirest.core.HttpResponse;
-import kong.unirest.core.JsonNode;
-import kong.unirest.core.Unirest;
-import kong.unirest.core.UnirestException;
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-
-import lombok.Setter;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.concurrent.CompletableFuture;
-
-@AllArgsConstructor
-@Getter
-public class Basics {
-
-    private static final Logger logger = LoggerFactory.getLogger(Basics.class);
-    private static String srvUrl;
-
-    public static void setSrvUrl(String srvUrl) {
-        Basics.srvUrl = srvUrl;
-    }
-
-    public static InitResponse connectAccount(String login) {
-        try {
-            CompletableFuture<HttpResponse<JsonNode>> resp = AsyncExec.asyncExec(() -> Unirest.post(srvUrl + "/init/" + login).asJson(), 0);
-            HttpResponse<JsonNode> response = (HttpResponse<JsonNode>) resp.join();
-//            logger.debug(response.getBody().toPrettyString());
-            InitResponse initResponse = Json.parse(response.getBody().toString(), InitResponse.class);
-            if (initResponse.error != null) {
-                logger.error("Error in server response");
-                throw new RuntimeException("Cannot create account");
-            }
-            return initResponse;
-        } catch (UnirestException e) {
-            logger.error("Cannot create account.");
-            throw e;
-        }
-    }
-
-
-    public static StatisticsResponse getStatistics() {
-        try {
-            CompletableFuture<HttpResponse<JsonNode>> resp = AsyncExec.asyncExec(() -> Unirest.get(srvUrl + "/statistics").asJson(), 0);
-            HttpResponse<JsonNode> response = resp.join();
-            return Json.parse(response.getBody().toString(), StatisticsResponse.class);
-        } catch (UnirestException e) {
-            logger.error("Cannot retrieve statistics.");
-            throw e;
-        }
-    }
-
-    // Asks the server for a certain report
-    public static Report getReport (String reportId) {
-        HttpResponse<JsonNode> response = null;
-        try {
-            response = Unirest.get(srvUrl + "/report/" + reportId).asJson();
-//            logger.debug("Got report: " + response.getBody().toPrettyString());
-            Report report =  Json.parseReport(response.getBody().toString());
-            handleReport(report);
-            return report;
-        } catch (UnirestException e) {
-            logger.error("Could not retrieve report");
-            throw new RuntimeException(e);
-        } catch (NoReportException e) {
-            logger.error("Could not parse report: not a report");
-            logger.debug(response.getBody().toPrettyString());
-            throw new RuntimeException(e);
-        }
-    }
-
-    public static void handleReport(Report report) {
-        Cartographer c = Cartographer.INSTANCE;
-        if (report.opcode.startsWith("farm")) {
-            c.register((FarmReport) report);
-        }
-        else if (report.opcode.startsWith("gather")) {
-            c.register((GatherReport) report);
-        }
-        else if (report.opcode.startsWith("move")) {
-            c.register((MoveReport) report);
-        }
-        else if (report.opcode.startsWith("build")) {
-            c.register((BuildReport) report);
-        }
-        else if (report.opcode.startsWith("observe")) {
-            c.register((ObserveReport) report);
-        }
-        else if (report.opcode.startsWith("spawn"))
-        {
-            SpawnReport spawnReport = (SpawnReport) report;
-            if (spawnReport.errorCode != null) {
-                logger.warn("Could not spawn unit: got report with an error: " + report.errorCode);
-            }
-            if (spawnReport.spawnedUnit.opcode.endsWith("turret")) {
-                Turret turret = new Turret(Program.getLogin(), spawnReport.spawnedUnitId, spawnReport.spawnedUnit.position);
-                Unit.getUnits().add(turret);
-            }
-            else if (spawnReport.spawnedUnit.opcode.endsWith("bomber-bot")) {
-                BomberBot bombhero = new BomberBot(Program.getLogin(), spawnReport.spawnedUnitId, spawnReport.spawnedUnit.position);
-                Unit.getUnits().add(bombhero);
-            }
-            else {
-                logger.warn("Spawned unit is an unknown type. Ignored...");
-            }
-        }
-        else if (report.opcode.startsWith("fire")) {
-            logger.debug("FIRREEE!!");
-        }
-        else {
-            logger.warn("Unknown opcode '" + report.opcode + "' in the server report. Ignored...");
-        }
-    }
-
-}

src/main/java/com/epita/creeps/units/BomberBot.java

@@ -1,26 +0,0 @@
-package com.epita.creeps.units;
-
-import com.epita.creeps.given.extra.Cartographer;
-import com.epita.creeps.given.json.Json;
-import com.epita.creeps.given.vo.geometry.Point;
-import com.epita.creeps.given.vo.parameter.FireParameter;
-
-import java.util.List;
-
-public class BomberBot extends Unit {
-
-    public BomberBot(String login, String id, Point position) {
-        super(login, id, position);
-    }
-
-    // Retrieves all units that are turrets
-    public static List<Unit> getBomberBotUnits() {
-        return getUnits().stream().filter(unit -> unit.getClass() == BomberBot.class).toList();
-    }
-
-    public BomberBot fire() {
-        FireParameter fp = new FireParameter(this.position);
-        sendActionWithBody("fire:bomber-bot", Json.serialize(fp), 2);
-        return this;
-    }
-}

src/main/java/com/epita/creeps/units/Building.java

@@ -1,14 +0,0 @@
-package com.epita.creeps.units;
-
-public enum Building {
-    TOWNHALL("town-hall"),
-    HOUSEHOLD("household"),
-    SAWMILL("sawmill"),
-    SMELTERY("smeltery"),
-    ROAD("road");
-
-    public final String name;
-    private Building(final String building) {
-        this.name = building;
-    }
-}

src/main/java/com/epita/creeps/units/Citizen.java

@@ -1,70 +0,0 @@
-package com.epita.creeps.units;
-
-import com.epita.creeps.AsyncExec;
-import com.epita.creeps.ServerReponseException;
-import com.epita.creeps.commands.Basics;
-import com.epita.creeps.given.exception.NoReportException;
-import com.epita.creeps.given.json.Json;
-import com.epita.creeps.given.vo.geometry.Direction;
-import com.epita.creeps.given.vo.geometry.Point;
-import com.epita.creeps.given.vo.parameter.MessageParameter;
-import com.epita.creeps.given.vo.report.MoveReport;
-import com.epita.creeps.given.vo.report.Report;
-import com.epita.creeps.given.vo.response.CommandResponse;
-import kong.unirest.core.HttpResponse;
-import kong.unirest.core.JsonNode;
-import kong.unirest.core.Unirest;
-
-import java.util.concurrent.CompletableFuture;
-
-
-public class Citizen extends Unit {
-
-    public Citizen(String login, String citizen_id, Point position) {
-        super(login, citizen_id, position);
-    }
-
-    public Citizen move(Direction direction) {
-        sendAction("move:"+direction.direction, 2);
-        return this;
-    }
-    public Citizen observe() {
-        sendAction("observe", 1);
-        return this;
-    }
-    public Citizen gather() {
-        sendAction("gather", 4);
-        return this;
-    }
-    public Citizen unload() {
-        sendAction("unload", 3);
-        return this;
-    }
-    public Citizen farm() {
-        sendAction("farm", 10);
-        return this;
-    }
-    public Citizen build(Building building) {
-        sendAction("build:" + building.name, 20);
-        return this;
-    }
-    public Citizen spawn(String unit) {
-        sendAction("spawn:" + unit, 6);
-        return this;
-    }
-    public Citizen refine(String resource) {
-        sendAction("refine:" + resource, 8);
-        return this;
-    }
-    public Citizen sendMessage(String receiver, String message) {
-        MessageParameter mp = new MessageParameter(receiver, message);
-        sendActionWithBody("message:send", Json.serialize(mp), 1);
-        return this;
-    }
-    public Citizen fetchMessages() {
-        sendAction("message:fetch", 1);
-        return this;
-    }
-
-
-}

src/main/java/com/epita/creeps/units/Turret.java

@@ -1,27 +0,0 @@
-package com.epita.creeps.units;
-
-import com.epita.creeps.given.extra.Cartographer;
-import com.epita.creeps.given.json.Json;
-import com.epita.creeps.given.vo.geometry.Point;
-import com.epita.creeps.given.vo.parameter.FireParameter;
-
-import java.util.List;
-
-public class Turret extends Unit {
-
-    public Turret(String login, String id, Point position) {
-        super(login, id, position);
-    }
-
-    // Retrieves all units that are turrets
-    public static List<Unit> getTurretUnits() {
-        return getUnits().stream().filter(unit -> unit.getClass() == Turret.class).toList();
-    }
-
-    public Turret fire(Point target) {
-        FireParameter fp = new FireParameter(target);
-        Cartographer cartographer = Cartographer.INSTANCE;
-        sendActionWithBody("fire:turret", Json.serialize(fp), 2);
-        return this;
-    }
-}

src/main/java/com/epita/creeps/units/Unit.java

@@ -1,113 +0,0 @@
-package com.epita.creeps.units;
-
-import com.epita.creeps.AsyncExec;
-import com.epita.creeps.ServerReponseException;
-import com.epita.creeps.commands.Basics;
-import com.epita.creeps.given.json.Json;
-import com.epita.creeps.given.vo.geometry.Point;
-import com.epita.creeps.given.vo.report.Report;
-import com.epita.creeps.given.vo.response.CommandResponse;
-import kong.unirest.core.HttpResponse;
-import kong.unirest.core.JsonNode;
-import kong.unirest.core.Unirest;
-import lombok.Getter;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-
-public abstract class Unit {
-
-    @Getter
-    private static final List<Unit> units = new ArrayList<>();
-    public static String srvUrl;
-    public static final Logger logger = LoggerFactory.getLogger(Unit.class);
-
-    protected final String id;
-    @Getter
-    protected final Point position;
-    protected final String command_uri;
-    protected CompletableFuture<HttpResponse<JsonNode>> pendingAction;
-    protected CompletableFuture<Report> pendingReport;
-    protected Report lastReport;
-    protected boolean idle = true;
-
-    public Unit(String login, String id, Point position) {
-        if (srvUrl == null) {
-            throw new RuntimeException("Tried to create a citizen without properly initializing static fields");
-        }
-        this.id = id;
-        this.position = position;
-        command_uri = srvUrl + "/command/" + login + "/" + id + "/";
-    }
-
-    // Sends a specific action to the server using it's HTTPS string representation
-    // Sets pending action accordingly and asks for a report after `delay` ticks
-    public void sendActionWithBody(String actionCode, String body, long delay) {
-        if (!idle) {
-//            logger.warn("Unit is already busy, queuing action");
-            this.waitFinished();
-        }
-        // Do
-        idle = false;
-        pendingAction = AsyncExec.asyncExec(() -> Unirest.post(command_uri + actionCode).body(body).asJson(), delay)
-                .thenApplyAsync( x -> x );
-        // Get report
-        pendingReport = getCommandReport();
-    }
-
-    // Just sends an action with an empty body
-    public void sendAction(String actionCode, long delay) {
-        sendActionWithBody(actionCode, "{}", delay);
-    }
-
-    public void upgrade() {
-        sendAction("upgrade", 1);
-    }
-    public void noop() {
-        sendAction("noop", 1);
-    }
-
-    /*
-     * @return true if action succeeded, false otherwise
-     */
-    public boolean waitFinished() {
-        if (idle) {
-            logger.warn("Tried to wait for an idle citizen");
-            return false;
-        }
-        if (pendingAction == null || pendingReport == null) {
-            logger.warn("Tried to wait a citizen with no pending action or report");
-            return false;
-        }
-        lastReport = pendingReport.join();
-        if (lastReport == null) {
-            logger.warn("Invalid report received: null value");
-            return false;
-        }
-//        logger.debug("Got report: " + lastReport);
-        idle = true;
-
-        return lastReport.errorCode != null;
-    }
-
-
-    // Retrieves the report of the current pending action from the server
-    private CompletableFuture<Report> getCommandReport() {
-        if (pendingAction == null) {
-            logger.warn("Tried to retrieve report but there's no pending action");
-            return null;
-        }
-        return AsyncExec.thenAsyncExec(pendingAction, x -> {
-            CommandResponse cr = Json.parse(x.getBody().toString(), CommandResponse.class);
-            if (cr.error != null) {
-                logger.debug("Server reponse: " + cr.toString());
-                throw new ServerReponseException("Error retrieving the report id");
-            }
-            String reportId = cr.reportId;
-            return Basics.getReport(reportId);
-        }, 0);
-    }
-}