mirror of https://github.com/webbukkit/dynmap.git
113 lines
3.3 KiB
Java
113 lines
3.3 KiB
Java
import java.io.*;
|
|
import java.net.*;
|
|
import java.util.*;
|
|
|
|
import java.util.logging.Logger;
|
|
|
|
public class WebServerRequest extends Thread {
|
|
protected static final Logger log = Logger.getLogger("Minecraft");
|
|
|
|
private Socket sock;
|
|
private MapManager mgr;
|
|
|
|
public WebServerRequest(Socket socket, MapManager mgr)
|
|
{
|
|
sock = socket;
|
|
this.mgr = mgr;
|
|
}
|
|
|
|
private static void sendHeader(BufferedOutputStream out, int code, String contentType, long contentLength, long lastModified) throws IOException
|
|
{
|
|
out.write(("HTTP/1.0 " + code + " OK\r\n" +
|
|
"Date: " + new Date().toString() + "\r\n" +
|
|
"Server: JibbleWebServer/1.0\r\n" +
|
|
"Content-Type: " + contentType + "\r\n" +
|
|
"Expires: Thu, 01 Dec 1994 16:00:00 GMT\r\n" +
|
|
((contentLength != -1) ? "Content-Length: " + contentLength + "\r\n" : "") +
|
|
"Last-modified: " + new Date(lastModified).toString() + "\r\n" +
|
|
"\r\n").getBytes());
|
|
}
|
|
|
|
private static void sendError(BufferedOutputStream out, int code, String message) throws IOException
|
|
{
|
|
message = message + "<hr>" + WebServer.VERSION;
|
|
sendHeader(out, code, "text/html", message.length(), System.currentTimeMillis());
|
|
out.write(message.getBytes());
|
|
out.flush();
|
|
out.close();
|
|
}
|
|
|
|
public void run()
|
|
{
|
|
InputStream reader = null;
|
|
try {
|
|
sock.setSoTimeout(30000);
|
|
BufferedReader in = new BufferedReader(new InputStreamReader(sock.getInputStream()));
|
|
BufferedOutputStream out = new BufferedOutputStream(sock.getOutputStream());
|
|
|
|
String request = in.readLine();
|
|
if (request == null || !request.startsWith("GET ") || !(request.endsWith(" HTTP/1.0") || request.endsWith("HTTP/1.1"))) {
|
|
// Invalid request type (no "GET")
|
|
sendError(out, 500, "Invalid Method.");
|
|
return;
|
|
}
|
|
|
|
String path = request.substring(4, request.length() - 9);
|
|
|
|
int current = (int) (System.currentTimeMillis() / 1000);
|
|
long cutoff = 0;
|
|
if(path.charAt(0) == '/') {
|
|
try {
|
|
cutoff = ((long) Integer.parseInt(path.substring(1))) * 1000;
|
|
} catch(NumberFormatException e) {
|
|
}
|
|
}
|
|
|
|
sendHeader(out, 200, "text/plain", -1, System.currentTimeMillis());
|
|
|
|
StringBuilder sb = new StringBuilder();
|
|
sb.append(current + "\n");
|
|
|
|
for(Player player : etc.getServer().getPlayerList()) {
|
|
sb.append(player.getName() + " " + player.getX() + " " + player.getY() + " " + player.getZ() + "\n");
|
|
}
|
|
|
|
for(MapMarker marker : mgr.markers.values())
|
|
{
|
|
sb.append(marker.name + " marker " + marker.owner + " " + marker.px + " " + marker.py + " " + marker.pz + "\n");
|
|
}
|
|
|
|
// TODO: Find a way to load the warps from the server. Currently loading the from the flatfile over and over...
|
|
ArrayList<Warp> warps = mgr.loadWarps();
|
|
|
|
for(Warp warp : warps)
|
|
{
|
|
sb.append(warp.Name + " warp unknown " + warp.Location.x + " " + warp.Location.y + " " + warp.Location.z + "\n");
|
|
}
|
|
|
|
synchronized(mgr.lock) {
|
|
for(TileUpdate tu : mgr.tileUpdates) {
|
|
if(tu.at >= cutoff) {
|
|
sb.append(tu.tile.px + "_" + tu.tile.py + " " + tu.tile.zpx + "_" + tu.tile.zpy + "\n");
|
|
}
|
|
}
|
|
}
|
|
|
|
out.write(sb.toString().getBytes());
|
|
|
|
out.flush();
|
|
out.close();
|
|
}
|
|
catch (IOException e) {
|
|
if (reader != null) {
|
|
try {
|
|
reader.close();
|
|
}
|
|
catch (Exception anye) {
|
|
// Do nothing.
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|