Added Responce for banned users.

This commit is contained in:
James Quinley 2022-01-27 14:48:34 -08:00
parent 705d1749c6
commit 7e9d20950c

View File

@ -53,8 +53,7 @@ public class delegationServices {
int requesttype = (int) Lrequest.get("type");
if (requesttype == 0) {
System.out.println("Sync Request (TKN)");
Document TResolve = dCollection.find(eq("type", 0)).first();
String CTOKEN = (String) TResolve.get("Token");
String CTOKEN = (String) Lrequest.get("Token");
Document accountServer;
String Password;
String Token;
@ -65,6 +64,7 @@ public class delegationServices {
try {
accountServer = accountS.find(eq("Token", CTOKEN)).first();
Password = (String) accountServer.get("Token");
if (accountServer.get("Status").equals("Active")) {
if (Password.equals(CTOKEN)) {
Token = (String) accountServer.get("Token");
Password = (String) accountServer.get("Password");
@ -125,6 +125,20 @@ public class delegationServices {
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){
System.out.println("Malformed Request");
BasicDBObject searchQuery = new BasicDBObject();
@ -146,6 +160,7 @@ public class delegationServices {
if (requesttype == 1) {
//sync write request
System.out.println("Sync Request (Write)");
}
if (requesttype == 2) {
System.out.println("Login Request (USR&PASS)");
@ -159,6 +174,7 @@ public class delegationServices {
try {
accountServer = accountS.find(eq("User", username)).first();
Password = (String) accountServer.get("Password");
if (accountServer.get("Status").equals("Active")) {
if (Password.equals(password)) {
Token = (String) accountServer.get("Token");
Fname = (String) accountServer.get("FName");
@ -217,6 +233,20 @@ public class delegationServices {
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 (Exception ERC) {
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid", ClientID);
@ -231,6 +261,7 @@ public class delegationServices {
dCollection.updateOne(searchQuery, updateQuery1);
//delegationTimer.trigger();
}
}
if (requesttype == 3) {
System.out.println("Login Request (TKN)");
@ -246,6 +277,7 @@ public class delegationServices {
try {
accountServer = accountS.find(eq("Token", CTOKEN)).first();
TKN = (String) accountServer.get("Token");
if (accountServer.get("Status").equals("Active")) {
if (TKN.equals(CTOKEN)) {
Password = (String) accountServer.get("Password");
Fname = (String) accountServer.get("FName");
@ -301,6 +333,20 @@ public class delegationServices {
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) {
System.out.println("Malformed Request");
BasicDBObject searchQuery = new BasicDBObject();