JamesQ/MatchmakingBackend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v1.5 Of the AOTSK Server, this is now production software.

Browse Source 
It will work with the latest internal version of the launcher.
This commit is contained in:
James 2022-02-06 18:31:44 -08:00
parent a24c8c73b2
commit 46513d7a9c
1 changed files with 464 additions and 455 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/com/jamesquinley/DelegationServices/delegationServices.java
View File

@ -39,6 +39,11 @@ public class delegationServices {
//still need to config //still need to config
public static void delegationProcesser() { public static void delegationProcesser() {
Document Lrequest = dCollection.find(eq("status", false)).first(); Document Lrequest = dCollection.find(eq("status", false)).first();
if ((boolean) Lrequest.get("status") == true)
{
System.out.println("This request was completed, ignoring");
Lrequest = null;
} else {
int ClientID = 0; int ClientID = 0;
int requesttype = (int) Lrequest.get("type"); int requesttype = (int) Lrequest.get("type");
@ -75,6 +80,7 @@ public class delegationServices {
Token = (int) accountServer.get("Token"); Token = (int) accountServer.get("Token");
if (accountServer.get("Status").equals(true)) { if (accountServer.get("Status").equals(true)) {
if (Token == CTOKEN) { if (Token == CTOKEN) {
Token = (int) accountServer.get("Token"); Token = (int) accountServer.get("Token");
Password = (String) accountServer.get("Password"); Password = (String) accountServer.get("Password");
Fname = (String) accountServer.get("FName"); Fname = (String) accountServer.get("FName");
@ -118,7 +124,7 @@ public class delegationServices {
} else { } else {
System.out.println("Sync Failure"); System.out.println("Sync Failure");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("rid",(int) Lrequest.get("rid"));
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); BasicDBObject updateQuery1 = new BasicDBObject();
@ -183,7 +189,7 @@ public class delegationServices {
Token = (int) Lrequest.get("Token"); Token = (int) Lrequest.get("Token");
Password = (String) Lrequest.get("Password"); Password = (String) Lrequest.get("Password");
Fname = (String) Lrequest.get("FName"); Fname = (String) Lrequest.get("FName");
Path = (String) Lrequest.get("path"); Path = (String) Lrequest.get("Path");
Email = (String) Lrequest.get("Email"); Email = (String) Lrequest.get("Email");
UserName = (String) Lrequest.get("User"); UserName = (String) Lrequest.get("User");
@ -228,7 +234,7 @@ public class delegationServices {
} else { } else {
System.out.println("Sync Failure"); System.out.println("Sync Failure");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("rid",(int) Lrequest.get("rid"));
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); BasicDBObject updateQuery1 = new BasicDBObject();
@ -499,6 +505,9 @@ public class delegationServices {
} }
}
//above is finding one request and starting wheels //above is finding one request and starting wheels
//delegationTimer.trigger(); //delegationTimer.trigger();
delegate(); delegate();