Mrkj\Laposta\Laposta

Complexity

Total Complexity

22

Size/Duplication

Total Lines	199
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	2
Bugs	1	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	18	4
A	getLists()	0	12	2
A	getList()	0	8	1
A	createList()	0	8	1
A	updateList()	0	8	1
A	deleteList()	0	6	1
B	getMembers()	0	20	5
A	getMember()	0	10	2
A	updateMember()	0	8	1
A	get()	0	4	1
A	post()	0	4	1
A	delete()	0	4	1
A	request()	0	8	1

<?php

namespace Mrkj\Laposta;

use GuzzleHttp\Client;
use Mrkj\Laposta\Models\List_;
use Mrkj\Laposta\Models\Member;
use Mrkj\Laposta\Transformers\ListTransformer;
use Mrkj\Laposta\Transformers\MemberTransformer;

class Laposta
{
    /**
     * @var string
     */
    private $apiKey;

    /**
     * @var Client
     */
    private $client;

    /**
     * Laposta constructor.
     * @param null|string $apiKey
     * @param null|Client $client
     * @throws \Exception
     */
    public function __construct($apiKey = null, $client = null)
    {
        if (empty(trim($apiKey))) {
            throw new \Exception('No API key provided');
        }

        $this->apiKey = $apiKey;

        if ($client && $client instanceof Client) {
            $this->client = $client;
        } else {
            $this->client = new Client([
                'base_uri' => 'https://api.laposta.nl/v2/',
                'auth' => [$this->apiKey, ''],
                'http_errors' => true,
            ]);
        }
    }

    /**
     * @return List_[]
     */
    public function getLists() : array
    {
        $data = $this->get('list');

        $lists = [];

        foreach ($data['data'] as $listResponse) {
            $lists[] = List_::createFromResponse($listResponse['list']);
        }

        return $lists;
    }

    /**
     * @param $listId
     * @return List_
     */
    public function getList($listId) : List_
    {
        $data = $this->get('list/'.$listId);

        $list = List_::createFromResponse($data['list']);

        return $list;
    }

    /**
     * @param List_ $list
     */
    public function createList(List_ $list)
    {
        $data = $this->post('list', [
            'form_params' => ListTransformer::toFormParams($list),
        ]);

        $list->updateFromResponse($data['list']);
    }

    /**
     * @param List_ $list
     */
    public function updateList(List_ $list)
    {
        $data = $this->post('list/'.$list->id, [
            'form_params' => ListTransformer::toFormParams($list),
        ]);

        $list->updateFromResponse($data['list']);
    }

    /**
     * @param List_ $list
     */
    public function deleteList(List_ $list)
    {
        $data = $this->delete('list/'.$list->id);

        $list->updateFromResponse($data['list']);
    }

    /**
     * @param List_|string $list
     * @param string $state
     * @return Member[]
     */
    public function getMembers($list, $state = Member::STATE_ACTIVE) : array
    {
        $listId = $list instanceof List_ ? $list->id : $list;

        $params = ['list_id' => $listId];

        if (! is_null($state) && in_array($state, Member::STATES)) {
            $params['state'] = $state;
        }

        $data = $this->get('member?'.http_build_query($params));

        $members = [];

        foreach ($data['data'] as $listResponse) {
            $members[] = Member::createFromResponse($listResponse['member']);
        }

        return $members;
    }

    /**
     * @param List_|string $list
     * @param string $memberId
     * @return Member
     */
    public function getMember($list, string $memberId) : Member
    {
        $listId = $list instanceof List_ ? $list->id : $list;

        $data = $this->get('member/'.$memberId.'?'.http_build_query(['list_id' => $listId]));

        $member = Member::createFromResponse($data['member']);

        return $member;
    }

    /**
     * @param Member $member
     */
    public function updateMember(Member $member)
    {
        $data = $this->post('member/'.$member->id.'?'.http_build_query(['list_id' => $member->listId]), [
            'form_params' => MemberTransformer::toFormParams($member),
        ]);

        $member->updateFromResponse($data['member']);
    }

    /**
     * @param string $uri
     * @param array $options
     * @return mixed
     */
    private function get($uri, $options = []) : array
    {
        return $this->request('get', $uri, $options);
    }

    /**
     * @param string $uri
     * @param array $options
     * @return mixed
     */
    private function post($uri, $options = []) : array
    {
        return $this->request('post', $uri, $options);
    }

    /**
     * @param string $uri
     * @param array $options
     * @return array
     */
    private function delete($uri, $options = []) : array
    {
        return $this->request('delete', $uri, $options);
    }

    /**
     * @param string $method
     * @param string $uri
     * @param array $options
     * @return array
     */
    private function request($method, $uri, $options = []) : array
    {
        $response = $this->client->request($method, $uri, $options);

        $data = json_decode($response->getBody()->getContents(), true);

        return $data;
    }
}