chore: added routes and functionality for adding room to db

Author: AdityaByte

src/main/java/com/connect/controller/ChatRoomController.java

@@ -5,7 +5,10 @@
 import com.connect.dto.RoomDTO;
 import com.connect.model.Room;
 import com.connect.service.ChatUserService;
+import com.connect.service.JwtTokenService;
 import com.connect.service.RoomService;
+import com.connect.utils.JwtUtil;
+import jakarta.servlet.http.HttpServletRequest;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
@@ -15,7 +18,6 @@
 import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.web.bind.annotation.*;
 
-import java.security.Principal;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -30,6 +32,9 @@ public class ChatRoomController {
     @Autowired
     private RoomService roomService;
 
+    @Autowired
+    private JwtTokenService jwtTokenService;
+
     @Autowired
     private SimpMessagingTemplate messagingTemplate;
 
@@ -48,13 +53,29 @@ public void joinRoom(@Payload Map<String, String> joinReq) {
     // Handler when the user creates a new room.
     // Person who is creating the room must give the necessary information as in body.
     @PostMapping("/room/create")
-    public ResponseEntity<String> createRoom(@RequestBody  Room room, Principal principal) {
-        // Room name is been given by the owner.
-        // Here we derive the name of the user who is request with the help of principal.
-        Room createdRoom = roomService.addNewRoom(room, principal);
+    public ResponseEntity<Map<String, String>> createRoom(@RequestBody Room room, HttpServletRequest request) {
+        log.info("New Room request");
+        String rawToken = request.getHeader("Authorization");
+        // Checking the token is valid or not.
+        // This service extracts the username till then the token is valid otherwise it will not.
+        String token = rawToken.substring(7);
+        String username = jwtTokenService.extractUsername(token);
+
+        if (username.isEmpty()) {
+            return ResponseEntity
+                    .status(HttpStatus.UNAUTHORIZED)
+                    .body(Map.of("response", "Invalid Token"));
+        }
+        // Here we need to send the data to the service class.
+        var createdRoom = roomService.addNewRoom(room, username);
+        if (createdRoom == null) {
+            return ResponseEntity
+                    .status(HttpStatus.INTERNAL_SERVER_ERROR)
+                    .body(Map.of("response", "Something went wrong at the server! Try again later."));
+        }
         return ResponseEntity
                 .status(HttpStatus.CREATED)
-                .body("Room created successfully");
+                .body(Map.of("response", createdRoom.getRoomId().toString()));
     }
 
     @GetMapping("/room/getall")

src/main/java/com/connect/controller/ChatUserController.java

@@ -72,9 +72,7 @@ public void fetchUsers() {
                     .stream()
                     .map(UserDTO::new)
                     .collect(Collectors.toList());
-            System.out.println("working dude");
             messagingTemplate.convertAndSend("/topic/users", modifiedUsers);
         });
     }
-
 }

src/main/java/com/connect/service/ChatUserService.java

@@ -93,6 +93,7 @@ public Optional<List<Message>> chatHistoryHandler(String roomId) {
     }
 
     public Optional<List<User>> fetchUser() {
+        log.info("Fetching all users from database");
         return userRepository.findAllUser();
     }
 

src/main/java/com/connect/service/RoomService.java

@@ -67,13 +67,8 @@ public boolean isRoomExists(ObjectId roomId) {
     }
 
     // Method for adding a new Room
-    public Room addNewRoom(Room room, Principal principal) {
-        String user = principal.getName();
-        if (user.isEmpty()) {
-            log.error("User not found, failed to create the room");
-            return null;
-        }
-        Optional<User> fetchedUser = userRepository.findByUsername(user);
+    public Room addNewRoom(Room room, String username) {
+        Optional<User> fetchedUser = userRepository.findByUsername(username);
         if (fetchedUser.isEmpty()) {
             log.error("No user found in the DB, failed to create new room");
             return null;