Sky 25

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/application/flight/GetFlightsUseCase.java

@@ -2,8 +2,10 @@
 
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
-import pl.skyroster.skyroster_backend.domain.model.Flight;
 import pl.skyroster.skyroster_backend.domain.port.FlightRepository;
+import pl.skyroster.skyroster_backend.generated.model.FlightResponse;
+import pl.skyroster.skyroster_backend.infrastructure.mappers.AircraftResponseMapper;
+import pl.skyroster.skyroster_backend.infrastructure.mappers.OperationalBaseInfoMapper;
 
 import java.util.List;
 
@@ -16,7 +18,19 @@ public GetFlightsUseCase(FlightRepository flightRepository) {
     }
 
     @Transactional(readOnly = true)
-    public List<Flight> execute() {
-        return flightRepository.findAll();
+    public List<FlightResponse> execute() {
+        return flightRepository.findAll().stream().map(flight -> {
+            var aircraftResponse = AircraftResponseMapper.map(flight.getAircraft());
+
+            return new FlightResponse(
+                    flight.getId(),
+                    aircraftResponse,
+                    flight.getFlightStart(),
+                    flight.getFlightEnd(),
+                    OperationalBaseInfoMapper.map(flight.getStartAirport()),
+                    OperationalBaseInfoMapper.map(flight.getEndAirport()),
+                    flight.getDescription()
+            );
+        }).toList();
     }
 }

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/application/pilot/AddPilotUseCase.java

@@ -0,0 +1,24 @@
+package pl.skyroster.skyroster_backend.application.pilot;
+
+import jakarta.transaction.Transactional;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import pl.skyroster.skyroster_backend.domain.exception.PilotAlreadyExistsException;
+import pl.skyroster.skyroster_backend.domain.port.PilotRepository;
+import pl.skyroster.skyroster_backend.generated.model.PilotRequest;
+import pl.skyroster.skyroster_backend.infrastructure.mappers.PilotMapper;
+import pl.skyroster.skyroster_backend.generated.model.PilotResponse;
+@Service
+@RequiredArgsConstructor
+public class AddPilotUseCase {
+  private final PilotRepository pilotRepository;
+
+  @Transactional
+  public PilotResponse addPilot(PilotRequest request) {
+    if (pilotRepository.existsByLicence(request.getLicence())){
+      throw new PilotAlreadyExistsException("Pilot already exists");
+    }
+    var pilot = PilotMapper.toEntity(request);
+    return PilotMapper.toResponse(pilotRepository.save(pilot));
+  }
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/application/pilot/DeletePilotUseCase.java

@@ -0,0 +1,35 @@
+package pl.skyroster.skyroster_backend.application.pilot;
+
+import jakarta.transaction.Transactional;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import pl.skyroster.skyroster_backend.domain.exception.PilotNotFoundException;
+import pl.skyroster.skyroster_backend.domain.port.FlightRepository;
+import pl.skyroster.skyroster_backend.domain.port.PilotRepository;
+
+import java.time.OffsetDateTime;
+import java.util.UUID;
+
+@Service
+@RequiredArgsConstructor
+public class DeletePilotUseCase {
+
+  private final PilotRepository pilotRepository;
+  private final FlightRepository flightRepository;
+
+  @Transactional
+  public void deletePilotById(UUID pilotId) {
+    if (!pilotRepository.existsById(pilotId)) {
+      throw new PilotNotFoundException(pilotId);
+    }
+
+    if(pilotHasScheduledFlights(pilotId))
+      throw new IllegalStateException("Pilot has ongoing or incoming flights");
+
+    pilotRepository.deleteById(pilotId);
+  }
+
+  private boolean pilotHasScheduledFlights(UUID pilotId){
+    return flightRepository.existsByPilotIdAndFlightEndAfter(pilotId, OffsetDateTime.now());
+  }
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/application/pilot/GetPilotUseCase.java

@@ -0,0 +1,59 @@
+package pl.skyroster.skyroster_backend.application.pilot;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.stereotype.Service;
+import pl.skyroster.skyroster_backend.domain.model.Pilot;
+import pl.skyroster.skyroster_backend.domain.port.PilotRepository;
+import pl.skyroster.skyroster_backend.generated.model.PagedPilotResponse;
+import pl.skyroster.skyroster_backend.infrastructure.mappers.PilotMapper;
+
+@Service
+@RequiredArgsConstructor
+public class GetPilotUseCase {
+
+  private final PilotRepository pilotRepository;
+
+  public PagedPilotResponse getPilots(Integer page, Integer size, String sort) {
+    Pageable pageable = createPageable(page, size, sort);
+
+    Page<Pilot> pilotsPage = pilotRepository.findAllWithRelations(pageable);
+
+    return new PagedPilotResponse()
+        .content(
+            pilotsPage.getContent()
+                .stream()
+                .map(PilotMapper::toResponse)
+                .toList()
+        )
+        .page(pilotsPage.getNumber())
+        .size(pilotsPage.getSize())
+        .totalElements(pilotsPage.getTotalElements())
+        .totalPages(pilotsPage.getTotalPages())
+        .first(pilotsPage.isFirst())
+        .last(pilotsPage.isLast());
+  }
+
+  private Pageable createPageable(Integer page, Integer size, String sort) {
+    int resolvedPage = page == null ? 0 : page;
+    int resolvedSize = size == null ? 20 : Math.min(size, 100);
+
+    Sort resolvedSort = Sort.by(Sort.Direction.ASC, "lastName");
+
+    if (sort != null && !sort.isBlank()) {
+      String[] parts = sort.split(",");
+      String property = parts[0];
+
+      Sort.Direction direction = parts.length > 1
+          ? Sort.Direction.fromOptionalString(parts[1]).orElse(Sort.Direction.ASC)
+          : Sort.Direction.ASC;
+
+      resolvedSort = Sort.by(direction, property);
+    }
+
+    return PageRequest.of(resolvedPage, resolvedSize, resolvedSort);
+  }
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/application/pilot/PatchPilotUseCase.java

@@ -0,0 +1,55 @@
+package pl.skyroster.skyroster_backend.application.pilot;
+
+import jakarta.transaction.Transactional;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import pl.skyroster.skyroster_backend.domain.model.AircraftType;
+import pl.skyroster.skyroster_backend.domain.model.Pilot;
+import pl.skyroster.skyroster_backend.domain.model.Qualification;
+import pl.skyroster.skyroster_backend.domain.port.OperationalBaseRepository;
+import pl.skyroster.skyroster_backend.domain.port.PilotRepository;
+import pl.skyroster.skyroster_backend.generated.model.PilotPatchRequest;
+import pl.skyroster.skyroster_backend.infrastructure.mappers.AircraftTypeInfoMapper;
+import pl.skyroster.skyroster_backend.infrastructure.mappers.PilotMapper;
+import pl.skyroster.skyroster_backend.generated.model.PilotResponse;
+import pl.skyroster.skyroster_backend.infrastructure.mappers.PilotQualificationMapper;
+
+import java.util.Set;
+import java.util.UUID;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+public class PatchPilotUseCase {
+  private final PilotRepository pilotRepository;
+  private final OperationalBaseRepository operationalBaseRepository;
+
+  @Transactional
+  public PilotResponse patchPilot(UUID id, PilotPatchRequest request) {
+    Pilot pilot = pilotRepository.findById(id)
+        .orElseThrow(() -> new IllegalArgumentException("Pilot not found: " + id));
+
+    String name = request.getName();
+    if (name != null) {
+      pilot.setName(name);
+    }
+    String surname = request.getSurname();
+    if (surname != null) {
+      pilot.setSurname(surname);
+    }
+    String icaoCode = request.getOperationalBaseIcaoCode();
+    if (icaoCode != null) {
+      pilot.setOperationalBase(
+          operationalBaseRepository.findByIcaoCode(icaoCode)
+              .orElseThrow(() -> new IllegalArgumentException("Operational base not found: " + icaoCode))
+      );
+    }
+    Set<Qualification> qualifications = request.getQualifications().stream().map(PilotQualificationMapper::fromPilotQualificationInfo).collect(Collectors.toSet());
+    pilot.setQualifications(qualifications);
+
+    Set<AircraftType> aircraftTypes = request.getAircraftTypes().stream().map(AircraftTypeInfoMapper::toAircraftTypeInfo).collect(Collectors.toSet());
+    pilot.setAircraftTypes(aircraftTypes);
+
+    return PilotMapper.toResponse(pilotRepository.save(pilot));
+  }
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/application/rule/GetRulesUseCase.java

@@ -0,0 +1,23 @@
+package pl.skyroster.skyroster_backend.application.rule;
+
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import pl.skyroster.skyroster_backend.domain.model.Rule;
+import pl.skyroster.skyroster_backend.domain.port.RuleRepository;
+
+import java.util.List;
+
+@Service
+public class GetRulesUseCase {
+
+    private final RuleRepository ruleRepository;
+
+    public GetRulesUseCase(RuleRepository ruleRepository) {
+        this.ruleRepository = ruleRepository;
+    }
+
+    @Transactional(readOnly = true)
+    public List<Rule> execute() {
+        return ruleRepository.findAll();
+    }
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/exception/PilotAlreadyExistsException.java

@@ -0,0 +1,7 @@
+package pl.skyroster.skyroster_backend.domain.exception;
+
+public class PilotAlreadyExistsException extends RuntimeException {
+  public PilotAlreadyExistsException(String message) {
+    super(message);
+  }
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/exception/PilotNotFoundException.java

@@ -0,0 +1,9 @@
+package pl.skyroster.skyroster_backend.domain.exception;
+
+import java.util.UUID;
+
+public class PilotNotFoundException extends RuntimeException {
+  public PilotNotFoundException(UUID pilotId) {
+    super("Pilot with id " + pilotId + " not found");
+  }
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/model/Pilot.java

@@ -1,11 +1,19 @@
 package pl.skyroster.skyroster_backend.domain.model;
 
+import jakarta.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
 import java.util.Set;
 import java.util.UUID;
 
-import jakarta.persistence.*;
-
 @Entity
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
 public class Pilot {
 
     @Id

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/model/Qualification.java

@@ -3,10 +3,16 @@
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.Id;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
 
 import java.util.UUID;
 
 @Entity
+@Getter
+@AllArgsConstructor
+@NoArgsConstructor
 public class Qualification {
 
     @Id

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/model/Rule.java

@@ -0,0 +1,41 @@
+package pl.skyroster.skyroster_backend.domain.model;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.util.UUID;
+
+@Entity
+@Table(name = "rules")
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+public class Rule {
+
+    @Id
+    private UUID id;
+
+    @Column(nullable = false, length = 100)
+    private String name;
+
+    @Enumerated(EnumType.STRING)
+    @Column(nullable = false, length = 30)
+    private RuleType type;
+
+    @Column(nullable = false)
+    private Integer value;
+
+    @Enumerated(EnumType.STRING)
+    @Column(nullable = false, length = 10)
+    private RulePeriod period;
+
+    @Column(length = 500)
+    private String description;
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/model/RulePeriod.java

@@ -0,0 +1,7 @@
+package pl.skyroster.skyroster_backend.domain.model;
+
+public enum RulePeriod {
+    DAY,
+    WEEK,
+    MONTH
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/model/RuleType.java

@@ -0,0 +1,7 @@
+package pl.skyroster.skyroster_backend.domain.model;
+
+public enum RuleType {
+    MAX_WORK_TIME,
+    MIN_REST_TIME,
+    MIN_FLIGHT_TIME
+}

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/port/FlightRepository.java

@@ -1,11 +1,17 @@
 package pl.skyroster.skyroster_backend.domain.port;
 
+import org.springframework.data.jpa.repository.JpaRepository;
 import pl.skyroster.skyroster_backend.domain.model.Flight;
 
+import java.time.OffsetDateTime;
 import java.util.List;
 import java.util.UUID;
 
-public interface FlightRepository {
+public interface FlightRepository extends JpaRepository<Flight, UUID> {
     List<Flight> findAll();
     boolean existsByAircraftId(UUID aircraftId);
+    boolean existsByPilotIdAndFlightEndAfter(
+        UUID pilotId,
+        OffsetDateTime now
+    );
 }

skyroster-backend/src/main/java/pl/skyroster/skyroster_backend/domain/port/PilotRepository.java

@@ -0,0 +1,25 @@
+package pl.skyroster.skyroster_backend.domain.port;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.EntityGraph;
+import org.springframework.data.jpa.repository.Query;
+import pl.skyroster.skyroster_backend.domain.model.Pilot;
+
+import java.util.Optional;
+import java.util.UUID;
+
+public interface PilotRepository {
+  @EntityGraph(attributePaths = {
+      "qualifications",
+      "aircraftTypes",
+      "operationalBase"
+  })
+  @Query("SELECT p FROM Pilot p")
+  Page<Pilot> findAllWithRelations(Pageable pageable);
+  Optional<Pilot> findById(UUID id);
+  boolean existsById(UUID id);
+  boolean existsByLicence(String licence);
+  void deleteById(UUID id);
+  Pilot save(Pilot pilot);
+}