Refactors storage API for statelessness

Removes cache implementations, KVStorage interface, and direct implementations.
Renames and refactors classes to clarify the stateless nature of the storage API.
Updates Credentials to use a builder pattern.

Author: casperwtf

src/main/java/wtf/casper/storageapi/Credentials.java

@@ -1,14 +1,12 @@
 package wtf.casper.storageapi;
 
-import lombok.AccessLevel;
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-import lombok.RequiredArgsConstructor;
+import lombok.*;
 import org.jetbrains.annotations.Nullable;
 
 @Getter
 @AllArgsConstructor(access = AccessLevel.PRIVATE)
 @RequiredArgsConstructor(access = AccessLevel.PRIVATE)
+@Builder
 public final class Credentials {
 
     private final StorageType type;
@@ -30,10 +28,6 @@ public final class Credentials {
     @Nullable
     private Integer port;
 
-    public static Credentials of(final StorageType type, @Nullable final String host, @Nullable final String username, @Nullable final String password, @Nullable final String database, @Nullable String collection, @Nullable String table, @Nullable final String uri, final int port) {
-        return new Credentials(type, host, username, password, database, collection, table, uri, port);
-    }
-
     public StorageType getType(StorageType defaultValue) {
         return type == null ? defaultValue : type;
     }

…er/storageapi/StatelessFieldStorage.java …/wtf/casper/storageapi/FieldStorage.javasrc/main/java/wtf/casper/storageapi/StatelessFieldStorage.java renamed to src/main/java/wtf/casper/storageapi/FieldStorage.java src/main/java/wtf/casper/storageapi/StatelessFieldStorage.java renamed to src/main/java/wtf/casper/storageapi/FieldStorage.java

@@ -1,16 +1,11 @@
 package wtf.casper.storageapi;
 
-import wtf.casper.storageapi.misc.ConstructableValue;
-import wtf.casper.storageapi.misc.KeyValue;
-import wtf.casper.storageapi.utils.ReflectionUtil;
 import wtf.casper.storageapi.utils.StorageAPIConstants;
 
-import java.lang.reflect.ParameterizedType;
-import java.lang.reflect.Type;
 import java.util.Collection;
 import java.util.concurrent.CompletableFuture;
 
-public interface StatelessFieldStorage<K, V> {
+public interface FieldStorage<K, V> {
 
     /**
      * @param field the field to search for.
@@ -58,55 +53,6 @@ default CompletableFuture<Collection<V>> get(int limit, Filter... filters) {
      */
     CompletableFuture<V> get(final K key);
 
-    /**
-     * @param key the key to search for.
-     * @return a future that will complete with the value that matches the given key or a generated value if not found.
-     */
-    default CompletableFuture<V> getOrDefault(final K key) {
-        return get(key).thenApply((v) -> {
-
-            if (v != null) {
-                return v;
-            }
-
-            if (this instanceof ConstructableValue<?, ?>) {
-                v = ((ConstructableValue<K, V>) this).constructValue(key);
-                if (v == null) {
-                    throw new RuntimeException("Failed to create default value for V with key " + key + ". " +
-                            "Please create a constructor in V for only the key");
-                }
-                return v;
-            }
-
-            if (this instanceof KeyValue<?, ?>) {
-                KeyValue<K, V> keyValueGetter = (KeyValue<K, V>) this;
-                try {
-                    return ReflectionUtil.createInstance(keyValueGetter.value(), key);
-                } catch (final Exception e) {
-                    e.printStackTrace();
-                    throw new RuntimeException("Failed to create default value for V with key " + key + ". " +
-                            "Please create a constructor in V for only the key.", e);
-                }
-            }
-
-            try {
-                if (getClass().getGenericSuperclass() instanceof ParameterizedType parameterizedType) {
-                    Type type = parameterizedType.getActualTypeArguments()[1];
-                    Class<V> aClass = (Class<V>) Class.forName(type.getTypeName());
-                    return ReflectionUtil.createInstance(aClass, key);
-                }
-
-                throw new RuntimeException("Failed to create default value for V with key " + key + ". " +
-                        "Please create a constructor in V for only the key.");
-
-            } catch (Exception e) {
-                e.printStackTrace();
-                throw new RuntimeException("Failed to create default value for V with key " + key + ". " +
-                        "Please create a constructor in V for only the key.");
-            }
-        });
-    }
-
     /**
      * @param field the field to search for.
      * @param value the value to search for.
@@ -178,7 +124,7 @@ default CompletableFuture<Void> close() {
      * @param storage the storage to migrate from. The data will be copied from the given storage to this storage.
      * @return a future that will complete with a boolean that represents whether the migration was successful.
      */
-    default CompletableFuture<Boolean> migrate(final StatelessFieldStorage<K, V> storage) {
+    default CompletableFuture<Boolean> migrate(final FieldStorage<K, V> storage) {
         return CompletableFuture.supplyAsync(() -> {
             storage.allValues().thenAccept(this::saveAll).join();
             return true;

src/main/java/wtf/casper/storageapi/KVStorage.java

@@ -11,7 +11,7 @@
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 
-public interface StatelessKVStorage<K, V> {
+public interface KeyedStorage<K, V> {
 
     /**
      * @param key the key to search for.
@@ -115,7 +115,7 @@ default CompletableFuture<Boolean> contains(K key) {
      * @param storage the storage to migrate from. The data will be copied from the given storage to this storage.
      * @return a future that will complete with a boolean that represents whether the migration was successful.
      */
-    default CompletableFuture<Boolean> migrate(final StatelessKVStorage<K, V> storage) {
+    default CompletableFuture<Boolean> migrate(final KeyedStorage<K, V> storage) {
         return CompletableFuture.supplyAsync(() -> {
             Collection<V> vs = storage.allValues().join();
             saveAll(vs).join(); // save all will batch if the implementation supports it (mongo for example)