Mock Asynch bus

CommandBusMock.php

<?php

namespace Xeonys\Tests\Features\Mock;

use Rezzza\CommandBus\Domain\CommandBusInterface;
use Rezzza\CommandBus\Domain\CommandInterface;

class CommandBusMock implements CommandBusInterface
{
    const FILENAME = 'async_queue';

    private $cmd = array();


    public function getHandleType()
    {
        return;
    }

    public function handle(CommandInterface $command, $priority = null)
    {
        $this->cmd[] = $this->dumpCmd($command);
        file_put_contents(__DIR__.'/../../../../web/'.self::FILENAME . '.json', json_encode(['items' => $this->cmd]));
    }

    private function dumpCmd(CommandInterface $command)
    {
        $className  = get_class($command);
        $user       = $command->getUser();
        $connection = $command->getConnection();

        return [
            'className'  => $className,
            'user'       => $user,
            'connection' => $connection,
            'channel'    => $command->getChannel()->getName(),
            'cmd'        => $command,
        ];
    }
}