Naman, can you please check

pom.xml

@@ -58,6 +58,11 @@
         <artifactId>mysql-connector-j</artifactId>
         <scope>runtime</scope>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-oauth2-resource-server</artifactId>
+            <version>3.3.5</version>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/dev/naman/productservice/controllers/ProductController.java

@@ -3,29 +3,36 @@
 import dev.naman.productservice.dtos.ExceptionDto;
 import dev.naman.productservice.dtos.GenericProductDto;
 import dev.naman.productservice.exceptions.NotFoundException;
+import dev.naman.productservice.security.JwtObject;
+import dev.naman.productservice.security.TokenValidator;
 import dev.naman.productservice.services.ProductService;
+import jakarta.annotation.Nullable;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
+import java.util.Optional;
 
 @RestController
 @RequestMapping("/products")
 public class ProductController {
 //    @Autowired
     // field injection
     private ProductService productService;
+    private TokenValidator tokenValidator;
     // ....;
     // ...;
 
 
 
     // constructor injection
 //    @Autowired
-    public ProductController(ProductService productService) {
+    public ProductController(ProductService productService, TokenValidator tokenValidator) {
         this.productService = productService;
+        this.tokenValidator = tokenValidator;
     }
 //
 
@@ -44,8 +51,21 @@ public List<GenericProductDto> getAllProducts() {
     // localhost:8080/products/{id}
     // localhost:8080/products/123
     @GetMapping("{id}")
-    public GenericProductDto getProductById(@PathVariable("id") Long id) throws NotFoundException {
-        return productService.getProductById(id);
+    public GenericProductDto getProductById(@Nullable @RequestHeader(HttpHeaders.AUTHORIZATION)String authToken, @PathVariable("id") Long id) throws NotFoundException {
+
+        System.out.println(authToken+" <-authtoken");
+        Optional<JwtObject> jwtObjectOptional;
+        String userId= "351e99b7-3150-49db-ad27-74c793d0aea5";
+        JwtObject jwtObject = null;
+        if(authToken!=null){
+            jwtObjectOptional = tokenValidator.validateToken(authToken,userId);
+           if (jwtObjectOptional.isEmpty()){
+               System.out.println("failinggggg");
+           }
+           jwtObject = jwtObjectOptional.get();
+
+        }
+        return productService.getProductById(id,jwtObject.getUserId());
     }
 
     @DeleteMapping("{id}")

src/main/java/dev/naman/productservice/dtos/ValidateRequestDto.java

@@ -0,0 +1,9 @@
+package dev.naman.productservice.dtos;
+
+import lombok.Data;
+
+@Data
+public class ValidateRequestDto {
+    String token;
+    String userId;
+}

src/main/java/dev/naman/productservice/enums/SessionStatus.java

@@ -0,0 +1,9 @@
+package dev.naman.productservice.enums;
+
+public enum SessionStatus {
+    ACTIVE,
+    INACTIVE,
+    ENDED
+}
+
+

src/main/java/dev/naman/productservice/repositories/ProductRepository.java

@@ -9,6 +9,7 @@
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
+import java.util.Optional;
 import java.util.UUID;
 import java.util.function.Function;
 

src/main/java/dev/naman/productservice/repositories/SelfProductRepository.java

@@ -0,0 +1,22 @@
+package dev.naman.productservice.repositories;
+
+import dev.naman.productservice.dtos.GenericProductDto;
+import dev.naman.productservice.models.Product;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface SelfProductRepository extends JpaRepository<Product,Long> {
+
+    @Override
+    Optional<Product> findById(Long aLong);
+
+    <S extends Product> S save(GenericProductDto entity);
+
+    @Override
+    List<Product> findAll();
+
+    @Override
+    void deleteById(Long aLong);
+}

src/main/java/dev/naman/productservice/security/JwtObject.java

@@ -0,0 +1,16 @@
+package dev.naman.productservice.security;
+
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+@Data
+public class JwtObject {
+    private String email;
+    private String userId;
+    private Date createdAt;
+    private Date expiryAt;
+    private List<Role> roles = new ArrayList<>();
+}

src/main/java/dev/naman/productservice/security/Role.java

@@ -0,0 +1,11 @@
+package dev.naman.productservice.security;
+
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class Role {
+    private String id;
+    private String role;
+}

src/main/java/dev/naman/productservice/security/TokenValidator.java

@@ -0,0 +1,38 @@
+package dev.naman.productservice.security;
+
+import dev.naman.productservice.dtos.ValidateRequestDto;
+import dev.naman.productservice.enums.SessionStatus;
+import dev.naman.productservice.thirdpartyclients.productsservice.fakestore.FakeStoreProductDto;
+import org.springframework.boot.web.client.RestTemplateBuilder;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Optional;
+
+@Service
+public class TokenValidator {
+    /**
+     * call user service validate the token
+     * if token is not vald,optionial is valid
+     * @param token
+     * @return
+     */
+    private RestTemplateBuilder restTemplateBuilder;
+    public TokenValidator(RestTemplateBuilder restTemplateBuilder){
+        this.restTemplateBuilder = restTemplateBuilder;
+    }
+    public Optional<JwtObject> validateToken(String token, String userId) {
+
+        RestTemplate restTemplate = restTemplateBuilder.build();
+
+
+        ValidateRequestDto validateRequestDto= new ValidateRequestDto();
+        validateRequestDto.setToken(token);
+        validateRequestDto.setUserId(userId);
+        ResponseEntity<SessionStatus> response =
+                restTemplate.postForEntity("https://localhost:8081/auth/validate",validateRequestDto,SessionStatus.class);
+
+        return Optional.empty();
+    }
+}

src/main/java/dev/naman/productservice/services/FakeStoreProductService.java

@@ -2,6 +2,7 @@
 
 import dev.naman.productservice.dtos.GenericProductDto;
 import dev.naman.productservice.exceptions.NotFoundException;
+import dev.naman.productservice.security.JwtObject;
 import dev.naman.productservice.thirdpartyclients.productsservice.fakestore.FakeStoreProductDto;
 import dev.naman.productservice.thirdpartyclients.productsservice.fakestore.FakeStoryProductServiceClient;
 import org.springframework.context.annotation.Primary;
@@ -42,7 +43,7 @@ public GenericProductDto createProduct(GenericProductDto product) {
     }
 
     @Override
-    public GenericProductDto getProductById(Long id) throws NotFoundException {
+    public GenericProductDto getProductById(Long id, String userIdTryingToAccess) throws NotFoundException {
         return convertFakeStoreProductIntoGenericProduct(fakeStoryProductServiceClient.getProductById(id));
     }
 

src/main/java/dev/naman/productservice/services/ProductService.java

@@ -2,14 +2,15 @@
 
 import dev.naman.productservice.dtos.GenericProductDto;
 import dev.naman.productservice.exceptions.NotFoundException;
+import dev.naman.productservice.security.JwtObject;
 
 import java.util.List;
 
 public interface ProductService {
 
     GenericProductDto createProduct(GenericProductDto product);
 
-    GenericProductDto getProductById(Long id) throws NotFoundException;
+    GenericProductDto getProductById(Long id, String userIdTryingToAccess) throws NotFoundException;
 
     List<GenericProductDto> getAllProducts();
 

src/main/java/dev/naman/productservice/services/SelfProductServiceImpl.java

@@ -3,37 +3,76 @@
 import dev.naman.productservice.dtos.GenericProductDto;
 import dev.naman.productservice.models.Product;
 import dev.naman.productservice.repositories.ProductRepository;
+import dev.naman.productservice.repositories.SelfProductRepository;
+import dev.naman.productservice.security.JwtObject;
 import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
 
 @Primary
 @Service("selfProductServiceImpl")
 public class SelfProductServiceImpl implements ProductService {
-    private ProductRepository productRepository;
+    private SelfProductRepository selfProductRepository;
 
-    public SelfProductServiceImpl(ProductRepository productRepository) {
-        this.productRepository = productRepository;
+    public SelfProductServiceImpl(SelfProductRepository selfProductRepository) {
+        this.selfProductRepository = selfProductRepository;
     }
 
     @Override
-    public GenericProductDto getProductById(Long id) {
-        return null;
+    public GenericProductDto getProductById(Long id, String userIdTryingToAccess) {
+        Optional<Product> product =  selfProductRepository.findById(id);
+        if(product.isEmpty()){
+            return new GenericProductDto();
+        }
+        GenericProductDto genericProductDto = new GenericProductDto();
+        genericProductDto.setTitle(product.get().getTitle());
+        genericProductDto.setPrice(product.get().getPrice().getPrice());
+        genericProductDto.setDescription(product.get().getDescription());
+        genericProductDto.setImage(product.get().getImage());
+        genericProductDto.setCategory(product.get().getCategory().getName());
+        genericProductDto.setId(id);
+
+        return genericProductDto;
     }
 
     @Override
     public GenericProductDto createProduct(GenericProductDto product) {
-        return null;
+     Product prod =  selfProductRepository.save(product);
+       GenericProductDto genericProductDto = new GenericProductDto();
+        genericProductDto.setTitle(prod.getTitle());
+        genericProductDto.setPrice(prod.getPrice().getPrice());
+        genericProductDto.setDescription(prod.getDescription());
+        genericProductDto.setImage(prod.getImage());
+        genericProductDto.setCategory(prod.getCategory().getName());
+        genericProductDto.setId(product.getId());
+        return genericProductDto;
     }
 
     @Override
     public List<GenericProductDto> getAllProducts() {
-        return null;
+    List<Product> products = selfProductRepository.findAll();
+            List<GenericProductDto> genericProductDtos = new ArrayList<>();
+            for(Product product: products){
+                GenericProductDto genericProductDto = new GenericProductDto();
+                genericProductDto.setTitle(product.getTitle());
+                genericProductDto.setPrice(product.getPrice().getPrice());
+                genericProductDto.setDescription(product.getDescription());
+                genericProductDto.setImage(product.getImage());
+//                genericProductDto.setCategory(product.getCategory().getName());
+                genericProductDto.setId(1L);
+                genericProductDtos.add(genericProductDto);
+            }
+            return genericProductDtos;
     }
 
     @Override
     public GenericProductDto deleteProduct(Long id) {
-        return null;
+         selfProductRepository.deleteById(id);
+        // process is same as getbyID
+    return  null;
     }
 }

src/main/resources/application.properties

@@ -12,9 +12,11 @@ fakestore.api.paths.product=/products
 server.error.include-stacktrace=never
 
 spring.jpa.hibernate.ddl-auto=update
-spring.datasource.url=jdbc:mysql://localhost:3306/sep23productservice
-spring.datasource.username=sep23productservice
+spring.datasource.url=jdbc:mysql://localhost:3306/productservice
+spring.datasource.username=productservice
 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
 spring.jpa.show-sql=true
+spring.security.oauth2.resourceserver.jwt.issuer-uri=http://localhost:8081
+spring.security.oauth2.resourceserver.jwt.audiences=productclient
 #logging.level.org.hibernate.SQL=DEBUG
 #logging.level.org.hibernate.type=TRACE