VideoCall feature updated

Author: MonuChaudhary14

src/main/java/org/spacehub/DTO/VideoRoom/VideoRoomDTO.java

@@ -0,0 +1,18 @@
+package org.spacehub.DTO.VideoRoom;
+
+import lombok.Data;
+import org.spacehub.entities.VideoRoom.VideoRoom;
+
+@Data
+public class VideoRoomDTO {
+
+    private int janusRoomId;
+    private String name;
+    private String createdBy;
+
+    public VideoRoomDTO(VideoRoom entity) {
+        this.janusRoomId = entity.getJanusRoomId();
+        this.name = entity.getName();
+        this.createdBy = entity.getCreatedBy();
+    }
+}

src/main/java/org/spacehub/configuration/webSocket/WebSocketConfigVideo.java

@@ -1,24 +1,25 @@
-//package org.spacehub.configuration;
-//
-//import org.springframework.context.annotation.Configuration;
-//import org.springframework.messaging.simp.config.MessageBrokerRegistry;
-//import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
-//import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
-//import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
-//
-//@Configuration
-//@EnableWebSocketMessageBroker
-//public class WebSocketConfigVideo implements WebSocketMessageBrokerConfigurer {
-//
-//  @Override
-//  public void configureMessageBroker(MessageBrokerRegistry config) {
-//    config.enableSimpleBroker("/video");
-//    config.setApplicationDestinationPrefixes("/videoapp");
-//  }
-//
-//  @Override
-//  public void registerStompEndpoints(StompEndpointRegistry registry) {
-//    registry.addEndpoint("/call").setAllowedOrigins("*").withSockJS();
-//  }
-//
-//}
+package org.spacehub.configuration.webSocket;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.simp.config.MessageBrokerRegistry;
+import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
+import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
+import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
+
+@Configuration
+@EnableWebSocketMessageBroker
+public class WebSocketConfigVideo implements WebSocketMessageBrokerConfigurer {
+
+  @Override
+  public void configureMessageBroker(MessageBrokerRegistry config) {
+    config.enableSimpleBroker("/topic/video");
+    config.setApplicationDestinationPrefixes("/app");
+  }
+
+  @Override
+  public void registerStompEndpoints(StompEndpointRegistry registry) {
+    registry.addEndpoint("/video-ws")
+            .setAllowedOriginPatterns("*")
+            .withSockJS();
+  }
+}

src/main/java/org/spacehub/controller/VideoCall/VideoCallController.java

@@ -0,0 +1,75 @@
+package org.spacehub.controller.VideoRoom;
+
+import lombok.RequiredArgsConstructor;
+import org.spacehub.DTO.VideoRoom.VideoRoomDTO;
+import org.spacehub.entities.ChatRoom.ChatRoom;
+import org.spacehub.entities.VideoRoom.VideoRoom;
+import org.spacehub.repository.ChatRoom.ChatRoomRepository;
+import org.spacehub.service.Interface.IVideoRoomService;
+import org.spacehub.service.VideoRoom.JanusVideoService;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.*;
+
+@RestController
+@RequestMapping("/api/v1/video-room")
+@RequiredArgsConstructor
+public class VideoCallController {
+
+    private final JanusVideoService janusVideoService;
+    private final IVideoRoomService videoRoomService;
+    private final ChatRoomRepository chatRoomRepository;
+
+    @PostMapping("/create")
+    public ResponseEntity<?> createVideoRoom(@RequestParam UUID chatRoomId, @RequestParam String roomName, @RequestParam String createdBy) {
+
+        ChatRoom chatRoom = chatRoomRepository.findById(chatRoomId)
+                .orElseThrow(() -> new RuntimeException("ChatRoom not found"));
+
+        VideoRoom videoRoom = videoRoomService.createVideoRoom(chatRoom, roomName, createdBy);
+
+        return ResponseEntity.ok(Map.of(
+                "message", "Video room created successfully",
+                "videoRoom", new VideoRoomDTO(videoRoom)));
+    }
+
+    @PostMapping("/join")
+    public ResponseEntity<?> joinVideoRoom(@RequestParam int janusRoomId, @RequestParam String displayName) {
+
+        String sessionId = janusVideoService.createSession();
+        String handleId = janusVideoService.attachVideoRoomPlugin(sessionId);
+        janusVideoService.joinVideoRoom(sessionId, handleId, janusRoomId, displayName);
+
+        return ResponseEntity.ok(Map.of(
+                "message", "Joined video room successfully",
+                "janusRoomId", janusRoomId,
+                "sessionId", sessionId,
+                "handleId", handleId));
+    }
+
+    @GetMapping("/list/{chatRoomId}")
+    public ResponseEntity<?> listVideoRooms(@PathVariable UUID chatRoomId) {
+        ChatRoom chatRoom = chatRoomRepository.findById(chatRoomId)
+                .orElseThrow(() -> new RuntimeException("ChatRoom not found"));
+
+        List<VideoRoom> rooms = videoRoomService.getVideoRoomsForChatRoom(chatRoom);
+
+        return ResponseEntity.ok(Map.of(
+                "count", rooms.size(),
+                "videoRooms", rooms
+        ));
+    }
+
+    @DeleteMapping("/delete")
+    public ResponseEntity<?> deleteVideoRoom(@RequestParam UUID chatRoomId, @RequestParam String roomName, @RequestParam String requester) {
+
+        ChatRoom chatRoom = chatRoomRepository.findById(chatRoomId)
+                .orElseThrow(() -> new RuntimeException("ChatRoom not found"));
+
+        videoRoomService.deleteVideoRoom(chatRoom, roomName, requester);
+
+        return ResponseEntity.ok(Map.of("message", "Video room deleted successfully"));
+    }
+
+}