this is super messy but nfunctional right now

pom.xml

@@ -62,6 +62,31 @@
             <artifactId>spring-restdocs-mockmvc</artifactId>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.webjars</groupId>
+            <artifactId>webjars-locator-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.webjars</groupId>
+            <artifactId>sockjs-client</artifactId>
+            <version>1.0.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.webjars</groupId>
+            <artifactId>stomp-websocket</artifactId>
+            <version>2.3.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.webjars</groupId>
+            <artifactId>bootstrap</artifactId>
+            <version>3.3.7</version>
+        </dependency>
+        <dependency>
+            <groupId>org.webjars</groupId>
+            <artifactId>jquery</artifactId>
+            <version>3.1.0</version>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/com/ziplinegreen/vault/Config/WebSocketConfig.java

@@ -21,7 +21,7 @@ public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
 
     @Override
     public void registerStompEndpoints(StompEndpointRegistry registry) {
-        registry.addEndpoint("/posts");
-        registry.addEndpoint("/posts").withSockJS();
+        //registry.addEndpoint("/posts");
+        registry.addEndpoint("/vault-socket").withSockJS();
     }
 }

src/main/java/com/ziplinegreen/vault/Controller/PostController.java

@@ -1,5 +1,6 @@
 package com.ziplinegreen.vault.Controller;
 
+import com.sun.deploy.net.HttpResponse;
 import com.ziplinegreen.vault.Exception.ResourceNotFoundException;
 import com.ziplinegreen.vault.Model.Post;
 import com.ziplinegreen.vault.Model.User;
@@ -12,31 +13,61 @@ import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.handler.annotation.SendTo;
+import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.*;
 
 import javax.validation.Valid;
 import java.util.Set;
 
-
+@Controller
 public class PostController {
 
+    @Autowired
     private PostService postService;
+    @Autowired
     private UserController userController;
 
     @Autowired
+    private PostRepository repository;
+
+    @Autowired
     public PostController(PostService postService) {
         this.postService = postService;
     }
 
-    @PostMapping("/posts/{userId}")
-    public ResponseEntity createPost(@PathVariable Long userId, @RequestBody Post post) {
-        userController.updatePosts(userId,post);
-        return new ResponseEntity(HttpStatus.OK);
+//    @PostMapping("/posts/{userId}")
+//    public ResponseEntity createPost(@PathVariable Long userId, @RequestBody Post post) {
+//        //userController.updatePosts(userId,post);
+//        return new ResponseEntity(userController.updatePosts(userId, post), HttpStatus.OK);
+//
+//    }
+
+    @MessageMapping("/posts/{userId}")
+    //@MessageMapping("/posts")
+    @SendTo("/topic/posts")
+    public Post createPost(@DestinationVariable("userId") Long userId, @RequestBody Post post) {
+    //public Post createPost(@RequestBody Post post) {
+        System.out.println(post.getMessage());
+        post.setUserName(userController.getUserById(userId).getBody().getUsername());
+        //return userController.updatePosts(userId,post);
+        return repository.save(post);
+        //return post;
+        //return new ResponseEntity(userController.updatePosts(userId, post), HttpStatus.OK);
 
     }
 
+    @GetMapping("/posts/all")
+    public Iterable<Post> getAllPosts() {
+        return repository.findAll();
+    }
+
+
 
     @GetMapping("/posts/{userId}")
+    //@SendTo("/topic/posts")
     public ResponseEntity<Iterable<Post>> getAllPostsByUserId(@PathVariable Long userId) {
         return postService.findByUserId(userId);
     }

src/main/java/com/ziplinegreen/vault/Model/Post.java

@@ -19,22 +19,23 @@ public class Post extends AuditModel{
     @NotNull
     @Lob
     private String message;
+    @OnDelete(action = OnDeleteAction.CASCADE)
+    @JsonIgnore
     private Long userId;
-//    @OnDelete(action = OnDeleteAction.CASCADE)
-//    @JsonIgnore
+    private String userName;
 
     public Post(){
     }
-    public Post(@NotNull String message, Long userId) {
+    public Post(@NotNull String message, Long userId, String userName) {
         this.message = message;
         this.userId = userId;
+        this.userName = userName;
     }
 
     public Long getId() {
         return Id;
     }
 
-
     public String getMessage() {
         return message;
     }
@@ -47,4 +48,10 @@ public class Post extends AuditModel{
         return userId;
     }
 
+    public String getUserName() { return userName; }
+
+    public void setUserName(String userName) {
+        this.userName = userName;
+    }
+
 }

src/main/java/com/ziplinegreen/vault/Service/PostService.java

@@ -11,6 +11,7 @@ import org.springframework.stereotype.Service;
 @Service
 public class PostService {
 
+    @Autowired
     private PostRepository postRepository;
 
     @Autowired

src/main/java/com/ziplinegreen/vault/Service/UserService.java

@@ -17,6 +17,7 @@ import java.util.List;
 @Service
 public class UserService {
 
+    @Autowired
     private UserRepository userRepository;
     //private PostController postController;
 

src/main/resources/static/app.js

@@ -1,54 +1,3 @@
-// var stompClient = null;
-//
-// function setConnected(connected) {
-//     $("#connect").prop("disabled", connected);
-//     $("#disconnect").prop("disabled", !connected);
-//     if (connected) {
-//         $("#conversation").show();
-//     }
-//     else {
-//         $("#conversation").hide();
-//     }
-//     $("#greetings").html("");
-// }
-//
-// function connect() {
-//     var socket = new SockJS('/gs-guide-websocket');
-//     stompClient = Stomp.over(socket);
-//     stompClient.connect({}, function (frame) {
-//         setConnected(true);
-//         console.log('Connected: ' + frame);
-//         stompClient.subscribe('/topic/posts', function (post) {
-//             showGreeting(JSON.parse(post.body).message);
-//         });
-//     });
-// }
-//
-// function disconnect() {
-//     if (stompClient !== null) {
-//         stompClient.disconnect();
-//     }
-//     setConnected(false);
-//     console.log("Disconnected");
-// }
-//
-// function sendName() {
-//     stompClient.send("/users/1/posts/", {}, JSON.stringify({'message': $("#message").val(), 'userId': '1'}));
-// }
-//
-// function showGreeting(message) {
-//     $("#greetings").append("<tr><td>" + message + "</td></tr>");
-// }
-//
-// $(function () {
-//     $("form").on('submit', function (e) {
-//         e.preventDefault();
-//     });
-//     $( "#connect" ).click(function() { connect(); });
-//     $( "#disconnect" ).click(function() { disconnect(); });
-//     $( "#send" ).click(function() { sendName(); });
-// });
-
 var stompClient = null;
 
 function setConnected(connected) {
@@ -60,17 +9,18 @@ function setConnected(connected) {
     else {
         $("#conversation").hide();
     }
-    $("#greetings").html("");
+    $("#messages").html("");
 }
 
 function connect() {
-    var socket = new SockJS('/gs-guide-websocket');
+    var socket = new SockJS('/vault-socket');
     stompClient = Stomp.over(socket);
     stompClient.connect({}, function (frame) {
         setConnected(true);
         console.log('Connected: ' + frame);
-        stompClient.subscribe('/topic/greetings', function (greeting) {
-            showGreeting(JSON.parse(greeting.body).content);
+        stompClient.subscribe('/topic/posts', function (greeting) {
+            showGreeting(JSON.parse(greeting.body).message, JSON.parse(greeting.body).userName);
+            //showGreeting()
         });
     });
 }
@@ -83,12 +33,35 @@ function disconnect() {
     console.log("Disconnected");
 }
 
+var userId = 1;
+var userPostUrl = "/app/posts/1";
+
+function user1() {
+    $('#user1').prop("disabled", true);
+    $('#user2').prop("disabled", false);
+    userId = 1;
+}
+
+function user2() {
+    $('#user1').prop("disabled", false);
+    $('#user2').prop("disabled", true);
+    userId = 2;
+    userPostUrl = "/app/posts/2";
+}
+
+// function sendName() {
+//     stompClient.send("/app/posts/1", {}, JSON.stringify({'id': '','message': $("#message").val(),'userId': '1'}));
+// }
+
+
+
 function sendName() {
-    stompClient.send("/app/hello", {}, JSON.stringify({'name': $("#name").val()}));
+
+    stompClient.send(userPostUrl, {}, JSON.stringify({'id': '','message': $("#message").val(),'userId': userId}))
 }
 
-function showGreeting(message) {
-    $("#greetings").append("<tr><td>" + message + "</td></tr>");
+function showGreeting(message, userName) {
+    $("#messages").append("<tr><td>" + userName + ": " + message + "</td></tr>");
 }
 
 $(function () {
@@ -98,4 +71,6 @@ $(function () {
     $( "#connect" ).click(function() { connect(); });
     $( "#disconnect" ).click(function() { disconnect(); });
     $( "#send" ).click(function() { sendName(); });
+    $( "#user1" ).click(function() { user1(); });
+    $( "#user2" ).click(function() { user2(); })
 });

src/main/resources/static/index.html

@@ -3,11 +3,11 @@
 <head>
     <title>Hello WebSocket</title>
     <link href="/webjars/bootstrap/css/bootstrap.min.css" rel="stylesheet">
-    <link href="/main.css" rel="stylesheet">
+    <!--<link href="/main.css" rel="stylesheet">-->
     <script src="/webjars/jquery/jquery.min.js"></script>
     <script src="/webjars/sockjs-client/sockjs.min.js"></script>
     <script src="/webjars/stomp-websocket/stomp.min.js"></script>
-    <script src="/app.js"></script>
+    <script src="./app.js"></script>
 </head>
 <body>
 <noscript><h2 style="color: #ff0000">Seems your browser doesn't support Javascript! Websocket relies on Javascript being
@@ -22,6 +22,8 @@
                     <button id="connect" class="btn btn-default" type="submit">Connect</button>
                     <button id="disconnect" class="btn btn-default" type="submit" disabled="disabled">Disconnect
                     </button>
+                    <button id="user1" class="btn btn-default" type="submit" disabled="disabled">User 1</button>
+                    <button id="user2" class="btn btn-default" type="submit">User 2</button>
                 </div>
             </form>
         </div>