for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace Umbrellio\TableSync\Integration\Laravel\Receive;
use Illuminate\Support\Facades\App;
use Umbrellio\TableSync\Integration\Laravel\Exceptions\UnknownMessageEvent;
use Umbrellio\TableSync\Integration\Laravel\Receive\MessageData\MessageDataRetriever;
use Umbrellio\TableSync\Integration\Laravel\Receive\Upserter\Upserter;
use Umbrellio\TableSync\Messages\ReceivedMessage;
class Receiver
{
private $dataRetriever;
public function __construct(MessageDataRetriever $dataRetriever)
$this->dataRetriever = $dataRetriever;
}
public function receive(ReceivedMessage $message): void
$event = $message->getEvent();
$data = $this->dataRetriever->retrieve($message);
switch ($event) {
case 'update':
$upserter = App::make(Upserter::class);
$upserter->upsert($data, $message->getVersion());
break;
case 'destroy':
$destroyer = new Destroyer();
$destroyer->destroy($data);
default:
throw new UnknownMessageEvent("Unknown event: {$event}");
umbrellio /
php-table-sync
