Peer-at-Code/peer-at-code-framework
5
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Fix possible sync problems

Browse source
This commit is contained in:
jeffcheasey88 2023-09-08 01:22:09 +02:00
parent d77fe329b8
commit 896a2be120
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/dev/peerat/framework/RouteMapper.java
View file

@ -32,12 +32,14 @@ public class RouteMapper{
} }
public boolean exec(Context context, String path, User user, HttpReader reader, HttpWriter writer) throws Exception{ public boolean exec(Context context, String path, User user, HttpReader reader, HttpWriter writer) throws Exception{
Response result = null;
Matcher matcher = null;
synchronized(responses){ synchronized(responses){
for(int i = 0; i < responses.length; i++){ for(int i = 0; i < responses.length; i++){
Response response = responses[i]; Response response = responses[i];
Route route = routes[i]; Route route = routes[i];
Pattern pattern = patterns[i]; Pattern pattern = patterns[i];
Matcher matcher = pattern.matcher(path); matcher = pattern.matcher(path);
if(matcher.matches()){ if(matcher.matches()){
if(user == null && route.needLogin()){ if(user == null && route.needLogin()){
writer.response(401, "Access-Control-Allow-Origin: *"); writer.response(401, "Access-Control-Allow-Origin: *");
@ -48,12 +50,16 @@ public class RouteMapper{
reader = new WebSocketReader(reader); reader = new WebSocketReader(reader);
writer = new WebSocketWriter(writer); writer = new WebSocketWriter(writer);
} }
response.exec(matcher, context, reader, writer);
order(i); order(i);
result = response;
break;
}
}
}
if(result != null){
result.exec(matcher, context, reader, writer);
return true; return true;
} }
}
}
return false; return false;
} }