Glorand\Drip\Api\Events

Complexity

Total Complexity

8

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	store()	0	8	1
A	batchStore()	0	25	4
A	list()	0	11	3

<?php

namespace Glorand\Drip\Api;

use Glorand\Drip\Api\Response\ApiResponse;
use Glorand\Drip\Exceptions\DripException;
use Glorand\Drip\Models\Event;

class Events extends Api
{
    /**
     * @param int $page
     * @param int $perPage
     *
     * @return \Glorand\Drip\Api\Response\ApiResponse
     * @throws \Glorand\Drip\Exceptions\DripException
     */
    public function list(int $page = 1, int $perPage = 100): ApiResponse
    {
        if (1 > $perPage || 1000 < $perPage) {
            throw new DripException('Invalid per page; maximum 1000');
        }

        return $this->sendGet(
            ':account_id:/event_actions',
            [
                'page'     => $page,
                'per_page' => $perPage,
            ]
        );
    }

    /**
     * Record an event
     * @see https://developer.drip.com/?shell#events
     * @param \Glorand\Drip\Models\Event $event
     *
     * @return bool
     */
    public function store(Event $event): bool
    {
        $response = $this->sendPost(
            ':account_id:/events',
            $event->toDrip()
        );

        return $response->isSuccess();
    }

    /**
     * @param array $events
     *
     * @return bool
     */
    public function batchStore(array $events)
    {
        $data = [];
        foreach ($events as $event) {
            if (is_array($event)) {
                $data[] = $event;
            } elseif ($event instanceof Event) {
                $data[] = $event->jsonSerialize();
            }
        }

        $postData = [
            'batches' => [
                [
                    'events' => $data,
                ],
            ],
        ];

        $response = $this->sendPost(
            ':account_id:/events/batches',
            $postData
        );

        return $response->isSuccess();
    }
}