Added MongoStorageHandler

Author: noahhusby

.github/workflows/publish.yml

@@ -1,5 +1,5 @@
 name: build
-on: [push]
+on: [ push ]
 jobs:
   publish:
     runs-on: ubuntu-latest

CODE_OF_CONDUCT.md

@@ -2,124 +2,98 @@
 
 ## Our Pledge
 
-We as members, contributors, and leaders pledge to make participation in our
-community a harassment-free experience for everyone, regardless of age, body
-size, visible or invisible disability, ethnicity, sex characteristics, gender
-identity and expression, level of experience, education, socio-economic status,
-nationality, personal appearance, race, religion, or sexual identity
-and orientation.
+We as members, contributors, and leaders pledge to make participation in our community a harassment-free experience for
+everyone, regardless of age, body size, visible or invisible disability, ethnicity, sex characteristics, gender identity
+and expression, level of experience, education, socio-economic status, nationality, personal appearance, race, religion,
+or sexual identity and orientation.
 
-We pledge to act and interact in ways that contribute to an open, welcoming,
-diverse, inclusive, and healthy community.
+We pledge to act and interact in ways that contribute to an open, welcoming, diverse, inclusive, and healthy community.
 
 ## Our Standards
 
-Examples of behavior that contributes to a positive environment for our
-community include:
+Examples of behavior that contributes to a positive environment for our community include:
 
 * Demonstrating empathy and kindness toward other people
 * Being respectful of differing opinions, viewpoints, and experiences
 * Giving and gracefully accepting constructive feedback
-* Accepting responsibility and apologizing to those affected by our mistakes,
-  and learning from the experience
-* Focusing on what is best not just for us as individuals, but for the
-  overall community
+* Accepting responsibility and apologizing to those affected by our mistakes, and learning from the experience
+* Focusing on what is best not just for us as individuals, but for the overall community
 
 Examples of unacceptable behavior include:
 
-* The use of sexualized language or imagery, and sexual attention or
-  advances of any kind
+* The use of sexualized language or imagery, and sexual attention or advances of any kind
 * Trolling, insulting or derogatory comments, and personal or political attacks
 * Public or private harassment
-* Publishing others' private information, such as a physical or email
-  address, without their explicit permission
-* Other conduct which could reasonably be considered inappropriate in a
-  professional setting
+* Publishing others' private information, such as a physical or email address, without their explicit permission
+* Other conduct which could reasonably be considered inappropriate in a professional setting
 
 ## Enforcement Responsibilities
 
-Community leaders are responsible for clarifying and enforcing our standards of
-acceptable behavior and will take appropriate and fair corrective action in
-response to any behavior that they deem inappropriate, threatening, offensive,
+Community leaders are responsible for clarifying and enforcing our standards of acceptable behavior and will take
+appropriate and fair corrective action in response to any behavior that they deem inappropriate, threatening, offensive,
 or harmful.
 
-Community leaders have the right and responsibility to remove, edit, or reject
-comments, commits, code, wiki edits, issues, and other contributions that are
-not aligned to this Code of Conduct, and will communicate reasons for moderation
-decisions when appropriate.
+Community leaders have the right and responsibility to remove, edit, or reject comments, commits, code, wiki edits,
+issues, and other contributions that are not aligned to this Code of Conduct, and will communicate reasons for
+moderation decisions when appropriate.
 
 ## Scope
 
-This Code of Conduct applies within all community spaces, and also applies when
-an individual is officially representing the community in public spaces.
-Examples of representing our community include using an official e-mail address,
-posting via an official social media account, or acting as an appointed
-representative at an online or offline event.
+This Code of Conduct applies within all community spaces, and also applies when an individual is officially representing
+the community in public spaces. Examples of representing our community include using an official e-mail address, posting
+via an official social media account, or acting as an appointed representative at an online or offline event.
 
 ## Enforcement
 
-Instances of abusive, harassing, or otherwise unacceptable behavior may be
-reported to the community leaders responsible for enforcement at
-[email protected].
-All complaints will be reviewed and investigated promptly and fairly.
+Instances of abusive, harassing, or otherwise unacceptable behavior may be reported to the community leaders responsible
+for enforcement at [email protected]. All complaints will be reviewed and investigated promptly and fairly.
 
-All community leaders are obligated to respect the privacy and security of the
-reporter of any incident.
+All community leaders are obligated to respect the privacy and security of the reporter of any incident.
 
 ## Enforcement Guidelines
 
-Community leaders will follow these Community Impact Guidelines in determining
-the consequences for any action they deem in violation of this Code of Conduct:
+Community leaders will follow these Community Impact Guidelines in determining the consequences for any action they deem
+in violation of this Code of Conduct:
 
 ### 1. Correction
 
-**Community Impact**: Use of inappropriate language or other behavior deemed
-unprofessional or unwelcome in the community.
+**Community Impact**: Use of inappropriate language or other behavior deemed unprofessional or unwelcome in the
+community.
 
-**Consequence**: A private, written warning from community leaders, providing
-clarity around the nature of the violation and an explanation of why the
-behavior was inappropriate. A public apology may be requested.
+**Consequence**: A private, written warning from community leaders, providing clarity around the nature of the violation
+and an explanation of why the behavior was inappropriate. A public apology may be requested.
 
 ### 2. Warning
 
-**Community Impact**: A violation through a single incident or series
-of actions.
+**Community Impact**: A violation through a single incident or series of actions.
 
-**Consequence**: A warning with consequences for continued behavior. No
-interaction with the people involved, including unsolicited interaction with
-those enforcing the Code of Conduct, for a specified period of time. This
-includes avoiding interactions in community spaces as well as external channels
-like social media. Violating these terms may lead to a temporary or
-permanent ban.
+**Consequence**: A warning with consequences for continued behavior. No interaction with the people involved, including
+unsolicited interaction with those enforcing the Code of Conduct, for a specified period of time. This includes avoiding
+interactions in community spaces as well as external channels like social media. Violating these terms may lead to a
+temporary or permanent ban.
 
 ### 3. Temporary Ban
 
-**Community Impact**: A serious violation of community standards, including
-sustained inappropriate behavior.
+**Community Impact**: A serious violation of community standards, including sustained inappropriate behavior.
 
-**Consequence**: A temporary ban from any sort of interaction or public
-communication with the community for a specified period of time. No public or
-private interaction with the people involved, including unsolicited interaction
-with those enforcing the Code of Conduct, is allowed during this period.
-Violating these terms may lead to a permanent ban.
+**Consequence**: A temporary ban from any sort of interaction or public communication with the community for a specified
+period of time. No public or private interaction with the people involved, including unsolicited interaction with those
+enforcing the Code of Conduct, is allowed during this period. Violating these terms may lead to a permanent ban.
 
 ### 4. Permanent Ban
 
-**Community Impact**: Demonstrating a pattern of violation of community
-standards, including sustained inappropriate behavior,  harassment of an
-individual, or aggression toward or disparagement of classes of individuals.
+**Community Impact**: Demonstrating a pattern of violation of community standards, including sustained inappropriate
+behavior, harassment of an individual, or aggression toward or disparagement of classes of individuals.
 
-**Consequence**: A permanent ban from any sort of public interaction within
-the community.
+**Consequence**: A permanent ban from any sort of public interaction within the community.
 
 ## Attribution
 
-This Code of Conduct is adapted from the [Contributor Covenant][homepage],
-version 2.0, available at
+This Code of Conduct is adapted from the [Contributor Covenant][homepage], version 2.0, available at
 https://www.contributor-covenant.org/version/2/0/code_of_conduct.html.
 
-Community Impact Guidelines were inspired by [Mozilla's code of conduct
-enforcement ladder](https://github.com/mozilla/diversity).
+Community Impact Guidelines were inspired
+by [Mozilla's code of conduct enforcement ladder](https://github.com/mozilla/diversity).
 
 [homepage]: https://www.contributor-covenant.org
 

application/src/main/java/com/noahhusby/lib/application/config/Config.java

@@ -21,8 +21,8 @@
 package com.noahhusby.lib.application.config;
 
 import com.noahhusby.lib.application.config.provider.ConfigurationProvider;
-import com.noahhusby.lib.application.config.provider.JsonConfigurationProvider;
 import com.noahhusby.lib.application.config.provider.HoconConfigurationProvider;
+import com.noahhusby.lib.application.config.provider.JsonConfigurationProvider;
 import com.noahhusby.lib.application.config.provider.YamlConfigurationProvider;
 import lombok.AllArgsConstructor;
 import lombok.Getter;

application/src/main/java/com/noahhusby/lib/application/config/provider/HoconConfigurationProvider.java

@@ -116,7 +116,7 @@ private void writeProperties(BufferedWriter writer, Map<String, Property> proper
                     }
                     writer.write(indent + "]\n");
                 } else {
-                    if(property.getValue().getValue() instanceof String) {
+                    if (property.getValue().getValue() instanceof String) {
                         writer.write(indent + property.getKey() + " = \"" + property.getValue().getValue() + "\"\n\n");
                     } else {
                         writer.write(indent + property.getKey() + " = " + property.getValue().getValue() + "\n\n");

build.gradle

@@ -31,6 +31,7 @@ allprojects {
         mysqlVersion = "8.0.27"
         hikariVersion = "4.0.3"
         lombokVersion = "1.18.22"
+        mongoVersion = "3.12.10"
     }
 
     group "com.noahhusby.lib"

data/build.gradle

@@ -23,4 +23,5 @@ dependencies {
     compileOnly "com.google.code.gson:gson:$gsonVersion"
     compileOnly "com.google.guava:guava:$guavaVersion"
     compileOnly "com.zaxxer:HikariCP:$hikariVersion"
+    compileOnly "org.mongodb:mongo-java-driver:$mongoVersion"
 }

data/src/main/java/com/noahhusby/lib/data/sql/Credentials.java

@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright 2020-2021 noahhusby
+ * Copyright 2020-2022 noahhusby
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation
  * files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy,

data/src/main/java/com/noahhusby/lib/data/storage/handlers/MongoStorageHandler.java

@@ -0,0 +1,102 @@
+/*
+ * MIT License
+ *
+ * Copyright 2020-2021 noahhusby
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation
+ * files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy,
+ * modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software
+ * is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
+ * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
+ * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ *
+ */
+
+package com.noahhusby.lib.data.storage.handlers;
+
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
+import com.mongodb.client.FindIterable;
+import com.mongodb.client.MongoCollection;
+import com.mongodb.client.model.changestream.ChangeStreamDocument;
+import com.mongodb.client.model.changestream.OperationType;
+import com.noahhusby.lib.data.storage.StorageUtil;
+import com.noahhusby.lib.data.storage.compare.ComparatorAction;
+import com.noahhusby.lib.data.storage.compare.CompareResult;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import org.bson.Document;
+
+import java.util.Map;
+import java.util.function.Consumer;
+
+@RequiredArgsConstructor
+public class MongoStorageHandler extends StorageHandler {
+    @Getter
+    private final MongoCollection<Document> collection;
+
+    @Override
+    public void save(CompareResult result) {
+        try {
+            if (result.isCleared()) {
+                collection.deleteMany(new Document());
+            }
+
+            for (Map.Entry<JsonObject, ComparatorAction> r : result.getComparedOutput().entrySet()) {
+                JsonObject object = r.getKey();
+                if (r.getValue() == ComparatorAction.REMOVE) {
+                    collection.deleteOne(new Document("_id", object.get(result.getKey()).getAsString()));
+                }
+
+                if (r.getValue() == ComparatorAction.ADD) {
+                    Document document = Document.parse(StorageUtil.gson.toJson(object));
+                    if (result.getKey() != null) {
+                        document.append("_id", document.get(result.getKey()));
+                    }
+                    collection.insertOne(document);
+                }
+
+                if (r.getValue() == ComparatorAction.UPDATE) {
+                    Document document = Document.parse(StorageUtil.gson.toJson(object));
+                    collection.replaceOne(new Document("_id", document.get(result.getKey())), document);
+                }
+            }
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Override
+    public JsonArray load() {
+        FindIterable<Document> documents = collection.find();
+        JsonArray array = new JsonArray();
+        for (Document document : documents) {
+            array.add(StorageUtil.gson.toJsonTree(document));
+        }
+        return array;
+    }
+
+    public void enableEventUpdates() {
+        collection.watch().forEach((Consumer<? super ChangeStreamDocument<Document>>) x -> {
+            if (x.getOperationType() == OperationType.INSERT || x.getOperationType() == OperationType.REPLACE || x.getOperationType() == OperationType.DELETE) {
+                load();
+            }
+        });
+    }
+
+    @Override
+    public boolean isAvailable() {
+        return true;
+    }
+
+    @Override
+    public void close() {
+    }
+}