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

Adds:

Browse Source 
-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)
This commit is contained in:
James Quinley 2023-05-03 23:20:27 -07:00
parent b8fe2cd5c3
commit 4bbafc3a34
1 changed files with 192 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -63,6 +63,7 @@ public class delegationServices {
dCollection = dClientDatabase.getCollection("accountRequest"); dCollection = dClientDatabase.getCollection("accountRequest");
RGFilterDB = dClient.getDatabase("rgcon"); RGFilterDB = dClient.getDatabase("rgcon");
RGFilter = RGFilterDB.getCollection("blocked"); RGFilter = RGFilterDB.getCollection("blocked");
} }
} }
@ -79,6 +80,9 @@ public class delegationServices {
static MongoClient accountGetClient = MongoClients.create(AccountSettings); static MongoClient accountGetClient = MongoClients.create(AccountSettings);
static MongoDatabase accountDatabase = accountGetClient.getDatabase("account"); static MongoDatabase accountDatabase = accountGetClient.getDatabase("account");
static MongoCollection<Document> accountS = accountDatabase.getCollection("UserPass"); static MongoCollection<Document> accountS = accountDatabase.getCollection("UserPass");
static MongoDatabase database = accountGetClient.getDatabase("guilds");
static MongoCollection<Document> scCollection = database.getCollection("userCredits");
static int RequestR; static int RequestR;
//still need to config //still need to config
public static String lastNet = null; public static String lastNet = null;
@ -185,8 +189,7 @@ public class delegationServices {
System.out.println(RG); System.out.println(RG);
System.out.println("Delegation Has Started"); 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) { if (requesttype == 47) {
System.out.println("Self Updater download Request"); System.out.println("Self Updater download Request");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();
@ -2546,6 +2549,193 @@ public class delegationServices {
dCollection.updateOne(searchQuery, updateQuery3); dCollection.updateOne(searchQuery, updateQuery3);
delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); 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 { } else {
System.out.println("Malformed Request, Non Recoverable (Request Type Not Found)"); System.out.println("Malformed Request, Non Recoverable (Request Type Not Found)");
BasicDBObject searchQuery = new BasicDBObject(); BasicDBObject searchQuery = new BasicDBObject();