[AFP-55] Work on ProductController

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

 package com.nisum.ascend.inventory.controller;
 
-//import dto.ProductDto;
-//import model.Product;
+import com.nisum.ascend.inventory.dto.ProductDto;
+import com.nisum.ascend.inventory.model.Product;
+import io.swagger.models.Response;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
 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.Flux;
 
 
 @RestController
@@ -14,9 +18,8 @@ public class ProductController {
     @Autowired
     ProductService productService;
 
-//    @GetMapping()
-//    public Flux<Product> findAll() {
-//        Flux<Product> prods = productService.findAll();
-//        return prods;
-//    }
+    @GetMapping()
+    public ResponseEntity<Flux<ProductDto>> findAll() {
+        return ResponseEntity.ok(productService.findAll());
+    }
 }

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/service/ProductService.java

 package com.nisum.ascend.inventory.service;
 
 import com.nisum.ascend.inventory.dto.ProductDto;
+import com.nisum.ascend.inventory.model.Product;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import reactor.core.publisher.Flux;
@@ -11,4 +12,12 @@ public class ProductService {
     @Autowired
     ProductRepository productRepository;
 
+    public Flux<ProductDto> findAll() {
+
+        return productRepository.findAll()
+                .map(ProductDto::generateDtoFromProduct)
+                .flatMap(Flux::just);
+    }
+
+
 }