get product by sku controller / service

src/main/java/com/nisum/ascend/inventory/controller/ProductController.java

 package com.nisum.ascend.inventory.controller;
 
+import com.nisum.ascend.inventory.dto.ProductDto;
+import com.nisum.ascend.inventory.model.Product;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 import com.nisum.ascend.inventory.service.ProductService;
+import reactor.core.publisher.Mono;
 
 @RestController
+@RequestMapping("/products")
 public class ProductController {
     @Autowired
     ProductService productService;
+
+    @GetMapping("{sku}")
+    public ResponseEntity<Mono<ProductDto>> getProductDto(@PathVariable String sku) {
+        Mono<ProductDto> monoProd = productService.getProduct(sku);
+        HttpStatus status = monoProd != null ? HttpStatus.OK : HttpStatus.NOT_FOUND;
+        return new ResponseEntity<>(monoProd, status);
+    }
 }

src/main/java/com/nisum/ascend/inventory/dto/ProductDto.java

@@ -24,6 +24,5 @@ public class ProductDto {
         PromotionDto promotion = new PromotionDto();
 
         return new ProductDto(product.getSku(), product.getUpc(), product.getProdName(), product.getProdDesc(), product.getPrice(), product.getProdImgUrl(), product.getBrand(), product.getCategory(), product.getAvailableStock(), promotion);
-
     }
 }

src/main/java/com/nisum/ascend/inventory/exception/ResourceNotFoundException.java

+package com.nisum.ascend.inventory.exception;
+
+import org.springframework.http.HttpStatus;
+
+public class ResourceNotFoundException extends Exception{
+    HttpStatus status;
+
+    public ResourceNotFoundException(HttpStatus status, String message) {
+        super(message);
+        this.status = status;
+    }
+}

src/main/java/com/nisum/ascend/inventory/model/Product.java

@@ -8,7 +8,7 @@ import org.springframework.data.mongodb.core.mapping.Document;
 
 @Getter
 @Setter
-@Document
+@Document(collection = "products")
 public class Product {
     @Id
     private String id;

src/main/java/com/nisum/ascend/inventory/repository/ProductRepository.java

 package com.nisum.ascend.inventory.repository;
 
 import com.nisum.ascend.inventory.model.Product;
+import org.springframework.data.mongodb.repository.Query;
 import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
 import org.springframework.stereotype.Repository;
+import reactor.core.publisher.Mono;
 
 @Repository
 public interface ProductRepository extends ReactiveMongoRepository<Product, String> {
+
+
+    Mono<Product> findBySku(String sku);
 }

src/main/java/com/nisum/ascend/inventory/service/ProductService.java

 package com.nisum.ascend.inventory.service;
 
 import com.nisum.ascend.inventory.dto.ProductDto;
+import com.nisum.ascend.inventory.exception.ResourceNotFoundException;
+import com.nisum.ascend.inventory.model.Product;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
 import org.springframework.stereotype.Service;
 import reactor.core.publisher.Flux;
 import com.nisum.ascend.inventory.repository.ProductRepository;
+import reactor.core.publisher.Mono;
+
+import static com.nisum.ascend.inventory.dto.ProductDto.generateDtoFromProduct;
 
 @Service
 public class ProductService {
     @Autowired
     ProductRepository productRepository;
 
+    public Mono<ProductDto> getProduct(String sku){
+        return productRepository.findBySku(sku)
+                .map(existingProduct -> generateDtoFromProduct(existingProduct))
+                .switchIfEmpty(Mono.error(new ResourceNotFoundException(HttpStatus.NOT_FOUND, "product not found")));
+    }
 }

src/main/resources/application.properties

@@ -3,4 +3,4 @@ spring.config.import=classpath:secret.properties
 server.port=8080
 spring.data.mongodb.uri=mongodb+srv://admin:${db.password}@inventory-promotions.d4nfz.mongodb\
   .net/${spring.data.mongodb.database}?retryWrites=true&w=majority
-spring.data.mongodb.database=products-promotions-DB
+spring.data.mongodb.database=test

src/test/java/com/nisum/ascend/inventory/controller/ProductControllerTest.java

+package com.nisum.ascend.inventory.controller;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class ProductControllerTest {
+
+    @BeforeEach
+    void setUp() {
+    }
+
+    @Test
+    void getProductDto() {
+    }
+}
\ No newline at end of file