00asdf/LibHttpServer
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

Compare commits

base: 00asdf:master
Branches Tags
00asdf:master
00asdf:0.0.1
..
compare: 00asdf:0.0.1
Branches Tags
00asdf:master
00asdf:0.0.1

No commits in common. "master" and "0.0.1" have entirely different histories.
master ... 0.0.1

6 changed files with 75 additions and 109 deletions
Show Stats Expand all files Collapse all files

122
src/dev/asdf00/lib/httpserver/HttpServerApi.java
View File

@ -30,7 +30,7 @@ public class HttpServerApi {
throw new HttpHandlingException(404);
}
public static HttpServer create(int port, String rootLocation, Executor exec, Class<?>... apiDefinitions) throws IOException {
public static HttpServer create(int port, String rootLocation, Class<?> apiDefinition, Executor exec) throws IOException {
HttpServer server = HttpServer.create(new InetSocketAddress( port), 0);
server.setExecutor(exec);
@ -38,68 +38,66 @@ public class HttpServerApi {
HashMap<String, EndpointContainer>[] endpoints = new HashMap[3];
HashSet<String> locations = new HashSet<>();
for (int i = 0; i < endpoints.length; endpoints[i++] = new HashMap<>());
for (var apiDefinition : apiDefinitions) {
endpointLoop:
for (Method endpoint : apiDefinition.getDeclaredMethods()) {
HttpEndpoint spec = endpoint.getAnnotation(HttpEndpoint.class);
if (spec == null || spec.type() == INVALID) {
continue;
}
if (!endpoint.getReturnType().equals(Response.class)) {
System.err.printf("invalid return type %s!\nskipping %s ...\n", endpoint.getReturnType().getSimpleName(), endpoint.getName());
continue;
}
RequestType type = spec.type();
String location = spec.location();
HashMap<String, EndpointContainer> epMap = endpoints[type.id];
if (epMap.containsKey(location)) {
System.err.printf("HttpEndpoint for type %s and location \"%s\" is defined multiple times!\nskipping %s ...\n",
type.name(), location, endpoint.getName());
continue;
}
Parameter[] params = endpoint.getParameters();
if (params.length < 1 || !HttpExchange.class.equals(params[0].getType())) {
System.err.printf("HttpEndpoint must have HttpExchange as first parameter!\nskipping %s ...\n",
endpoint.getReturnType().getSimpleName(), endpoint.getName());
continue;
}
params = Arrays.stream(params).skip(1).toArray(Parameter[]::new);
Class<?>[] pTypes = Arrays.stream(params).map(p -> p.getType()).toArray(Class[]::new);
String[] pNames = new String[params.length];
String[] stringVals = new String[params.length];
for (int i = 0; i < params.length; i++) {
QParam name = params[i].getAnnotation(QParam.class);
if (name == null) {
System.err.printf("missing QParam annotation!\nskipping %s ...\n", endpoint.getName());
continue endpointLoop;
}
pNames[i] = name.name();
stringVals[i] = name.empty();
}
Object[] pDefaults = new Object[pTypes.length];
try {
for (int i = 0; i < pTypes.length; i++) {
pDefaults[i] = parseValue(pTypes[i], stringVals[i]);
}
} catch (IllegalArgumentException e) {
System.err.printf("encountered error setting up HttpEndpoint (%s)!\nskipping %s ...\n", e.getMessage(), endpoint.getName());
continue;
}
Authorizer auth;
try {
auth = spec.auth().getConstructor().newInstance();
} catch (ReflectiveOperationException e) {
System.err.printf("encountered error setting up HttpEndpoint (%s)!\nskipping %s ...\n", e.getMessage(), endpoint.getName());
continue;
}
epMap.put(location, new EndpointContainer(endpoint, auth, pTypes, pNames, pDefaults));
locations.add(location);
endpointLoop:
for (Method endpoint : apiDefinition.getDeclaredMethods()) {
HttpEndpoint spec = endpoint.getAnnotation(HttpEndpoint.class);
if (spec == null || spec.type() == INVALID) {
continue;
}
if (!endpoint.getReturnType().equals(Response.class)) {
System.err.printf("invalid return type %s!\nskipping %s ...\n", endpoint.getReturnType().getSimpleName(), endpoint.getName());
continue;
}
RequestType type = spec.type();
String location = spec.location();
HashMap<String, EndpointContainer> epMap = endpoints[type.id];
if (epMap.containsKey(location)) {
System.err.printf("HttpEndpoint for type %s and location \"%s\" is defined multiple times!\nskipping %s ...\n",
type.name(), location, endpoint.getName());
continue;
}
Parameter[] params = endpoint.getParameters();
if (params.length < 1 || !HttpExchange.class.equals(params[0].getType())) {
System.err.printf("HttpEndpoint must have HttpExchange as first parameter!\nskipping %s ...\n",
endpoint.getReturnType().getSimpleName(), endpoint.getName());
continue;
}
params = Arrays.stream(params).skip(1).toArray(Parameter[]::new);
Class<?>[] pTypes = Arrays.stream(params).map(p -> p.getType()).toArray(Class[]::new);
String[] pNames = new String[params.length];
String[] stringVals = new String[params.length];
for (int i = 0; i < params.length; i++) {
QParam name = params[i].getAnnotation(QParam.class);
if (name == null) {
System.err.printf("missing QParam annotation!\nskipping %s ...\n", endpoint.getName());
continue endpointLoop;
}
pNames[i] = name.name();
stringVals[i] = name.empty();
}
Object[] pDefaults = new Object[pTypes.length];
try {
for (int i = 0; i < pTypes.length; i++) {
pDefaults[i] = parseValue(pTypes[i], stringVals[i]);
}
} catch (IllegalArgumentException e) {
System.err.printf("encountered error setting up HttpEndpoint (%s)!\nskipping %s ...\n", e.getMessage(), endpoint.getName());
continue;
}
Authorizer auth;
try {
auth = spec.auth().getConstructor().newInstance();
} catch (ReflectiveOperationException e) {
System.err.printf("encountered error setting up HttpEndpoint (%s)!\nskipping %s ...\n", e.getMessage(), endpoint.getName());
continue;
}
epMap.put(location, new EndpointContainer(endpoint, auth, pTypes, pNames, pDefaults));
locations.add(location);
}
// create appropriate contexts and headers

19
src/dev/asdf00/lib/httpserver/HttpServerApiUtils.java
View File

@ -5,13 +5,10 @@ import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpPrincipal;
import dev.asdf00.lib.httpserver.exceptions.HttpHandlingException;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.*;
import java.net.URI;
import java.nio.file.InvalidPathException;
import java.nio.file.Path;
import java.util.List;
import java.util.Map;
import java.util.stream.Stream;
@ -86,18 +83,4 @@ public class HttpServerApiUtils {
}
throw new IllegalArgumentException(type.getSimpleName() + " is not a primitive");
}
public static String readCookie(String key, List<String> cookies) {
String value = null;
outer:
for (var cookie : cookies) {
for (String s : cookie.split("; ")) {
if (s.startsWith(key + "=")) {
value = s.substring(key.length() + 1);
break outer;
}
}
}
return value;
}
}

9
src/dev/asdf00/lib/httpserver/internal/HttpHandlerImpl.java
View File

@ -2,8 +2,8 @@ package dev.asdf00.lib.httpserver.internal;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import dev.asdf00.lib.httpserver.HttpServerApiUtils;
import dev.asdf00.lib.httpserver.exceptions.HttpHandlingException;
import dev.asdf00.lib.httpserver.utils.ContentType;
import dev.asdf00.lib.httpserver.utils.RequestType;
import dev.asdf00.lib.httpserver.utils.Response;
@ -28,7 +28,7 @@ public class HttpHandlerImpl implements HttpHandler {
EndpointContainer target = endpointContainer[type.id];
if (!target.auth.isAuthenticated(exchange)) {
throw new HttpHandlingException(498);
throw new HttpHandlingException(402);
}
String query = exchange.getRequestURI().getQuery();
@ -47,8 +47,9 @@ public class HttpHandlerImpl implements HttpHandler {
} else if (e instanceof IndexOutOfBoundsException) {
errorCode = 400;
}
Response r = new Response(exchange).status(errorCode).contentType(ContentType.HTML);
r.append(String.format("<p><img src=\"https://http.cat/%s\" /></p>\n<h3>&nbsp;</h3><h3>Error message:</h3>\n<p>\n%s\n</p>", errorCode, e.getMessage()));
Response r = new Response(exchange).status(errorCode).contentType(Response.ContentType.HTML);
r.append(String.format("<h1>ERROR %s</h1>\n", errorCode));
r.append(String.format("<p>something fucky is a foot!\n%s</p>", e.getMessage()));
r.send();
}
}

12
src/dev/asdf00/lib/httpserver/utils/ContentType.java
View File

@ -1,12 +0,0 @@
package dev.asdf00.lib.httpserver.utils;
public enum ContentType {
PLAIN("text/plain"),
HTML("text/html"),
JS("application/javascript"),
JSON("application/json");
public final String type;
ContentType(String type) {
this.type = type;
}
}

15
src/dev/asdf00/lib/httpserver/utils/Response.java
View File

@ -9,7 +9,15 @@ import java.util.stream.Collectors;
import java.util.stream.Stream;
public class Response {
public enum ContentType {
PLAIN("text/plain"),
HTML("text/html"),
JS("text/javascript");
private final String type;
ContentType(String type) {
this.type = type;
}
}
private int statusCode = 500;
private ContentType cType = ContentType.PLAIN;
@ -31,11 +39,6 @@ public class Response {
return this;
}
public Response append(String format, Object... params) {
response.append(String.format(format, params));
return this;
}
public Response append(String line) {
response.append(line);
return this;

7
src/module-info.java
View File

@ -1,7 +0,0 @@
module asdf00.lib.httpserver {
requires jdk.httpserver;
exports dev.asdf00.lib.httpserver;
exports dev.asdf00.lib.httpserver.annotations;
exports dev.asdf00.lib.httpserver.exceptions;
exports dev.asdf00.lib.httpserver.utils;
}