feat | add redisservice

thiagochirana · Aug 4, 2024 · 19f9f2d · 19f9f2d
1 parent 784c7f1
commit 19f9f2d
Show file tree

Hide file tree

Showing 6 changed files with 87 additions and 8 deletions.
diff --git a/app/backend/pom.xml b/app/backend/pom.xml
@@ -94,6 +94,11 @@
 			<artifactId>spring-boot-starter-data-jpa</artifactId>
 		</dependency>
 
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+		</dependency>
+
 	</dependencies>
 
 	<build>

diff --git a/app/backend/src/main/java/br/com/streampix/app/controllers/CheckoutController.java b/app/backend/src/main/java/br/com/streampix/app/controllers/CheckoutController.java
@@ -1,13 +1,12 @@
 package br.com.streampix.app.controllers;
 
+import br.com.streampix.app.models.GetRedis;
 import br.com.streampix.app.models.records.checkout.CheckoutJson;
 import br.com.streampix.app.services.CheckoutService;
+import com.fasterxml.jackson.core.JsonProcessingException;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 @RestController
 @RequestMapping("/api/v1/checkout")
@@ -17,7 +16,12 @@ public class CheckoutController {
     private final CheckoutService checkoutService;
 
     @PostMapping
-    public ResponseEntity doCheckout(@RequestBody CheckoutJson json){
+    public ResponseEntity doCheckout(@RequestBody CheckoutJson json) throws JsonProcessingException {
         return checkoutService.doCheckout(json);
     }
+
+    @GetMapping
+    public ResponseEntity getCheckout(@RequestBody GetRedis json) throws JsonProcessingException {
+        return checkoutService.getRedis(json.nickname());
+    }
 }
diff --git a/app/backend/src/main/java/br/com/streampix/app/models/GetRedis.java b/app/backend/src/main/java/br/com/streampix/app/models/GetRedis.java
@@ -0,0 +1,6 @@
+package br.com.streampix.app.models;
+
+public record GetRedis(
+        String nickname
+) {
+}
diff --git a/app/backend/src/main/java/br/com/streampix/app/security/ApiConfiguration.java b/app/backend/src/main/java/br/com/streampix/app/security/ApiConfiguration.java
@@ -11,6 +11,7 @@
 import org.springframework.security.web.SecurityFilterChain;
 import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
 
+import static org.springframework.http.HttpMethod.GET;
 import static org.springframework.http.HttpMethod.POST;
 import static org.springframework.security.config.http.SessionCreationPolicy.STATELESS;
 
@@ -32,6 +33,7 @@ public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Excepti
                                 .permitAll()
                                 .requestMatchers(POST,"/api/v1/auth/login").permitAll()
                                 .requestMatchers(POST,"/api/v1/checkout").permitAll()
+                                .requestMatchers(GET,"/api/v1/checkout").permitAll()
                                 .requestMatchers(POST,"/api/v1/auth/sign_up").permitAll()
                                 .requestMatchers(POST,"/api/v1/auth/refresh_token").permitAll()
                                 .anyRequest()

diff --git a/app/backend/src/main/java/br/com/streampix/app/services/CheckoutService.java b/app/backend/src/main/java/br/com/streampix/app/services/CheckoutService.java
@@ -3,19 +3,33 @@
 import br.com.streampix.app.models.checkout.Checkout;
 import br.com.streampix.app.models.records.checkout.CheckoutJson;
 import br.com.streampix.app.repositories.CheckoutRepositoryRedis;
+import com.fasterxml.jackson.core.JsonProcessingException;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+import java.util.Optional;
+
 @Service
 @RequiredArgsConstructor
 public class CheckoutService {
 
     private final CheckoutRepositoryRedis checkoutRepositoryRedis;
+    private final RedisService redis;
 
-    public ResponseEntity doCheckout(CheckoutJson json){
+    public ResponseEntity doCheckout(CheckoutJson json) throws JsonProcessingException {
         Checkout checkout = new Checkout(null, json.nickname(), json.message(), json.value(), "100");
-        Checkout co = checkoutRepositoryRedis.save(checkout);
-        return ResponseEntity.ok().body("Deu bom rapaziada ===> " + co.toString());
+        redis.put("CO_"+json.nickname(), checkout);
+        return ResponseEntity.ok().body("Deu bom em por no Redis");
+    }
+
+    public ResponseEntity getRedis(String nickname) throws JsonProcessingException {
+        List<Checkout> checkouts = redis.findByAttribute("CO_"+nickname, "nickname", nickname, Checkout.class);
+        if (checkouts.isEmpty()) {
+            return ResponseEntity.notFound().build();
+        } else {
+            return ResponseEntity.ok(checkouts);
+        }
     }
 }
diff --git a/app/backend/src/main/java/br/com/streampix/app/services/RedisService.java b/app/backend/src/main/java/br/com/streampix/app/services/RedisService.java
@@ -0,0 +1,48 @@
+package br.com.streampix.app.services;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonMappingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+
+@Service
+@RequiredArgsConstructor
+public class RedisService {
+
+    private final RedisTemplate<String, String> redisTemplate;
+    private final ObjectMapper objectMapper;
+
+    public <T> void put(String key, T model) throws JsonProcessingException {
+        String modelJson = objectMapper.writeValueAsString(model);
+        redisTemplate.opsForValue().set(key, modelJson);
+    }
+
+    public <T> T get(String key, Class<T> clazz) throws JsonProcessingException {
+        String modelJson = redisTemplate.opsForValue().get(key);
+        if (modelJson != null) {
+            return objectMapper.readValue(modelJson, clazz);
+        } else {
+            return null;
+        }
+    }
+
+    public <T> List<T> findByAttribute(String prefix, String attributeName, String attributeValue, Class<T> clazz) throws JsonProcessingException, JsonMappingException {
+        List<T> models = new ArrayList<>();
+        for (String key : Objects.requireNonNull(redisTemplate.keys(prefix + "*"))) {
+            String modelJson = redisTemplate.opsForValue().get(key);
+            if (modelJson != null) {
+                T model = objectMapper.readValue(modelJson, clazz);
+                String attributeJsonValue = objectMapper.convertValue(model, Map.class).get(attributeName).toString();
+                if (attributeValue.equals(attributeJsonValue)) {
+                    models.add(model);
+                }
+            }
+        }
+        return models;
+    }
+}