From 9d7fd0e04f0785478a9570163fbd00e6a219f920 Mon Sep 17 00:00:00 2001 From: James Quinley Date: Tue, 20 Jun 2023 12:01:03 -0700 Subject: [PATCH] Remove junk. --- .idea/compiler.xml | 1 + .../Asecure/electronicMailHandler.java | 392 --- .../com/jamesquinley/Asecure/secureCalls.java | 71 - .../chatSessionCreator.java | 5 - .../delegationServices.java | 2838 +---------------- .../DelegationServices/delegationTimer.java | 55 - .../DelegationServices/localNet.java | 27 - .../DelegationServices/status.java | 6 - src/main/java/com/jamesquinley/Main.java | 10 +- src/main/java/com/jamesquinley/variables.java | 6 - 10 files changed, 8 insertions(+), 3403 deletions(-) delete mode 100644 src/main/java/com/jamesquinley/Asecure/electronicMailHandler.java delete mode 100644 src/main/java/com/jamesquinley/Asecure/secureCalls.java delete mode 100644 src/main/java/com/jamesquinley/DelegationServices/chatSessionCreator.java delete mode 100644 src/main/java/com/jamesquinley/DelegationServices/delegationTimer.java delete mode 100644 src/main/java/com/jamesquinley/DelegationServices/localNet.java delete mode 100644 src/main/java/com/jamesquinley/DelegationServices/status.java delete mode 100644 src/main/java/com/jamesquinley/variables.java diff --git a/.idea/compiler.xml b/.idea/compiler.xml index 3926126..f1e8cc9 100644 --- a/.idea/compiler.xml +++ b/.idea/compiler.xml @@ -6,6 +6,7 @@ + diff --git a/src/main/java/com/jamesquinley/Asecure/electronicMailHandler.java b/src/main/java/com/jamesquinley/Asecure/electronicMailHandler.java deleted file mode 100644 index 02eb34f..0000000 --- a/src/main/java/com/jamesquinley/Asecure/electronicMailHandler.java +++ /dev/null @@ -1,392 +0,0 @@ -package com.jamesquinley.Asecure; - -import javax.mail.*; -import javax.mail.internet.InternetAddress; -import javax.mail.internet.MimeMessage; -import java.text.SimpleDateFormat; -import java.util.Date; -import java.util.Properties; - -public class electronicMailHandler { - /* - This will handle both account creation verify and login verify tasks, it will not verify for token based logins as - that form of login is client controlled and no user input is allowed, hacked clients are also locked out of the network - */ - static final String senderEmailId = "obsidiancorestudios@gmail.com"; - static final String senderPassword = "dcixokaivbyxbmnj"; - static final String emailSMTPserver = "smtp.gmail.com"; - static final String emailSMTPPort = "465"; - public static void Onboarding(String receiverEmail, String User, String UUID) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Welcome To Obsidian Core Studios!"); - message.setText("Thanks for joining our platform!\n\n" + - "Usage rules apply, account subject to moderation in accordance to our various agreements." + - "\nYou'll Only Get This Email Once." + - "\nThis Account Was Created For: " + User - + - "\nView the web dashboard here: http://obsidiancorestudios.com/login"); - - Transport.send(message); - System.out.println("Sent Onboarding Email"); - } catch (Exception e) { - e.printStackTrace(); - System.err.println("Email ONBOARD Not sent due to an error"); - secureCalls.banAction(UUID); - System.out.println("Banned user due to invalid email."); - - } - } - public static void Onboardingdisabled(String receiverEmail, String User) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Obsidian Core Account Message"); - message.setText("Hey there, account creation has been disabled.\n" + - "Due to a technical issue account creation has been disabled, see https://status.obsidiancorestudios.com for more info." + - "\nHave a good day, " + User); - - Transport.send(message); - } catch (Exception e) { - e.printStackTrace(); - } - } - public static void offBoarding(String receiverEmail, String User, String Name) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Sorry to see you go"); - message.setText("Hey " + Name + "," + - "\n" + - "We're sorry to see you go, you probably have a pretty valid reason to do so." + - "\n" + - "As such any data we have that you submitted is being deleted, this will take around a minute." + - "\n" + - "Thank you again for using our services, have a great day." + - "\n" + - "-Obsidian Core Services Team" + - "\n" + - "This email is for, " + User + ". If this is not your account, ignore this and check who has your email."); - - Transport.send(message); - System.out.println("Sent goodbye Email"); - } catch (Exception e) { - e.printStackTrace(); - - } - } - public static void newLocation (String receiverEmail, String User, String Adr, String OldAdr) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Obsidian Core Account Login Notice | " + Date); - message.setText("Something seems fishy, a login was detected at a new location " + Adr +" "+ "(at " + dateFormat.format(dt) + " PST)" + ".\nIf this was you ignore this email, if it wasn't you, please contact us (Respond to this email).\n\n\n\n" + - "\nThis email (" + receiverEmail + ") is linked to the Obsidian Core account: "+ User + " \nThese security emails can't be opted out of.\n\nThis was sent on behalf of Obsidian Core Studios by our super cool login robots.\n\n\n\n" + - "The IP address used has been set as your account's default, as well as past logins ("+Adr + ")"); - - Transport.send(message); - System.out.println("Alert Sent"); - } catch (Exception e) { - e.printStackTrace(); - System.err.println("Was Not Sent Because Of An Error."); - } - } - public static void newLink (String receiverEmail, String Platform, String User) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Obsidian Core Account Linked to " + Platform + " | " + Date); - message.setText("Hello, " + User - + "\nYou've linked your " + Platform + " account with your Obsidian Core Studios account. \n" + - "You can now use our services which we ofter there with the same account as the launcher! \n" + - "This is an automated email, please don't reply." + - "\n See the account management dashboard at https://www.obsidiancorestudios.com/account/" + - "\nYour use of our services regardless of platform are subject to our usage agreements, which can be found at https://www.obsidiancorestudios.com/legal/eula"); - - Transport.send(message); - System.out.println("Alert Sent"); - } catch (Exception e) { - e.printStackTrace(); - System.err.println("Was Not Sent Because Of An Error."); - } - } - - public static void otkEmail (String receiverEmail, String Key, String User) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Obsidian Core Account Notice"); - message.setText("Hey there, as you may have seen in the launcher, you need a one time key to continue, this email can help! " + - "\nBefore we give you the required key to continue, a gentle reminder to NEVER SHARE YOUR PASSWORD OR ONE TIME KEY! " + - "\nWell, good luck! Your one time key is: " + Key + - "\nThis key will remain active until used, it was generated at your login attempt, and won't be regenerated after the initial creation of said key." + - "\nThis key will only work with the account tied to the username: " + User + ", and will only work one time, its in the name."); - - Transport.send(message); - System.out.println("Alert Sent"); - } catch (Exception e) { - e.printStackTrace(); - System.err.println("Was Not Sent Because Of An Error."); - } - - } - public static void otkDeletionEmail (String receiverEmail, String Key, String User) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Obsidian Core Account Notice"); - message.setText("Hey there, as you may have seen in the launcher, you need a one time key to delete your account, this email can help! " + - "\nBefore we give you the required key to continue, a gentle reminder to NEVER SHARE YOUR PASSWORD OR ONE TIME KEY! " + - "\nWell, good luck! Your one time key is: " + Key + - "\nThis key will remain active until used, it was generated at your login attempt, and won't be regenerated after the initial creation of said key." + - "\nThis key will only work with the account tied to the username: " + User + ", and will only work one time, its in the name." + - "\nWe're sorry to see you go."); - - Transport.send(message); - System.out.println("Alert Sent"); - } catch (Exception e) { - e.printStackTrace(); - System.err.println("Was Not Sent Because Of An Error."); - } - - } - public static void otkDeletionEmailResend (String receiverEmail, String Key, String User) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Obsidian Core Account Notice"); - message.setText("It seems you've tried to delete your account in the past, and clicked the button again so here's the same info." + - "\nHey there, as you may have seen in the launcher, you need a one time key to delete your account, this email can help! " + - "\nBefore we give you the required key to continue, a gentle reminder to NEVER SHARE YOUR PASSWORD OR ONE TIME KEY! " + - "\nWell, good luck! Your one time key is: " + Key + - "\nThis key will remain active until used, it was generated at your login attempt, and won't be regenerated after the initial creation of said key." + - "\nThis key will only work with the account tied to the username: " + User + ", and will only work one time, its in the name." + - "\nWe're sorry to see you go."); - - Transport.send(message); - System.out.println("Alert RESent"); - } catch (Exception e) { - e.printStackTrace(); - System.err.println("Was Not Sent Because Of An Error."); - } - - } - public static void otkMigrate (String receiverEmail, String User) { - //get date for email - Date date = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy"); - String Date = formatter.format(date); - //get time for sign in time - Date dt = new Date(); - SimpleDateFormat dateFormat; - dateFormat = new SimpleDateFormat("kk:mm:ss"); - - Properties props = new Properties(); - props.put("mail.smtp.host", emailSMTPserver); - props.put("mail.smtp.socketFactory.port", emailSMTPPort); - props.put("mail.smtp.socketFactory.class", - "javax.net.ssl.SSLSocketFactory"); - props.put("mail.smtp.auth", "true"); - props.put("mail.smtp.port", emailSMTPPort); - - try { - Authenticator auth = new SMTPAuthenticator(); - Session session = Session.getInstance(props, auth); - Message message = new MimeMessage(session); - message.setFrom(new InternetAddress(senderEmailId)); - message.setRecipients(Message.RecipientType.TO, - InternetAddress.parse(receiverEmail)); - message.setSubject("Obsidian Core Account Notice"); - message.setText("The migration process has been completed, and the key is no longer valid.\n" + - "You will not receive a migration popup on login unless the account service changes hashes again.\n" + - "Welcome back to your account, and have a great day!\n" + - "\n\n\n\n\n" + - "This email is automated, sent to the owner of the account (" + User + ")." + " Please don't reply to this email."); - - Transport.send(message); - System.out.println("Alert Sent"); - } catch (Exception e) { - e.printStackTrace(); - System.err.println("Was Not Sent Because Of An Error."); - } - - } - private static class SMTPAuthenticator extends - javax.mail.Authenticator { - public PasswordAuthentication - getPasswordAuthentication() { - return new PasswordAuthentication(senderEmailId, - senderPassword); - } - } - -} diff --git a/src/main/java/com/jamesquinley/Asecure/secureCalls.java b/src/main/java/com/jamesquinley/Asecure/secureCalls.java deleted file mode 100644 index a3751e7..0000000 --- a/src/main/java/com/jamesquinley/Asecure/secureCalls.java +++ /dev/null @@ -1,71 +0,0 @@ -package com.jamesquinley.Asecure; - -import com.jamesquinley.DelegationServices.delegationServices; - -public class secureCalls { - public static void locationBasedEmail (String email, String user, String adr, String oldAdr) - { - final Runnable runnable = new Runnable() { - public void run() { - electronicMailHandler.newLocation(email , user, adr, oldAdr); - } - }; - runnable.run(); - } - - public static void banAction (String UUID) - { - final Runnable runnable = new Runnable() { - public void run() { - delegationServices.banUserID(UUID); - } - }; - runnable.run(); - - } - public static void oneTimeKeyEmail (String email, String key, String user) - { - final Runnable runnable = new Runnable() { - public void run() { - electronicMailHandler.otkEmail(email,key,user); - } - }; - runnable.run(); - } - public static void accountLinked (String email, String Platform, String user) - { - final Runnable runnable = new Runnable() { - public void run() { - electronicMailHandler.newLink(email,Platform,user); - } - }; - runnable.run(); - } - public static void accountMigrationComplete (String email, String user) - { - final Runnable runnable = new Runnable() { - public void run() { - electronicMailHandler.otkMigrate(email, user); - } - }; - runnable.run(); - } - public static void accountCreationComplete (String email, String user, String UUID) - { - final Runnable runnable = new Runnable() { - public void run() { - electronicMailHandler.Onboarding(email,user,UUID); - } - }; - runnable.run(); - } - public static void accountCreationDisabled (String email, String user) - { - final Runnable runnable = new Runnable() { - public void run() { - electronicMailHandler.Onboardingdisabled(email,user); - } - }; - runnable.run(); - } -} diff --git a/src/main/java/com/jamesquinley/DelegationServices/chatSessionCreator.java b/src/main/java/com/jamesquinley/DelegationServices/chatSessionCreator.java deleted file mode 100644 index 3981b18..0000000 --- a/src/main/java/com/jamesquinley/DelegationServices/chatSessionCreator.java +++ /dev/null @@ -1,5 +0,0 @@ -package com.jamesquinley.DelegationServices; - -public class chatSessionCreator { - -} diff --git a/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java b/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java index 41801c2..aff5fca 100644 --- a/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java +++ b/src/main/java/com/jamesquinley/DelegationServices/delegationServices.java @@ -1,6 +1,4 @@ package com.jamesquinley.DelegationServices; -import com.jamesquinley.Asecure.secureCalls; -import com.jamesquinley.variables; import com.mongodb.BasicDBObject; import com.mongodb.ConnectionString; import com.mongodb.MongoClientSettings; @@ -20,8 +18,6 @@ import java.time.LocalDateTime; import java.util.Date; import java.util.Random; -import static com.jamesquinley.Asecure.electronicMailHandler.*; -import static com.jamesquinley.Asecure.secureCalls.accountMigrationComplete; import static com.mongodb.client.model.Filters.eq; import static java.util.concurrent.TimeUnit.SECONDS; @@ -34,24 +30,8 @@ public class delegationServices { static MongoDatabase RGFilterDB; static MongoCollection RGFilter; static Document Lrequest = null; - public static void connectionInit(Boolean beta) { - //TODO Send Server Version As Standard. - if (beta) { - scReadconnectionString = new ConnectionString("mongodb+srv://betaServer:fi0tZ6yvJjTm16yA@obsidiancorebetaapi.s0mzauh.mongodb.net/?retryWrites=true&w=majority"); - //connects to database that beta clients can use. - System.out.println("This is a beta server build (and will only work on that type)"); - scReadsettings = MongoClientSettings.builder() - .applyConnectionString(scReadconnectionString) - .applyToSocketSettings(builder -> - builder.connectTimeout(5, SECONDS) - .readTimeout(6, SECONDS)) - .build(); - dClient = MongoClients.create(scReadsettings); - dClientDatabase = dClient.getDatabase("DelegationRequest"); - dCollection = dClientDatabase.getCollection("accountRequest"); - RGFilterDB = dClient.getDatabase("rgcon"); - RGFilter = RGFilterDB.getCollection("blocked"); - } else { + public static void connectionInit() { + scReadconnectionString = new ConnectionString("mongodb+srv://serverClient:x2sJ8Qu0VVMifNLX@accountdelegation.n06hb.mongodb.net/DelegationRequest?retryWrites=true&w=majority"); //connects to database that production clients can use System.out.println("This is a production server build (and will only work on that type)"); @@ -67,10 +47,7 @@ public class delegationServices { RGFilterDB = dClient.getDatabase("rgcon"); RGFilter = RGFilterDB.getCollection("blocked"); - } } - - //TODO get switcher working, NPE currently triggers on post init, move below code block into if statement, or outside of it so it will do the same thing regardless of t/f switch output static ConnectionString AccountCon = new ConnectionString("mongodb://accountserver:x2sJ8Qu0VVMifNLX@192.168.1.5:27017/account?retryWrites=true&w=majority"); //mongodb://localhost:27017 //mongodb://accountserver:x2sJ8Qu0VVMifNLX@192.168.1.5:27017/account?retryWrites=true&w=majority @@ -88,2814 +65,13 @@ public class delegationServices { static MongoCollection scCollection = database.getCollection("userCredits"); static int RequestR; //still need to config - public static String lastNet = null; - public static String IPA = null; - private static Boolean legacy = false; - private static double version = 0.0; - public static void banUserID(String UUID) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("UUID", UUID); - BasicDBObject updateQuery2 = new BasicDBObject(); - updateQuery2.append("$set", - new BasicDBObject().append("Status", false)); - accountS.updateOne(searchQuery, updateQuery2); - } public static void delegationProcesser() { Document Filter; Object ClientID = null; - try { - String RG = (String) Lrequest.get("rg"); + String RG = (String) Lrequest.get("filter"); Filter = RGFilter.find(eq("rgkey", "UAROCKS")).first(); - try { - ClientID = Lrequest.get("_id"); - } catch (Exception exrp) { - System.out.println("This request has opted out of CID."); - } - try { - IPA = (String) Lrequest.get("net"); - } catch (Exception exrp) { - System.out.println("This request has opted out of NET."); - } - try { - version = (double) Lrequest.get("apiversion"); - if (version >= (double) Filter.get("currentAPIVersion")) { - legacy =false; - System.out.println("nonlegacy"); - } else { - legacy =true; - System.out.println("legacy"); - } - } catch (Exception exrp) { - legacy = true; - System.out.println("legacy"); - } - String blockedRG = (String) Filter.get("rgflag"); - if ((Boolean) Filter.get("serviceState") == false) { - if ((Boolean) Filter.get("serviceTermination") == true) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("rid", Lrequest.get("rid")); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 60)); - updateQuery2.append("$set", - new BasicDBObject().append("dn", Filter.get("serviceTerminationNotes"))); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } else { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("rid", Lrequest.get("rid")); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 52)); - updateQuery2.append("$set", - new BasicDBObject().append("dn", Filter.get("deniedmsg"))); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - - } else { - if (blockedRG.contains(RG)) { - 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", 19)); - 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("User On Allowed Region"); - int requesttype = (int) Lrequest.get("type"); - System.out.println("Got Type, Getting Doc ID"); - RequestR = requesttype; - - 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 || requesttype == 87 || requesttype == 91 || requesttype == 95) { - if (requesttype == 47) { - System.out.println("Self Updater download Request"); - BasicDBObject searchQuery = new BasicDBObject(); - BasicDBObject SqS = new BasicDBObject(); - SqS.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - BasicDBObject updateQuery4 = new BasicDBObject(); - BasicDBObject updateQuery6 = new BasicDBObject(); - try { - - Document LCP = RGFilter.find(eq("rgkey", "UAROCKS")).first(); - String UPDT; - if ((double) Lrequest.get("apiversion") == (double) Filter.get("modernUpdaterAPIRequire")) { - UPDT = (String) LCP.get("MUURI"); - System.out.println("Modern: " + UPDT); - } else { - UPDT = (String) LCP.get("UURI"); - System.out.println("Legacy: " + UPDT); - } - String config = (String) LCP.get("config"); - updateQuery.append("$set", - new BasicDBObject().append("type", 42)); - updateQuery2.append("$set", - new BasicDBObject().append("uri", UPDT)); - updateQuery3.append("$set", - new BasicDBObject().append("winconfig", config)); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - } catch (Exception ex) { - updateQuery.append("$set", - new BasicDBObject().append("type", 43)); - updateQuery2.append("$set", - new BasicDBObject().append("uri", "F")); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - } - dCollection.updateOne(SqS, updateQuery); - dCollection.updateOne(SqS, updateQuery2); - dCollection.updateOne(SqS, updateQuery3); - dCollection.updateOne(SqS, updateQuery6); - System.out.println("Finished Updater Request"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - - } - - if (requesttype == 41) { - System.out.println("Internal Launcher Download Request"); - BasicDBObject searchQuery = new BasicDBObject(); - BasicDBObject SqS = new BasicDBObject(); - SqS.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - BasicDBObject updateQuery4 = new BasicDBObject(); - BasicDBObject updateQuery6 = new BasicDBObject(); - try { - Document LCP = RGFilter.find(eq("rgkey", "UAROCKS")).first(); - String UPDT; - if ((double) Lrequest.get("apiversion") == (double) Filter.get("modernUpdaterAPIRequire")) { - UPDT = (String) LCP.get("MURI"); - System.out.println("Modern: " + UPDT); - } else { - UPDT = (String) LCP.get("URI"); - System.out.println("Legacy: " + UPDT); - } - - updateQuery.append("$set", - new BasicDBObject().append("type", 42)); - updateQuery2.append("$set", - new BasicDBObject().append("uri", UPDT)); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - } catch (Exception ex) { - updateQuery.append("$set", - new BasicDBObject().append("type", 43)); - updateQuery2.append("$set", - new BasicDBObject().append("uri", "F")); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - } - dCollection.updateOne(SqS, updateQuery); - dCollection.updateOne(SqS, updateQuery2); - dCollection.updateOne(SqS, updateQuery6); - System.out.println("Finished Updater Request"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - - } - if (requesttype == 0) { - String CTOKEN = (String) Lrequest.get("Token"); - System.out.println("Sync Request (Read)"); - Document accountServer; - String Token; - String Fname; - String UserName; - String Email; - try { - accountServer = accountS.find(eq("Token", CTOKEN)).first(); - Token = (String) accountServer.get("Token"); - if (accountServer.get("Status").equals(true)) { - if (Token.equals(CTOKEN)) { - - Token = (String) accountServer.get("Token"); - Fname = (String) accountServer.get("FName"); - Email = (String) accountServer.get("Email"); - UserName = (String) accountServer.get("User"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - BasicDBObject updateQuery4 = new BasicDBObject(); - BasicDBObject updateQuery6 = new BasicDBObject(); - BasicDBObject updateQuery7 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 12)); - updateQuery1.append("$set", - new BasicDBObject().append("Token", Token)); - updateQuery2.append("$set", - new BasicDBObject().append("Fname", Fname)); - updateQuery3.append("$set", - new BasicDBObject().append("Path", "Path has been removed from the service, please update to remove this message.")); - updateQuery4.append("$set", - new BasicDBObject().append("User", UserName)); - updateQuery7.append("$set", - new BasicDBObject().append("Email", Email)); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - dCollection.updateOne(searchQuery, updateQuery4); - dCollection.updateOne(searchQuery, updateQuery6); - dCollection.updateOne(searchQuery, updateQuery7); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - System.out.println("Finished Sync Read Op"); - } else { - System.out.println("Sync Failure"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("rid", Lrequest.get("rid")); - - 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.DeleteTargetRequestByID(Lrequest.get("_id")); - //delegationTimer.trigger(); - } - } else { - System.out.println("Banned Account"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", 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); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } catch (MongoCommandException ERC) { - System.out.println("Malformed Request"); - 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)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } - //sync write request - if (requesttype == 1) { - System.out.println("Sync Request (Write)"); - String CTOKEN = (String) Lrequest.get("Token"); - Document accountServer; - String Token; - String Fname; - String UserName; - try { - accountServer = accountS.find(eq("Token", CTOKEN)).first(); - if (!(accountServer == null)) { - Token = (String) accountServer.get("Token"); - if (accountServer.get("Status").equals(true)) { - if (Token.equals(CTOKEN)) { - Token = (String) Lrequest.get("Token"); - System.out.println("Got info."); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("Token", Token); - BasicDBObject SqS = new BasicDBObject(); - SqS.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - BasicDBObject updateQuery6 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 12)); - updateQuery3.append("$set", - new BasicDBObject().append("DummyWriteSyncData", "1")); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(SqS, updateQuery); - dCollection.updateOne(SqS, updateQuery6); - accountS.updateOne(searchQuery, updateQuery3); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } else { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("rid", (int) Lrequest.get("rid")); - - 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", 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); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } else { - System.out.println("Malformed Request"); - 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)); - 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", 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)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } - if (requesttype == 2) { - System.out.println("Login Request (USR&PASS)"); - String username = (String) Lrequest.get("User"); - String password = (String) Lrequest.get("Password"); - Document accountServer; - String Password; - String Token; - String Fname; - String UserName; - String Email; - String keychainUUID; - - Boolean accountKeyStatus = false; - try { - accountServer = accountS.find(eq("User", username)).first(); - Password = (String) accountServer.get("Password"); - Email = (String) accountServer.get("Email"); - if (accountServer.get("Status").equals(true)) { - if (accountServer.get("Version").equals("1")) { - try { - accountKeyStatus = accountServer.getBoolean("keyStatus"); - } catch (Exception NPE) { - System.out.println("Assuming False Due To Variable Not Existing For User."); - accountKeyStatus = false; - } - if (accountKeyStatus == false) { - System.out.println(accountKeyStatus); - String alphabet = "ABCDEFGHIJKLMNOPQRSTUVWXYZ123456789"; - StringBuilder sb = new StringBuilder(); - Random random = new Random(); - int length = 15; - for (int i = 0; i < length; i++) { - int index = random.nextInt(alphabet.length()); - char randomChar = alphabet.charAt(index); - sb.append(randomChar); - } - String OTK = sb.toString(); - BasicDBObject searchQuery = new BasicDBObject(); - BasicDBObject keyApplicationIndex = new BasicDBObject(); - searchQuery.append("_id", ClientID); - keyApplicationIndex.append("User", username); - secureCalls.oneTimeKeyEmail(((String) accountServer.get("Email")), OTK, username); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject keyApply = new BasicDBObject(); - BasicDBObject keyAccountState = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 53)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - keyAccountState.append("$set", - new BasicDBObject().append("keyStatus", true)); - keyApply.append("$set", - new BasicDBObject().append("tempKey", OTK)); - accountS.updateOne(keyApplicationIndex, keyApply); - accountS.updateOne(keyApplicationIndex, keyAccountState); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - accountKeyStatus = true; - } else { - System.out.println("RS1"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 53)); - 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("RSC"); - if (Password.equals(password)) { - System.out.println("R3c"); - Token = (String) accountServer.get("Token"); - Fname = (String) accountServer.get("FName"); - Email = (String) accountServer.get("Email"); - UserName = (String) accountServer.get("User"); - lastNet = (String) accountServer.get("lastNet"); - keychainUUID = (String) accountServer.get("UUID"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - BasicDBObject updateQuery4 = new BasicDBObject(); - BasicDBObject updateQuery5 = new BasicDBObject(); - BasicDBObject updateQuery6 = new BasicDBObject(); - BasicDBObject updateQuery7 = new BasicDBObject(); - BasicDBObject updateQuery8 = new BasicDBObject(); - BasicDBObject updateQuery10 = new BasicDBObject(); - //below if is used for custom greetings, and home messages, for holidays and such. (Also right before update ops) - BasicDBObject updateQuery9 = new BasicDBObject(); - BasicDBObject updateQuery12 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 8)); - updateQuery1.append("$set", - new BasicDBObject().append("Token", Token)); - updateQuery2.append("$set", - new BasicDBObject().append("Fname", Fname)); - updateQuery3.append("$set", - new BasicDBObject().append("Path", "Path has been removed from the service, please update to remove this message.")); - updateQuery4.append("$set", - new BasicDBObject().append("User", UserName)); - updateQuery5.append("$set", - new BasicDBObject().append("Password", Password)); - updateQuery7.append("$set", - new BasicDBObject().append("Email", Email)); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - updateQuery8.append("$set", - new BasicDBObject().append("keychainUUID", keychainUUID)); - if (legacy) { - if ((Boolean) Filter.get("legacyPRDisable") == true) { - BasicDBObject updateQuery11 = new BasicDBObject(); - updateQuery11.append("$set", - new BasicDBObject().append("home", Filter.get("legacyHome"))); - updateQuery12.append("$set", - new BasicDBObject().append("hs",true)); - dCollection.updateOne(searchQuery, updateQuery11); - dCollection.updateOne(searchQuery, updateQuery12); - } - } else { - if (Filter.get("customHome").equals(true)) { - BasicDBObject updateQuery11 = new BasicDBObject(); - updateQuery11.append("$set", - new BasicDBObject().append("home", Filter.get("valHome"))); - updateQuery12.append("$set", - new BasicDBObject().append("hs",true)); - dCollection.updateOne(searchQuery, updateQuery11); - dCollection.updateOne(searchQuery, updateQuery12); - } else { - updateQuery12.append("$set", - new BasicDBObject().append("hs",false)); - dCollection.updateOne(searchQuery, updateQuery12); - } - } - /* - if (Filter.get("customGreeting").equals(true)) { - BasicDBObject updateQuery12 = new BasicDBObject(); - updateQuery12.append("$set", - new BasicDBObject().append("greeting", Filter.get("valGreet"))); - updateQuery10.append("$set", - new BasicDBObject().append("gs",true)); - dCollection.updateOne(searchQuery, updateQuery12); - dCollection.updateOne(searchQuery, updateQuery10); - }else { - updateQuery10.append("$set", - new BasicDBObject().append("gs",false)); - dCollection.updateOne(searchQuery, updateQuery10); - } - Planned for later, current UI wont allow - */ - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - dCollection.updateOne(searchQuery, updateQuery4); - dCollection.updateOne(searchQuery, updateQuery5); - dCollection.updateOne(searchQuery, updateQuery6); - dCollection.updateOne(searchQuery, updateQuery7); - dCollection.updateOne(searchQuery, updateQuery8); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - localNet.macRead(IPA, lastNet, Email, UserName, Token); - } else { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - 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", 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); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } catch (Exception ERC) { - System.out.println("Something Went Wrong: " + ERC.getLocalizedMessage()); - 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)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - - } - if (requesttype == 54) { - System.out.println("Verifying OTK"); - String userKey = (String) Lrequest.get("otk"); - String userName = (String) Lrequest.get("recoverUser"); - String serverUserName; - userKey = userKey.toUpperCase(); - System.out.println(userKey); - Document accountServer; - try { - accountServer = accountS.find(eq("tempKey", userKey)).first(); - serverUserName = (String) accountServer.get("User"); - if (accountServer.get("Status").equals(true)) { - if (userName.equalsIgnoreCase(serverUserName)) { - System.out.println("This key is correct."); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 55)); - 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("This key is incorrect"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 56)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } - } catch (Exception ERC) { - System.out.println("This key is incorrect." + ERC); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 56)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - - } - if (requesttype == 57) { - System.out.println("Verifying email with account tied to OTK"); - try { - String userKey = (String) Lrequest.get("otk"); - String requestedPassword = (String) Lrequest.get("paw"); - String email = (String) Lrequest.get("email"); - String serverEmail; - userKey = userKey.toUpperCase(); - Document accountServer; - accountServer = accountS.find(eq("tempKey", userKey)).first(); - serverEmail = (String) accountServer.get("Email"); - String userName = (String) accountServer.get("User"); - String serverKey = (String) accountServer.get("tempKey"); - if (email.equalsIgnoreCase(serverEmail) && userKey.equals(serverKey)) { - System.out.println("All Matching, lets go!"); - BasicDBObject searchQuery = new BasicDBObject(); - BasicDBObject searchQuery1 = new BasicDBObject(); - searchQuery.append("Email", serverEmail); - searchQuery1.append("_id", ClientID); - System.out.println("Send indexes are ready."); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - System.out.println("Objects are ready."); - updateQuery.append("$set", - new BasicDBObject().append("Password", requestedPassword)); - updateQuery1.append("$unset", - new BasicDBObject().append("tempKey", "")); - updateQuery2.append("$set", - new BasicDBObject().append("Version", "2")); - updateQuery3.append("$set", - new BasicDBObject().append("keyStatus", false)); - System.out.println("Objects set"); - accountS.updateOne(searchQuery, updateQuery); - accountS.updateOne(searchQuery, updateQuery1); - accountS.updateOne(searchQuery, updateQuery2); - accountS.updateOne(searchQuery, updateQuery3); - System.out.println("Objects send"); - BasicDBObject closeRequestType = new BasicDBObject(); - BasicDBObject finalizeRequest = new BasicDBObject(); - System.out.println("Objects close init"); - closeRequestType.append("$set", - new BasicDBObject().append("type", 58)); - finalizeRequest.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery1, closeRequestType); - dCollection.updateOne(searchQuery1, finalizeRequest); - System.out.println("Objects close send"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - System.out.println("request finished correctly"); - accountMigrationComplete(serverEmail, userName); - } else { - System.out.println("request denied"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 59)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } catch (Exception ex) { - System.out.println("Unable to reset password, making that known." + ex); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 59)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } - if (requesttype == 3) { - 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 UserName; - String Email; - String keychainUUID; - try { - accountServer = accountS.find(eq("Token", CTOKEN)).first(); - if (!(accountServer == null)) { - TKN = (String) accountServer.get("Token"); - if (accountServer.get("Status").equals(true)) { - if (TKN.equals(CTOKEN)) { - TKN = (String) accountServer.get("Token"); - Password = (String) accountServer.get("Password"); - Fname = (String) accountServer.get("FName"); - Email = (String) accountServer.get("Email"); - UserName = (String) accountServer.get("User"); - lastNet = (String) accountServer.get("lastNet"); - keychainUUID = (String) accountServer.get("UUID"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - 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(); - BasicDBObject updateQuery10 = new BasicDBObject(); - BasicDBObject updateQuery12 = 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 has been removed from the service, please update to remove this message.")); - 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)); - if (legacy) { - if ((Boolean) Filter.get("legacyPRDisable") == true) { - BasicDBObject updateQuery11 = new BasicDBObject(); - updateQuery11.append("$set", - new BasicDBObject().append("home", Filter.get("legacyHome"))); - updateQuery12.append("$set", - new BasicDBObject().append("hs",true)); - dCollection.updateOne(searchQuery, updateQuery11); - dCollection.updateOne(searchQuery, updateQuery12); - } - } else { - if (Filter.get("customHome").equals(true)) { - BasicDBObject updateQuery11 = new BasicDBObject(); - updateQuery11.append("$set", - new BasicDBObject().append("home", Filter.get("valHome"))); - updateQuery12.append("$set", - new BasicDBObject().append("hs",true)); - dCollection.updateOne(searchQuery, updateQuery11); - dCollection.updateOne(searchQuery, updateQuery12); - } else { - updateQuery12.append("$set", - new BasicDBObject().append("hs",false)); - dCollection.updateOne(searchQuery, updateQuery12); - } - } - 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")); - localNet.macRead(IPA, lastNet, Email, UserName, TKN); - } else { - System.out.println("Login Failure"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - 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", 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); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - - } - } else { - System.out.println("Login Failure"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - 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")); - } - } catch (MongoCommandException ERC) { - System.out.println("Malformed Request"); - 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)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - //delegationTimer.trigger(); - } - } - if (requesttype == 18) { - if ((Boolean) Filter.get("gameActive") == true) { - //Deprecated, a killswitch has been added under rgcon in the field "gameActive" - //TOKEN LOGIN FOR GAME, DOES NOT SEND EMAIL, LAUNCHER WILL NOT USE THIS. - System.out.println("Game Login"); - String CTOKEN = (String) Lrequest.get("Token"); - Document accountServer; - String TKN; - String Password; - String Fname; - String UserName; - String Email; - String Uid; - System.out.println("VarInit"); - try { - accountServer = accountS.find(eq("Token", CTOKEN)).first(); - System.out.println("PollServer"); - TKN = (String) accountServer.get("Token"); - System.out.println("TokenPulled"); - if (accountServer.get("Status").equals(true)) { - if (TKN.equals(CTOKEN)) { - System.out.println("TokenGood"); - TKN = (String) accountServer.get("Token"); - Password = (String) accountServer.get("Password"); - Fname = (String) accountServer.get("FName"); - Email = (String) accountServer.get("Email"); - // Uid = (String) accountServer.get("Uid"); - UserName = (String) accountServer.get("User"); - System.out.println("GotAccount"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - Filter = RGFilter.find(eq("rgkey", "UAROCKS")).first(); - String apiV = (String) Filter.get("gameAPI"); - String MOTD = (String) Filter.get("motd"); - System.out.println("ApiGrabbed"); - - - System.out.println("initBasicDBObject"); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - BasicDBObject updateQuery4 = new BasicDBObject(); - BasicDBObject updateQuery5 = new BasicDBObject(); - BasicDBObject updateQuery6 = new BasicDBObject(); - BasicDBObject updateQuery7 = new BasicDBObject(); - BasicDBObject updateQuery8 = new BasicDBObject(); - BasicDBObject updateQuery9 = new BasicDBObject(); - BasicDBObject updateQuery10 = new BasicDBObject(); - // BasicDBObject updateQuery11 = 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", "API_DENY_PATHFETCH")); - updateQuery4.append("$set", - new BasicDBObject().append("User", UserName)); - updateQuery5.append("$set", - new BasicDBObject().append("Password", Password)); - updateQuery7.append("$set", - new BasicDBObject().append("Email", Email)); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - updateQuery8.append("$set", - new BasicDBObject().append("Token", TKN)); - updateQuery9.append("$set", - new BasicDBObject().append("api", apiV)); - updateQuery10.append("$set", - new BasicDBObject().append("motd", MOTD)); - System.out.println("Sending Info To Forwarding Server"); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery10); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - dCollection.updateOne(searchQuery, updateQuery4); - dCollection.updateOne(searchQuery, updateQuery5); - dCollection.updateOne(searchQuery, updateQuery8); - dCollection.updateOne(searchQuery, updateQuery7); - dCollection.updateOne(searchQuery, updateQuery9); - dCollection.updateOne(searchQuery, updateQuery6); - //delegationTimer.trigger(); - System.out.println("Pushed"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } else { - System.out.println("Login Failure"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - 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", 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); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } catch (MongoCommandException ERC) { - System.out.println("Mongodb Error " + ERC); - 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)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - //delegationTimer.trigger(); - } - } else { - System.out.println("Login rejected, game client EOS has been reached."); - 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)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - - } - if (requesttype == 10) { - if (legacy && (Boolean) Filter.get("legacyPRDisable") == true) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 52)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - System.out.println("Update Request With Aborted Status"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } else { - Document DServer = dCollection.find(eq("_id", ClientID)).first(); - String User = (String) DServer.get("User"); - String Password = (String) DServer.get("Password"); - String Email = (String) DServer.get("Email"); - String FName = (String) DServer.get("FName"); - int DOB = (int) DServer.get("UDOB"); - String yearString = new SimpleDateFormat("yyyy").format(new Date()); - int year = Integer.parseInt(yearString); - if (year-DOB >= 13) { - if ((Boolean) Filter.get("creationEnabled")) { - String sourcet = "ABCDEFGHIJKLMNOPQRSTUVWXYZ123456789"; - StringBuilder sbt = new StringBuilder(); - Random random = new Random(); - int tokenlength = 60; - for (int i = 0; i < tokenlength; i++) { - int index = random.nextInt(sourcet.length()); - char randomChar = sourcet.charAt(index); - sbt.append(randomChar); - } - String Token = "OCST" + sbt.toString(); - //Above makes token, it will be remade if it already exists - String source = "ABCDEFGHIJKLMNOPQRSTUVWXYZ123456789"; - StringBuilder sb = new StringBuilder(); - int length = 40; - for (int i = 0; i < length; i++) { - int index = random.nextInt(source.length()); - char randomChar = source.charAt(index); - sb.append(randomChar); - } - String UUID = sb.toString(); - //Above makes UUID, will be remade if it already exists. - - try { - - Document DupeEmail = accountS.find(eq("Email", Email)).first(); - String DUPEEMAIL = (String) DupeEmail.get("Email"); - if (DUPEEMAIL.equals(null)) { - Document DupeUser = accountS.find(eq("User", User)).first(); - String DUPE = (String) DupeUser.get("User"); - } - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 6)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } catch (Exception exr) { - System.out.println("Username & Email Is Open"); - try { - Document DupeToken = accountS.find(eq("Token", Token)).first(); - String DupeToke1n = (String) DupeToken.get("Token"); - System.out.println("Got Token from request"); - Boolean TokenOpen = false; - while (TokenOpen == false) { - for (int i = 0; i < tokenlength; i++) { - int index = random.nextInt(sourcet.length()); - char randomChar = sourcet.charAt(index); - sbt.append(randomChar); - } - Token = sbt.toString(); - try { - DupeToken = accountS.find(eq("Token", Token)).first(); - DupeToke1n = (String) DupeToken.get("Token"); - System.out.println("Token Is Reserved, Try Again."); - for (int i = 0; i < tokenlength; i++) { - int index = random.nextInt(sourcet.length()); - char randomChar = sourcet.charAt(index); - sbt.append(randomChar); - } - } catch (Exception exDr) { - TokenOpen = true; - System.out.println("Token Free (While EXP)"); - } - } - } catch (Exception token) { - System.out.println("Working on UUID"); - try { - Document DupeUUID = accountS.find(eq("UUID", UUID)).first(); - String DupeUUIDS = (String) DupeUUID.get("UUID"); - System.out.println("Got Gen UUID"); - Boolean UUIDOPEN = false; - while (UUIDOPEN == false) { - length = 40; - sb = new StringBuilder(); - for (int i = 0; i < length; i++) { - int index = random.nextInt(source.length()); - char randomChar = source.charAt(index); - sb.append(randomChar); - } - String UUIDGEN = sb.toString(); - try { - System.out.println("Retry UUID"); - DupeUUID = accountS.find(eq("UUID", UUID)).first(); - DupeUUIDS = (String) DupeUUID.get("UUID"); - System.out.println("UUID Is Reserved, Try Again."); - length = 40; - sb = new StringBuilder(); - for (int i = 0; i < length; i++) { - int index = random.nextInt(source.length()); - char randomChar = source.charAt(index); - sb.append(randomChar); - } - UUIDGEN = sb.toString(); - UUID = UUIDGEN; - } catch (Exception exDr) { - UUIDOPEN = true; - System.out.println("UUID Free (While EXP)" + exDr); - } - } - } catch (NullPointerException uuid) { - System.out.println("UUID Free"); - } - System.out.println("Token Free"); - System.out.println("Token & UUID Free (Main)"); - System.out.println("Creating."); - Document createForm = new Document(); - createForm.append("User", User); - createForm.append("Password", Password); - createForm.append("Status", true); - createForm.append("Flagged", false); - createForm.append("Email", Email); - createForm.append("FName", FName); - createForm.append("Entitlements", "NA"); - createForm.append("Freinds", " "); - createForm.append("Token", Token); - createForm.append("UUID", UUID); - createForm.append("Control", 1); - createForm.append("Upgrade", 0); - createForm.append("Version", "2"); - createForm.append("keyStatus", false); - //createForm.append("Uid",uid); - createForm.append("lastNet", IPA); - accountS.insertOne(createForm); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - secureCalls.accountCreationComplete(Email, User, UUID); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 4)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - System.out.println("Update Request With Finished Status"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - - } - } else { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - try { secureCalls.accountCreationDisabled(Email, User);} catch (Exception ex) {System.out.println("Unable to send disabled msg to user"); - } - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 52)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - System.out.println("Update Request With Finished Status"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } else { - //Please set to a custom flag - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 97)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } - } - if (requesttype == 20) - //TODO rewrite to just need username, password will be set by system later - { - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - System.out.println("Shadow Account Creation Request"); - Document DServer = dCollection.find(eq("_id", ClientID)).first(); - String User = (String) DServer.get("User"); - String Password = (String) DServer.get("Password"); - // String Email = (String) DServer.get("Email"); - String FName = User; - String sourcet = "ABCDEFGHIJKLMNOPQRSTUVWXYZ123456789"; - StringBuilder sbt = new StringBuilder(); - Random random = new Random(); - int tokenlength = 60; - for (int i = 0; i < tokenlength; i++) { - int index = random.nextInt(sourcet.length()); - char randomChar = sourcet.charAt(index); - sbt.append(randomChar); - } - String Token = "OCST" + sbt.toString(); - try { - Document DupeUser = accountS.find(eq("User", User)).first(); - String DUPE = (String) DupeUser.get("User"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 6)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - System.out.println("User Exists"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } catch (Exception exr) { - System.out.println("Username Is Open"); - try { - Document DupeToken = accountS.find(eq("Token", Token)).first(); - String DupeToke1n = (String) DupeToken.get("Token"); - System.out.println("Got Token from request"); - Boolean TokenOpen = false; - while (TokenOpen == false) { - for (int i = 0; i < tokenlength; i++) { - int index = random.nextInt(sourcet.length()); - char randomChar = sourcet.charAt(index); - sbt.append(randomChar); - } - Token = sbt.toString(); - try { - DupeToken = accountS.find(eq("Token", Token)).first(); - DupeToke1n = (String) DupeToken.get("Token"); - System.out.println("Token Is Reserved, Try Again."); - for (int i = 0; i < tokenlength; i++) { - int index = random.nextInt(sourcet.length()); - char randomChar = sourcet.charAt(index); - sbt.append(randomChar); - } - } catch (Exception exDr) { - TokenOpen = true; - System.out.println("Token Free (While EXP)"); - } - } - } catch (Exception exrs) { - System.out.println("Token Free (Main)"); - System.out.println("Creating."); - Document createForm = new Document(); - createForm.append("User", User); - createForm.append("Status", true); - createForm.append("limited", true); - createForm.append("Flagged", false); - createForm.append("Password", Password); - createForm.append("FName", FName); - createForm.append("Entitlements", "NA"); - createForm.append("Token", Token); - createForm.append("Control", 1); - accountS.insertOne(createForm); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 4)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - System.out.println("Update Request With Finished Status"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - - } - - } - } - if (requesttype == 21) { - //Friends Network Login Goes Here, Fun. - } - if (requesttype == 48) { - - System.out.println("Launcher Startup Request"); - String lV = (String) Lrequest.get("version"); - String platKey = (String) Lrequest.get("key"); - System.out.println("GrabbedInfo"); - try { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - Filter = RGFilter.find(eq("rgkey", "UAROCKS")).first(); - String pKey = (String) Filter.get("platformKey"); - String version = (String) Filter.get("platformVersion"); - String platformUpdateNotes = (String) Filter.get("platformUpdateNotes"); - String dr = (String) Filter.get("deniedmsg"); - String nw = (String) Filter.get("lnews"); - System.out.println("ApiGrabbed"); - - - System.out.println("initBasicDBObject"); - 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 updateQuery11 = new BasicDBObject(); - if (pKey.equals(platKey)) { - if (lV.equals(version)) { - System.out.println("Approved"); - updateQuery.append("$set", - new BasicDBObject().append("type", 49)); - } else { - System.out.println("UpdateRequred"); - updateQuery.append("$set", - new BasicDBObject().append("type", 51)); - } - } else { - updateQuery.append("$set", - new BasicDBObject().append("type", 50)); - updateQuery7.append("$set", - new BasicDBObject().append("dn", dr)); - System.out.println("Denied"); - } - if (legacy) { - if ((Boolean) Filter.get("legacyPRDisable") == true) { - updateQuery2.append("$set", - new BasicDBObject().append("uNotes", (String) Filter.get("legacyPRUpdateDisplay"))); - updateQuery3.append("$set", - new BasicDBObject().append("pushV", version)); - updateQuery4.append("$set", - new BasicDBObject().append("keyReq", pKey)); - updateQuery8.append("$set", - new BasicDBObject().append("news", (String) Filter.get("legacyNews"))); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - updateQuery7.append("$set", - new BasicDBObject().append("dn", dr)); - System.out.println("Sending Info To Forwarding Server"); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - dCollection.updateOne(searchQuery, updateQuery4); - dCollection.updateOne(searchQuery, updateQuery7); - dCollection.updateOne(searchQuery, updateQuery8); - dCollection.updateOne(searchQuery, updateQuery6); - } else { - updateQuery2.append("$set", - new BasicDBObject().append("uNotes", platformUpdateNotes)); - updateQuery3.append("$set", - new BasicDBObject().append("pushV", version)); - updateQuery4.append("$set", - new BasicDBObject().append("keyReq", pKey)); - updateQuery8.append("$set", - new BasicDBObject().append("news", nw)); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - updateQuery7.append("$set", - new BasicDBObject().append("dn", dr)); - System.out.println("Sending Info To Forwarding Server"); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - dCollection.updateOne(searchQuery, updateQuery4); - dCollection.updateOne(searchQuery, updateQuery7); - dCollection.updateOne(searchQuery, updateQuery8); - dCollection.updateOne(searchQuery, updateQuery6); - } - } else { - updateQuery2.append("$set", - new BasicDBObject().append("uNotes", platformUpdateNotes)); - updateQuery3.append("$set", - new BasicDBObject().append("pushV", version)); - updateQuery4.append("$set", - new BasicDBObject().append("keyReq", pKey)); - updateQuery8.append("$set", - new BasicDBObject().append("news", nw)); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - updateQuery7.append("$set", - new BasicDBObject().append("dn", dr)); - System.out.println("Sending Info To Forwarding Server"); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - dCollection.updateOne(searchQuery, updateQuery4); - dCollection.updateOne(searchQuery, updateQuery7); - dCollection.updateOne(searchQuery, updateQuery8); - dCollection.updateOne(searchQuery, updateQuery6); - } - //delegationTimer.trigger(); - System.out.println("Pushed"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - - } catch (MongoCommandException ERC) { - System.out.println("Mongodb Error " + ERC); - 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)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - //delegationTimer.trigger(); - } - } - if (requesttype == 61) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - System.out.println("Init ClientTraceback"); - String policyDocument; - try { - policyDocument = Files.readString(Path.of(System.getProperty("user.home") + "/ocs/policy/launcher/legal/eula.txt")); - } catch (Exception EXR) { - System.out.println("Unable to pull file, fallback."); - policyDocument = "Policy file does not exist on server. This is an issue on our end. Error ID: " + EXR; - } - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 62)); - updateQuery2.append("$set", - new BasicDBObject().append("policyDocument", policyDocument)); - updateQuery3.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - if (requesttype == 63) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - System.out.println("Init ClientTraceback"); - String policyDocument; - try { - // File homedir = new File(System.getProperty("user.home")); - policyDocument = Files.readString(Path.of(System.getProperty("user.home") + "/ocs/policy/launcher/legal/eula.txt")); - } catch (Exception EXR) { - System.out.println("Unable to pull file, fallback."); - policyDocument = "Policy file does not exist on server. This is an issue on our end. Error ID: " + EXR; - } - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 64)); - updateQuery2.append("$set", - new BasicDBObject().append("policyDocument", policyDocument)); - updateQuery3.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - if (requesttype == 65) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - System.out.println("Collecting Error Data"); - File homedir = new File(System.getProperty("user.home")); - String applicationName = Lrequest.get("applicationName").toString(); - String bugType = Lrequest.get("bugType").toString(); - String bugDetails = Lrequest.get("bugDetails").toString(); - String bugSeverity = Lrequest.get("bugSeverity").toString(); - String UUID = Lrequest.get("UUID").toString(); - String timeCurrent = LocalDateTime.now().toString(); //ISO-8601: yyyy-MM-ddTHH:mm:ss.S - try { - File myObj = new File(homedir + "/ocs/logs/" + applicationName + UUID + timeCurrent + ".txt"); - if (myObj.createNewFile()) { - System.out.println("Log File created: " + myObj.getName()); - FileWriter writer = new FileWriter(homedir + "/ocs/logs/" + applicationName + UUID + timeCurrent + ".txt", true); - writer.write("This bug report is for: " + applicationName); - writer.write("\r\n"); - writer.write("The bug severity is level: " + bugSeverity); - writer.write("\r\n"); - writer.write("The bug type is: " + bugType); - writer.write("\r\n"); - writer.write("More bug details: " + bugDetails); - writer.write("\r\n"); - writer.write("This is auto generated by the Obsidian Core backend services"); - writer.write("\r\n"); - writer.write("Submission Time (Local To Server): " + timeCurrent); - writer.close(); - - } else { - System.out.println("Log already exists."); - } - } catch (IOException e) { - System.out.println("An error occurred when attempting to log." + e); - } - BasicDBObject updateQuery = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - delegationServices.TargetDelete(Lrequest.get("_id")); - } - if (requesttype == 66) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - System.out.println("Collecting Error Data"); - File homedir = new File(System.getProperty("user.home")); - String applicationName = Lrequest.get("applicationName").toString(); - String bugType = Lrequest.get("bugType").toString(); - String bugDetails = Lrequest.get("bugDetails").toString(); - String bugSeverity = Lrequest.get("bugSeverity").toString(); - String bugLog = Lrequest.get("bugLog").toString(); - String UUID = Lrequest.get("UUID").toString(); - String timeCurrent = LocalDateTime.now().toString(); //ISO-8601: yyyy-MM-ddTHH:mm:ss.S - try { - File myObj = new File(homedir + "/ocs/logs/" + applicationName + UUID + timeCurrent + ".txt"); - if (myObj.createNewFile()) { - System.out.println("Log File created: " + myObj.getName()); - FileWriter writer = new FileWriter(homedir + "/ocs/logs/" + applicationName + UUID + timeCurrent + ".txt", true); - writer.write("This bug report is for: " + applicationName); - writer.write("\r\n"); - writer.write("The bug severity is level: " + bugSeverity); - writer.write("\r\n"); - writer.write("The bug type is: " + bugType); - writer.write("\r\n"); - writer.write("More bug details: " + bugDetails); - writer.write("\r\n"); - writer.write("This is auto generated by the Obsidian Core backend services"); - writer.write("\r\n"); - writer.write("Submission Time (Local To Server): " + timeCurrent); - writer.write("\r\n"); - writer.write("Full log file:"); - writer.write("\r\n"); - writer.write(bugLog); - writer.close(); - } else { - System.out.println("Log already exists."); - } - } catch (IOException e) { - System.out.println("An error occurred while attempting to log." + e); - } - BasicDBObject updateQuery = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - delegationServices.TargetDelete(Lrequest.get("_id")); - } - if (requesttype == 71) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - System.out.println("Collecting Telemetry Data"); - File homedir = new File(System.getProperty("user.home")); - String applicationName = Lrequest.get("applicationName").toString(); - String telemetryType = Lrequest.get("TelemetryType").toString(); - String telemetryDetails = Lrequest.get("TelemetryDetails").toString(); - String UUID = Lrequest.get("UUID").toString(); - String timeCurrent = LocalDateTime.now().toString(); //ISO-8601: yyyy-MM-ddTHH:mm:ss.S - try { - File myObj = new File(homedir + "/ocs/telemetry/" + UUID + "/" + applicationName + timeCurrent + ".txt"); - File myFold = new File(homedir + "/ocs/telemetry/" + UUID); - myFold.mkdir(); - if (myObj.createNewFile()) { - System.out.println("Log File created: " + myObj.getName()); - FileWriter writer = new FileWriter(homedir + "/ocs/telemetry/" + UUID + "/" + applicationName + timeCurrent + ".txt", true); - writer.write("This Telemetry report is for: " + applicationName); - writer.write("\r\n"); - writer.write("Type of telemetry: " + telemetryType); - writer.write("\r\n"); - writer.write("Telemetry: " + telemetryDetails); - writer.write("\r\n"); - writer.write("This is auto generated by the Obsidian Core backend services"); - writer.write("\r\n"); - writer.write("Submission Time (Local To Server): " + timeCurrent); - writer.close(); - - } else { - System.out.println("Log already exists."); - } - } catch (IOException e) { - System.out.println("An error occurred when attempting to log." + e); - } - BasicDBObject updateQuery = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - delegationServices.TargetDelete(Lrequest.get("_id")); - } - if (requesttype == 72) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - System.out.println("Collecting Telemetry Data"); - File homedir = new File(System.getProperty("user.home")); - String applicationName = Lrequest.get("applicationName").toString(); - String telemetryType = Lrequest.get("telemetryType").toString(); - String telemetryDetails = Lrequest.get("telemetryDetails").toString(); - String telemetryLog = Lrequest.get("telemetryLog").toString(); - String UUID = Lrequest.get("UUID").toString(); - String timeCurrent = LocalDateTime.now().toString(); //ISO-8601: yyyy-MM-ddTHH:mm:ss.S - try { - File myObj = new File(homedir + "/ocs/telemetry/" + UUID + "/" + applicationName + "logfile" + timeCurrent + ".txt"); - File myFold = new File(homedir + "/ocs/telemetry/" + UUID); - myFold.mkdir(); - if (myObj.createNewFile()) { - System.out.println("Log File created: " + myObj.getName()); - FileWriter writer = new FileWriter(homedir + "/ocs/telemetry/" + UUID + "/" + applicationName + "logfile" + timeCurrent + ".txt", true); - writer.write("This telemetry report is for: " + applicationName); - writer.write("\r\n"); - writer.write("The telemetry type is: " + telemetryType); - writer.write("\r\n"); - writer.write("More telemetry details: " + telemetryDetails); - writer.write("\r\n"); - writer.write("This is auto generated by the Obsidian Core backend services"); - writer.write("\r\n"); - writer.write("Submission Time (Local To Server): " + timeCurrent); - writer.write("\r\n"); - writer.write("Full log file:"); - writer.write("\r\n"); - writer.write(telemetryLog); - writer.close(); - } else { - System.out.println("telemetry already exists. (wow that's rare)"); - } - } catch (IOException e) { - System.out.println("An error occurred while attempting to save telemetry." + e); - } - BasicDBObject updateQuery = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - delegationServices.TargetDelete(Lrequest.get("_id")); - } - if (requesttype == 68) { - System.out.println("Verifying OTK"); - String userKey = (String) Lrequest.get("otk"); - String clientUUID = (String) Lrequest.get("uuid"); - String serverUUID; - userKey = userKey.toUpperCase(); - Document accountServer; - try { - accountServer = accountS.find(eq("delOTK", userKey)).first(); - serverUUID = (String) accountServer.get("UUID"); - if (accountServer.get("Status").equals(true)) { - if (clientUUID.equalsIgnoreCase(serverUUID)) { - System.out.println("This key is correct."); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 69)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - //delegationTimer.trigger(); - offBoarding((String) accountServer.get("Email"), (String) accountServer.get("User"), (String) accountServer.get("FName")); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - accountS.deleteOne(accountServer); - } else { - System.out.println("This key is incorrect"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 70)); - 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("This key is incorrect, account is banned."); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 70)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - } catch (Exception ERC) { - System.out.println("This key is incorrect." + ERC); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 70)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - - } - if (requesttype == 67) { - if (legacy && (Boolean) Filter.get("legacyPRDisable") == true) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 52)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - System.out.println("Update Request With Aborted Status"); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } else - { - String OTK = "keyNotSetDueToError(ERR24)"; - Boolean keyStatus = false; - //default false, since will be set to true if the measurement exists on linked account - String accountUUID = (String) Lrequest.get("uuid"); - Document linkedAccount = accountS.find(eq("UUID", accountUUID)).first(); - try { - keyStatus = (boolean) linkedAccount.get("delStatus"); - } catch (Exception NPE) { - keyStatus = false; - } - if (keyStatus == false) { - String alphabet = "ABCDEFGHIJKLMNOPQRSTUVWXYZ123456789"; - StringBuilder sb = new StringBuilder(); - Random random = new Random(); - int length = 15; - for (int i = 0; i < length; i++) { - int index = random.nextInt(alphabet.length()); - char randomChar = alphabet.charAt(index); - sb.append(randomChar); - } - OTK = sb.toString(); - BasicDBObject deleteKey = new BasicDBObject(); - BasicDBObject deleteKeyStatus = new BasicDBObject(); - BasicDBObject deleteTie = new BasicDBObject(); - deleteTie.append("UUID", accountUUID); - deleteKey.append("$set", - new BasicDBObject().append("delOTK", OTK)); - deleteKeyStatus.append("$set", - new BasicDBObject().append("delStatus", true)); - accountS.updateOne(deleteTie, deleteKey); - accountS.updateOne(deleteTie, deleteKeyStatus); - otkDeletionEmail((String) linkedAccount.get("Email"), OTK, (String) linkedAccount.get("User")); - } else { - otkDeletionEmailResend((String) linkedAccount.get("Email"), (String) linkedAccount.get("delOTK"), (String) linkedAccount.get("User")); - } - BasicDBObject clearCL = new BasicDBObject(); - clearCL.append("_id", ClientID); - BasicDBObject clearUO = new BasicDBObject(); - clearUO.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(clearCL, clearUO); - TargetDelete(ClientID); - } - } - 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 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"); - This may be added later to serve session tokens, this however will be added before chat is released to the public. - */ - - if (accountServer.get("Status").equals(true)) { - if (TKN.equals(CTOKEN)) { - Fname = (String) accountServer.get("FName"); - UserName = (String) accountServer.get("User"); - keychainUUID = (String) accountServer.get("UUID"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", Lrequest.get("_id")); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery4 = new BasicDBObject(); - BasicDBObject updateQuery6 = new BasicDBObject(); - BasicDBObject updateQuery9 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 82)); - updateQuery2.append("$set", - new BasicDBObject().append("Fname", Fname)); - updateQuery4.append("$set", - new BasicDBObject().append("User", UserName)); - 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, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery4); - 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", 86)); - 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", 86)); - 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(); - } - } - if (requesttype == 73) { - System.out.println("Login Request (USR&PASS)"); - String username = (String) Lrequest.get("user"); - String password = (String) Lrequest.get("password"); - String session; - String sourcet = "ABCDEFGHIJKLMNOPQRSTUVWXYZ"; - StringBuilder sbt = new StringBuilder(); - Random srandom = new Random(); - int sidl = 100; - for (int i = 0; i < sidl; i++) { - int index = srandom.nextInt(sourcet.length()); - char randomChar = sourcet.charAt(index); - sbt.append(randomChar); - } - session = sbt.toString(); - Object objid = Lrequest.get("_id"); - System.out.println(objid); - Document accountServer; - String Password; String Token;String Fname; String UserName; String Email; String keychainUUID; Boolean accountKeyStatus = false; - try { - accountServer = accountS.find(eq("User", username)).first(); - Password = (String) accountServer.get("Password"); - Email = (String) accountServer.get("Email"); - if (accountServer.get("Status").equals(true)) { - if (accountServer.get("Version").equals("1")) { - try { - accountKeyStatus = accountServer.getBoolean("keyStatus"); - } catch (Exception NPE) { - System.out.println("Assuming False Due To Variable Not Existing For User."); - accountKeyStatus = false; - } - if (accountKeyStatus == false) { - System.out.println(accountKeyStatus); - String alphabet = "ABCDEFGHIJKLMNOPQRSTUVWXYZ123456789"; - StringBuilder sb = new StringBuilder(); - Random random = new Random(); - int length = 15; - for (int i = 0; i < length; i++) { - int index = random.nextInt(alphabet.length()); - char randomChar = alphabet.charAt(index); - sb.append(randomChar); - } - String OTK = sb.toString(); - BasicDBObject searchQuery = new BasicDBObject(); - BasicDBObject keyApplicationIndex = new BasicDBObject(); - searchQuery.append("_id", objid); - keyApplicationIndex.append("User", username); - secureCalls.oneTimeKeyEmail(((String) accountServer.get("Email")), OTK, username); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject keyApply = new BasicDBObject(); - BasicDBObject keyAccountState = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 53)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - keyAccountState.append("$set", - new BasicDBObject().append("keyStatus", true)); - keyApply.append("$set", - new BasicDBObject().append("tempKey", OTK)); - accountS.updateOne(keyApplicationIndex, keyApply); - accountS.updateOne(keyApplicationIndex, keyAccountState); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - accountKeyStatus = true; - } else { - System.out.println("RS1"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", objid); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 53)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - //delegationTimer.trigger(); - delegationTimer.DeleteTargetRequestByID(objid); - System.out.println("Deleted"); - } - - } else { - System.out.println("RSC"); - if (Password.equals(password)) { - System.out.println("R3c"); - Token = (String) accountServer.get("Token"); - Fname = (String) accountServer.get("FName"); - Email = (String) accountServer.get("Email"); - UserName = (String) accountServer.get("User"); - lastNet = (String) accountServer.get("lastNet"); - keychainUUID = (String) accountServer.get("UUID"); - System.out.println("4"); - BasicDBObject searchQuery = new BasicDBObject(); - BasicDBObject searchQueryAD = new BasicDBObject(); - searchQuery.append("_id", objid); - searchQueryAD.append("UUID", keychainUUID); - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = 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(); - BasicDBObject updateQueryAD = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 8)); - updateQuery1.append("$set", - new BasicDBObject().append("Token", Token)); - updateQuery2.append("$set", - new BasicDBObject().append("Fname", Fname)); - updateQuery3.append("$set", - new BasicDBObject().append("Path", "Path has been removed from the service, please update to remove this message.")); - updateQuery4.append("$set", - new BasicDBObject().append("User", UserName)); - updateQuery7.append("$set", - new BasicDBObject().append("Email", Email)); - updateQuery6.append("$set", - new BasicDBObject().append("status", true)); - updateQuery8.append("$set", - new BasicDBObject().append("keychainUUID", keychainUUID)); - updateQuery9.append("$set", - new BasicDBObject().append("session", session)); - updateQueryAD.append("$set", - new BasicDBObject().append("websession", session)); - System.out.println("3"); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery3); - dCollection.updateOne(searchQuery, updateQuery4); - dCollection.updateOne(searchQuery, updateQuery9); - dCollection.updateOne(searchQuery, updateQuery7); - dCollection.updateOne(searchQuery, updateQuery8); - dCollection.updateOne(searchQuery, updateQuery6); - accountS.updateOne(searchQueryAD,updateQueryAD); - /*The last update allows the server to add the current authed web session, home page - will verify session staus, if it is invalid the user will be pushed to create a new session. - */ - System.out.println("2"); - //delegationTimer.trigger(); - System.out.println("1"); - delegationTimer.DeleteTargetRequestByID(objid); - System.out.println("clear"); - } else { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", objid); - - 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(objid); - } - } - } 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", 11)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery1); - delegationTimer.DeleteTargetRequestByID(objid); - } - } catch (Exception ERC) { - System.out.println("Something Went Wrong: " + ERC.getLocalizedMessage()); - 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.trigger(); - delegationTimer.DeleteTargetRequestByID(objid); - } - - } - if (requesttype == 74) { - System.out.println("Login Request (TKN-WB)"); - String CTOKEN = (String) Lrequest.get("token"); - // Document TResolve = dCollection.find(eq("type", 3)).first(); - Document accountServer; - String TKN; - String Password; - String Fname; - 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"); - 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 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)); - 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, 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", 11)); - 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", 9)); - 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(); - } - } - if (requesttype == 75) { - System.out.println("Link request"); - String CTOKEN = (String) Lrequest.get("token"); - String platform = (String) Lrequest.get("linkplatform"); - String email = (String) Lrequest.get("emailtoken"); - String id = (String) Lrequest.get("linktoken"); - Document accountServer; - String TKN; - String Password; - String Fname; - String UserName; - String Email; - String keychainUUID; - String validSession; - try { - accountServer = accountS.find(eq("Token", CTOKEN)).first(); - if (!(accountServer == null)) { - TKN = (String) accountServer.get("Token"); - if (accountServer.get("Status").equals(true)) { - if (TKN.equals(CTOKEN)) { - if (accountServer.get(platform+"idstatus") == null) { - Email = (String) accountServer.get("Email"); - UserName = (String) accountServer.get("User"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", Lrequest.get("_id")); - BasicDBObject searchQueryASC = new BasicDBObject(); - searchQueryASC.append("Token", TKN); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - BasicDBObject updateQuery4 = new BasicDBObject(); - BasicDBObject updateQueryAD = new BasicDBObject(); - BasicDBObject updateQueryADBS = new BasicDBObject(); - BasicDBObject externalEmail = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 76)); - updateQuery4.append("$set", - new BasicDBObject().append("status", true)); - updateQueryAD.append("$set", - new BasicDBObject().append(platform + "id", id)); - updateQueryADBS.append("$set", - new BasicDBObject().append(platform + "idstatus", true)); - externalEmail.append("$set", - new BasicDBObject().append(platform + "email", email)); - System.out.println("Sending Info To Forwarding Server"); - dCollection.updateOne(searchQuery, updateQuery); - accountS.updateOne(searchQueryASC, updateQueryAD); - accountS.updateOne(searchQueryASC, externalEmail); - accountS.updateOne(searchQueryASC, updateQueryADBS); - dCollection.updateOne(searchQuery, updateQuery4); - secureCalls.accountLinked(Email, platform, UserName); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - //Make social credit profile if it doesn't exist - if (platform.equals("Discord")) { - Document user = scCollection.find(eq("User", id)).first(); - if (user == null) - { Document document = new Document(); - document.append("User", id); - document.append("UserFreindly", accountServer.get("User").toString()); - document.append("Credits", 1000); - document.append("npTH","0"); - document.append("controlVAR", 0); - document.append("wordRC",3); - document.append("banUntil",3); - document.append("npMUTE", false); - scCollection.insertOne(document); - System.out.println("Created a profile with Obsidian Core Bot Services."); - } else { - System.out.println("User already registered with bot.."); - } - } - - - } else { - System.out.println("Already linked"); - 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", 77)); - 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("Link 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", 77)); - 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", 77)); - 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", 9)); - 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(); - } - } - if (requesttype == 78) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - System.out.println("Collecting Telemetry Data"); - File homedir = new File(System.getProperty("user.home")); - String applicationName = Lrequest.get("useragent").toString(); - // String telemetryType = Lrequest.get("telemetryType").toString(); - String mclog = Lrequest.get("log").toString(); - String IGN = Lrequest.get("ign").toString(); - String timeCurrent = LocalDateTime.now().toString(); //ISO-8601: yyyy-MM-ddTHH:mm:ss.S - try { - File myObj = new File(homedir + "/crad/telemetry/" + IGN + "/" + timeCurrent + ".txt"); - File myFold = new File(homedir + "/crad/telemetry/" + IGN); - myFold.mkdir(); - if (myObj.createNewFile()) { - System.out.println("Log File created: " + myObj.getName()); - FileWriter writer = new FileWriter(homedir + "/crad/telemetry/" + IGN + "/" + timeCurrent + ".txt", true); - writer.write("This telemetry report is for: " + applicationName); - writer.write("\r\n"); - writer.write("\r\n"); - writer.write("This is auto generated by the Obsidian Core backend services (For Create Research & Development."); - writer.write("\r\n"); - writer.write("Submission Time (Local To Server): " + timeCurrent); - writer.write("\r\n"); - writer.write("Full log file:"); - writer.write("\r\n"); - writer.write(mclog); - writer.close(); - } else { - System.out.println("telemetry already exists. (wow that's rare)"); - } - } catch (IOException e) { - System.out.println("An error occurred while attempting to save telemetry." + e); - } - BasicDBObject updateQuery = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - if (requesttype == 79) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - System.out.println("Init ClientTraceback"); - String policyDocument; - try { - policyDocument = Files.readString(Path.of(System.getProperty("user.home") + "/ocs/policy/launcher/legal/eula.txt")); - } catch (Exception EXR) { - System.out.println("Unable to pull file, fallback."); - policyDocument = "Policy file does not exist on server. This is an issue on our end. Error ID: " + EXR; - } - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 80)); - updateQuery2.append("$set", - new BasicDBObject().append("policyDocument", policyDocument)); - updateQuery3.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery2); - 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(); - BasicDBObject updateQuery4 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 89)); - updateQuery2.append("$set", - new BasicDBObject().append("id", accountServer.get(platform + "id").toString())); - updateQuery3.append("$set", - new BasicDBObject().append("Link_Enabled", true)); - updateQuery4.append("$set", - new BasicDBObject().append("platform", platform)); - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery4); - 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")); - } - } - } else { - System.out.println("Invalid user"); - 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")); - } - - } - if (requesttype == 95) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("_id", ClientID); - - BasicDBObject updateQuery = new BasicDBObject(); - BasicDBObject updateQuery1 = new BasicDBObject(); - BasicDBObject updateQuery2 = new BasicDBObject(); - BasicDBObject updateQuery3 = new BasicDBObject(); - BasicDBObject updateQuery4 = new BasicDBObject(); - BasicDBObject updateQuery5 = new BasicDBObject(); - updateQuery.append("$set", - new BasicDBObject().append("type", 96)); - updateQuery2.append("$set", - new BasicDBObject().append("ServerVersion", variables.serverVersion)); - updateQuery3.append("$set", - new BasicDBObject().append("ServerRegion", variables.serverRegion)); - if ((Boolean) Filter.get("aboutServiceStatus")) { - updateQuery4.append("$set", - new BasicDBObject().append("ServiceStatus", Filter.get("statusMessage"))); - } else { - updateQuery4.append("$set", - new BasicDBObject().append("ServiceStatus", "Service is offline.")); - } - if (legacy && (Boolean) Filter.get("legacyPRDisable") == true) { - updateQuery5.append("$set", - new BasicDBObject().append("FeatureLevel", "Limited Features")); - } else { - updateQuery5.append("$set", - new BasicDBObject().append("FeatureLevel", "Full Features")); - } - - updateQuery1.append("$set", - new BasicDBObject().append("status", true)); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery3); - dCollection.updateOne(searchQuery, updateQuery2); - dCollection.updateOne(searchQuery, updateQuery4); - dCollection.updateOne(searchQuery, updateQuery5); - dCollection.updateOne(searchQuery,updateQuery1); - - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } - - } else { - System.out.println("Malformed Request, Non Recoverable (Request Type Not Found)"); - 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 Erp) { - System.out.println("Malformed Request, Non Recoverable ErrorInfo: "); - Erp.printStackTrace(); - 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)); - updateQuery1.append("$set", - new BasicDBObject().append("pos", "uk")); - Lrequest.append("status", true); - dCollection.updateOne(searchQuery, updateQuery1); - dCollection.updateOne(searchQuery, updateQuery); - dCollection.updateOne(searchQuery, updateQuery); - delegationTimer.DeleteTargetRequestByID(Lrequest.get("_id")); - } } public static void Purge() { @@ -2923,14 +99,6 @@ public class delegationServices { System.out.println("Flushed a targeted request (CID) from the server"); - } - public static void TargetDeleteRID(int CID) { - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("rid", CID); - dCollection.deleteMany(searchQuery); - System.out.println("Flushed a targeted request (RID) from the server"); - - } public static void userAuthetication() { Lrequest = dCollection.find(eq("status", false)).first(); diff --git a/src/main/java/com/jamesquinley/DelegationServices/delegationTimer.java b/src/main/java/com/jamesquinley/DelegationServices/delegationTimer.java deleted file mode 100644 index c72b5b5..0000000 --- a/src/main/java/com/jamesquinley/DelegationServices/delegationTimer.java +++ /dev/null @@ -1,55 +0,0 @@ -package com.jamesquinley.DelegationServices; - -import java.util.concurrent.Executors; -import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.TimeUnit; - -public class delegationTimer { - public static void DeleteTargetRequest (int CID) - { - final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); - final Runnable runnable = new Runnable() { - int countdownStarter = 5; - public void run() { - countdownStarter--; - if (countdownStarter <= 0) { - countdownStarter = 5; - delegationServices.TargetDelete(CID); - scheduler.shutdown(); - } - } - }; - scheduler.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS); - } - public static void DeleteTargetRequestByID (Object ID) - { - final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); - final Runnable runnable = new Runnable() { - int countdownStarter = 5; - public void run() { - countdownStarter--; - if (countdownStarter <= 0) { - countdownStarter = 5; - delegationServices.TargetDeleteByID(ID); - scheduler.shutdown(); - } - } - }; - scheduler.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS); - } - public static void DeleteTargetRequestRID (int RID) - { - final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); - final Runnable runnable = new Runnable() { - int countdownStarter = 9; - public void run() { - countdownStarter--; - if (countdownStarter <= 0) { - countdownStarter = 9; - delegationServices.TargetDeleteRID(RID); - scheduler.shutdown(); - } - } - }; - scheduler.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS); - }} diff --git a/src/main/java/com/jamesquinley/DelegationServices/localNet.java b/src/main/java/com/jamesquinley/DelegationServices/localNet.java deleted file mode 100644 index 0d595f8..0000000 --- a/src/main/java/com/jamesquinley/DelegationServices/localNet.java +++ /dev/null @@ -1,27 +0,0 @@ -package com.jamesquinley.DelegationServices; - -import com.jamesquinley.Asecure.electronicMailHandler; -import com.jamesquinley.Asecure.secureCalls; -import com.mongodb.BasicDBObject; - -import static com.jamesquinley.DelegationServices.delegationServices.accountS; - -public class localNet { - public static void macRead (String NewIp, String OldIp, String email, String UName, String Token) - { - if (OldIp.contains(NewIp)) - { - System.out.println("User Logged In From A Known Computer, not sending email"); - } else - { - System.out.println("Hey this user Logged In From A new Location, dispatching email!"); - secureCalls.locationBasedEmail(email,UName,NewIp, OldIp); - System.out.println("Switching Trusted Net To New Local"); - BasicDBObject searchQuery = new BasicDBObject(); - searchQuery.append("Token", Token); - BasicDBObject updateQuery = new BasicDBObject(); - updateQuery.append("$set", new BasicDBObject().append("lastNet", OldIp +" "+ NewIp)); - accountS.updateOne(searchQuery, updateQuery); - } - } -} diff --git a/src/main/java/com/jamesquinley/DelegationServices/status.java b/src/main/java/com/jamesquinley/DelegationServices/status.java deleted file mode 100644 index 2ef0125..0000000 --- a/src/main/java/com/jamesquinley/DelegationServices/status.java +++ /dev/null @@ -1,6 +0,0 @@ -package com.jamesquinley.DelegationServices; - -public class status { - public static boolean betaServer = false; - public static String serverVersion = "1.3"; -} diff --git a/src/main/java/com/jamesquinley/Main.java b/src/main/java/com/jamesquinley/Main.java index bf5c8ec..7431578 100644 --- a/src/main/java/com/jamesquinley/Main.java +++ b/src/main/java/com/jamesquinley/Main.java @@ -1,23 +1,21 @@ package com.jamesquinley; -import com.jamesquinley.DelegationServices.status; /** -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. +I/O and lobby management backend for new sandbox multiplayer game, go team (Marci and I!) */ public class Main { public static void main(String[] args) throws InterruptedException { - com.jamesquinley.DelegationServices.delegationServices.connectionInit(status.betaServer); + com.jamesquinley.DelegationServices.delegationServices.connectionInit(); com.jamesquinley.DelegationServices.delegationServices.Purge(); System.out.println("We're starting the login delegation server, please wait one moment while we check a few things."); System.out.println("We've started everything, requests are now being served"); while (true) { - isolatedTimer(); + isolatedTrigger(); Thread.sleep(500); } } - static void isolatedTimer() { + static void isolatedTrigger() { try { com.jamesquinley.DelegationServices.delegationServices.userAuthetication(); } catch (Exception e) { diff --git a/src/main/java/com/jamesquinley/variables.java b/src/main/java/com/jamesquinley/variables.java deleted file mode 100644 index 800bfcd..0000000 --- a/src/main/java/com/jamesquinley/variables.java +++ /dev/null @@ -1,6 +0,0 @@ -package com.jamesquinley; - -public class variables { - public static String serverVersion = "5.2.3 (Prod)"; - public static String serverRegion = "US West (CEN-CAL)"; -}