Quick Start

dotnet add package TurboMediator.Abstractions
dotnet add package TurboMediator.SourceGenerator

using TurboMediator;

// Query — read operation, returns data
public record GetUserQuery(Guid Id) : IQuery<User?>;

// Command — write operation, returns result
public record CreateUserCommand(string Name, string Email) : ICommand<User>;

// Request — generic request with response
public record PingRequest : IRequest<string>;

// Notification — fire-and-forget, multiple handlers
public record UserCreatedNotification(Guid UserId, string Email) : INotification;

// Supporting types
public record User(Guid Id, string Name, string Email);

using TurboMediator;

public class GetUserHandler : IQueryHandler<GetUserQuery, User?>
{
    public ValueTask<User?> Handle(GetUserQuery query, CancellationToken ct)
    {
        var user = new User(query.Id, "John Doe", "john@example.com");
        return new ValueTask<User?>(user);
    }
}

public class CreateUserHandler : ICommandHandler<CreateUserCommand, User>
{
    public ValueTask<User> Handle(CreateUserCommand command, CancellationToken ct)
    {
        var user = new User(Guid.NewGuid(), command.Name, command.Email);
        return new ValueTask<User>(user);
    }
}

public class PingHandler : IRequestHandler<PingRequest, string>
{
    public ValueTask<string> Handle(PingRequest request, CancellationToken ct)
    {
        return new ValueTask<string>("Pong!");
    }
}

// Multiple notification handlers are allowed
public class EmailNotificationHandler : INotificationHandler<UserCreatedNotification>
{
    public ValueTask Handle(UserCreatedNotification notification, CancellationToken ct)
    {
        Console.WriteLine($"Sending welcome email to {notification.Email}");
        return default;
    }
}

public class LogNotificationHandler : INotificationHandler<UserCreatedNotification>
{
    public ValueTask Handle(UserCreatedNotification notification, CancellationToken ct)
    {
        Console.WriteLine($"User created: {notification.UserId}");
        return default;
    }
}

using Microsoft.Extensions.DependencyInjection;

var builder = WebApplication.CreateBuilder(args);

// Register TurboMediator — handlers are auto-discovered
builder.Services.AddTurboMediator();

var app = builder.Build();

app.MapGet("/ping", async (IMediator mediator) =>
{
    var result = await mediator.Send(new PingRequest());
    return Results.Ok(result); // "Pong!"
});

app.MapGet("/users/{id}", async (Guid id, IMediator mediator) =>
{
    var user = await mediator.Send(new GetUserQuery(id));
    return user is not null ? Results.Ok(user) : Results.NotFound();
});

app.MapPost("/users", async (CreateUserCommand command, IMediator mediator) =>
{
    var user = await mediator.Send(command);

    // Publish notification — all handlers will be invoked
    await mediator.Publish(new UserCreatedNotification(user.Id, user.Email));

    return Results.Created($"/users/{user.Id}", user);
});

app.Run();