diff --git a/src/Services/Flight/src/Flight/Airports/Models/Airport.cs b/src/Services/Flight/src/Flight/Airports/Models/Airport.cs index 327e0b9..7eafe85 100644 --- a/src/Services/Flight/src/Flight/Airports/Models/Airport.cs +++ b/src/Services/Flight/src/Flight/Airports/Models/Airport.cs @@ -9,7 +9,7 @@ public record Airport : Aggregate { public Name Name { get; private set; } = default!; public Address Address { get; private set; } = default!; - public Code Code { get; private set; } + public Code Code { get; private set; } = default!; public static Airport Create(AirportId id, Name name, Address address, Code code, bool isDeleted = false) { diff --git a/src/Services/Flight/src/Flight/FlightCreatedConsumerHandler.cs b/src/Services/Flight/src/Flight/FlightCreatedConsumerHandler.cs deleted file mode 100644 index 334def9..0000000 --- a/src/Services/Flight/src/Flight/FlightCreatedConsumerHandler.cs +++ /dev/null @@ -1,15 +0,0 @@ -using System; -using System.Threading.Tasks; -using BuildingBlocks.Contracts.EventBus.Messages; -using MassTransit; - -namespace Flight; - -public class FlightCreatedConsumerHandler : IConsumer -{ - public Task Consume(ConsumeContext context) - { - Console.WriteLine($"We retrieve message: {context.Message}"); - return Task.CompletedTask; - } -} diff --git a/src/Services/Flight/src/Flight/Flights/Models/Flight.cs b/src/Services/Flight/src/Flight/Flights/Models/Flight.cs index fc78815..885e9ad 100644 --- a/src/Services/Flight/src/Flight/Flights/Models/Flight.cs +++ b/src/Services/Flight/src/Flight/Flights/Models/Flight.cs @@ -11,16 +11,16 @@ using global::Flight.Flights.ValueObjects; public record Flight : Aggregate { - public FlightNumber? FlightNumber { get; private set; } = default!; - public AircraftId AircraftId { get; private set; } - public AirportId? DepartureAirportId { get; private set; } - public AirportId? ArriveAirportId { get; private set; } - public DurationMinutes? DurationMinutes { get; private set; } + public FlightNumber FlightNumber { get; private set; } = default!; + public AircraftId AircraftId { get; private set; } = default!; + public AirportId DepartureAirportId { get; private set; } = default!; + public AirportId ArriveAirportId { get; private set; } = default!; + public DurationMinutes DurationMinutes { get; private set; } = default!; public Enums.FlightStatus Status { get; private set; } - public Price? Price { get; private set; } - public ArriveDate? ArriveDate { get; private set; } - public DepartureDate? DepartureDate { get; private set; } - public FlightDate? FlightDate { get; private set; } + public Price Price { get; private set; } = default!; + public ArriveDate ArriveDate { get; private set; } = default!; + public DepartureDate DepartureDate { get; private set; } = default!; + public FlightDate FlightDate { get; private set; } = default!; public static Flight Create(FlightId id, FlightNumber flightNumber, AircraftId aircraftId, AirportId departureAirportId, DepartureDate departureDate, ArriveDate arriveDate, diff --git a/src/Services/Flight/src/Flight/Identity/Consumers/RegisterNewUser/V1/RegisterNewUserConsumerHandler.cs b/src/Services/Flight/src/Flight/Identity/Consumers/RegisterNewUser/V1/RegisterNewUserConsumerHandler.cs deleted file mode 100644 index 6b81d90..0000000 --- a/src/Services/Flight/src/Flight/Identity/Consumers/RegisterNewUser/V1/RegisterNewUserConsumerHandler.cs +++ /dev/null @@ -1,29 +0,0 @@ -namespace Flight.Identity.Consumers.RegisterNewUser.V1; - -using System.Threading.Tasks; -using BuildingBlocks.Contracts.EventBus.Messages; -using BuildingBlocks.Web; -using Humanizer; -using MassTransit; -using Microsoft.Extensions.Logging; -using Microsoft.Extensions.Options; - -public class RegisterNewUserConsumerHandler : IConsumer -{ - private readonly AppOptions _options; - private readonly ILogger _logger; - - public RegisterNewUserConsumerHandler(IOptions options, - ILogger logger) - { - _options = options.Value; - _logger = logger; - } - - public Task Consume(ConsumeContext context) - { - _logger.LogInformation($"this is a test consumer for {nameof(UserCreated).Underscore()} in {_options.Name}"); - _logger.LogInformation($"we got this message: {context?.Message}"); - return Task.CompletedTask; - } -} diff --git a/src/Services/Flight/src/Flight/Seats/Models/Seat.cs b/src/Services/Flight/src/Flight/Seats/Models/Seat.cs index 6f2653a..51947e5 100644 --- a/src/Services/Flight/src/Flight/Seats/Models/Seat.cs +++ b/src/Services/Flight/src/Flight/Seats/Models/Seat.cs @@ -14,7 +14,7 @@ public record Seat : Aggregate public SeatNumber SeatNumber { get; private set; } = default!; public Enums.SeatType Type { get; private set; } public Enums.SeatClass Class { get; private set; } - public FlightId FlightId { get; private set; } + public FlightId FlightId { get; private set; } = default!; public static Seat Create(SeatId id, SeatNumber seatNumber, Enums.SeatType type, Enums.SeatClass @class, FlightId flightId, bool isDeleted = false) diff --git a/src/Services/Identity/src/Identity/UserCreatedConsumerHandler.cs b/src/Services/Identity/src/Identity/UserCreatedConsumerHandler.cs deleted file mode 100644 index eb7202b..0000000 --- a/src/Services/Identity/src/Identity/UserCreatedConsumerHandler.cs +++ /dev/null @@ -1,15 +0,0 @@ -namespace Identity; - -using System; -using System.Threading.Tasks; -using BuildingBlocks.Contracts.EventBus.Messages; -using MassTransit; - -public class UserCreatedConsumerHandler : IConsumer -{ - public Task Consume(ConsumeContext context) - { - Console.WriteLine($"We retrieve message: {context.Message}"); - return Task.CompletedTask; - } -}