DingRobot\Message\Base

Complexity

Total Complexity

20

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Test Coverage

Coverage

96.77%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	jsonSerialize()	0	6	2
A	__construct()	0	2	1
A	send()	0	14	4
A	__callStatic()	0	3	1
B	validate()	0	12	9
A	__call()	0	9	3

<?php

namespace DingRobot\Message;

use DingRobot\Contract\RequesterContract;
use DingRobot\Message\Traits\At;
use DingRobot\Requester\CurlRequester;

/**
 * Base Class
 *
 * @package DingRobot\Message
 */
abstract class Base implements \JsonSerializable
{
    use At;
    /**
     * @var string
     */
    protected $bodyName;
    protected $at;
    protected $body;

    public function __construct()
    {
    }

    public function jsonSerialize()
    {
        return [
            'msgtype'       => $this->bodyName,
            $this->bodyName => $this->getBody(),
        ] + $this->getAt() ?: [];
    }

    abstract protected function getBody();

    abstract protected function bodyFields();

    protected function validate()
    {
        if (empty($this->bodyFields())) {
            return;
        }
        foreach ($this->bodyFields() as $field => $config) {
            $content  = isset($this->body[$field]) ? $this->body[$field] : null;
            if ($config['required'] && $content === null) {
                throw new \InvalidArgumentException("{$field} is required");
            }
            if ($config['type'] == 'string' && $content && !is_string($content)) {
                throw new \InvalidArgumentException("{$field} must be string");
            }
        }
    }

    /**
     * 发送
     * send
     *
     * @param string            $wen_hook 接口地址
     * @param RequesterContract $requester
     *
     * @return mixed
     */
    public function send($wen_hook = '', RequesterContract $requester = null)
    {
        $wen_hook = $wen_hook? $wen_hook : d_web_hook();

        if (!$wen_hook) {
            throw new \InvalidArgumentException("set web hook");
        }

        $this->validate();

        if ($requester) {
            return $requester->request($wen_hook, json_encode($this->jsonSerialize()));
        } else {
            return (new CurlRequester())->request($wen_hook, json_encode($this->jsonSerialize()));
        }
    }

    public function __call($name, $args)
    {
        if (array_key_exists($name, $this->bodyFields())) {
            $this->body[$name] = isset($args[0]) ? $args[0] : '';
        } else {
            throw new \BadMethodCallException("field {$name} not found");
        }

        return $this;
    }

    public static function __callStatic($name, $args)
    {
        return (new static)->$name(...$args);
    }
}