TudbuT/Tryumph
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: TudbuT:bfcee3705d559309af24751a552d27f008873a00
Branches Tags
TudbuT:master
..
compare: TudbuT:80c7e0961a8f0e34ed7828d24a2e0f011e92cdb9
Branches Tags
TudbuT:master

No commits in common. "bfcee3705d559309af24751a552d27f008873a00" and "80c7e0961a8f0e34ed7828d24a2e0f011e92cdb9" have entirely different histories.
bfcee3705d ... 80c7e0961a

5 changed files with 36 additions and 77 deletions
Show stats Expand all files Collapse all files

6
src/de/tudbut/tryumph/Launch.java
View file

@ -1,10 +1,14 @@
package de.tudbut.tryumph;
import java.util.Arrays;
import de.tudbut.async.Task;
import de.tudbut.tryumph.config.IRequestCatcher;
import de.tudbut.tryumph.config.RequestCatcherConfig;
import de.tudbut.tryumph.config.TryConfig;
import de.tudbut.tryumph.err.ProjectException;
import de.tudbut.tryumph.server.http.Server;
import de.tudbut.tryumph.util.Bug;
import tudbut.global.DebugStateManager;
public class Launch {
@ -28,7 +32,7 @@ public class Launch {
IRequestCatcher requestCatcher = catcher.load().ok().await();
server.listen(requestCatcher);
} catch(Throwable e) {
throw new Error("HTTP Server died.", e);
throw new Bug("HTTP server died, but all errors from HTTP should usually be catched", e);
}
}

32
src/de/tudbut/tryumph/example/FileServer.java
View file

@ -1,6 +1,5 @@
package de.tudbut.tryumph.example;
import java.io.File;
import java.net.Socket;
import org.w3c.dom.Document;
@ -8,14 +7,12 @@ import org.w3c.dom.Element;
import de.tudbut.async.Callback;
import de.tudbut.async.ComposeCallback;
import de.tudbut.async.Task;
import de.tudbut.async.TaskCallable;
import de.tudbut.tryumph.config.IRequestCatcher;
import de.tudbut.tryumph.config.TryConfig;
import de.tudbut.tryumph.events.GET;
import de.tudbut.tryumph.events.Path;
import de.tudbut.tryumph.events.RequestHandler;
import de.tudbut.tryumph.server.BrowserContext;
import de.tudbut.tryumph.server.Request;
import de.tudbut.tryumph.server.Response;
import tudbut.parsing.TCN;
@ -61,28 +58,28 @@ public class FileServer implements IRequestCatcher, RequestHandler.Listener {
private String fileContent(Request request, String s) {
String r;
if(new File(s + "/index.html").exists())
s += "/index.html";
if(!s.endsWith(".html") && !s.endsWith(".htm") && !(new File(s).isDirectory())) {
r = request.context.fileUTF(s, data.getBoolean("autoindex") ? request.realPath : null);
if(!s.endsWith(".html") && !s.endsWith(".htm")) {
r = request.context.file(s);
r = "<pre>" + r.replace("<", "&lt;").replace(">", "&gt;") + "</pre>";
}
else
r = request.context.fileUTF(s, data.getBoolean("autoindex") ? request.realPath : null);
r = request.context.fileUTF(s);
return r;
}
@GET
@Path("/.*")
@Path(".*/")
public void onIndex(Request request, Callback<Response> res, Callback<Throwable> rej) {
res.call(new Response(request, fileContent(request, data.getString("dir") + request.realPath.replace("..", "") + "/index.html"), 200, "OK"));
}
@GET
@Path("/.+")
public void onFile(Request request, Callback<Response> res, Callback<Throwable> rej) {
if(request.realPath.equals("/style.css")) {
res.call(new Response(request, request.context.file("style.css"), 200, "OK", "text/css"));
return;
}
if(request.realPath.matches("/.$|/./|/..$|/../")) {
res.call(new Response(request, "<h1>" + request.realPath + " is an illegal path</h1>", 400, "Bad request"));
return;
}
res.call(new Response(request, fileContent(request, data.getString("dir") + request.realPath.replace("..", "")), 200, "OK"));
}
@ -91,13 +88,4 @@ public class FileServer implements IRequestCatcher, RequestHandler.Listener {
rej.call(error);
}
@Override
public Task<BrowserContext> processBrowserContext(BrowserContext context) {
if(data.getBoolean("noscript") != null)
context.addJavaScript = !data.getBoolean("noscript");
if(data.getBoolean("cookies") != null)
context.addState = data.getBoolean("cookies");
return IRequestCatcher.super.processBrowserContext(context);
}
}

57
src/de/tudbut/tryumph/server/BrowserContext.java
View file

@ -3,7 +3,6 @@ package de.tudbut.tryumph.server;
import static de.tudbut.async.Async.*;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
@ -27,9 +26,8 @@ public class BrowserContext {
public final UUID uuid = UUID.randomUUID();
public TCN data;
private final IRequestCatcher requestCatcher;
public boolean useJavaScript = false;
private boolean needsChange = false;
public boolean addState = true;
public boolean addJavaScript = true;
private BrowserContext(IRequestCatcher requestCatcher) {
this.requestCatcher = requestCatcher;
@ -66,8 +64,7 @@ public class BrowserContext {
private Task<BrowserContext> init() {
return t((res, rej) -> {
requestCatcher.processBrowserContext(this).err(rej).then(res).ok();
if(addState)
needsChange = true;
needsChange = true;
});
}
@ -80,7 +77,7 @@ public class BrowserContext {
public Task<Response> onSend(Response response) {
return AsyncJSON.write(data)
.compose((resp, res, rej) -> {
if(addJavaScript && response.isHTML) {
if(response.isHTML) {
Document document = response.getHTML();
Element element = document.createElement("script");
Node text = document.createTextNode(
@ -112,13 +109,11 @@ public class BrowserContext {
head.appendChild(element);
response.updateHTMLData();
}
if(addState) {
if(needsChange) {
response.cookiesToSet.put("tryumph.data", resp);
needsChange = false;
}
response.cookiesToSet.put("tryumph.uuid", uuid.toString());
if(needsChange) {
response.cookiesToSet.put("tryumph.data", resp);
needsChange = false;
}
response.cookiesToSet.put("tryumph.uuid", uuid.toString());
res.call(response);
});
}
@ -129,37 +124,20 @@ public class BrowserContext {
private static final HashMap<String, String> cache = new HashMap<>();
public String file(String file) {
return file(file, null);
}
public String fileUTF(String file) {
return fileUTF(file, null);
}
public String file(String file, String path) {
if(cache.containsKey(file))
return cache.get(file);
StringBuilder builder = new StringBuilder();
try {
InputStream stream = requestCatcher.getClass().getClassLoader().getResourceAsStream(file);
if(stream == null) {
if(new File(file).isDirectory() && path != null) {
while(path.endsWith("/")) path = path.substring(0, path.length() - 1);
File[] files = new File(file).listFiles();
builder.append("<ul>");
for(int i = 0; i < files.length; i++) {
builder.append("<li><a href=\"" + path + "/" + files[i].getName() + "\">" + files[i].getName() + "</a></li>");
}
builder.append("</ul>");
return builder.toString();
}
if(stream == null)
stream = new FileInputStream(file);
}
int i = 0;
while((i = stream.read()) != -1) {
builder.append((char) i);
}
stream.close();
if(!TryConfig.nocache)
cache.put(file, builder.toString());
} catch (IOException e) {
@ -168,26 +146,14 @@ public class BrowserContext {
}
return builder.toString();
}
public String fileUTF(String file, String path) {
public String fileUTF(String file) {
if(cache.containsKey(file))
return cache.get(file);
String st = null;
try {
InputStream stream = requestCatcher.getClass().getClassLoader().getResourceAsStream(file);
if(stream == null) {
if(new File(file).isDirectory() && path != null) {
while(path.endsWith("/")) path = path.substring(0, path.length() - 1);
File[] files = new File(file).listFiles();
StringBuilder builder = new StringBuilder();
builder.append("<ul>");
for(int i = 0; i < files.length; i++) {
builder.append("<li><a href=\"" + path + "/" + files[i].getName() + "\">" + files[i].getName() + "</a></li>");
}
builder.append("</ul>");
return builder.toString();
}
if(stream == null)
stream = new FileInputStream(file);
}
ByteArrayOutputStream s = new ByteArrayOutputStream();
int i = 0;
@ -198,7 +164,6 @@ public class BrowserContext {
stream.close();
s.close();
st = new String(s.toByteArray());
if(!TryConfig.nocache)
cache.put(file, st);
} catch (IOException e) {

13
src/de/tudbut/tryumph/server/http/Server.java
View file

@ -93,11 +93,18 @@ public class Server {
break;
}
} catch (Stop stop) {
if(stop.getMessage() != null) {
System.out.println("Connection stopped: " + stop.getMessage());
}
else {
System.out.println("Connection stopped");
}
}
try {
socket.close();
} catch (IOException e) {
}
socket.close();
} catch (IOException e) {
}
System.out.println("Connection with " + socket + " ended");
}).start();
}
serverSocket.close();

5
style.css
View file

@ -39,8 +39,3 @@ input,button,select {
input.button,button,select {
border: 1px solid #cdd;
}
a {
color: #fff;
text-decoration: underline dashed #888 1px;
}