Compare commits
4 commits
main
...
escapegame
Author | SHA1 | Date | |
---|---|---|---|
ba8ab4c4a6 | |||
c745272bd9 | |||
9c0ffb62c6 | |||
def51bbf25 |
14 changed files with 13 additions and 28 deletions
Binary file not shown.
|
@ -59,18 +59,20 @@ 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) -> {
|
||||
(claims, user) -> {
|
||||
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) -> {
|
||||
(claims, user) -> {
|
||||
claims.setIssuer(config.getTokenIssuer());
|
||||
claims.setExpirationTimeMinutesInTheFuture(config.getTokenExpiration());
|
||||
user.write(claims);
|
||||
},
|
||||
(claims) -> new PeerAtUser(claims));
|
||||
JsonMap json = new JsonMap();
|
||||
|
@ -127,7 +129,6 @@ 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());
|
||||
|
@ -141,20 +142,7 @@ public class Main{
|
|||
|
||||
new Thread(new Runnable(){
|
||||
public void run(){
|
||||
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);
|
||||
router.getExceptionLogger().listen((throwable) -> throwable.printStackTrace(), (exception) -> exception.printStackTrace());
|
||||
}
|
||||
}).start();
|
||||
|
||||
|
@ -171,6 +159,7 @@ 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<>())
|
||||
|
|
|
@ -55,7 +55,6 @@ public class Bot extends Thread{
|
|||
}
|
||||
|
||||
while(true){
|
||||
locker.lock(key);
|
||||
Group group = locker.getValue(key);
|
||||
Integer chapter = group.getLinkToChapter();
|
||||
// Integer puzzle = group.getLinkToPuzzle();
|
||||
|
|
|
@ -14,7 +14,6 @@ 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);
|
||||
}
|
||||
|
|
|
@ -41,7 +41,6 @@ public class DynamicLeaderboard extends Leaderboard{
|
|||
}else{
|
||||
playersLeaderboard(writer);
|
||||
}
|
||||
locker.lock(key);
|
||||
}
|
||||
}catch(Exception e){
|
||||
e.printStackTrace();
|
||||
|
|
|
@ -28,7 +28,6 @@ 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();
|
||||
|
|
|
@ -115,7 +115,7 @@ public class PuzzleResponse implements Response {
|
|||
writer.write(responseJSON.toString());
|
||||
writer.flush();
|
||||
|
||||
leaderboard.setValue(completion);
|
||||
leaderboard.pushValue(completion);
|
||||
}
|
||||
|
||||
private void saveSourceCode(ReceivedResponse received, Player player){
|
||||
|
|
|
@ -25,7 +25,7 @@ public class GroupController {
|
|||
return;
|
||||
}
|
||||
|
||||
locker.setValue(new GroupMessage(json.get("group"), json.get("message")));
|
||||
locker.pushValue(new GroupMessage(json.get("group"), json.get("message")));
|
||||
context.response(200);
|
||||
}
|
||||
|
||||
|
|
|
@ -63,7 +63,6 @@ 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);
|
||||
|
|
|
@ -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.setValue(new Completion(0, 0));
|
||||
locker.pushValue(new Completion(0, 0));
|
||||
context.response(200);
|
||||
}
|
||||
|
||||
|
|
|
@ -71,7 +71,7 @@ public class GroupCreate extends FormResponse {
|
|||
if (this.repo.insertGroup(newGroup, user)) {
|
||||
context.response(200);
|
||||
|
||||
locker.setValue(newGroup);
|
||||
locker.pushValue(newGroup);
|
||||
} else {
|
||||
context.response(403);
|
||||
}
|
||||
|
|
|
@ -75,7 +75,7 @@ public class GroupJoin implements Response{
|
|||
if (this.groupRepo.insertUserInGroup(group, user)) {
|
||||
context.response(200);
|
||||
|
||||
leaderboard.setValue(new Completion(0, 0, 0, null, 0));
|
||||
leaderboard.pushValue(new Completion(0, 0, 0, null, 0));
|
||||
} else {
|
||||
context.response(403);
|
||||
}
|
||||
|
|
|
@ -67,7 +67,7 @@ public class GroupQuit implements Response{
|
|||
if (this.groupRepo.leaveGroup(group, user)) {
|
||||
context.response(200);
|
||||
|
||||
leaderboard.setValue(new Completion(0, 0, 0, null, 0));
|
||||
leaderboard.pushValue(new Completion(0, 0, 0, null, 0));
|
||||
} else {
|
||||
context.response(403);
|
||||
}
|
||||
|
|
|
@ -49,6 +49,7 @@ public class Register extends FormResponse{
|
|||
this.uuidBuilder = constructor;
|
||||
} catch (Exception e){
|
||||
e.printStackTrace();
|
||||
System.exit(0);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue