add some backend logic

src/main/java/com/ascendfinalproject/warehouse/controllers/WarehouseController.java

@@ -16,6 +16,12 @@ public class WarehouseController {
   @Autowired
   WarehouseOrderService orderService;
 
+//  @CrossOrigin
+//  @GetMapping(value = "/orders")
+//  public Mono<OrderResponse> getOrders() throws InterruptedException {
+//    return orderService.getOrders();
+//  }
+//  
   @CrossOrigin
   @GetMapping(value = "/orders")
   public Flux<WarehouseOrder> getOrders() {

src/main/java/com/ascendfinalproject/warehouse/models/OrderResponse.java

@@ -3,20 +3,26 @@ package com.ascendfinalproject.warehouse.models;
 import lombok.Getter;
 import lombok.Setter;
 
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 @Getter
 @Setter
 public class OrderResponse {
 
-    private List<String> allIds;
-    private HashMap<String, WarehouseOrder> byId;
+    private List<String> allIds = new ArrayList<>();
+    private Map<String, WarehouseOrder> byId = new HashMap<>();
 
     public void appendId(String id) {
         allIds.add(id);
     }
 
+    public void addOrder(WarehouseOrder order) {
+        byId.put(order.getId(), order);
+    }
+
     @Override
     public String toString() {
         return "OrderResponse{" +

src/main/java/com/ascendfinalproject/warehouse/services/WarehouseOrderService.java

 package com.ascendfinalproject.warehouse.services;
 
 import com.ascendfinalproject.warehouse.models.Item;
+import com.ascendfinalproject.warehouse.models.OrderResponse;
 import com.ascendfinalproject.warehouse.models.WarehouseOrder;
 import com.ascendfinalproject.warehouse.repositories.WarehouseOrderRepository;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -23,8 +25,28 @@ public class WarehouseOrderService {
     return orderRepository.findById(id);
   }
 
+//  public Mono<OrderResponse> getOrders() throws InterruptedException {
+    // add ResponseEntity
+//      return orderRepository.findAll();
+//    OrderResponse res = new OrderResponse();
+//    Flux<WarehouseOrder> warehouseOrderFlux = orderRepository.findAll().log().map(order -> {
+//      res.addOrder(order);
+//      res.appendId(order.getId());
+//      return order;
+//    });
+//    Mono<ResponseEntity<OrderResponse>>
+//    return warehouseOrderFlux.doOnComplete(() -> Mono.just(res));
+//    return warehouseOrderFlux.next().map(wareHouse -> res)
+//            .doOnSuccess(subscription -> Mono.just(res));
+//
+//
+//    System.out.println("-----");
+//    System.out.println(res);
+//    Thread.sleep(2000);
+//    return Mono.just(res);
+//  }
   public Flux<WarehouseOrder> getOrders() {
-      return orderRepository.findAll();
+    return orderRepository.findAll();
   }
 
   public Mono<WarehouseOrder> createOrder(WarehouseOrder order) {