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

Working Build

Browse Source
This commit is contained in:
James 2022-02-05 08:31:24 -08:00
parent 0006a0e887
commit 5a612c9e5a
4 changed files with 384 additions and 334 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
.idea/artifacts/LoginServer.xml generated Normal file
View File

@ -0,0 +1,21 @@
<component name="ArtifactManager">
<artifact type="jar" build-on-make="true" name="LoginServer">
<output-path>$PROJECT_DIR$/out/artifacts/LoginServer</output-path>
<root id="archive" name="AOTSK-Login-Delegation-Server.jar">
<element id="module-output" name="AOTSK-Login-Delegation-Server" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/hamcrest/hamcrest-core/1.1/hamcrest-core-1.1.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/mongodb/bson/4.3.2/bson-4.3.2.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/mongodb/mongodb-driver-core/4.3.2/mongodb-driver-core-4.3.2.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/com/jfoenix/jfoenix/8.0.10/jfoenix-8.0.10.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/junit/junit/4.10/junit-4.10.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/jsoup/jsoup/1.14.2/jsoup-1.14.2.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/apache/logging/log4j/log4j-core/2.17.0/log4j-core-2.17.0.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/slf4j/slf4j-api/1.7.32/slf4j-api-1.7.32.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/mongodb/mongodb-driver-sync/4.3.2/mongodb-driver-sync-4.3.2.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/apache/logging/log4j/log4j-api/2.17.0/log4j-api-2.17.0.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/controlsfx/controlsfx/11.1.1/controlsfx-11.1.1.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/com/googlecode/json-simple/json-simple/1.1.1/json-simple-1.1.1.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/net/lingala/zip4j/zip4j/2.6.1/zip4j-2.6.1.jar" path-in-jar="/" />
</root>
</artifact>
</component>

2
.idea/runConfigurations/Server.xml → .idea/runConfigurations/Server_Client_.xml generated
View File

@ -1,5 +1,5 @@
<component name="ProjectRunConfigurationManager"> <component name="ProjectRunConfigurationManager">
<configuration default="false" name="Server" type="Application" factoryName="Application"> <configuration default="false" name="Server Client " type="Application" factoryName="Application">
<option name="MAIN_CLASS_NAME" value="com.jamesquinley.startup" /> <option name="MAIN_CLASS_NAME" value="com.jamesquinley.startup" />
<module name="AOTSK-Login-Delegation-Server" /> <module name="AOTSK-Login-Delegation-Server" />
<method v="2"> <method v="2">

3
src/main/java/META-INF/MANIFEST.MF Normal file
View File

@ -0,0 +1,3 @@
Manifest-Version: 1.0
Main-Class: com.jamesquinley.startup

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

@ -40,100 +40,110 @@ public class delegationServices {
public static void delegationProcesser() { public static void delegationProcesser() {
Document Lrequest = dCollection.find(eq("status", false)).first(); Document Lrequest = dCollection.find(eq("status", false)).first();
int ClientID = 0; int ClientID = 0;
try {
ClientID = (int) Lrequest.get("clientid");
} catch (Exception exrp) {
}
//TODO ADD BAN CHECK TO PREVENT BAN CIRCUMNAVIGATION, THIS WILL BE ADDED LATER (This is being tested, already implemented)
String username = (String) Lrequest.get("User");
String password = (String) Lrequest.get("Password");
int CTOKEN = (int) Lrequest.get("Token");
int requesttype = (int) Lrequest.get("type"); int requesttype = (int) Lrequest.get("type");
if (requesttype == 0) { System.out.println("Got Type, Getting Doc ID");
System.out.println("Sync Request (Read" +
")"); //TODO Get this working, it broke and it wont get OBJ id
Document accountServer;
String Password; System.out.println("Delegation Has Started");
int Token; 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) {
String Fname; if (requesttype == 7) {
String Path; System.out.println("An Excluded Request (7MAL) Has Been Detected, Ignoring");
String UserName; }
String Email; String username = (String) Lrequest.get("User");
String password = (String) Lrequest.get("Password");
try { try {
accountServer = accountS.find(eq("Token", CTOKEN)).first(); ClientID = (int) Lrequest.get("clientid");
Token = (int) accountServer.get("Token"); } catch (Exception exrp) {
if (accountServer.get("Status").equals("Active")) { System.out.println("Failed To Get Client ID");
if (Token == CTOKEN) { }
Token = (int) accountServer.get("Token"); int CTOKEN = (int) Lrequest.get("Token");
Password = (String) accountServer.get("Password");
Fname = (String) accountServer.get("FName");
Path = (String) accountServer.get("Path"); if (requesttype == 0) {
Email = (String) accountServer.get("Email"); System.out.println("Sync Request (Read)");
UserName = (String) accountServer.get("User"); Document accountServer;
BasicDBObject searchQuery = new BasicDBObject(); String Password;
searchQuery.append("clientid", ClientID); int Token;
BasicDBObject updateQuery = new BasicDBObject(); String Fname;
BasicDBObject updateQuery1 = new BasicDBObject(); String Path;
BasicDBObject updateQuery2 = new BasicDBObject(); String UserName;
BasicDBObject updateQuery3 = new BasicDBObject(); String Email;
BasicDBObject updateQuery4 = new BasicDBObject(); try {
BasicDBObject updateQuery5 = new BasicDBObject(); accountServer = accountS.find(eq("Token", CTOKEN)).first();
BasicDBObject updateQuery6 = new BasicDBObject(); Token = (int) accountServer.get("Token");
BasicDBObject updateQuery7 = new BasicDBObject(); if (accountServer.get("Status").equals(true)) {
updateQuery.append("$set", if (Token == CTOKEN) {
new BasicDBObject().append("type", 12)); Token = (int) accountServer.get("Token");
updateQuery1.append("$set", Password = (String) accountServer.get("Password");
new BasicDBObject().append("Token", Token)); Fname = (String) accountServer.get("FName");
updateQuery2.append("$set", Path = (String) accountServer.get("Path");
new BasicDBObject().append("Fname", Fname)); Email = (String) accountServer.get("Email");
updateQuery3.append("$set", UserName = (String) accountServer.get("User");
new BasicDBObject().append("Path", Path)); BasicDBObject searchQuery = new BasicDBObject();
updateQuery4.append("$set", searchQuery.append("clientid", ClientID);
new BasicDBObject().append("User", UserName)); BasicDBObject updateQuery = new BasicDBObject();
updateQuery5.append("$set", BasicDBObject updateQuery1 = new BasicDBObject();
new BasicDBObject().append("Password", Password)); BasicDBObject updateQuery2 = new BasicDBObject();
updateQuery7.append("$set", BasicDBObject updateQuery3 = new BasicDBObject();
new BasicDBObject().append("Email", Email)); BasicDBObject updateQuery4 = new BasicDBObject();
updateQuery6.append("$set", BasicDBObject updateQuery5 = new BasicDBObject();
new BasicDBObject().append("status", true)); BasicDBObject updateQuery6 = new BasicDBObject();
dCollection.updateOne(searchQuery, updateQuery); BasicDBObject updateQuery7 = new BasicDBObject();
dCollection.updateOne(searchQuery, updateQuery1); updateQuery.append("$set",
dCollection.updateOne(searchQuery, updateQuery2); new BasicDBObject().append("type", 12));
dCollection.updateOne(searchQuery, updateQuery3); updateQuery1.append("$set",
dCollection.updateOne(searchQuery, updateQuery4); new BasicDBObject().append("Token", Token));
dCollection.updateOne(searchQuery, updateQuery5); updateQuery2.append("$set",
dCollection.updateOne(searchQuery, updateQuery6); new BasicDBObject().append("Fname", Fname));
dCollection.updateOne(searchQuery, updateQuery7); updateQuery3.append("$set",
new BasicDBObject().append("Path", Path));
updateQuery4.append("$set",
new BasicDBObject().append("User", UserName));
updateQuery5.append("$set",
new BasicDBObject().append("Password", Password));
updateQuery7.append("$set",
new BasicDBObject().append("Email", Email));
updateQuery6.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
dCollection.updateOne(searchQuery, updateQuery2);
dCollection.updateOne(searchQuery, updateQuery3);
dCollection.updateOne(searchQuery, updateQuery4);
dCollection.updateOne(searchQuery, updateQuery5);
dCollection.updateOne(searchQuery, updateQuery6);
dCollection.updateOne(searchQuery, updateQuery7);
} else {
System.out.println("Sync Failure");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 9));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
}
} else { } else {
System.out.println("Sync Failure"); System.out.println("Banned Account");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 9)); new BasicDBObject().append("type", 11));
updateQuery1.append("$set", updateQuery1.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery); dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
} }
} else {
System.out.println("Banned Account");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 11));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
}
} catch(MongoCommandException ERC){ } catch(MongoCommandException ERC){
System.out.println("Malformed Request"); System.out.println("Malformed Request");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
@ -152,171 +162,99 @@ public class delegationServices {
} }
//sync read request //sync read request
//TODO This has issues, and won't get past line 171. Working on a fix for that. //TODO This has issues, and won't get past line 171. Working on a fix for that.
if (requesttype == 1) { if (requesttype == 1) {
System.out.println("Sync Request (Write)"); System.out.println("Sync Request (Write)");
Document accountServer; Document accountServer;
String Password; String Password;
int Token; int Token;
String Fname; String Fname;
String Path; String Path;
String UserName; String UserName;
String Email; String Email;
try { try {
accountServer = accountS.find(eq("Token", CTOKEN)).first(); accountServer = accountS.find(eq("Token", CTOKEN)).first();
Token = (int) accountServer.get("Token"); Token = (int) accountServer.get("Token");
if (accountServer.get("Status").equals("Active")) { if (accountServer.get("Status").equals(true)) {
System.out.println("Account is OK"); System.out.println("Account is OK");
if (Token == CTOKEN) { if (Token == CTOKEN) {
System.out.println("Logged In"); System.out.println("Logged In");
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");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("Token", Token); searchQuery.append("Token", Token);
BasicDBObject SqS = new BasicDBObject(); BasicDBObject SqS = new BasicDBObject();
SqS.append("clientid", ClientID); SqS.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); BasicDBObject updateQuery1 = new BasicDBObject();
BasicDBObject updateQuery2 = new BasicDBObject(); BasicDBObject updateQuery2 = new BasicDBObject();
BasicDBObject updateQuery3 = new BasicDBObject(); BasicDBObject updateQuery3 = new BasicDBObject();
BasicDBObject updateQuery4 = new BasicDBObject(); BasicDBObject updateQuery4 = new BasicDBObject();
BasicDBObject updateQuery5 = new BasicDBObject(); BasicDBObject updateQuery5 = new BasicDBObject();
BasicDBObject updateQuery6 = new BasicDBObject(); BasicDBObject updateQuery6 = new BasicDBObject();
BasicDBObject updateQuery7 = new BasicDBObject(); BasicDBObject updateQuery7 = new BasicDBObject();
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 12)); new BasicDBObject().append("type", 12));
updateQuery1.append("$set", updateQuery1.append("$set",
new BasicDBObject().append("Token", Token)); new BasicDBObject().append("Token", Token));
updateQuery2.append("$set", updateQuery2.append("$set",
new BasicDBObject().append("FName", Fname)); new BasicDBObject().append("FName", Fname));
updateQuery3.append("$set", updateQuery3.append("$set",
new BasicDBObject().append("Path", Path)); new BasicDBObject().append("Path", Path));
updateQuery4.append("$set", updateQuery4.append("$set",
new BasicDBObject().append("User", UserName)); new BasicDBObject().append("User", UserName));
updateQuery7.append("$set", updateQuery7.append("$set",
new BasicDBObject().append("Email", Email)); new BasicDBObject().append("Email", Email));
updateQuery6.append("$set", updateQuery6.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
// System.out.println("Sending Info To Forwarding Server"); // System.out.println("Sending Info To Forwarding Server");
dCollection.updateOne(SqS, updateQuery); dCollection.updateOne(SqS, updateQuery);
dCollection.updateOne(SqS, updateQuery6); dCollection.updateOne(SqS, updateQuery6);
accountS.updateOne(searchQuery, updateQuery1); accountS.updateOne(searchQuery, updateQuery1);
accountS.updateOne(searchQuery, updateQuery2); accountS.updateOne(searchQuery, updateQuery2);
accountS.updateOne(searchQuery, updateQuery3); accountS.updateOne(searchQuery, updateQuery3);
accountS.updateOne(searchQuery, updateQuery4); accountS.updateOne(searchQuery, updateQuery4);
accountS.updateOne(searchQuery, updateQuery5); accountS.updateOne(searchQuery, updateQuery5);
accountS.updateOne(searchQuery, updateQuery7); accountS.updateOne(searchQuery, updateQuery7);
System.out.println("Updated Account"); System.out.println("Updated Account");
//delegationTimer.trigger(); //delegationTimer.trigger();
} else {
System.out.println("Sync Failure");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 9));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
}
} else { } else {
System.out.println("Sync Failure"); System.out.println("Banned Account");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 9)); new BasicDBObject().append("type", 11));
updateQuery1.append("$set", updateQuery1.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery); dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
} }
} else { } catch(MongoCommandException ERC){
System.out.println("Banned Account"); System.out.println("Malformed Request");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 11));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
}
} catch(MongoCommandException ERC){
System.out.println("Malformed Request");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 7));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
}
}
if (requesttype == 2) {
System.out.println("Login Request (USR&PASS)");
Document accountServer;
String Password;
int Token;
String Fname;
String Path;
String UserName;
String Email;
try {
accountServer = accountS.find(eq("User", username)).first();
Password = (String) accountServer.get("Password");
if (accountServer.get("Status").equals("Active")) {
if (Password.equals(password)) {
Token = (int) accountServer.get("Token");
Fname = (String) accountServer.get("FName");
Path = (String) accountServer.get("Path");
Email = (String) accountServer.get("Email");
UserName = (String) accountServer.get("User");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
BasicDBObject updateQuery2 = new BasicDBObject();
BasicDBObject updateQuery3 = new BasicDBObject();
BasicDBObject updateQuery4 = new BasicDBObject();
BasicDBObject updateQuery5 = new BasicDBObject();
BasicDBObject updateQuery6 = new BasicDBObject();
BasicDBObject updateQuery7 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 8));
updateQuery1.append("$set",
new BasicDBObject().append("Token", Token));
updateQuery2.append("$set",
new BasicDBObject().append("Fname", Fname));
updateQuery3.append("$set",
new BasicDBObject().append("Path", Path));
updateQuery4.append("$set",
new BasicDBObject().append("User", UserName));
updateQuery5.append("$set",
new BasicDBObject().append("Password", Password));
updateQuery7.append("$set",
new BasicDBObject().append("Email", Email));
updateQuery6.append("$set",
new BasicDBObject().append("status", true));
// System.out.println("Sending Info To Forwarding Server");
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
dCollection.updateOne(searchQuery, updateQuery2);
dCollection.updateOne(searchQuery, updateQuery3);
dCollection.updateOne(searchQuery, updateQuery4);
dCollection.updateOne(searchQuery, updateQuery5);
dCollection.updateOne(searchQuery, updateQuery6);
dCollection.updateOne(searchQuery, updateQuery7);
//delegationTimer.trigger();
} else {
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("clientid", ClientID);
@ -330,124 +268,196 @@ public class delegationServices {
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger(); //delegationTimer.trigger();
} }
} else {
System.out.println("Banned Account");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 11));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
} }
} catch (Exception ERC) { if (requesttype == 2) {
BasicDBObject searchQuery = new BasicDBObject(); System.out.println("Login Request (USR&PASS)");
searchQuery.append("clientid", ClientID); Document accountServer;
String Password;
int Token;
String Fname;
String Path;
String UserName;
String Email;
try {
accountServer = accountS.find(eq("User", username)).first();
Password = (String) accountServer.get("Password");
if (accountServer.get("Status").equals(true)) {
if (Password.equals(password)) {
Token = (int) accountServer.get("Token");
Fname = (String) accountServer.get("FName");
Path = (String) accountServer.get("Path");
Email = (String) accountServer.get("Email");
UserName = (String) accountServer.get("User");
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); searchQuery.append("clientid", ClientID);
updateQuery.append("$set",
new BasicDBObject().append("type", 9));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
}
} BasicDBObject updateQuery = new BasicDBObject();
if (requesttype == 3) { BasicDBObject updateQuery1 = new BasicDBObject();
System.out.println("Login Request (TKN)"); BasicDBObject updateQuery2 = new BasicDBObject();
// Document TResolve = dCollection.find(eq("type", 3)).first(); BasicDBObject updateQuery3 = new BasicDBObject();
Document accountServer; BasicDBObject updateQuery4 = new BasicDBObject();
int TKN; BasicDBObject updateQuery5 = new BasicDBObject();
String Password; BasicDBObject updateQuery6 = new BasicDBObject();
String Fname; BasicDBObject updateQuery7 = new BasicDBObject();
String Path; updateQuery.append("$set",
String UserName; new BasicDBObject().append("type", 8));
String Email; updateQuery1.append("$set",
try { new BasicDBObject().append("Token", Token));
accountServer = accountS.find(eq("Token", CTOKEN)).first(); updateQuery2.append("$set",
TKN = (int) accountServer.get("Token"); new BasicDBObject().append("Fname", Fname));
if (accountServer.get("Status").equals("Active")) { updateQuery3.append("$set",
if (TKN == CTOKEN) { new BasicDBObject().append("Path", Path));
TKN = (int) accountServer.get("Token"); updateQuery4.append("$set",
Password = (String) accountServer.get("Password"); new BasicDBObject().append("User", UserName));
Fname = (String) accountServer.get("FName"); updateQuery5.append("$set",
Path = (String) accountServer.get("Path"); new BasicDBObject().append("Password", Password));
Email = (String) accountServer.get("Email"); updateQuery7.append("$set",
UserName = (String) accountServer.get("User"); new BasicDBObject().append("Email", Email));
updateQuery6.append("$set",
new BasicDBObject().append("status", true));
// System.out.println("Sending Info To Forwarding Server");
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
dCollection.updateOne(searchQuery, updateQuery2);
dCollection.updateOne(searchQuery, updateQuery3);
dCollection.updateOne(searchQuery, updateQuery4);
dCollection.updateOne(searchQuery, updateQuery5);
dCollection.updateOne(searchQuery, updateQuery6);
dCollection.updateOne(searchQuery, updateQuery7);
//delegationTimer.trigger();
} else {
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
BasicDBObject updateQuery = new BasicDBObject(); new BasicDBObject().append("type", 7));
BasicDBObject updateQuery2 = new BasicDBObject(); updateQuery1.append("$set",
BasicDBObject updateQuery3 = new BasicDBObject(); new BasicDBObject().append("status", true));
BasicDBObject updateQuery4 = new BasicDBObject(); dCollection.updateOne(searchQuery, updateQuery);
BasicDBObject updateQuery5 = new BasicDBObject(); dCollection.updateOne(searchQuery, updateQuery1);
BasicDBObject updateQuery6 = new BasicDBObject(); //delegationTimer.trigger();
BasicDBObject updateQuery7 = new BasicDBObject(); }
BasicDBObject updateQuery8 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 8));
updateQuery2.append("$set",
new BasicDBObject().append("Fname", Fname));
updateQuery3.append("$set",
new BasicDBObject().append("Path", Path));
updateQuery4.append("$set",
new BasicDBObject().append("User", UserName));
updateQuery5.append("$set",
new BasicDBObject().append("Password", Password));
updateQuery7.append("$set",
new BasicDBObject().append("Email", Email));
updateQuery6.append("$set",
new BasicDBObject().append("status", true));
updateQuery8.append("$set",
new BasicDBObject().append("Token", TKN));
System.out.println("Sending Info To Forwarding Server");
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery2);
dCollection.updateOne(searchQuery, updateQuery3);
dCollection.updateOne(searchQuery, updateQuery4);
dCollection.updateOne(searchQuery, updateQuery5);
dCollection.updateOne(searchQuery, updateQuery6);
dCollection.updateOne(searchQuery, updateQuery8);
dCollection.updateOne(searchQuery, updateQuery7);
//delegationTimer.trigger();
} else { } else {
System.out.println("Login Failure"); System.out.println("Banned Account");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 9)); new BasicDBObject().append("type", 11));
updateQuery1.append("$set", updateQuery1.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery); dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
} }
} else { } catch (Exception ERC) {
System.out.println("Banned Account");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID); searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject(); BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject(); BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set", updateQuery.append("$set",
new BasicDBObject().append("type", 11)); new BasicDBObject().append("type", 9));
updateQuery1.append("$set", updateQuery1.append("$set",
new BasicDBObject().append("status", true)); new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery); dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
} }
}
if (requesttype == 3) {
System.out.println("Login Request (TKN)");
// Document TResolve = dCollection.find(eq("type", 3)).first();
Document accountServer;
int TKN;
String Password;
String Fname;
String Path;
String UserName;
String Email;
try {
accountServer = accountS.find(eq("Token", CTOKEN)).first();
TKN = (int) accountServer.get("Token");
if (accountServer.get("Status").equals(true)) {
if (TKN == CTOKEN) {
TKN = (int) accountServer.get("Token");
Password = (String) accountServer.get("Password");
Fname = (String) accountServer.get("FName");
Path = (String) accountServer.get("Path");
Email = (String) accountServer.get("Email");
UserName = (String) accountServer.get("User");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery2 = new BasicDBObject();
BasicDBObject updateQuery3 = new BasicDBObject();
BasicDBObject updateQuery4 = new BasicDBObject();
BasicDBObject updateQuery5 = new BasicDBObject();
BasicDBObject updateQuery6 = new BasicDBObject();
BasicDBObject updateQuery7 = new BasicDBObject();
BasicDBObject updateQuery8 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 8));
updateQuery2.append("$set",
new BasicDBObject().append("Fname", Fname));
updateQuery3.append("$set",
new BasicDBObject().append("Path", Path));
updateQuery4.append("$set",
new BasicDBObject().append("User", UserName));
updateQuery5.append("$set",
new BasicDBObject().append("Password", Password));
updateQuery7.append("$set",
new BasicDBObject().append("Email", Email));
updateQuery6.append("$set",
new BasicDBObject().append("status", true));
updateQuery8.append("$set",
new BasicDBObject().append("Token", TKN));
System.out.println("Sending Info To Forwarding Server");
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery2);
dCollection.updateOne(searchQuery, updateQuery3);
dCollection.updateOne(searchQuery, updateQuery4);
dCollection.updateOne(searchQuery, updateQuery5);
dCollection.updateOne(searchQuery, updateQuery6);
dCollection.updateOne(searchQuery, updateQuery8);
dCollection.updateOne(searchQuery, updateQuery7);
//delegationTimer.trigger();
} else {
System.out.println("Login Failure");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 9));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
}
} else {
System.out.println("Banned Account");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 11));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1);
}
} catch (MongoCommandException ERC) { } catch (MongoCommandException ERC) {
System.out.println("Malformed Request"); System.out.println("Malformed Request");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
@ -463,7 +473,28 @@ public class delegationServices {
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger(); //delegationTimer.trigger();
} }
} }
} else {
System.out.println("Malformed Request, Non Recoverable");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("type", requesttype);
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
updateQuery.append("$set",
new BasicDBObject().append("type", 7));
updateQuery1.append("$set",
new BasicDBObject().append("status", true));
Lrequest.append("status",true);
dCollection.updateOne(searchQuery, updateQuery1);
dCollection.updateOne(searchQuery, updateQuery);
}
//above is finding one request and starting wheels //above is finding one request and starting wheels
//delegationTimer.trigger(); //delegationTimer.trigger();
delegate(); delegate();
@ -473,26 +504,21 @@ public class delegationServices {
searchQuery.append("status", true); searchQuery.append("status", true);
BasicDBObject searchQuery1 = new BasicDBObject(); BasicDBObject searchQuery1 = new BasicDBObject();
searchQuery1.append("status", false); searchQuery1.append("status", false);
// dCollection.deleteMany(searchQuery); dCollection.deleteMany(searchQuery);
// dCollection.deleteMany(searchQuery1); dCollection.deleteMany(searchQuery1);
System.out.println("Flushed Server");
} }
public static void delegate () public static void delegate ()
{ {
Document userLookMutedLookUp = dCollection.find(eq("status", false)).first(); userAuthetication();
try {
userAuthetication(userLookMutedLookUp);
} catch (NullPointerException NPE) {
System.out.println("No Pending Authentication Requests");
delegationTimer.trigger();
}
} }
public static void userAuthetication (Document doc){ public static void userAuthetication (){
try { try {
delegationProcesser(); delegationProcesser();
} catch (Exception exr) { } catch (Exception exr) {
System.out.println("No Pending Authentication"); System.out.println("No Pending Authentication: ");
delegationTimer.trigger(); delegationTimer.trigger();
} }
} }