feat: Add getter for DynamoCacheWriter and DynamoSerializer

Author: derXear

src/main/java/com/dasburo/spring/cache/dynamo/DynamoCache.java

@@ -18,6 +18,7 @@
 import com.dasburo.spring.cache.dynamo.rootattribute.RootAttribute;
 import com.dasburo.spring.cache.dynamo.rootattribute.RootAttributeConfig;
 import com.dasburo.spring.cache.dynamo.rootattribute.RootAttributeReader;
+import com.dasburo.spring.cache.dynamo.serializer.DynamoSerializer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.cache.Cache;
@@ -166,6 +167,24 @@ public final List<RootAttributeConfig> getRootAttributes() {
     return cacheConfig.getRootAttributes();
   }
 
+  /**
+   * Returns the implementation of {@link DynamoCacheWriter} used for caching
+   *
+   * @return the DynamoCacheWriter implementation.
+   */
+  public final DynamoCacheWriter getWriter() {
+    return writer;
+  }
+
+  /**
+   * Returns the implementation of {@link DynamoSerializer} used to serialize the value to be cached
+   *
+   * @return the DynamoSerializer implementation.
+   */
+  public final DynamoSerializer getSerializer() {
+    return cacheConfig.getSerializer();
+  }
+
   @Override
   public void put(Object key, Object value) {
     Assert.isTrue(key instanceof String, "'key' must be an instance of 'java.lang.String'.");
@@ -210,8 +229,8 @@ private byte[] serialize(Object value) {
 
   private List<RootAttribute> readRootAttributes(List<RootAttributeConfig> rootAttributeConfigs, Object value) {
     return rootAttributeConfigs.stream()
-        .map(rootAttributeConfig -> rootAttributeReader.readRootAttribute(rootAttributeConfig, value))
-        .filter(Objects::nonNull)
-        .collect(Collectors.toList());
+      .map(rootAttributeConfig -> rootAttributeReader.readRootAttribute(rootAttributeConfig, value))
+      .filter(Objects::nonNull)
+      .collect(Collectors.toList());
   }
 }

src/test/java/com/dasburo/spring/cache/dynamo/DynamoCacheTest.java

@@ -19,7 +19,9 @@
 import com.amazonaws.services.dynamodbv2.model.GetItemResult;
 import com.dasburo.spring.cache.dynamo.helper.Address;
 import com.dasburo.spring.cache.dynamo.rootattribute.RootAttributeConfig;
+import com.dasburo.spring.cache.dynamo.serializer.DynamoSerializer;
 import com.dasburo.spring.cache.dynamo.serializer.Jackson2JsonSerializer;
+import com.dasburo.spring.cache.dynamo.serializer.StringSerializer;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.ClassRule;
@@ -63,13 +65,17 @@ public class DynamoCacheTest {
 
   private DynamoCache cache;
 
+  private DynamoSerializer serializer;
+
   @Before
   public void setup() {
     writer = spy(writer);
+    serializer = new StringSerializer();
 
     DynamoCacheConfiguration config = DynamoCacheConfiguration.defaultCacheConfig();
     config.setTtl(TTL);
     config.setFlushOnBoot(true);
+    config.setSerializer(serializer);
 
     cache = new DynamoCache(CACHE_NAME, writer, config);
     reset(writer);
@@ -126,6 +132,24 @@ public void getTtl() {
     Assert.assertEquals(TTL, ttl);
   }
 
+  /**
+   * Test for {@link DynamoCache#getWriter()}.
+   */
+  @Test
+  public void getCacheWriter() {
+    final Object cacheWriter = cache.getWriter();
+    Assert.assertEquals(writer, cacheWriter);
+  }
+
+  /**
+   * Test for {@link DynamoCache#getSerializer()}.
+   */
+  @Test
+  public void getSerializer() {
+    final DynamoSerializer serializer = cache.getSerializer();
+    Assert.assertEquals(this.serializer, serializer);
+  }
+
   /**
    * Test for {@link DynamoCache#get(Object)}.
    */