CQBus Mediator

Appearance

Pipelines (Middleware) ​

Pipelines allow you to wrap your Handlers in reusable logic. Think of them exactly like Laravel Middleware, but instead of operating at the HTTP layer, they operate directly at the Mediator layer.

💡 Why is this powerful?

Because pipelines run at the Mediator level, your logic (like Database Transactions or Auditing) will execute perfectly whether the handler was triggered by an HTTP Request, an Artisan Console Command, or a Queued Job!

1. Global Pipelines ​

Global pipelines run before every handler dispatched via the send() method. This is the perfect place for global logging or APM (Application Performance Monitoring) tracking.

Register them in your config/mediator.php file:

php
// config/mediator.php
return [
    'pipelines' => [
        \App\Pipelines\LoggingPipeline::class,
    ],
];

A pipeline is simply an invokable class that receives the payload and a $next Closure:

php
namespace App\Pipelines;

use Closure;
use Illuminate\Support\Facades\Log;

class LoggingPipeline
{
    public function handle(mixed $payload, Closure $next): mixed
    {
        Log::info('Started executing: ' . get_class($payload));
        
        $response = $next($payload); // Move deeper into the onion
        
        Log::info('Finished executing successfully.');
        
        return $response;
    }
}

2. Handler-Level Pipelines ​

Sometimes you only need a pipeline for specific actions. You can apply them directly to your handlers using the #[Pipeline] attribute.

Note: Handler-level pipelines run after Global pipelines.

php
use Ignaciocastro0713\CqbusMediator\Attributes\Pipeline;
use Ignaciocastro0713\CqbusMediator\Attributes\RequestHandler;

#[RequestHandler(CreateOrderRequest::class)]
#[Pipeline(DatabaseTransactionPipeline::class)] // 🛡️ Ensures DB consistency
class CreateOrderHandler
{
    public function handle(CreateOrderRequest $request): Order
    {
        return Order::create($request->validated());
    }
}

3. Skipping Global Pipelines ​

What if you have a simple health-check query, and you don't want it to trigger your heavy Global Logging pipeline? Use the #[SkipGlobalPipelines] attribute.

php
use Ignaciocastro0713\CqbusMediator\Attributes\RequestHandler;
use Ignaciocastro0713\CqbusMediator\Attributes\SkipGlobalPipelines;

#[RequestHandler(HealthCheckRequest::class)]
#[SkipGlobalPipelines] // 🛑 Global pipelines will be ignored
class HealthCheckHandler
{
    public function handle(HealthCheckRequest $request): string
    {
        return 'All systems operational.'; 
    }
}