Ddomanskyi\LaravelGmail\Services\Message

Complexity

Total Complexity

19

Size/Duplication

Total Lines	190
Duplicated Lines	0 %

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	hasNextPage()	0	3	1
A	next()	0	6	2
A	preload()	0	5	1
A	take()	0	5	1
A	getUser()	0	3	1
A	batchRequest()	0	21	3
A	getMessagesResponse()	0	11	2
A	__construct()	0	4	1
A	get()	0	5	1
A	all()	0	23	5
A	getRequest()	0	3	1

<?php

namespace Ddomanskyi\LaravelGmail\Services;

use Ddomanskyi\LaravelGmail\LaravelGmailClass;
use Ddomanskyi\LaravelGmail\Services\Message\Mail;
use Ddomanskyi\LaravelGmail\Traits\Filterable;
use Ddomanskyi\LaravelGmail\Traits\SendsParameters;
use Google_Service_Gmail;

class Message
{

	use SendsParameters,
		Filterable;

	public $service;

	public $preload = false;

	public $pageToken;

	public $client;

	/**
	 * Optional parameter for getting single and multiple emails
	 *
	 * @var array
	 */
	protected $params = [];

	/**
	 * Message constructor.
	 *
	 * @param  LaravelGmailClass  $client
	 */
	public function __construct(LaravelGmailClass $client)
	{
		$this->client = $client;
		$this->service = new Google_Service_Gmail($client);
	}

	/**
	 * Returns next page if available of messages or an empty collection
	 *
	 * @return \Illuminate\Support\Collection
	 * @throws \Google_Exception
	 */
	public function next()
	{
		if ($this->pageToken) {
			return $this->all($this->pageToken);
		} else {
			return new MessageCollection([], $this);
		}
	}

	/**
	 * Returns a collection of Mail instances
	 *
	 * @param null|string $pageToken
	 *
	 * @return \Illuminate\Support\Collection
	 * @throws \Google_Exception
	 */
	public function all($pageToken = null)
	{
		if (!is_null($pageToken)) {
			$this->add($pageToken, 'pageToken');
		}

		$messages = [];
		$response = $this->getMessagesResponse();
		$this->pageToken = method_exists( $response, 'getNextPageToken' ) ? $response->getNextPageToken() : null;

		$allMessages = $response->getMessages();

		if (!$this->preload) {
			foreach ($allMessages as $message) {
				$messages[] = new Mail($message, $this->preload);

$this->preload of type false is incompatible with the type Google_Service_Gmail_Message|null expected by parameter $message of Ddomanskyi\LaravelGmail\Services\Message\Mail::__construct().

			}
		} else {
			$messages = $this->batchRequest($allMessages);
		}

		$all = new MessageCollection($messages, $this);

		return $all;
	}

	/**
	 * Returns boolean if the page token variable is null or not
	 *
	 * @return bool
	 */
	public function hasNextPage()
	{
		return !!$this->pageToken;
	}

	/**
	 * Limit the messages coming from the queryxw
	 *
	 * @param  int  $number
	 *
	 * @return Message
	 */
	public function take($number)
	{
		$this->params['maxResults'] = abs((int) $number);

		return $this;
	}

	/**
	 * @param $id
	 *
	 * @return Mail
	 */
	public function get($id)
	{
		$message = $this->getRequest($id);

		return new Mail($message);
	}

	/**
	 * Creates a batch request to get all emails in a single call
	 *
	 * @param $allMessages
	 *
	 * @return array|null
	 */
	public function batchRequest($allMessages)
	{
		$this->client->setUseBatch(true);

		$batch = $this->service->createBatch();

		foreach ($allMessages as $key => $message) {
			$batch->add($this->getRequest($message->getId()), $key);

$this->getRequest($message->getId()) of type Google_Service_Gmail_Message is incompatible with the type Psr\Http\Message\RequestInterface expected by parameter $request of Google_Http_Batch::add().

		}

		$messagesBatch = $batch->execute();

		$this->client->setUseBatch(false);

		$messages = [];

		foreach ($messagesBatch as $message) {
			$messages[] = new Mail($message);
		}

		return $messages;
	}

	/**
	 * Preload the information on each Mail objects.
	 * If is not preload you will have to call the load method from the Mail class
	 * @return $this
	 * @see Mail::load()
	 *
	 */
	public function preload()
	{
		$this->preload = true;

		return $this;
	}

	public function getUser()
	{
		return $this->client->user();
	}

	/**
	 * @param $id
	 *
	 * @return \Google_Service_Gmail_Message
	 */
	private function getRequest($id)
	{
		return $this->service->users_messages->get('me', $id);
	}

	/**
	 * @return \Google_Service_Gmail_ListMessagesResponse|object
	 * @throws \Google_Exception
	 */
	private function getMessagesResponse()
	{
		$responseOrRequest = $this->service->users_messages->listUsersMessages( 'me', $this->params );

		if ( get_class( $responseOrRequest ) === "GuzzleHttp\Psr7\Request" ) {
			$response = $this->service->getClient()->execute( $responseOrRequest, 'Google_Service_Gmail_ListMessagesResponse' );

$responseOrRequest of type Google_Service_Gmail_ListMessagesResponse is incompatible with the type Psr\Http\Message\RequestInterface expected by parameter $request of Google_Client::execute().

			return $response;
		}

		return $responseOrRequest;
	}
}