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

This server revision allows for all requests to be denied with the serviceState flag being set to false

Browse Source
This commit is contained in:
James Quinley 2022-06-12 20:55:53 -07:00
parent 7fe710600e
commit b74bc82e9a
1 changed files with 972 additions and 970 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -103,9 +103,26 @@ public class delegationServices {
String RG = (String) Lrequest.get("rg"); String RG = (String) Lrequest.get("rg");
Filter = RGFilter.find(eq("rgkey", "UAROCKS")).first(); Filter = RGFilter.find(eq("rgkey", "UAROCKS")).first();
String blockedRG = (String) Filter.get("rgflag"); String blockedRG = (String) Filter.get("rgflag");
if ((Boolean)Filter.get("serviceState") == false)
{
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("rid", Lrequest.get("rid"));
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
BasicDBObject updateQuery2 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 52));
updateQuery2.append("$set",
new BasicDBObject().append("dn",Filter.get("deniedmsg")));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery2);
dCollection.updateOne(searchQuery, updateQuery1);
delegationTimer.DeleteTargetRequest(ClientID);
} else {
if (blockedRG.contains(RG)) { if (blockedRG.contains(RG)) {
System.out.println("User Is Trying To Join From A Blocked Region, Halted Login Request.");
System.out.println("Sync Failure");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("rid", Lrequest.get("rid")); searchQuery.append("rid", Lrequest.get("rid"));
@ -126,9 +143,8 @@ public class delegationServices {
System.out.println("Delegation Has Started"); System.out.println("Delegation Has Started");
if(requesttype == 0 || requesttype == 1 || requesttype == 2 || requesttype == 3 || requesttype == 4 || requesttype == 5 || requesttype == 6 || requesttype ==7 || requesttype == 8 || requesttype ==9 || requesttype ==10 || requesttype ==11 || requesttype ==12 || requesttype == 20 || requesttype == 21 || requesttype == 41 || requesttype == 18 || requesttype == 47 || requesttype == 48) { if (requesttype == 0 || requesttype == 1 || requesttype == 2 || requesttype == 3 || requesttype == 4 || requesttype == 5 || requesttype == 6 || requesttype == 7 || requesttype == 8 || requesttype == 9 || requesttype == 10 || requesttype == 11 || requesttype == 12 || requesttype == 20 || requesttype == 21 || requesttype == 41 || requesttype == 18 || requesttype == 47 || requesttype == 48) {
if (requesttype == 47) if (requesttype == 47) {
{
System.out.println("Self Updater download Request"); System.out.println("Self Updater download Request");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
BasicDBObject SqS = new BasicDBObject(); BasicDBObject SqS = new BasicDBObject();
@ -139,42 +155,38 @@ public class delegationServices {
BasicDBObject updateQuery3 = new BasicDBObject(); BasicDBObject updateQuery3 = new BasicDBObject();
BasicDBObject updateQuery4 = new BasicDBObject(); BasicDBObject updateQuery4 = new BasicDBObject();
BasicDBObject updateQuery6 = new BasicDBObject(); BasicDBObject updateQuery6 = new BasicDBObject();
try try {
{
Document LCP = RGFilter.find(eq("rgkey", "UAROCKS")).first(); Document LCP = RGFilter.find(eq("rgkey", "UAROCKS")).first();
String UPDT =(String)LCP.get("UURI"); String UPDT = (String) LCP.get("UURI");
String config = (String)LCP.get("config"); String config = (String) LCP.get("config");
System.out.println("ThisIsConfig " + config); System.out.println("ThisIsConfig " + config);
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 42)); new BasicDBObject().append("type", 42));
updateQuery2.append("$set", updateQuery2.append("$set",
new BasicDBObject().append("uri",UPDT)); new BasicDBObject().append("uri", UPDT));
updateQuery3.append("$set", updateQuery3.append("$set",
new BasicDBObject().append("winconfig", config)); new BasicDBObject().append("winconfig", config));
updateQuery6.append("$set", updateQuery6.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
} } catch (Exception ex) {
catch (Exception ex)
{
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 43)); new BasicDBObject().append("type", 43));
updateQuery2.append("$set", updateQuery2.append("$set",
new BasicDBObject().append("uri","F")); new BasicDBObject().append("uri", "F"));
updateQuery6.append("$set", updateQuery6.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
} }
dCollection.updateOne(SqS, updateQuery); dCollection.updateOne(SqS, updateQuery);
dCollection.updateOne(SqS,updateQuery2); dCollection.updateOne(SqS, updateQuery2);
dCollection.updateOne(SqS,updateQuery3); dCollection.updateOne(SqS, updateQuery3);
dCollection.updateOne(SqS, updateQuery6); dCollection.updateOne(SqS, updateQuery6);
System.out.println("Finished Updater Request"); System.out.println("Finished Updater Request");
delegationTimer.DeleteTargetRequest(ClientID); delegationTimer.DeleteTargetRequest(ClientID);
} }
if (requesttype == 41) if (requesttype == 41) {
{
System.out.println("Internal Launcher Download Request"); System.out.println("Internal Launcher Download Request");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
BasicDBObject SqS = new BasicDBObject(); BasicDBObject SqS = new BasicDBObject();
@ -185,28 +197,25 @@ public class delegationServices {
BasicDBObject updateQuery3 = new BasicDBObject(); BasicDBObject updateQuery3 = new BasicDBObject();
BasicDBObject updateQuery4 = new BasicDBObject(); BasicDBObject updateQuery4 = new BasicDBObject();
BasicDBObject updateQuery6 = new BasicDBObject(); BasicDBObject updateQuery6 = new BasicDBObject();
try try {
{
Document LCP = RGFilter.find(eq("rgkey", "UAROCKS")).first(); Document LCP = RGFilter.find(eq("rgkey", "UAROCKS")).first();
String UPDT =(String)LCP.get("URI"); String UPDT = (String) LCP.get("URI");
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 42)); new BasicDBObject().append("type", 42));
updateQuery2.append("$set", updateQuery2.append("$set",
new BasicDBObject().append("uri",UPDT)); new BasicDBObject().append("uri", UPDT));
updateQuery6.append("$set", updateQuery6.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
} } catch (Exception ex) {
catch (Exception ex)
{
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 43)); new BasicDBObject().append("type", 43));
updateQuery2.append("$set", updateQuery2.append("$set",
new BasicDBObject().append("uri","F")); new BasicDBObject().append("uri", "F"));
updateQuery6.append("$set", updateQuery6.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
} }
dCollection.updateOne(SqS, updateQuery); dCollection.updateOne(SqS, updateQuery);
dCollection.updateOne(SqS,updateQuery2); dCollection.updateOne(SqS, updateQuery2);
dCollection.updateOne(SqS, updateQuery6); dCollection.updateOne(SqS, updateQuery6);
System.out.println("Finished Updater Request"); System.out.println("Finished Updater Request");
delegationTimer.DeleteTargetRequest(ClientID); delegationTimer.DeleteTargetRequest(ClientID);
@ -301,7 +310,7 @@ public class delegationServices {
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
delegationTimer.DeleteTargetRequest(ClientID); delegationTimer.DeleteTargetRequest(ClientID);
} }
} catch(MongoCommandException ERC){ } catch (MongoCommandException ERC) {
System.out.println("Malformed Request"); System.out.println("Malformed Request");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("clientid", ClientID);
@ -373,7 +382,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("rid",(int) Lrequest.get("rid")); searchQuery.append("rid", (int) Lrequest.get("rid"));
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); BasicDBObject updateQuery1 = new BasicDBObject();
@ -401,7 +410,7 @@ public class delegationServices {
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
delegationTimer.DeleteTargetRequest(ClientID); delegationTimer.DeleteTargetRequest(ClientID);
} }
} catch(MongoCommandException ERC){ } catch (MongoCommandException ERC) {
System.out.println("Malformed Request"); System.out.println("Malformed Request");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("clientid", ClientID);
@ -440,7 +449,7 @@ public class delegationServices {
Email = (String) accountServer.get("Email"); Email = (String) accountServer.get("Email");
UserName = (String) accountServer.get("User"); UserName = (String) accountServer.get("User");
lastNet = (String) accountServer.get("lastNet"); lastNet = (String) accountServer.get("lastNet");
localNet.macRead(Macid,lastNet,Email,UserName,Token); localNet.macRead(Macid, lastNet, Email, UserName, Token);
// com.jamesquinley.Asecure.emailVerify.SendEmailThroughGmail(Email, UserName); // com.jamesquinley.Asecure.emailVerify.SendEmailThroughGmail(Email, UserName);
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
@ -551,7 +560,7 @@ public class delegationServices {
Email = (String) accountServer.get("Email"); Email = (String) accountServer.get("Email");
UserName = (String) accountServer.get("User"); UserName = (String) accountServer.get("User");
lastNet = (String) accountServer.get("lastNet"); lastNet = (String) accountServer.get("lastNet");
localNet.macRead(Macid,lastNet,Email,UserName,TKN); localNet.macRead(Macid, lastNet, Email, UserName, TKN);
// com.jamesquinley.Asecure.emailVerify.SendEmailThroughGmail(Email, UserName); // com.jamesquinley.Asecure.emailVerify.SendEmailThroughGmail(Email, UserName);
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("clientid", ClientID);
@ -679,7 +688,6 @@ public class delegationServices {
System.out.println("ApiGrabbed"); System.out.println("ApiGrabbed");
System.out.println("initBasicDBObject"); System.out.println("initBasicDBObject");
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery2 = new BasicDBObject(); BasicDBObject updateQuery2 = new BasicDBObject();
@ -709,9 +717,9 @@ public class delegationServices {
updateQuery8.append("$set", updateQuery8.append("$set",
new BasicDBObject().append("Token", TKN)); new BasicDBObject().append("Token", TKN));
updateQuery9.append("$set", updateQuery9.append("$set",
new BasicDBObject().append("api",apiV)); new BasicDBObject().append("api", apiV));
updateQuery10.append("$set", updateQuery10.append("$set",
new BasicDBObject().append("motd",MOTD)); new BasicDBObject().append("motd", MOTD));
System.out.println("Sending Info To Forwarding Server"); System.out.println("Sending Info To Forwarding Server");
dCollection.updateOne(searchQuery, updateQuery); dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery10); dCollection.updateOne(searchQuery, updateQuery10);
@ -775,17 +783,16 @@ public class delegationServices {
//delegationTimer.trigger(); //delegationTimer.trigger();
} }
} }
if (requesttype == 10) if (requesttype == 10) {
{
System.out.println("Account Creation Request"); System.out.println("Account Creation Request");
Document DServer = dCollection.find(eq("clientid",ClientID)).first(); Document DServer = dCollection.find(eq("clientid", ClientID)).first();
String User = (String) DServer.get("User"); String User = (String) DServer.get("User");
String Password = (String) DServer.get("Password"); String Password = (String) DServer.get("Password");
String Email = (String) DServer.get("Email"); String Email = (String) DServer.get("Email");
String FName = (String) DServer.get("FName"); String FName = (String) DServer.get("FName");
int min = 100000000; int min = 100000000;
int max = 999999999; int max = 999999999;
double tokenGEN = Math.random()*(max-min+1)+min; double tokenGEN = Math.random() * (max - min + 1) + min;
int tokenSTGEN = (int) tokenGEN; int tokenSTGEN = (int) tokenGEN;
//verify open cert //verify open cert
@ -812,13 +819,13 @@ public class delegationServices {
Boolean TokenOpen = false; Boolean TokenOpen = false;
while (TokenOpen == false) { while (TokenOpen == false) {
tokenGEN = Math.random()*(max-min+1)+min; tokenGEN = Math.random() * (max - min + 1) + min;
tokenSTGEN = (int) tokenGEN; tokenSTGEN = (int) tokenGEN;
try { try {
DupeToken = accountS.find(eq("Token", tokenSTGEN)).first(); DupeToken = accountS.find(eq("Token", tokenSTGEN)).first();
DupeToke1n = (int) DupeToken.get("Token"); DupeToke1n = (int) DupeToken.get("Token");
System.out.println("Token Is Reserved, Try Again."); System.out.println("Token Is Reserved, Try Again.");
tokenGEN = Math.random()*(max-min+1)+min; tokenGEN = Math.random() * (max - min + 1) + min;
tokenSTGEN = (int) tokenGEN; tokenSTGEN = (int) tokenGEN;
} catch (Exception exDr) { } catch (Exception exDr) {
TokenOpen = true; TokenOpen = true;
@ -875,14 +882,14 @@ public class delegationServices {
{ {
delegationTimer.DeleteTargetRequest(ClientID); delegationTimer.DeleteTargetRequest(ClientID);
System.out.println("Account Creation Request"); System.out.println("Account Creation Request");
Document DServer = dCollection.find(eq("clientid",ClientID)).first(); Document DServer = dCollection.find(eq("clientid", ClientID)).first();
String User = (String) DServer.get("User"); String User = (String) DServer.get("User");
String Password = (String) DServer.get("Password"); String Password = (String) DServer.get("Password");
// String Email = (String) DServer.get("Email"); // String Email = (String) DServer.get("Email");
String FName = User; String FName = User;
int min = 100000000; int min = 100000000;
int max = 999999999; int max = 999999999;
double tokenGEN = Math.random()*(max-min+1)+min; double tokenGEN = Math.random() * (max - min + 1) + min;
int tokenSTGEN = (int) tokenGEN; int tokenSTGEN = (int) tokenGEN;
//verify open cert //verify open cert
@ -910,13 +917,13 @@ public class delegationServices {
Boolean TokenOpen = false; Boolean TokenOpen = false;
while (TokenOpen == false) { while (TokenOpen == false) {
tokenGEN = Math.random()*(max-min+1)+min; tokenGEN = Math.random() * (max - min + 1) + min;
tokenSTGEN = (int) tokenGEN; tokenSTGEN = (int) tokenGEN;
try { try {
DupeToken = accountS.find(eq("Token", tokenSTGEN)).first(); DupeToken = accountS.find(eq("Token", tokenSTGEN)).first();
DupeToke1n = (int) DupeToken.get("Token"); DupeToke1n = (int) DupeToken.get("Token");
System.out.println("Token Is Reserved, Try Again."); System.out.println("Token Is Reserved, Try Again.");
tokenGEN = Math.random()*(max-min+1)+min; tokenGEN = Math.random() * (max - min + 1) + min;
tokenSTGEN = (int) tokenGEN; tokenSTGEN = (int) tokenGEN;
} catch (Exception exDr) { } catch (Exception exDr) {
TokenOpen = true; TokenOpen = true;
@ -964,8 +971,7 @@ public class delegationServices {
} }
} }
if (requesttype == 21) if (requesttype == 21) {
{
//Friends Network Login Goes Here, Fun. //Friends Network Login Goes Here, Fun.
} }
if (requesttype == 48) { if (requesttype == 48) {
@ -986,7 +992,6 @@ public class delegationServices {
System.out.println("ApiGrabbed"); System.out.println("ApiGrabbed");
System.out.println("initBasicDBObject"); System.out.println("initBasicDBObject");
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery2 = new BasicDBObject(); BasicDBObject updateQuery2 = new BasicDBObject();
@ -996,21 +1001,17 @@ public class delegationServices {
BasicDBObject updateQuery7 = new BasicDBObject(); BasicDBObject updateQuery7 = new BasicDBObject();
BasicDBObject updateQuery8 = new BasicDBObject(); BasicDBObject updateQuery8 = new BasicDBObject();
// BasicDBObject updateQuery11 = new BasicDBObject(); // BasicDBObject updateQuery11 = new BasicDBObject();
if (pKey.equals(platKey)) if (pKey.equals(platKey)) {
{ if (lV.equals(version)) {
if (lV.equals(version))
{
System.out.println("Approved"); System.out.println("Approved");
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 49)); new BasicDBObject().append("type", 49));
} else } else {
{
System.out.println("UpdateRequred"); System.out.println("UpdateRequred");
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 51)); new BasicDBObject().append("type", 51));
} }
} else } else {
{
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 50)); new BasicDBObject().append("type", 50));
updateQuery7.append("$set", updateQuery7.append("$set",
@ -1023,14 +1024,13 @@ public class delegationServices {
updateQuery3.append("$set", updateQuery3.append("$set",
new BasicDBObject().append("pushV", version)); new BasicDBObject().append("pushV", version));
updateQuery4.append("$set", updateQuery4.append("$set",
new BasicDBObject().append("keyReq",pKey)); new BasicDBObject().append("keyReq", pKey));
updateQuery8.append("$set", updateQuery8.append("$set",
new BasicDBObject().append("news",nw)); new BasicDBObject().append("news", nw));
updateQuery6.append("$set", updateQuery6.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
updateQuery7.append("$set", updateQuery7.append("$set",
new BasicDBObject().append("dn", dr)); new BasicDBObject().append("dn", dr));
System.out.println(dr);
System.out.println("Sending Info To Forwarding Server"); System.out.println("Sending Info To Forwarding Server");
dCollection.updateOne(searchQuery, updateQuery); dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery2); dCollection.updateOne(searchQuery, updateQuery2);
@ -1072,13 +1072,14 @@ public class delegationServices {
new BasicDBObject().append("type", 7)); new BasicDBObject().append("type", 7));
updateQuery1.append("$set", updateQuery1.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
Lrequest.append("status",true); Lrequest.append("status", true);
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
dCollection.updateOne(searchQuery, updateQuery); dCollection.updateOne(searchQuery, updateQuery);
delegationTimer.DeleteTargetRequest(ClientID); delegationTimer.DeleteTargetRequest(ClientID);
} }
} }
}
} catch (Exception Erp) { } catch (Exception Erp) {
System.out.println("Malformed Request, Non Recoverable ErrorInfo: " +Erp); System.out.println("Malformed Request, Non Recoverable ErrorInfo: " +Erp);
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
@ -1101,6 +1102,7 @@ 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();