HTTP API endpoint on port 8070

Author: BalaM314

README.md

@@ -1,23 +1,17 @@
+# Fish API
+
 ### Setup
 
 Clone this repository first.
 To edit the plugin display name and other data, take a look at `plugin.json`.
 Edit the name of the project itself by going into `settings.gradle`.
 
-### Basic Usage
-
-See `src/example/ExamplePlugin.java` for some basic commands and event handlers.  
-Every main plugin class must extend `Plugin`. Make sure that `plugin.json` points to the correct main plugin class.
-
-Please note that the plugin system is in beta, and as such is subject to changes.
-
 ### Building a Jar
 
 `gradlew jar` / `./gradlew jar`
 
 Output jar should be in `build/libs`.
 
-
 ### Installing
 
 Simply place the output jar from the step above in your server's `config/mods` directory and restart the server.

build.gradle

@@ -17,7 +17,7 @@ repositories{
 
 ext{
     //the build number that this plugin is made for
-    mindustryVersion = 'v145'
+    mindustryVersion = 'v146'
     jabelVersion = "93fde537c7"
 }
 

plugin.json

@@ -1,7 +1,7 @@
 {
-  "name": "ExamplePlugin",
-  "author": "Anuke",
-  "main": "example.ExamplePlugin",
-  "description": "A plugin to demonstrate some basic features.",
+  "name": "Fish API",
+  "author": "BalaM314",
+  "main": "fish.api.FishApiPlugin",
+  "description": "Contains an HTTP API, and exposes certain functions to JS.",
   "version": 1.0
-}
+}

src/example/ExamplePlugin.java

@@ -0,0 +1,22 @@
+package fish.api;
+
+import arc.util.*;
+import fish.api.http.Api;
+import mindustry.mod.*;
+
+import java.io.IOException;
+
+public class FishApiPlugin extends Plugin {
+
+	//called when game initializes
+	@Override
+	public void init(){
+		try {
+			Api.setupServer(8070);
+		} catch(IOException e){
+			Log.err("Failed to setup the API server");
+			e.printStackTrace();
+		}
+	}
+
+}

src/fish/api/FishApiPlugin.java

@@ -0,0 +1,83 @@
+package fish.api.http;
+
+import arc.ApplicationListener;
+import arc.Core;
+import arc.util.Log;
+import arc.util.Threads;
+import arc.util.serialization.*;
+import com.sun.net.httpserver.*;
+import java.io.*;
+import java.net.*;
+import mindustry.*;
+import mindustry.core.*;
+import mindustry.gen.*;
+import mindustry.net.Administration.*;
+
+
+public class Api {
+	static HttpServer server;
+
+	public static void respondString(HttpExchange t, int status, String data) throws IOException {
+		var bytes = data.getBytes();
+		t.getResponseHeaders().add("Content-Type", "application/json");
+		t.sendResponseHeaders(status, bytes.length);
+		OutputStream os = t.getResponseBody();
+		os.write(bytes);
+		os.close();
+		Log.info("Done");
+	}
+
+	public static void respondBlank(HttpExchange t, int status) throws IOException {
+		t.sendResponseHeaders(status, 0);
+		t.getResponseBody().close();
+	}
+
+	public static void writeStatus(JsonWriter json) throws IOException {
+		String description = !Config.desc.string().equals("off") ? Config.desc.string() : "";
+
+		json.object()
+			.name("name").value(Config.serverName.string())
+			.name("description").value(description)
+			.name("mapName").value(Vars.state.map.name())
+			.name("playerCount").value(Groups.player.size())
+			.name("limit").value(Vars.netServer.admins.getPlayerLimit())
+			.name("wave").value(Vars.state.wave)
+			.name("version").value(Version.build)
+			.name("gamemode").value(Vars.state.rules.mode());
+	}
+
+	public static void setupServer(int port) throws IOException {
+		server = HttpServer.create(new InetSocketAddress(port), 0);
+		server.createContext("/api", t -> {
+			try {
+				switch(t.getRequestMethod()){
+					case "GET" -> {
+						switch(t.getRequestURI().getPath()){
+							case "/api/v1/status" -> {
+								var buffer = new StringWriter();
+								var writer = new JsonWriter(buffer);
+								writeStatus(writer);
+								writer.close();
+								Log.info(buffer.toString());
+								respondString(t, 200, buffer.toString());
+							}
+							default -> respondBlank(t, 404);
+						}
+					}
+					default -> respondBlank(t, 405);
+				}
+			} catch(Exception e){
+				e.printStackTrace();
+				respondBlank(t, 500);
+			}
+		});
+		server.setExecutor(Threads.executor("http", 1));
+		server.start();
+		Core.app.addListener(new ApplicationListener() {
+			@Override
+			public void dispose() {
+				server.stop(0);
+			}
+		});
+	}
+}