App\Client\GmailClient

Complexity

Total Complexity

11

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Test Coverage

Coverage

66.67%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getLabels()	0	8	2
A	buildMessagesQuery()	0	10	2
A	getMessage()	0	6	2
A	getMessages()	0	27	4
A	__construct()	0	4	1

<?php

namespace App\Client;

use App\DataProvider\EmailTemplateProvider;
use App\Enum\PropertyFilter;
use App\Exception\GmailException;
use Exception;
use Google_Service_Gmail;
use Google_Service_Gmail_Label;
use Google_Service_Gmail_Message;

class GmailClient
{
    public function __construct(
        private Google_Service_Gmail $gmailService,
        private EmailTemplateProvider $emailTemplateProvider
    ) {}

    /**
     * @return array
     *
     * @throws GmailException
     */
    public function getMessages(array $criteria, string $accessToken, string $userId = 'me'): array
    {
        $this->gmailService->getClient()->setAccessToken($accessToken);

        $messages = [];
        $labelId = $criteria[PropertyFilter::GMAIL_LABEL] ?? null;
        $provider = $criteria[PropertyFilter::PROVIDER] ?? null;
        $newerThan = $criteria[PropertyFilter::NEWER_THAN];

        // Prepare the Gmail query
        $params = ['q' => $this->buildMessagesQuery($provider, $newerThan)];
        if (!empty($labelId)) {
            $params['labelIds'] = [$labelId];
        }

        do {
            try {
                $response = $this->gmailService->users_messages->listUsersMessages($userId, $params);
            } catch (Exception $e) {
                throw new GmailException($e->getMessage());
            }

            $messages[] = $response->getMessages();
        } while (null !== $params['pageToken'] = $response->getNextPageToken());

        // Flatten the array
        return array_merge(...$messages);
    }

    /**
     * @throws GmailException
     */
    public function getMessage(string $messageId, string $userId = 'me'): Google_Service_Gmail_Message
    {
        try {
            return $this->gmailService->users_messages->get($userId, $messageId);
        } catch (Exception $e) {
            throw new GmailException($e->getMessage());
        }
    }

    /**
     * @return Google_Service_Gmail_Label[]
     *
     * @throws GmailException
     */
    public function getLabels(string $accessToken, string $userId = 'me'): array
    {
        $this->gmailService->getClient()->setAccessToken($accessToken);

        try {
            return $this->gmailService->users_labels->listUsersLabels($userId)->getLabels();
        } catch (Exception $e) {
            throw new GmailException($e->getMessage());
        }
    }

    private function buildMessagesQuery(string $provider = null, int $newerThan = null): string
    {
        $addresses = null !== $provider ?
            $this->emailTemplateProvider->getAddressesByMainProvider($provider) :
            $this->emailTemplateProvider->getAllAddresses();

        $fromFilter = sprintf('from:(%s)', implode(' | ', $addresses));
        $dateFilter = sprintf('newer_than:%dd', $newerThan);

        return implode(' ', [$fromFilter, $dateFilter]);
    }
}