Dhanman.Shared.Contracts 1.8.5

Dhanman.Shared.Contracts

This project contains shared data transfer objects (DTOs), events, and message contracts used across multiple Dhanman microservices.

Purpose

• Define common event and command contracts for inter-service communication.
• Keep shared message schemas consistent and centralized.
• Avoid tight coupling by sharing only contract definitions, not implementations.

Usage

1. Reference this package from any microservice that needs to publish or consume these contracts.

2. Use the DTOs, event classes, and commands here for MassTransit message serialization and deserialization.

3. Keep contracts immutable and versioned carefully to maintain backward compatibility.

Example Contract

public class UserCreatedEvent : IEvent
{
    public Guid UserId { get; set; }
    public Guid CompanyId { get; set; }
    public string FirstName { get; set; } = string.Empty;
    public string LastName { get; set; } = string.Empty;
    public string Email { get; set; } = string.Empty;
    public string PhoneNumber { get; set; } = string.Empty;
}

MassTransit Integration

This library is designed to work seamlessly with MassTransit. Events defined here can be published and consumed using MassTransit's type-based routing.

Publishing Events with MassTransit

public class MyService
{
    private readonly IPublishEndpoint _publishEndpoint;
    
    public MyService(IPublishEndpoint publishEndpoint)
    {
        _publishEndpoint = publishEndpoint;
    }
    
    public async Task CreateUser(...)
    {
        // Business logic...
        
        await _publishEndpoint.Publish(new UserCreatedEvent
        {
            UserId = user.Id,
            CompanyId = user.CompanyId,
            // ... other properties
        });
    }
}

Consuming Events with MassTransit

public class UserCreatedEventConsumer : IConsumer<UserCreatedEvent>
{
    private readonly ILogger<UserCreatedEventConsumer> _logger;
    
    public UserCreatedEventConsumer(ILogger<UserCreatedEventConsumer> logger)
    {
        _logger = logger;
    }
    
    public async Task Consume(ConsumeContext<UserCreatedEvent> context)
    {
        var message = context.Message;
        
        // Use structured logging (not string interpolation)
        _logger.LogInformation(
            "[MESSAGE] Consuming UserCreatedEvent for UserId {UserId}",
            message.UserId);
        
        // Handle the event...
    }
}

Logging Best Practices

When implementing message handlers:

• Use structured logging with placeholders like {PropertyName}, not string interpolation $"{value}"
• Tag message logs with [MESSAGE] prefix to distinguish from general application logs
• Include key identifiers: UserId, CompanyId, MessageId, CorrelationId
• Use appropriate log levels: Information for normal flow, Warning for retries, Error for failures

See MIGRATION_GUIDE.md for comprehensive logging guidelines.

Legacy Routing Keys

The RoutingKeys class is marked as obsolete. MassTransit uses type-based routing automatically, so explicit routing keys are no longer needed. The class is kept for backward compatibility during the migration period.