src/dev/peerat/backend/Main.java

@@ -59,20 +59,18 @@ public class Main{
 			for(Entry<String, Object> entry : json.entries()) params.put(entry.getKey(), entry.getValue());
 			auth = new JwtAuthenticator<PeerAtUser>().configure(
 					(builder) -> builder.setExpectedIssuer(config.getTokenIssuer()),
-					(claims, user) -> {
+					(claims) -> {
 						claims.setIssuer(config.getTokenIssuer());
 						claims.setExpirationTimeMinutesInTheFuture(config.getTokenExpiration());
-						user.write(claims);
 					}, 
 					(claims) -> new PeerAtUser(claims),
 					params);
 		}else{
 			auth = new JwtAuthenticator<PeerAtUser>().configure(
 					(builder) -> builder.setExpectedIssuer(config.getTokenIssuer()),
-					(claims, user) -> {
+					(claims) -> {
 						claims.setIssuer(config.getTokenIssuer());
 						claims.setExpirationTimeMinutesInTheFuture(config.getTokenExpiration());
-						user.write(claims);
 					}, 
 					(claims) -> new PeerAtUser(claims));
 			JsonMap json = new JsonMap();
@@ -129,6 +127,7 @@ public class Main{
 				locker.init(key);
 				try {
 					while(true){
+						locker.lock(key);
 						Context instance = locker.getValue(key);
 						if(instance == null) continue;
 						System.out.println("["+((instance.isLogged()) ? repo.getPlayerRepository().getPlayer(instance.<PeerAtUser>getUser().getId()).getPseudo() : "?")+"] "+instance.getType()+" "+instance.getPath()+" -> "+instance.getResponseCode());
@@ -142,7 +141,20 @@ public class Main{
 		
 		new Thread(new Runnable(){
 			public void run(){
-				router.getExceptionLogger().listen((throwable) -> throwable.printStackTrace(), (exception) -> exception.printStackTrace());
+				Key key = new Key();
+				
+				Locker<Throwable> locker = router.getExceptionLogger();
+				
+				locker.init(key);
+				try {
+					while(true){
+						locker.lock(key);
+						locker.getValue(key).printStackTrace();
+					}
+				}catch(Exception e){
+					e.printStackTrace();
+				}
+				locker.remove(key);
 			}
 		}).start();
 		
@@ -159,7 +171,6 @@ public class Main{
 			return false;
 		};
 		
-		
 		router.registerPackages("dev.peerat.backend.routes",new DependencyInjector()
 				.of(repo, router, config, new RouteExtracter(router), config.getMail(), isAdmin)
 				.of("waitting", new HashMap<>())

src/dev/peerat/backend/bonus/discord/Bot.java

@@ -55,6 +55,7 @@ public class Bot extends Thread{
 			}
 			
 			while(true){
+				locker.lock(key);
 				Group group = locker.getValue(key);
 				Integer chapter = group.getLinkToChapter();
 //				Integer puzzle = group.getLinkToPuzzle();

src/dev/peerat/backend/model/PeerAtUser.java

@@ -14,6 +14,7 @@ public class PeerAtUser extends dev.peerat.framework.User{
 		this.id = ((Long) claims.getClaimValue("id")).intValue();
 	}
 	
+	@Override
 	public void write(JwtClaims claims){
 		claims.setClaim("id", this.id);
 	}

src/dev/peerat/backend/routes/DynamicLeaderboard.java

@@ -41,6 +41,7 @@ public class DynamicLeaderboard extends Leaderboard{
 				}else{
 					playersLeaderboard(writer);
 				}
+				locker.lock(key);
 			}
 		}catch(Exception e){
 			e.printStackTrace();

src/dev/peerat/backend/routes/EventSSE.java

@@ -28,6 +28,7 @@ public class EventSSE{
 		locker.init(key);
 		try {
 			while(true){
+				locker.lock(key);
 				GroupMessage message = locker.getValue(key);
 				if(message.getGroup() == null || message.getGroup().equals(group)){
 					JsonMap send = new JsonMap();

src/dev/peerat/backend/routes/PuzzleResponse.java

@@ -115,7 +115,7 @@ public class PuzzleResponse implements Response {
 		writer.write(responseJSON.toString());
 		writer.flush();
 		
-		leaderboard.pushValue(completion);
+		leaderboard.setValue(completion);
 	}
 
 	private void saveSourceCode(ReceivedResponse received, Player player){

src/dev/peerat/backend/routes/admins/GroupController.java

@@ -25,7 +25,7 @@ public class GroupController {
 			return;
 		}
 		
-		locker.pushValue(new GroupMessage(json.get("group"), json.get("message")));
+		locker.setValue(new GroupMessage(json.get("group"), json.get("message")));
 		context.response(200);
 	}
 

src/dev/peerat/backend/routes/admins/LogController.java

@@ -63,6 +63,7 @@ public class LogController {
 		locker.init(key);
 		try {
 			while(!reader.isClosed()){
+				locker.lock(key);
 				T instance  = locker.getValue(key);
 				JsonMap json = new JsonMap();
 				consumer.accept(json, instance);

src/dev/peerat/backend/routes/admins/WebHookLeaderboard.java

@@ -21,7 +21,7 @@ public class WebHookLeaderboard implements Response{
 	
 	@Route(path = "^/admin/webhook/leaderboard/$", needLogin = true)
 	public void exec(Matcher matcher, Context context, HttpReader reader, HttpWriter writer) throws Exception{
-		locker.pushValue(new Completion(0, 0));
+		locker.setValue(new Completion(0, 0));
 		context.response(200);
 	}
 

src/dev/peerat/backend/routes/groups/GroupCreate.java

@@ -71,7 +71,7 @@ public class GroupCreate extends FormResponse {
 				if (this.repo.insertGroup(newGroup, user)) {
 					context.response(200);
 					
-					locker.pushValue(newGroup);
+					locker.setValue(newGroup);
 				} else {
 					context.response(403);
 				}

src/dev/peerat/backend/routes/groups/GroupJoin.java

@@ -75,7 +75,7 @@ public class GroupJoin implements Response{
 		if (this.groupRepo.insertUserInGroup(group, user)) {
 			context.response(200);
 			
-			leaderboard.pushValue(new Completion(0, 0, 0, null, 0));
+			leaderboard.setValue(new Completion(0, 0, 0, null, 0));
 		} else {
 			context.response(403);
 		}

src/dev/peerat/backend/routes/groups/GroupQuit.java

@@ -67,7 +67,7 @@ public class GroupQuit implements Response{
 		if (this.groupRepo.leaveGroup(group, user)) {
 			context.response(200);
 			
-			leaderboard.pushValue(new Completion(0, 0, 0, null, 0));
+			leaderboard.setValue(new Completion(0, 0, 0, null, 0));
 		} else {
 			context.response(403);
 		}

src/dev/peerat/backend/routes/users/Register.java

@@ -49,7 +49,6 @@ public class Register extends FormResponse{
 			this.uuidBuilder = constructor;
 		} catch (Exception e){
 			e.printStackTrace();
-			System.exit(0);
 		}
 	}