User can remove user frmo connection

src/main/java/com/michael/controller/ConnectionController.java

@@ -63,4 +63,24 @@ public ResponseEntity<?> store(@PathVariable Long connectionId, HttpSession sess
         return new ResponseEntity<>(messageResponse, new HttpHeaders(), HttpStatus.CREATED);
 
     }
+
+    @DeleteMapping(path = "{connectionId}")
+    public ResponseEntity<?> destroy(@PathVariable Long connectionId, HttpSession session) {
+        User owner = authUser(session);
+        if (owner == null) throw new UserException("User Not Found. Please Login");
+        User connection = userService.getUserById(connectionId);
+        if (connection == null) throw new UserException("User Not Found. Check User Id");
+
+        boolean isConnected = connectionService.checkIfUserAlreadyExistInConnection(owner, connection);
+        if (!isConnected) {
+            throw new ConnectionException("Connection Not In List");
+        }
+
+        connectionService.removeConnection(owner, connection);
+
+        MessageResponse messageResponse = new MessageResponse("Connection Removed!!!");
+
+        return new ResponseEntity<>(messageResponse, new HttpHeaders(), HttpStatus.OK);
+    }
+
 }

src/main/java/com/michael/service/ConnectionService.java

@@ -52,4 +52,13 @@ public List<User> getConnections(User owner) {
 
         return null;
     }
+
+    @Override
+    public void removeConnection(User owner, User connection) {
+        Optional<Connection> connectionOptional = connectionRepository.findConnectionByOwnerAndConnecton(owner, connection);
+        if (connectionOptional.isPresent()) {
+            Connection connection1 = connectionOptional.get();
+            connectionRepository.delete(connection1);
+        }
+    }
 }

src/main/java/com/michael/service/contracts/IConnectionService.java

@@ -11,4 +11,6 @@ public interface IConnectionService {
     boolean checkIfUserAlreadyExistInConnection(User owner, User connection);
 
     List<User> getConnections(User owner);
+
+    void removeConnection(User owner, User connection);
 }