Umbrellio\TableSync\Integration\Laravel\Receive\Receiver::receive()

Complexity

Conditions	3
Paths	3

Size

Total Lines	16
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	4.125

Importance

Changes	1
Bugs	0	Features	0

<?php
    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}");
        }