Umbrellio\TableSync\Integration\Laravel\Receive\Receiver

Complexity

Total Complexity

4

Size/Duplication

Total Lines	25
Duplicated Lines	0 %

Test Coverage

Coverage

57.14%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	receive()	0	16	3

<?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);
                break;
            default:
                throw new UnknownMessageEvent("Unknown event: {$event}");
        }
    }
}