PHP code example of think-codee / laravel-command-bus

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

think-codee / laravel-command-bus example snippets

return [
    'buses' => [
        'default' => [
            'class' => \ThinkCodee\Laravel\CommandBus\Default\Bus::class,
            'interface' => \ThinkCodee\Laravel\CommandBus\Contracts\Bus::class,
            'alias' => 'bus.default',
            'middleware' => [],
            'handler_resolver' => \ThinkCodee\Laravel\CommandBus\Resolvers\SuffixHandlerResolver::class,
            'handler_method' => 'handle',
        ],
    ]
];

use ThinkCodee\Laravel\CommandBus\Contracts\CommandBus;

interface QueryBusInterface extends CommandBus
{
}

use ThinkCodee\Laravel\CommandBus\Bus;

class QueryBus extends Bus implements QueryBusInterface
{
}

'query' => [
    'class' => \App\Buses\Query\QueryBus::class,
    'interface' => \App\Buses\Query\QueryBusInterface::class,
    'alias' => 'bus.query',
];

use App\Buses\Query\QueryBusinterface; 

class Controller
{
    public function __construct(
        private QueryBusInterface $queryBus,
    ) {}

    public function show(int $id)
    {
        $users = $this->queryBus->handle(
            new GetUserQuery($id)
        );

        // Alternatively:
        // app('bus.query')->handle(
        //     new GetUsersQuery()  
        // );
    }
}

use ThinkCodee\Laravel\CommandBus\Contracts\Command;

class GetUserQuery implements Command
{
    public function __construct(public int $id) {}
}

class GetUserQueryHandler
{
    public function handle(GetUserQuery $query)
    {
        // Handle the command, e.g., process $query->id
        // return User::findOrFail($query->id);
    }
}

class LogExceptionsMiddleware
{
    public function handle(Command $command, Closure $next)
    {
        try {
            return $next($command);
        } catch (\Exception $e) {
            Log::error($e->getMessage());
            
            throw $e;
        }
    }
}

// This will prepend LogExceptionsMiddleware to the existing middleware
#[Middleware([LogExceptionsMiddleware::class], true)]
class StoreUserCommandHandler
{
    public function handle(StoreUserCommand $command): int
    {
        // Handle the command, e.g., process $command->email
        
        // $user = User::create(['email' => $command->email]);
        // return $user->id;
    }
}

// Handle the command with LogExceptionsMiddleware only
#[ResetMiddleware]
#[Middleware([LogExceptionsMiddleware::class])]
class StoreUserCommandHandler
{
    public function handle(StoreUserCommand $command): int
    {
        // Handle the command, e.g., process $command->email
        
        // $user = User::create(['email' => $command->email]);
        // return $user->id;
    }
}

'default' => [
    'class' => \ThinkCodee\Laravel\CommandBus\Default\Bus::class,
    'interface' => \ThinkCodee\Laravel\CommandBus\Contracts\Bus::class,
    'alias' => 'bus.default',
    'middleware' => [
        LogExceptionsMiddleware::class,
        //e.g. ExecuteWithinDatabaseTransaction
    ],
],

'handler_resolver' => \ThinkCodee\Laravel\CommandBus\Resolvers\SuffixHandlerResolver::class,
'handler_method' => 'handle',

#[Handler(StoreUserCustomHandler::class, 'customMethod')]
class StoreUserCommand
{
    // Command implementation
}

bash
php artisan vendor:publish --tag="command-bus-config"

bash
php artisan command-bus:make:bus QueryBus