Added transactional annotations to the service classes.

src/main/java/com/projects/aeroplannerrestapi/service/impl/AuthenticationServiceImpl.java

@@ -24,6 +24,7 @@
 import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
 import org.springframework.security.crypto.password.PasswordEncoder;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
 
 import java.util.HashSet;
@@ -34,6 +35,7 @@
 
 @Service
 @RequiredArgsConstructor
+@Transactional
 public class AuthenticationServiceImpl implements AuthenticationService {
 
     private static final Log LOG = LogFactory.getLog(AuthenticationServiceImpl.class);

src/main/java/com/projects/aeroplannerrestapi/service/impl/EmailServiceImpl.java

@@ -18,6 +18,7 @@
 import org.springframework.mail.javamail.MimeMessageHelper;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.thymeleaf.TemplateEngine;
 import org.thymeleaf.context.Context;
 
@@ -29,6 +30,7 @@
 import static com.projects.aeroplannerrestapi.constants.SecurityRoleConstants.HEADER;
 
 @Service
+@Transactional
 @RequiredArgsConstructor
 public class EmailServiceImpl implements EmailService {
 

src/main/java/com/projects/aeroplannerrestapi/service/impl/FlightServiceImpl.java

@@ -22,13 +22,15 @@
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class FlightServiceImpl implements FlightService {
 
     private static final Log LOG = LogFactory.getLog(FlightServiceImpl.class);
 
     private final FlightRepository flightRepository;
 
     @Override
+    @Transactional
     public FlightResponse createFlight(FlightRequest flightRequest) {
         Flight flight = FlightMapper.INSTANCE.flightRequestToFlight(flightRequest);
         flight.setCurrentAvailableSeat(flightRequest.getSeatAvailability());

src/main/java/com/projects/aeroplannerrestapi/service/impl/PassengerServiceImpl.java

@@ -16,6 +16,7 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Sort;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Collections;
 import java.util.List;
@@ -25,6 +26,7 @@
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class PassengerServiceImpl implements PassengerService {
 
     private static final Log LOG = LogFactory.getLog(PassengerServiceImpl.class);
@@ -60,6 +62,7 @@ public UserResponse getPassenger(Long id) {
     }
 
     @Override
+    @Transactional
     public void deletePassenger(Long id) {
         if (!userRepository.existsByIdAndRoles_Name(id, RoleEnum.USER)) {
             throw new ResourceNotFoundException(PASSENGER, ID, id.toString());

src/main/java/com/projects/aeroplannerrestapi/service/impl/PaymentServiceImpl.java

@@ -28,6 +28,7 @@
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class PaymentServiceImpl implements PaymentService {
 
     private static final Log LOG = LogFactory.getLog(PaymentServiceImpl.class);
@@ -67,7 +68,6 @@ public PaymentResponse processPayment(PaymentRequest paymentRequest) {
     }
 
     @Override
-    @Transactional(readOnly = true)
     public Payment getPaymentDetails(Long id) {
         return paymentRepository.findById(id)
                 .orElseThrow(() -> new ResourceNotFoundException(PAYMENT, ID, id.toString()));

src/main/java/com/projects/aeroplannerrestapi/service/impl/ReservationServiceImpl.java

@@ -28,6 +28,7 @@
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class ReservationServiceImpl implements ReservationService {
 
     private static final Log LOG = LogFactory.getLog(ReservationServiceImpl.class);
@@ -36,6 +37,7 @@ public class ReservationServiceImpl implements ReservationService {
     private final FlightRepository flightRepository;
 
     @Override
+    @Transactional
     public ReservationResponse createReservation(ReservationRequest reservationRequest) {
         Reservation reservation = ReservationMapper.INSTANCE.reservationRequestToReservation(reservationRequest);
         Long flightId = reservationRequest.getFlightId();

src/main/java/com/projects/aeroplannerrestapi/service/impl/SuperAdminServiceImpl.java

@@ -27,6 +27,7 @@
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class SuperAdminServiceImpl implements SuperAdminService {
 
     private static final Log LOG = LogFactory.getLog(SuperAdminServiceImpl.class);
@@ -36,6 +37,7 @@ public class SuperAdminServiceImpl implements SuperAdminService {
     private final PasswordEncoder passwordEncoder;
 
     @Override
+    @Transactional
     public UserResponse createAdministrator(RegisterRequest registerRequest) {
         String email = registerRequest.getEmail();
         Optional<Role> role = roleRepository.findByName(RoleEnum.ADMIN);
@@ -54,14 +56,14 @@ public UserResponse createAdministrator(RegisterRequest registerRequest) {
     }
 
     @Override
-    @Transactional(readOnly = true)
     public UserResponse getAdministrator(Long id) {
         User user = findByIdAndRole(id);
         LOG.debug(String.format("Administrator %d : %s", id, user.getEmail()));
         return UserMapper.INSTANCE.userToUserResponse(user);
     }
 
     @Override
+    @Transactional
     public UserResponse updateAdministrator(Long id, RegisterRequest registerRequest) {
         User user = findByIdAndRole(id);
         user.setUpdatedAt(LocalDateTime.now());
@@ -74,6 +76,7 @@ public UserResponse updateAdministrator(Long id, RegisterRequest registerRequest
     }
 
     @Override
+    @Transactional
     public void deleteAdministrator(Long id) {
         User user = findByIdAndRole(id);
         userRepository.delete(user);

src/main/java/com/projects/aeroplannerrestapi/service/impl/TicketServiceImpl.java

@@ -15,6 +15,7 @@
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
 import java.util.List;
@@ -23,6 +24,7 @@
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class TicketServiceImpl implements TicketService {
 
     private static final Log LOG = LogFactory.getLog(TicketServiceImpl.class);
@@ -31,6 +33,7 @@ public class TicketServiceImpl implements TicketService {
     private final ReservationRepository reservationRepository;
 
     @Override
+    @Transactional
     public TicketResponse createTicket(TicketRequest ticketRequest) {
         Long reservationId = ticketRequest.getReservationId();
         Reservation reservation = reservationRepository.findById(reservationId)
@@ -61,6 +64,7 @@ public TicketResponse getTicket(Long id) {
     }
 
     @Override
+    @Transactional
     public void cancelTicket(Long id) {
         Ticket ticket = ticketRepository.findById(id)
                 .orElseThrow(() -> new ResourceNotFoundException(TICKET, ID, id.toString()));

src/main/java/com/projects/aeroplannerrestapi/service/impl/TokenBlacklistServiceImpl.java

@@ -5,6 +5,7 @@
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.HashSet;
 import java.util.Set;

src/main/java/com/projects/aeroplannerrestapi/service/impl/UserServiceImpl.java

@@ -25,14 +25,14 @@
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class UserServiceImpl implements UserService {
 
     private static final Log LOG = LogFactory.getLog(UserServiceImpl.class);
 
     private final UserRepository userRepository;
 
     @Override
-    @Transactional(readOnly = true)
     public UserResponse getAuthenticatedUser() {
         Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
         String email = authentication.getName();
@@ -43,7 +43,6 @@ public UserResponse getAuthenticatedUser() {
     }
 
     @Override
-    @Transactional(readOnly = true)
     public PaginatedAndSortedUserResponse getAllUsers(int pageNumber, int pageSize, String sortBy, String sortDirection) {
         Sort sort = sortDirection.equalsIgnoreCase(Sort.Direction.ASC.name()) ? Sort.by(sortBy).ascending() :
                 Sort.by(sortBy).descending();