This commit is contained in:
James 2022-02-03 23:18:47 -08:00
parent ec8c5edeb1
commit 3fe6214120
2 changed files with 4 additions and 6 deletions

View File

@ -45,13 +45,14 @@ public class delegationServices {
} catch (Exception exrp) { } catch (Exception exrp) {
} }
//TODO ADD BAN CHECK TO PREVENT BAN CIRCUMNAVIGATION, THIS WILL BE ADDED LATER //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 username = (String) Lrequest.get("User");
String password = (String) Lrequest.get("Password"); String password = (String) Lrequest.get("Password");
int CTOKEN = (int) Lrequest.get("Token"); int CTOKEN = (int) Lrequest.get("Token");
int requesttype = (int) Lrequest.get("type"); int requesttype = (int) Lrequest.get("type");
if (requesttype == 0) { if (requesttype == 0) {
System.out.println("Sync Request (TKN)"); System.out.println("Sync Request (Read" +
")");
Document accountServer; Document accountServer;
String Password; String Password;
int Token; int Token;
@ -70,10 +71,8 @@ public class delegationServices {
Path = (String) accountServer.get("Path"); Path = (String) accountServer.get("Path");
Email = (String) accountServer.get("Email"); Email = (String) accountServer.get("Email");
UserName = (String) accountServer.get("User"); UserName = (String) accountServer.get("User");
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();
BasicDBObject updateQuery2 = new BasicDBObject(); BasicDBObject updateQuery2 = new BasicDBObject();
@ -98,7 +97,6 @@ public class delegationServices {
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");
dCollection.updateOne(searchQuery, updateQuery); dCollection.updateOne(searchQuery, updateQuery);
dCollection.updateOne(searchQuery, updateQuery1); dCollection.updateOne(searchQuery, updateQuery1);
dCollection.updateOne(searchQuery, updateQuery2); dCollection.updateOne(searchQuery, updateQuery2);
@ -107,7 +105,6 @@ public class delegationServices {
dCollection.updateOne(searchQuery, updateQuery5); dCollection.updateOne(searchQuery, updateQuery5);
dCollection.updateOne(searchQuery, updateQuery6); dCollection.updateOne(searchQuery, updateQuery6);
dCollection.updateOne(searchQuery, updateQuery7); dCollection.updateOne(searchQuery, updateQuery7);
//delegationTimer.trigger();
} else { } else {
System.out.println("Sync Failure"); System.out.println("Sync Failure");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
@ -155,6 +152,7 @@ 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.
if (requesttype == 1) { if (requesttype == 1) {
System.out.println("Sync Request (Write)"); System.out.println("Sync Request (Write)");
Document accountServer; Document accountServer;