LineMob\Core\Receiver

Complexity

Total Complexity

15

Size/Duplication

Total Lines	131
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	validate()	0	3	1
B	handle()	0	21	5
B	captureInput()	0	34	6
A	captureReceiveMessageText()	0	11	2

<?php

/*
 * This file is part of the LineMob package.
 *
 * (c) Ishmael Doss <nukboon@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace LineMob\Core;

use League\Tactician\CommandBus;
use LineMob\Core\Command\FallbackCommand;
use LineMob\Core\Exception\DerailException;

/**
 * @author Ishmael Doss <nukboon@gmail.com>
 */
class Receiver
{
    /**
     * @var LineBot
     */
    private $bot;

    /**
     * @var CommandBus
     */
    private $commandBus;

    /**
     * @var RegistryInterface
     */
    private $registry;

    /**
     * @var SenderHandlerInterface
     */
    private $handler;

    public function __construct(
        LineBot $bot,
        RegistryInterface $registry,
        CommandBus $commandBus,
        SenderHandlerInterface $handler
    ) {
        $this->bot = $bot;
        $this->registry = $registry;
        $this->commandBus = $commandBus;
        $this->handler = $handler;
    }

    /**
     * @param $body
     * @param $signature
     *
     * @return bool
     */
    public function validate($body, $signature)
    {
        return $this->bot->validateSignature($body, $signature);
    }

    /**
     * @param array $eventData
     *
     * @return string
     */
    private function captureReceiveMessageText(array $eventData)
    {
        $type = strtolower(@$eventData['message']['type']);

        switch ($type) {
            case Constants::REVEIVE_TYPE_MESSAGE_TEXT:
                return @$eventData['message']['text'];
                break;

break is not strictly necessary here and could be removed.

            default:
                throw new \RuntimeException("Unknown message type `$type`.");
        }
    }

    /**
     * @param array $eventData
     *
     * @return Input
     */
    private function captureInput(array $eventData)
    {
        $inputData = [];

        if (empty($eventData['replyToken'])) {
            throw new \InvalidArgumentException("Require `replyToken` to run.");
        }

        if (empty($eventData['source']['userId'])) {
            throw new \InvalidArgumentException("Require `userId` to run.");
        }

        $inputData['replyToken'] = $eventData['replyToken'];
        $inputData['userId'] = $eventData['source']['userId'];
        $type = strtolower(@$eventData['type']);

        switch ($type) {
            case Constants::REVEIVE_TYPE_FOLLOW:
                $inputData['text'] = ':follow';
                break;

            case Constants::REVEIVE_TYPE_MESSAGE:
                $inputData['text'] = $this->captureReceiveMessageText($eventData);
                break;

            default:
                throw new \RuntimeException("Unsupported type `$type`.");
        }

        if (!$inputData['text']) {
            $inputData['text'] = FallbackCommand::CMD;
        }

        return new Input($inputData);
    }

    /**
     * @param $payload
     *
     * @return array
     */
    public function handle($payload)
    {
        $data = json_decode($payload, true) ?: [];
        $events = (array)@$data['events'];
        $results = [];

        foreach ($events as $event) {
            try {
                $input = $this->captureInput($event);
                $command = $this->registry->findCommand($input);
                $command->input = $input;

                $results[] = $this->commandBus->handle($command);
            } catch (DerailException $e) {
                $results[] = $this->handler->handle($e->command);
            } catch (\Exception $e) {
                $results[] = sprintf('ERROR: %s', $e->getMessage());
            }
        }
dump($results);
        return $results;
    }
}