fixed socket

src/main/java/edu/uchicago/mpcs/topics/Application.java

@@ -17,15 +17,11 @@ package edu.uchicago.mpcs.topics;
 
 import edu.uchicago.mpcs.topics.auction.Item;
 import edu.uchicago.mpcs.topics.auction.ItemCategory;
-import edu.uchicago.mpcs.topics.controller.ItemController;
 import edu.uchicago.mpcs.topics.db.ItemCategoryRepository;
 import edu.uchicago.mpcs.topics.db.ItemRepository;
-import edu.uchicago.mpcs.topics.db.UserDB;
-import edu.uchicago.mpcs.topics.user.User;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.context.ApplicationContext;
 import org.springframework.context.annotation.Bean;
 import org.springframework.web.servlet.config.annotation.CorsRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
@@ -75,16 +71,16 @@ public class Application {
 
 
 
-//    @Bean
-//    public WebMvcConfigurer corsConfigurer() {
-//        return new WebMvcConfigurer() {
-//            @Override
-//            public void addCorsMappings(CorsRegistry registry) {
-//                registry.addMapping("/**")
-//                        .allowedOrigins("http://localhost:3000")
-//                        .allowedMethods("GET", "POST","PUT", "DELETE");
-//            }
-//        };
-//    }
+    @Bean
+    public WebMvcConfigurer corsConfigurer() {
+        return new WebMvcConfigurer() {
+            @Override
+            public void addCorsMappings(CorsRegistry registry) {
+                registry.addMapping("/**")
+                        .allowedOrigins("http://localhost:3000")
+                        .allowedMethods("GET", "POST","PUT", "DELETE");
+            }
+        };
+    }
 }
 // end::code[]
\ No newline at end of file

src/main/java/edu/uchicago/mpcs/topics/WebSocketConfig.java

@@ -17,14 +17,13 @@ public class WebSocketConfig implements  WebSocketMessageBrokerConfigurer
     @Override
     public void configureMessageBroker(MessageBrokerRegistry config)
     {
-        config.enableSimpleBroker("/item/list");
-//        config.setApplicationDestinationPrefixes("/app");
+        config.enableSimpleBroker("/");
     }
 
     @Override
     public void registerStompEndpoints(StompEndpointRegistry registry)
     {
-        registry.addEndpoint("/item/list");
+        registry.addEndpoint("/add").setAllowedOrigins("*").withSockJS();
     }
 
 }
\ No newline at end of file

src/main/java/edu/uchicago/mpcs/topics/controller/ItemController.java

 package edu.uchicago.mpcs.topics.controller;
 
 import edu.uchicago.mpcs.topics.auction.Item;
-import edu.uchicago.mpcs.topics.auction.Status;
 import edu.uchicago.mpcs.topics.db.ItemRepository;
 import edu.uchicago.mpcs.topics.db.SearchRepository;
 import edu.uchicago.mpcs.topics.service.ItemService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.messaging.handler.annotation.MessageMapping;
 import org.springframework.messaging.handler.annotation.SendTo;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
@@ -20,6 +21,9 @@ import java.util.Optional;
 @RequestMapping("/item")
 public class ItemController
 {
+    @Autowired
+    private SimpMessagingTemplate webSocket;
+
     private ItemService itemService;
     private ItemRepository itemRepository;
     private SearchRepository searchRepository;
@@ -74,9 +78,11 @@ public class ItemController
         return searchRepository.findAllByDescriptionContains(q);
     }
 
-    @SendTo("/list")
+    @MessageMapping("/add")
+    @SendTo("/socket")
     public Item webSocketUpdateItem(Item item)
     {
+        this.webSocket.convertAndSend("/socket", item);
         return item;
     }
 }
\ No newline at end of file