mirror of
https://github.com/meysamhadeli/booking-microservices.git
synced 2026-05-02 19:02:55 +08:00
refactor: Set default value for aggregates
This commit is contained in:
parent
7348c2c6ac
commit
11fc165a80
@ -9,7 +9,7 @@ public record Airport : Aggregate<AirportId>
|
|||||||
{
|
{
|
||||||
public Name Name { get; private set; } = default!;
|
public Name Name { get; private set; } = default!;
|
||||||
public Address Address { 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)
|
public static Airport Create(AirportId id, Name name, Address address, Code code, bool isDeleted = false)
|
||||||
{
|
{
|
||||||
|
|||||||
@ -1,15 +0,0 @@
|
|||||||
using System;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using BuildingBlocks.Contracts.EventBus.Messages;
|
|
||||||
using MassTransit;
|
|
||||||
|
|
||||||
namespace Flight;
|
|
||||||
|
|
||||||
public class FlightCreatedConsumerHandler : IConsumer<FlightCreated>
|
|
||||||
{
|
|
||||||
public Task Consume(ConsumeContext<FlightCreated> context)
|
|
||||||
{
|
|
||||||
Console.WriteLine($"We retrieve message: {context.Message}");
|
|
||||||
return Task.CompletedTask;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -11,16 +11,16 @@ using global::Flight.Flights.ValueObjects;
|
|||||||
|
|
||||||
public record Flight : Aggregate<FlightId>
|
public record Flight : Aggregate<FlightId>
|
||||||
{
|
{
|
||||||
public FlightNumber? FlightNumber { get; private set; } = default!;
|
public FlightNumber FlightNumber { get; private set; } = default!;
|
||||||
public AircraftId AircraftId { get; private set; }
|
public AircraftId AircraftId { get; private set; } = default!;
|
||||||
public AirportId? DepartureAirportId { get; private set; }
|
public AirportId DepartureAirportId { get; private set; } = default!;
|
||||||
public AirportId? ArriveAirportId { get; private set; }
|
public AirportId ArriveAirportId { get; private set; } = default!;
|
||||||
public DurationMinutes? DurationMinutes { get; private set; }
|
public DurationMinutes DurationMinutes { get; private set; } = default!;
|
||||||
public Enums.FlightStatus Status { get; private set; }
|
public Enums.FlightStatus Status { get; private set; }
|
||||||
public Price? Price { get; private set; }
|
public Price Price { get; private set; } = default!;
|
||||||
public ArriveDate? ArriveDate { get; private set; }
|
public ArriveDate ArriveDate { get; private set; } = default!;
|
||||||
public DepartureDate? DepartureDate { get; private set; }
|
public DepartureDate DepartureDate { get; private set; } = default!;
|
||||||
public FlightDate? FlightDate { get; private set; }
|
public FlightDate FlightDate { get; private set; } = default!;
|
||||||
|
|
||||||
public static Flight Create(FlightId id, FlightNumber flightNumber, AircraftId aircraftId,
|
public static Flight Create(FlightId id, FlightNumber flightNumber, AircraftId aircraftId,
|
||||||
AirportId departureAirportId, DepartureDate departureDate, ArriveDate arriveDate,
|
AirportId departureAirportId, DepartureDate departureDate, ArriveDate arriveDate,
|
||||||
|
|||||||
@ -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<UserCreated>
|
|
||||||
{
|
|
||||||
private readonly AppOptions _options;
|
|
||||||
private readonly ILogger<RegisterNewUserConsumerHandler> _logger;
|
|
||||||
|
|
||||||
public RegisterNewUserConsumerHandler(IOptions<AppOptions> options,
|
|
||||||
ILogger<RegisterNewUserConsumerHandler> logger)
|
|
||||||
{
|
|
||||||
_options = options.Value;
|
|
||||||
_logger = logger;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Task Consume(ConsumeContext<UserCreated> 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;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -14,7 +14,7 @@ public record Seat : Aggregate<SeatId>
|
|||||||
public SeatNumber SeatNumber { get; private set; } = default!;
|
public SeatNumber SeatNumber { get; private set; } = default!;
|
||||||
public Enums.SeatType Type { get; private set; }
|
public Enums.SeatType Type { get; private set; }
|
||||||
public Enums.SeatClass Class { 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,
|
public static Seat Create(SeatId id, SeatNumber seatNumber, Enums.SeatType type, Enums.SeatClass @class, FlightId flightId,
|
||||||
bool isDeleted = false)
|
bool isDeleted = false)
|
||||||
|
|||||||
@ -1,15 +0,0 @@
|
|||||||
namespace Identity;
|
|
||||||
|
|
||||||
using System;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using BuildingBlocks.Contracts.EventBus.Messages;
|
|
||||||
using MassTransit;
|
|
||||||
|
|
||||||
public class UserCreatedConsumerHandler : IConsumer<UserCreated>
|
|
||||||
{
|
|
||||||
public Task Consume(ConsumeContext<UserCreated> context)
|
|
||||||
{
|
|
||||||
Console.WriteLine($"We retrieve message: {context.Message}");
|
|
||||||
return Task.CompletedTask;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
x
Reference in New Issue
Block a user