fixed problem with cookies
This commit is contained in:
@@ -3,6 +3,7 @@ package de.srsoftware.cookies;
|
|||||||
|
|
||||||
import com.sun.net.httpserver.Headers;
|
import com.sun.net.httpserver.Headers;
|
||||||
import com.sun.net.httpserver.HttpExchange;
|
import com.sun.net.httpserver.HttpExchange;
|
||||||
|
import java.util.Arrays;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
@@ -35,8 +36,8 @@ public abstract class Cookie implements Map.Entry<String, String> {
|
|||||||
return value;
|
return value;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected static Optional<List<String>> of(HttpExchange ex) {
|
protected static List<String> of(HttpExchange ex) {
|
||||||
return Optional.ofNullable(ex.getRequestHeaders().get("Cookie"));
|
return Optional.ofNullable(ex.getRequestHeaders().get("Cookie")).stream().flatMap(List::stream).flatMap(s -> Arrays.stream(s.split(";"))).map(String::trim).toList();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ public class SessionToken extends Cookie {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public static Optional<SessionToken> from(HttpExchange ex) {
|
public static Optional<SessionToken> from(HttpExchange ex) {
|
||||||
return Cookie.of(ex).orElseGet(List::of).stream().filter(cookie -> cookie.startsWith("sessionToken=")).map(cookie -> cookie.split("=", 2)[1]).map(id -> new SessionToken(id)).findAny();
|
return Cookie.of(ex).stream().filter(cookie -> cookie.startsWith("sessionToken=")).map(cookie -> cookie.split("=", 2)[1]).map(id -> new SessionToken(id)).findAny();
|
||||||
}
|
}
|
||||||
|
|
||||||
public String sessionId() {
|
public String sessionId() {
|
||||||
|
|||||||
@@ -5,10 +5,7 @@ package de.srsoftware.oidc.app;
|
|||||||
import static de.srsoftware.oidc.api.Permission.MANAGE_CLIENTS;
|
import static de.srsoftware.oidc.api.Permission.MANAGE_CLIENTS;
|
||||||
|
|
||||||
import com.sun.net.httpserver.HttpServer;
|
import com.sun.net.httpserver.HttpServer;
|
||||||
import de.srsoftware.oidc.api.ClientService;
|
|
||||||
import de.srsoftware.oidc.api.SessionService;
|
|
||||||
import de.srsoftware.oidc.api.User;
|
import de.srsoftware.oidc.api.User;
|
||||||
import de.srsoftware.oidc.api.UserService;
|
|
||||||
import de.srsoftware.oidc.backend.Backend;
|
import de.srsoftware.oidc.backend.Backend;
|
||||||
import de.srsoftware.oidc.datastore.file.FileStore;
|
import de.srsoftware.oidc.datastore.file.FileStore;
|
||||||
import de.srsoftware.oidc.datastore.file.UuidHasher;
|
import de.srsoftware.oidc.datastore.file.UuidHasher;
|
||||||
@@ -40,13 +37,10 @@ public class Application {
|
|||||||
var firstHash = passwordHasher.hash(FIRST_USER_PASS, FIRST_UUID);
|
var firstHash = passwordHasher.hash(FIRST_USER_PASS, FIRST_UUID);
|
||||||
var firstUser = new User(FIRST_USER, firstHash, FIRST_USER, "%s@internal".formatted(FIRST_USER), FIRST_UUID).add(MANAGE_CLIENTS);
|
var firstUser = new User(FIRST_USER, firstHash, FIRST_USER, "%s@internal".formatted(FIRST_USER), FIRST_UUID).add(MANAGE_CLIENTS);
|
||||||
FileStore fileStore = new FileStore(storageFile, passwordHasher).init(firstUser);
|
FileStore fileStore = new FileStore(storageFile, passwordHasher).init(firstUser);
|
||||||
ClientService clientService = fileStore;
|
|
||||||
SessionService sessionService = fileStore;
|
|
||||||
UserService userService = fileStore;
|
|
||||||
HttpServer server = HttpServer.create(new InetSocketAddress(8080), 0);
|
HttpServer server = HttpServer.create(new InetSocketAddress(8080), 0);
|
||||||
new StaticPages(basePath).bindPath(STATIC_PATH, FAVICON).on(server);
|
new StaticPages(basePath).bindPath(STATIC_PATH, FAVICON).on(server);
|
||||||
new Forward(INDEX).bindPath(ROOT).on(server);
|
new Forward(INDEX).bindPath(ROOT).on(server);
|
||||||
new Backend(clientService, sessionService, userService).bindPath(BACKEND, WELL_KNOWN).on(server);
|
new Backend(fileStore, fileStore, fileStore).bindPath(BACKEND, WELL_KNOWN).on(server);
|
||||||
server.setExecutor(Executors.newCachedThreadPool());
|
server.setExecutor(Executors.newCachedThreadPool());
|
||||||
server.start();
|
server.start();
|
||||||
}
|
}
|
||||||
@@ -55,11 +49,11 @@ public class Application {
|
|||||||
var tokens = new ArrayList<>(List.of(args));
|
var tokens = new ArrayList<>(List.of(args));
|
||||||
var map = new HashMap<String, Object>();
|
var map = new HashMap<String, Object>();
|
||||||
while (!tokens.isEmpty()) {
|
while (!tokens.isEmpty()) {
|
||||||
var token = tokens.remove(0);
|
var token = tokens.removeFirst();
|
||||||
switch (token) {
|
switch (token) {
|
||||||
case "--base":
|
case "--base":
|
||||||
if (tokens.isEmpty()) throw new IllegalArgumentException("--path option requires second argument!");
|
if (tokens.isEmpty()) throw new IllegalArgumentException("--path option requires second argument!");
|
||||||
map.put(BASE_PATH, Path.of(tokens.remove(0)));
|
map.put(BASE_PATH, Path.of(tokens.removeFirst()));
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
System.err.printf("Unknown option: %s\n", token);
|
System.err.printf("Unknown option: %s\n", token);
|
||||||
|
|||||||
Reference in New Issue
Block a user