From 4bbafc3a3441a0cec6a4424b466ba8d40252011d Mon Sep 17 00:00:00 2001 From: James Quinley Date: Wed, 3 May 2023 23:20:27 -0700 Subject: [PATCH] Adds: -Checking of link status of external platforms -Public Dave Bot Data fetch Coming soon: -Internal Dave Bot information fetch (Requires user's token, as it would assist in merging the two profiles for use on the dashboard) --- .../delegationServices.java | 194 +++++++++++++++++- 1 file changed, 192 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java b/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java index 92b30db..e6dd6f2 100644 --- a/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java +++ b/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java @@ -63,6 +63,7 @@ public class delegationServices { dCollection = dClientDatabase.getCollection("accountRequest"); RGFilterDB = dClient.getDatabase("rgcon"); RGFilter = RGFilterDB.getCollection("blocked"); + } } @@ -79,6 +80,9 @@ public class delegationServices { static MongoClient accountGetClient = MongoClients.create(AccountSettings); static MongoDatabase accountDatabase = accountGetClient.getDatabase("account"); static MongoCollection accountS = accountDatabase.getCollection("UserPass"); + static MongoDatabase database = accountGetClient.getDatabase("guilds"); + + static MongoCollection scCollection = database.getCollection("userCredits"); static int RequestR; //still need to config public static String lastNet = null; @@ -185,8 +189,7 @@ public class delegationServices { System.out.println(RG); 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 == 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 || requesttype == 73 || requesttype == 74 || requesttype == 75 || requesttype ==78 || requesttype == 79 || requesttype == 81 - ) { + 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 || requesttype == 73 || requesttype == 74 || requesttype == 75 || requesttype ==78 || requesttype == 79 || requesttype == 81 || requesttype == 87 || requesttype == 91) { if (requesttype == 47) { System.out.println("Self Updater download Request"); BasicDBObject searchQuery = new BasicDBObject(); @@ -2546,6 +2549,193 @@ public class delegationServices { dCollection.updateOne(searchQuery, updateQuery3); delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); } + + if (requesttype == 87) { + String CTOKEN = (String) Lrequest.get("Token"); + String platform = (String) Lrequest.get("Platform"); + // Document TResolve = dCollection.find(eq("type", 3)).first(); + Document accountServer; + String level; + String token; + try { + accountServer = accountS.find(eq("Token", CTOKEN)).first(); + if (!(accountServer == null)) { + System.out.println("HERE WE GO"); + String TKN = (String) accountServer.get("Token"); + if (accountServer.get("Status").equals(true)) { + System.out.println("Account Is Good"); + if (TKN.equals(CTOKEN)) { + System.out.println("Token is good"); + if ((Boolean) accountServer.get(platform + "idstatus")) { + System.out.println("Platform is linked and enabled"); + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", ClientID); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery1 = new BasicDBObject(); + BasicDBObject updateQuery2 = new BasicDBObject(); + BasicDBObject updateQuery3 = new BasicDBObject(); + updateQuery.append("$set", + new BasicDBObject().append("type", 89)); + updateQuery2.append("$set", + new BasicDBObject().append(platform + "id", accountServer.get(platform + "id").toString())); + updateQuery3.append("$set", + new BasicDBObject().append("Link_Enabled", true)); + updateQuery1.append("$set", + new BasicDBObject().append("status", true)); + dCollection.updateOne(searchQuery, updateQuery); + dCollection.updateOne(searchQuery,updateQuery2); + dCollection.updateOne(searchQuery, updateQuery3); + dCollection.updateOne(searchQuery, updateQuery1); + System.out.println("Done."); + BasicDBObject clearCL = new BasicDBObject(); + clearCL.append("_id", ClientID); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } else { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", ClientID); + accountServer.get(platform + "id"); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery1 = new BasicDBObject(); + updateQuery.append("$set", + new BasicDBObject().append("type", 90)); + updateQuery1.append("$set", + new BasicDBObject().append("status", true)); + Lrequest.append("status", true); + dCollection.updateOne(searchQuery, updateQuery1); + dCollection.updateOne(searchQuery, updateQuery); + BasicDBObject clearCL = new BasicDBObject(); + clearCL.append("_id", ClientID); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } + } else { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", 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)); + Lrequest.append("status", true); + dCollection.updateOne(searchQuery, updateQuery1); + dCollection.updateOne(searchQuery, updateQuery); + BasicDBObject clearCL = new BasicDBObject(); + clearCL.append("_id", ClientID); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } + } + } + } catch (Exception ex) { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", 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)); + Lrequest.append("status", true); + dCollection.updateOne(searchQuery, updateQuery1); + dCollection.updateOne(searchQuery, updateQuery); + BasicDBObject clearCL = new BasicDBObject(); + clearCL.append("_id", ClientID); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } + + } + if (requesttype == 91) { + + try + { + String accessLevel = Lrequest.get("level").toString(); + Document user = scCollection.find(eq("User", Lrequest.get("ID").toString())).first(); + int currency = (int) user.get("Credits"); + if (!user.equals(null)) + { + if (accessLevel.equals("basic")) { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", ClientID); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery1 = new BasicDBObject(); + BasicDBObject updateQuery2 = new BasicDBObject(); + BasicDBObject updateQuery3 = new BasicDBObject(); + updateQuery.append("$set", + new BasicDBObject().append("type", 93)); + updateQuery2.append("$set", + new BasicDBObject().append("isTrustedLevel", false)); + updateQuery3.append("$set", + new BasicDBObject().append("UserCredit", currency)); + updateQuery1.append("$set", + new BasicDBObject().append("status", true)); + dCollection.updateOne(searchQuery, updateQuery); + dCollection.updateOne(searchQuery, updateQuery3); + dCollection.updateOne(searchQuery, updateQuery2); + dCollection.updateOne(searchQuery,updateQuery1); + + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } + if (accessLevel.equals("system")) {} + } else { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", 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)); + Lrequest.append("status", true); + dCollection.updateOne(searchQuery, updateQuery1); + dCollection.updateOne(searchQuery, updateQuery); + BasicDBObject clearCL = new BasicDBObject(); + clearCL.append("_id", ClientID); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + System.out.println("thing"); + } + } catch (NullPointerException ex) + { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", ClientID); + + BasicDBObject updateQuery = new BasicDBObject(); + BasicDBObject updateQuery1 = new BasicDBObject(); + updateQuery.append("$set", + new BasicDBObject().append("type", 94)); + updateQuery1.append("$set", + new BasicDBObject().append("status", true)); + Lrequest.append("status", true); + dCollection.updateOne(searchQuery, updateQuery1); + dCollection.updateOne(searchQuery, updateQuery); + BasicDBObject clearCL = new BasicDBObject(); + clearCL.append("_id", ClientID); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } + catch (Exception exr) { + BasicDBObject searchQuery = new BasicDBObject(); + searchQuery.append("_id", 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)); + Lrequest.append("status", true); + dCollection.updateOne(searchQuery, updateQuery1); + dCollection.updateOne(searchQuery, updateQuery); + BasicDBObject clearCL = new BasicDBObject(); + clearCL.append("_id", ClientID); + delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); + } + + } + } else { System.out.println("Malformed Request, Non Recoverable (Request Type Not Found)"); BasicDBObject searchQuery = new BasicDBObject();