From ed0f4fe666826156f2b375c60c4a7a5a6f47eb6f Mon Sep 17 00:00:00 2001 From: James Quinley Date: Wed, 22 Mar 2023 21:40:51 -0700 Subject: [PATCH] Bleeding edge server build, DO NOT DEPLOY. --- .../delegationServices.java | 137 +++++++++++++++++- src/main/java/com/jamesquinley/Main.java | 2 +- 2 files changed, 136 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java b/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java index 8fb2194..4816946 100644 --- a/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java +++ b/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java @@ -172,7 +172,7 @@ public class delegationServices { System.out.println("Delegation Has Started"); - if (!RG.equals("web")) + if (!RG.equals("web") || !RG.equals("chat")) { 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 == 14 || requesttype == 20 || requesttype == 21 || requesttype == 41 || requesttype == 18 || requesttype == 47 || requesttype == 48 || requesttype == 54 || requesttype == 57 || requesttype == 61 || requesttype == 63 || requesttype == 65 || requesttype == 66 || requesttype == 67 || requesttype == 68 || requesttype == 71 || requesttype == 72) { if (requesttype == 47) { @@ -1825,7 +1825,7 @@ public class delegationServices { } else { System.out.println("Running in limited mode (Web Request)"); - if (requesttype == 73 || requesttype == 74 || requesttype == 75 || requesttype ==78 || requesttype == 79) { + if (requesttype == 73 || requesttype == 74 || requesttype == 75 || requesttype ==78 || requesttype == 79 || requesttype == 81) { if (requesttype == 73) { System.out.println("Login Request (USR&PASS)"); String username = (String) Lrequest.get("user"); @@ -2358,6 +2358,139 @@ public class delegationServices { dCollection.updateOne(searchQuery, updateQuery3); delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); } + if (requesttype == 81) { + System.out.println("Login Request (TKN)"); + String CTOKEN = (String) Lrequest.get("token"); + // Document TResolve = dCollection.find(eq("type", 3)).first(); + Document accountServer; + String TKN; + String Password; + String Fname; + String Path; + String UserName; + String Email; + String keychainUUID; + String validSession; + try { + accountServer = accountS.find(eq("Token", CTOKEN)).first(); + if (!(accountServer == null)) { + TKN = (String) accountServer.get("Token"); + validSession = (String) accountServer.get("websession"); + if (accountServer.get("Status").equals(true)) { + if (TKN.equals(CTOKEN) && Lrequest.get("sessionID").equals(validSession)) { + TKN = (String) 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"); + validSession = (String) accountServer.get("session"); + keychainUUID = (String) accountServer.get("UUID"); + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", Lrequest.get("_id")); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery2 = new BasicDBObject(); + BasicDBObject updateQuery3 = new BasicDBObject(); + BasicDBObject updateQuery4 = new BasicDBObject(); + BasicDBObject updateQuery6 = new BasicDBObject(); + BasicDBObject updateQuery7 = new BasicDBObject(); + BasicDBObject updateQuery8 = new BasicDBObject(); + BasicDBObject updateQuery9 = 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)); + updateQuery7.append("$set", + new BasicDBObject().append("Email", Email)); + updateQuery8.append("$set", + new BasicDBObject().append("Token", TKN)); + updateQuery9.append("$set", + new BasicDBObject().append("keychainUUID", keychainUUID)); + updateQuery6.append("$set", + new BasicDBObject().append("status", true)); + System.out.println("Sending Info To Forwarding Server"); + dCollection.updateOne(searchQuery, updateQuery8); + dCollection.updateOne(searchQuery, updateQuery); + dCollection.updateOne(searchQuery, updateQuery2); + dCollection.updateOne(searchQuery, updateQuery3); + dCollection.updateOne(searchQuery, updateQuery4); + dCollection.updateOne(searchQuery, updateQuery8); + dCollection.updateOne(searchQuery, updateQuery7); + dCollection.updateOne(searchQuery, updateQuery9); + dCollection.updateOne(searchQuery, updateQuery6); + //delegationTimer.trigger(); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } else { + System.out.println("Login Failure"); + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", Lrequest.get("_id")); + + 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(); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + + } + } else { + System.out.println("Banned Account"); + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", Lrequest.get("_id")); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery1 = new BasicDBObject(); + updateQuery.append("$set", + new BasicDBObject().append("type", 84)); + updateQuery1.append("$set", + new BasicDBObject().append("status", true)); + dCollection.updateOne(searchQuery, updateQuery); + dCollection.updateOne(searchQuery, updateQuery1); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + + } + } else { + System.out.println("Login Failure"); + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", Lrequest.get("_id")); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery1 = new BasicDBObject(); + updateQuery.append("$set", + new BasicDBObject().append("type", 83)); + updateQuery1.append("$set", + new BasicDBObject().append("status", true)); + dCollection.updateOne(searchQuery, updateQuery); + dCollection.updateOne(searchQuery, updateQuery1); + //delegationTimer.trigger(); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } + } catch (MongoCommandException ERC) { + System.out.println("Malformed Request"); + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", Lrequest.get("_id")); + + 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.DeleteTargetRequestByID(Lrequest.get("_id")); + //delegationTimer.trigger(); + } + } } else { System.out.println("Type does not exist (ERR4)"); BasicDBObject searchQuery = new BasicDBObject(); diff --git a/src/main/java/com/jamesquinley/Main.java b/src/main/java/com/jamesquinley/Main.java index 4da15f7..bf5c8ec 100644 --- a/src/main/java/com/jamesquinley/Main.java +++ b/src/main/java/com/jamesquinley/Main.java @@ -2,7 +2,7 @@ package com.jamesquinley; import com.jamesquinley.DelegationServices.status; /** -Hey there! This is the source code for AOTSK-Delegation Server, self explanatory. +Hey there! This is the source code for AOTSK-Delegation Server, self-explanatory. Also this is multi line so I can justify using this type of comment. */ public class Main {