setuppati i messaggi

Author: umbertocicciaa

src/app/api/services/websocket.service.ts

@@ -11,16 +11,20 @@ export class WebSocketService implements OnDestroy {
   private stompClient: Client;
   private messagesSubject = new BehaviorSubject<any[]>([]);
   public messages$: Observable<any[]> = this.messagesSubject.asObservable();
+  private connectionSubject = new BehaviorSubject<boolean>(false);
+  public connection$: Observable<boolean> =
+    this.connectionSubject.asObservable();
 
   constructor(private http: HttpClient) {
-    const socket = new SockJS("http://localhost:8080/ws");
+    const socket = new SockJS("http://localhost:8080/chat-socket");
     this.stompClient = new Client({
       webSocketFactory: () => socket as WebSocket,
       reconnectDelay: 5000,
     });
 
     this.stompClient.onConnect = () => {
-      this.stompClient.subscribe("/user/queue/messages", (message: Message) => {
+      this.connectionSubject.next(true);
+      this.stompClient.subscribe("/chat/queue/messages", (message: Message) => {
         this.messagesSubject.next([
           ...this.messagesSubject.value,
           JSON.parse(message.body),
@@ -30,16 +34,21 @@ export class WebSocketService implements OnDestroy {
 
     this.stompClient.onStompError = (error) => {
       console.error("WebSocket connection error", error);
+      this.connectionSubject.next(false);
     };
 
     this.stompClient.activate();
   }
 
   sendMessage(message: any): void {
-    this.stompClient.publish({
-      destination: "/app/chat",
-      body: JSON.stringify(message),
-    });
+    if (this.connectionSubject.value) {
+      this.stompClient.publish({
+        destination: "/app/chat",
+        body: JSON.stringify(message),
+      });
+    } else {
+      console.error("WebSocket connection is not established");
+    }
   }
 
   loadMessages(conversationId: number): void {

src/app/message/message.component.ts

@@ -30,7 +30,6 @@ export class MessageComponent implements OnInit, OnDestroy {
       this.recipientId = params["destId"];
       this.userId = params["userId"];
     });
-    console.log(this.userId, this.recipientId);
   }
 
   async ngOnInit() {
@@ -52,6 +51,7 @@ export class MessageComponent implements OnInit, OnDestroy {
       const message = {
         text: this.newMessage,
         recipient: { id: this.recipientId },
+        sender: { id: this.userId },
       };
       this.webSocketService.sendMessage(message);
       this.newMessage = "";