Feature/reactive data redis

data/data-samples/pom.xml

@@ -35,6 +35,7 @@
         <module>sample-data-mysql-book</module>
         <module>sample-data-mysql-reactive-book</module>
         <module>sample-data-redis-book</module>
+        <module>sample-data-redis-reactive-book</module>
     </modules>
 
 </project>

data/data-samples/sample-data-redis-book/src/main/resources/data-book-application.properties

@@ -13,6 +13,6 @@
 #
 spring.data.redis.database=0
 spring.data.redis.host=localhost
-spring.data.redis.port=16379
-spring.data.redis.password=password
+spring.data.redis.port=6379
+spring.data.redis.password=
 spring.data.redis.timeout=60000

data/data-samples/sample-data-redis-book/src/test/java/io/americanexpress/data/book/config/BookDataConfigTest.java

@@ -27,7 +27,7 @@ public class BookDataConfigTest {
     private RedisServer redisServer;
 
     public BookDataConfigTest(Environment environment) {
-        this.redisServer = new RedisServer(Integer.parseInt(environment.getRequiredProperty("spring.redis.port")));
+        this.redisServer = new RedisServer(Integer.parseInt(environment.getRequiredProperty("spring.data.redis.port")));
     }
 
     @PostConstruct

data/data-samples/sample-data-redis-book/src/test/java/io/americanexpress/data/book/config/BookDataTestConfig.java

@@ -20,6 +20,6 @@
  * {@code BookDataTestConfig} class contains configurations for tests.
  */
 @Configuration
-@Import({BookDataConfig.class})
+@Import({BookDataConfigTest.class})
 public class BookDataTestConfig {
 }

data/data-samples/sample-data-redis-book/src/test/java/io/americanexpress/data/book/repository/BookRepositoryIT.java

@@ -38,8 +38,7 @@ class BookRepositoryIT {
     private BookRepository bookRepository;
 
     @Test
-    public void save_givenValidBook_expectedSavedBookSuccess() {
-        UUID id = UUID.randomUUID();
+    void save_givenValidBook_expectedSavedBookSuccess() {
         BookEntity bookEntity = new BookEntity("Alice Wonderland", "Lewis Carroll");
         BookEntity saved = bookRepository.save(bookEntity);
         assertNotNull(saved);

data/data-samples/sample-data-redis-reactive-book/pom.xml

@@ -0,0 +1,51 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+    Copyright 2020 American Express Travel Related Services Company, Inc.
+
+    Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+    in compliance with the License. You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing, software distributed under the License
+    is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+    or implied. See the License for the specific language governing permissions and limitations under
+    the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <artifactId>data-samples</artifactId>
+        <groupId>io.americanexpress.synapse</groupId>
+        <version>0.3.14-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>sample-data-redis-reactive-book</artifactId>
+
+    <dependencies>
+        <!-- Synapse dependencies -->
+        <dependency>
+            <groupId>io.americanexpress.synapse</groupId>
+            <artifactId>synapse-data-redis</artifactId>
+        </dependency>
+        <!-- Spring dependencies -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-test-autoconfigure</artifactId>
+        </dependency>
+        <!-- Third party dependencies -->
+        <dependency>
+            <groupId>it.ozimov</groupId>
+            <artifactId>embedded-redis</artifactId>
+            <version>0.7.2</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>

data/data-samples/sample-data-redis-reactive-book/src/main/java/io/americanexpress/data/book/config/BookDataConfig.java

@@ -0,0 +1,78 @@
+/*
+ * Copyright 2020 American Express Travel Related Services Company, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.americanexpress.data.book.config;
+
+import io.americanexpress.data.book.entity.BookEntity;
+import io.americanexpress.synapse.data.redis.config.BaseReactiveRedisDataConfig;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.PropertySource;
+import org.springframework.core.env.Environment;
+import org.springframework.data.redis.connection.ReactiveRedisConnectionFactory;
+import org.springframework.data.redis.core.ReactiveRedisTemplate;
+import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.GenericToStringSerializer;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+/**
+ * {@code BookDataConfig} is the configuration class to load all the properties for the book data module.
+ */
+@Configuration
+@PropertySource("classpath:data-book-application.properties")
+@ComponentScan(basePackages = BookDataConfig.PACKAGE_NAME)
+@EnableRedisRepositories(basePackages = BookDataConfig.PACKAGE_NAME)
+public class BookDataConfig extends BaseReactiveRedisDataConfig {
+
+    /**
+     * The Package name.
+     */
+    static final String PACKAGE_NAME = "io.americanexpress.data.book";
+
+    /**
+     * The {@link BookDataConfig} overloaded constructor.
+     * @param environment the environment
+     */
+    public BookDataConfig(Environment environment) {
+        super(environment);
+    }
+
+    /**
+     * Overriding method to configure redis template for serialization/deserialization for key, value mapping of String and {@link BookEntity} type.
+     *
+     * @param factory the redis connection factory
+     * @return the reactive redis template specifically for <Stirng, BookEntity>
+     */
+    @Override
+    public ReactiveRedisTemplate<String, BookEntity> reactiveRedisTemplate(ReactiveRedisConnectionFactory factory) {
+        return new ReactiveRedisTemplate<>(factory, getSerializationContext());
+    }
+
+    /**
+     * Overriding method to provide configuration for serialization/deserialization of {@link BookEntity}.
+     *
+     * @return the redis serialization context
+     */
+    @Override
+    protected RedisSerializationContext<String, BookEntity> getSerializationContext() {
+        return  RedisSerializationContext
+                .<String, BookEntity>newSerializationContext(new StringRedisSerializer())
+                .key(new StringRedisSerializer())
+                .value(new GenericToStringSerializer<>(BookEntity.class))
+                .hashKey(new StringRedisSerializer())
+                .hashValue(new GenericJackson2JsonRedisSerializer())
+                .build();
+    }
+}

data/data-samples/sample-data-redis-reactive-book/src/main/java/io/americanexpress/data/book/entity/BookEntity.java

@@ -0,0 +1,88 @@
+/*
+ * Copyright 2020 American Express Travel Related Services Company, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.americanexpress.data.book.entity;
+
+import io.americanexpress.synapse.data.redis.entity.BaseEntity;
+import org.springframework.data.redis.core.RedisHash;
+
+/**
+ * {@code BookEntity} class represents the domain of the books table.
+ */
+@RedisHash("books")
+public class BookEntity extends BaseEntity {
+
+    /**
+     * The title.
+     */
+    private String title;
+
+    /**
+     * The author.
+     */
+    private String author;
+
+    /**
+     * Instantiates a new Book entity.
+     *
+     * @param title  the title
+     * @param author the author
+     */
+    public BookEntity(String title, String author) {
+        this.title = title;
+        this.author = author;
+    }
+
+    /**
+     * Instantiates a new Book entity.
+     */
+    public BookEntity() {}
+
+    /**
+     * Gets title.
+     *
+     * @return the title
+     */
+    public String getTitle() {
+        return title;
+    }
+
+    /**
+     * Sets title.
+     *
+     * @param title the title
+     */
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    /**
+     * Gets author.
+     *
+     * @return the author
+     */
+    public String getAuthor() {
+        return author;
+    }
+
+    /**
+     * Sets author.
+     *
+     * @param author the author
+     */
+    public void setAuthor(String author) {
+        this.author = author;
+    }
+
+}
+

data/data-samples/sample-data-redis-reactive-book/src/main/java/io/americanexpress/data/book/repository/BookRepository.java

@@ -0,0 +1,49 @@
+/*
+ * Copyright 2020 American Express Travel Related Services Company, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.americanexpress.data.book.repository;
+
+import io.americanexpress.data.book.entity.BookEntity;
+import io.americanexpress.synapse.data.redis.repository.BaseRedisHashReactiveRepository;
+import org.springframework.data.redis.core.ReactiveRedisOperations;
+import org.springframework.stereotype.Repository;
+import reactor.core.publisher.Mono;
+
+/**
+ * {@code BookRepository} is used to access redis store.
+ */
+@Repository
+public class BookRepository extends BaseRedisHashReactiveRepository<String, BookEntity> {
+    protected BookRepository(ReactiveRedisOperations<String, BookEntity> reactiveRedisOperations) {
+        super(reactiveRedisOperations);
+    }
+
+    @Override
+    public String getKey() {
+        return "books";
+    }
+
+    /**
+     * Find by title.
+     *
+     * @param title the title
+     * @return the mono BookEntity if book exists with title
+     */
+    public Mono<BookEntity> findByTitle(String title) {
+        return reactiveRedisOperations.<String, BookEntity>opsForHash()
+                .values(getKey())
+                .filter(book -> book.getTitle().equals(title))
+                .singleOrEmpty();
+    }
+}
+

data/data-samples/sample-data-redis-book/src/test/resources/application.properties → data/data-samples/sample-data-redis-reactive-book/src/main/resources/data-book-application.properties

@@ -11,5 +11,8 @@
 # or implied. See the License for the specific language governing permissions and limitations under
 # the License.
 #
-#spring.redis.host=localhost
-#spring.redis.port=6370
+spring.data.redis.database=0
+spring.data.redis.host=localhost
+spring.data.redis.port=6379
+spring.data.redis.password=
+spring.data.redis.timeout=60000

data/synapse-data-redis/pom.xml

@@ -26,7 +26,7 @@
         <!-- Spring Dependencies -->
         <dependency>
             <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-data-redis</artifactId>
+            <artifactId>spring-boot-starter-data-redis-reactive</artifactId>
         </dependency>
         <dependency>
             <groupId>org.springframework.data</groupId>
@@ -36,8 +36,6 @@
         <dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>
-            <version>3.3.0</version>
-            <type>jar</type>
         </dependency>
     </dependencies>