DansMaCulotte\Newsletter\Drivers\MailchimpDriver

Complexity

Total Complexity

21

Size/Duplication

Total Lines	222
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscriberHash()	0	3	1
A	subscribe()	0	13	2
A	hasMember()	0	13	3
A	getApi()	0	3	1
A	delete()	0	7	1
A	getMember()	0	5	1
A	subscribeOrUpdate()	0	13	2
A	__construct()	0	4	1
A	isSubscribed()	0	13	3
A	getSubscriptionOptions()	0	11	1
A	addMember()	0	5	1
A	unsubscribe()	0	13	2
A	getMembers()	0	5	1
A	getLastError()	0	3	1

<?php

namespace DansMaCulotte\Newsletter\Drivers;

use DrewM\MailChimp\MailChimp;
use DansMaCulotte\Newsletter\Exceptions\ApiError;
use DansMaCulotte\Newsletter\Exceptions\InvalidNewsletterList;
use DansMaCulotte\Newsletter\NewsletterListCollection;

class MailchimpDriver implements Driver
{
    /** @var MailChimp */
    public $client;

    /** @var NewsletterListCollection */
    public $lists;

    /**
     * MailchimpDriver constructor.
     * @param array $credentials
     * @param array $config
     * @throws InvalidNewsletterList
     */
    public function __construct(array $credentials, array $config)
    {
        $this->client = new Mailchimp($credentials['apiKey']);
        $this->lists = NewsletterListCollection::createFromConfig($config);
    }


    /**
     * @param string $email
     * @param array $options
     * @param string $listName
     * @return array|false
     * @throws ApiError
     * @throws InvalidNewsletterList
     */
    public function subscribe(string $email, array $options = [], string $listName = '')
    {
        $list = $this->lists->findByName($listName);

        $options = $this->getSubscriptionOptions($email, $options);

        $response = $this->client->post("lists/{$list->getId()}/members", $options);

        if (! $this->client->success()) {
            throw ApiError::responseError($this->client->getLastError(), 'mailchimp');

It seems like $this->client->getLastError() can also be of type false; however, parameter $error of DansMaCulotte\Newsletter\Exceptions\ApiError::responseError() does only seem to accept string, maybe add an additional type check?

        }

        return $response;
    }


    /**
     * @param string $email
     * @param array $options
     * @param string $listName
     * @return array|bool|false
     * @throws ApiError
     * @throws InvalidNewsletterList
     */
    public function subscribeOrUpdate(string $email, array $options = [], string $listName = '')
    {
        $list = $this->lists->findByName($listName);

        $options = $this->getSubscriptionOptions($email, $options);

        $response = $this->client->put("lists/{$list->getId()}/members/{$this->getSubscriberHash($email)}", $options);

        if (! $this->client->success()) {
            throw ApiError::responseError($this->client->getLastError(), 'mailchimp');

It seems like $this->client->getLastError() can also be of type false; however, parameter $error of DansMaCulotte\Newsletter\Exceptions\ApiError::responseError() does only seem to accept string, maybe add an additional type check?

        }

        return $response;
    }

    public function addMember(string $email, array $options = [], string $listName = '')
    {
        return $this->subscribe($email, array_merge([
            'status' => 'unsubscribed',
        ], $options), $listName);
    }

    /**
     * @param string $listName
     * @param array $parameters
     * @return array|false
     * @throws InvalidNewsletterList
     */
    public function getMembers(string $listName = '', array $parameters = [])
    {
        $list = $this->lists->findByName($listName);

        return $this->client->get("lists/{$list->getId()}/members", $parameters);
    }

    /**
     * @param string $email
     * @param string $listName
     * @return array|false
     * @throws InvalidNewsletterList
     */
    public function getMember(string $email, string $listName = '')
    {
        $list = $this->lists->findByName($listName);

        return $this->client->get("lists/{$list->getId()}/members/{$this->getSubscriberHash($email)}");
    }

    /**
     * @param string $email
     * @param string $listName
     * @return bool
     * @throws InvalidNewsletterList
     */
    public function hasMember(string $email, string $listName = ''): bool
    {
        $response = $this->getMember($email, $listName);

        if (! isset($response['email_address'])) {
            return false;
        }

        if (strtolower($response['email_address']) !== strtolower($email)) {
            return false;
        }

        return true;
    }

    /**
     * @param string $email
     * @param string $listName
     * @return bool
     * @throws InvalidNewsletterList
     */
    public function isSubscribed(string $email, string $listName = ''): bool
    {
        $response = $this->getMember($email, $listName);

        if (! isset($response)) {
            return false;
        }

        if ($response['status'] !== 'subscribed') {
            return false;
        }

        return true;
    }

    /**
     * @param string $email
     * @param string $listName
     * @return array|false
     * @throws ApiError
     * @throws InvalidNewsletterList
     */
    public function unsubscribe(string $email, string $listName = '')
    {
        $list = $this->lists->findByName($listName);

        $response = $this->client->patch("lists/{$list->getId()}/members/{$this->getSubscriberHash($email)}", [
            'status' => 'unsubscribed',
        ]);

        if (! $this->client->success()) {
            throw ApiError::responseError($this->client->getLastError(), 'mailchimp');

It seems like $this->client->getLastError() can also be of type false; however, parameter $error of DansMaCulotte\Newsletter\Exceptions\ApiError::responseError() does only seem to accept string, maybe add an additional type check?

        }

        return $response;
    }


    /**
     * @param string $email
     * @param string $listName
     * @return array|false
     * @throws InvalidNewsletterList
     */
    public function delete(string $email, string $listName = '')
    {
        $list = $this->lists->findByName($listName);

        $response = $this->client->delete("lists/{$list->getId()}/members/{$this->getSubscriberHash($email)}");

        return $response;
    }

    /**
     * @return string|false
     */
    public function getLastError()
    {
        return $this->client->getLastError();
    }

    /**
     * @return MailChimp
     */
    public function getApi(): MailChimp
    {
        return $this->client;
    }

    /**
     * @param string $email
     * @return string
     */
    protected function getSubscriberHash(string $email): string
    {
        return $this->client->subscriberHash($email);
    }

    /**
     * @param string $email
     * @param array $options
     * @return array
     */
    protected function getSubscriptionOptions(string $email, array $options): array
    {
        $defaultOptions = [
            'email_address' => $email,
            'status' => 'subscribed',
            'email_type' => 'html',
        ];

        $options = array_merge($defaultOptions, $options);

        return $options;
    }
}