Dacastro4\LaravelGmail\GmailConnection

Complexity

Total Complexity

44

Size/Duplication

Total Lines	350
Duplicated Lines	0 %

Importance

Changes	11
Bugs	3	Features	3

22 Methods

Rating	Name	Duplication	Size	Complexity
A	refreshTokenIfNeeded()	0	11	2
A	setAccessToken()	0	3	1
A	setBothAccessToken()	0	4	1
A	getToken()	0	3	2
A	getAccessToken()	0	5	2
A	isAccessTokenExpired()	0	9	2
A	__construct()	0	16	2
A	checkPreviouslyLoggedIn()	0	18	3
A	setToken()	0	3	1
A	check()	0	3	1
A	haveReadScope()	0	5	1
A	deleteAccessToken()	0	16	3
A	saveAccessToken()	0	28	6
A	makeToken()	0	22	6
A	logout()	0	3	1
A	getProfile()	0	5	1
A	stopWatch()	0	5	1
A	historyList()	0	5	1
A	setWatch()	0	5	1
A	labelsList()	0	5	1
A	firstOrCreateLabel()	0	15	4
A	createLabel()	0	4	1

<?php

namespace Dacastro4\LaravelGmail;

use Dacastro4\LaravelGmail\Traits\Configurable;
use Google_Client;
use Google_Service_Gmail;
use Illuminate\Container\Container;
use Illuminate\Support\Facades\Request;
use Illuminate\Support\Facades\Storage;

class GmailConnection extends Google_Client
{

	use Configurable {

The trait Dacastro4\LaravelGmail\Traits\Configurable requires the property $id which is not provided by Dacastro4\LaravelGmail\GmailConnection.

		__construct as configConstruct;
	}

	protected $emailAddress;
	protected $refreshToken;
	protected $app;
	protected $accessToken;
	protected $token;
	private $configuration;
	public $userId;

	public function __construct($config = null, $userId = null)
	{
		$this->app = Container::getInstance();

		$this->userId = $userId;

		$this->configConstruct($config);

		$this->configuration = $config;

		parent::__construct($this->getConfigs());

		$this->configApi();

		if ($this->checkPreviouslyLoggedIn()) {
			$this->refreshTokenIfNeeded();
		}

	}

	/**
	 * Check and return true if the user has previously logged in without checking if the token needs to refresh
	 *
	 * @return bool
	 */
	public function checkPreviouslyLoggedIn()
	{
		$fileName = $this->getFileName();
		$file = "gmail/tokens/$fileName.json";
		$allowJsonEncrypt = $this->_config['gmail.allow_json_encrypt'];

		if (Storage::disk('local')->exists($file)) {
			if ($allowJsonEncrypt) {
				$savedConfigToken = json_decode(decrypt(Storage::disk('local')->get($file)), true);
			} else {
				$savedConfigToken = json_decode(Storage::disk('local')->get($file), true);
			}

			return !empty($savedConfigToken['access_token']);

		}

		return false;
	}

	/**
	 * Refresh the auth token if needed
	 *
	 * @return mixed|null
	 */
	private function refreshTokenIfNeeded()
	{
		if ($this->isAccessTokenExpired()) {
			$this->fetchAccessTokenWithRefreshToken($this->getRefreshToken());
			$token = $this->getAccessToken();
			$this->setBothAccessToken($token);

			return $token;
		}

		return $this->token;
	}

	/**
	 * Check if token exists and is expired
	 * Throws an AuthException when the auth file its empty or with the wrong token
	 *
	 *
	 * @return bool Returns True if the access_token is expired.
	 */
	public function isAccessTokenExpired()
	{
		$token = $this->getToken();

		if ($token) {
			$this->setAccessToken($token);
		}

		return parent::isAccessTokenExpired();
	}

	public function getToken()
	{
		return parent::getAccessToken() ?: $this->config();
	}

	public function setToken($token)
	{
		$this->setAccessToken($token);
	}

	public function getAccessToken()
	{
		$token = parent::getAccessToken() ?: $this->config();

		return $token;
	}

	/**
	 * @param  array|string  $token
	 */
	public function setAccessToken($token)
	{
		parent::setAccessToken($token);
	}

	/**
	 * @param $token
	 */
	public function setBothAccessToken($token)
	{
		$this->setAccessToken($token);
		$this->saveAccessToken($token);
	}

	/**
	 * Save the credentials in a file
	 *
	 * @param  array  $config
	 */
	public function saveAccessToken(array $config)
	{
		$disk = Storage::disk('local');
		$fileName = $this->getFileName();
		$file = "gmail/tokens/$fileName.json";
		$allowJsonEncrypt = $this->_config['gmail.allow_json_encrypt'];
		$config['email'] = $this->emailAddress;

		if ($disk->exists($file)) {

			if (empty($config['email'])) {
				if ($allowJsonEncrypt) {
					$savedConfigToken = json_decode(decrypt($disk->get($file)), true);
				} else {
					$savedConfigToken = json_decode($disk->get($file), true);
				}
				if(isset( $savedConfigToken['email'])) {
					$config['email'] = $savedConfigToken['email'];
				}
			}

			$disk->delete($file);
		}

		if ($allowJsonEncrypt) {
			$disk->put($file, encrypt(json_encode($config)));
		} else {
			$disk->put($file, json_encode($config));
		}

	}

	/**
	 * @return array|string
	 * @throws \Exception
	 */
	public function makeToken()
	{
		if (!$this->check()) {
			$request = Request::capture();
			$code = (string) $request->input('code', null);
			if (!is_null($code) && !empty($code)) {

The condition is_null($code) is always false.

				$accessToken = $this->fetchAccessTokenWithAuthCode($code);
				if($this->haveReadScope()) {
					$me = $this->getProfile();
					if (property_exists($me, 'emailAddress')) {
						$this->emailAddress = $me->emailAddress;
						$accessToken['email'] = $me->emailAddress;
					}
				}
				$this->setBothAccessToken($accessToken);

				return $accessToken;
			} else {
				throw new \Exception('No access token');
			}
		} else {
			return $this->getAccessToken();
		}
	}

	/**
	 * Check
	 *
	 * @return bool
	 */
	public function check()
	{
		return !$this->isAccessTokenExpired();
	}

	/**
	 * Gets user profile from Gmail
	 *
	 * @return \Google_Service_Gmail_Profile
	 */
	public function getProfile()
	{
		$service = new Google_Service_Gmail($this);

		return $service->users->getProfile('me');
	}

	/**
	 * Revokes user's permission and logs them out
	 */
	public function logout()
	{
		$this->revokeToken();
	}

	/**
	 * Delete the credentials in a file
	 */
	public function deleteAccessToken()
	{
		$disk = Storage::disk('local');
		$fileName = $this->getFileName();
		$file = "gmail/tokens/$fileName.json";

		$allowJsonEncrypt = $this->_config['gmail.allow_json_encrypt'];

		if ($disk->exists($file)) {
			$disk->delete($file);
		}

		if ($allowJsonEncrypt) {
			$disk->put($file, encrypt(json_encode([])));
		} else {
			$disk->put($file, json_encode([]));
		}

	}

	private function haveReadScope()
	{
		$scopes = $this->getUserScopes();

		return in_array(Google_Service_Gmail::GMAIL_READONLY, $scopes);
	}

    /**
     * users.stop receiving push notifications for the given user mailbox.
     *
     * @param  string  $userEmail  Email address
     * @param  array  $optParams
     * @return \Google_Service_Gmail_Stop

The type Google_Service_Gmail_Stop was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    public function stopWatch($userEmail, $optParams = [])
    {
        $service = new Google_Service_Gmail($this);

        return $service->users->stop($userEmail, $optParams);
    }

    /**
     * Set up or update a push notification watch on the given user mailbox.
     *
     * @param string $userEmail Email address
     * @param Google_Service_Gmail_WatchRequest $postData

The type Dacastro4\LaravelGmail\Google_Service_Gmail_WatchRequest was not found. Did you mean Google_Service_Gmail_WatchRequest? If so, make sure to prefix the type with \.

     *
     * @return \Google_Service_Gmail_WatchResponse
     */
    public function setWatch($userEmail, \Google_Service_Gmail_WatchRequest $postData): \Google_Service_Gmail_WatchResponse
    {
        $service = new Google_Service_Gmail($this);

        return $service->users->watch($userEmail, $postData);
    }

    /**
     * Lists the history of all changes to the given mailbox. History results are returned in chronological order (increasing historyId).
     * @param $userEmail
     * @param $params
     * @return \Google\Service\Gmail\ListHistoryResponse
     */
    public function historyList($userEmail, $params)
    {
        $service = new Google_Service_Gmail($this);

        return $service->users_history->listUsersHistory($userEmail, $params);
    }


	/**
     * List the labels in the user's mailbox.
     *
     * @param $userEmail
     *
    * @return \Google\Service\Gmail\Google_Service_Gmail_ListLabelsResponse

The type Google\Service\Gmail\Google_Service_Gmail_ListLabelsResponse was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    public function labelsList($userEmail)
    {
        $service = new Google_Service_Gmail($this);

        return $service->users_labels->listUsersLabels($userEmail);

The expression return $service->users_labels->listUsersLabels($userEmail) returns the type Google\Service\Gmail\ListLabelsResponse which is incompatible with the documented return type Google\Service\Gmail\Google_Service_Gmail_ListLabelsResponse.

    }

	/**
     * Create new label by name.
     *
     * @param $userEmail
     * @param $label
     *
     * @return \Google\Service\Gmail\Google_Service_Gmail_Label

The type Google\Service\Gmail\Google_Service_Gmail_Label was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    public function createLabel($userEmail, $label)
    {
		$service = new Google_Service_Gmail($this);
		return $service->users_labels->create($userEmail, $label);

The expression return $service->users_labels->create($userEmail, $label) returns the type Google\Service\Gmail\Label which is incompatible with the documented return type Google\Service\Gmail\Google_Service_Gmail_Label.

    }

	/**
     * first or create label in the user's mailbox.
     *
     * @param $userEmail
     * @param $label
     *
     * @return \Google\Service\Gmail\Google_Service_Gmail_Label
     */
    public function firstOrCreateLabel($userEmail, $nLabel)
    {
        $labels = $this->labelsList($userEmail);
        $label = null;
        foreach ($labels->getLabels() as $existLabel) {
            if ($existLabel->getName() == $nLabel->getName()) {
				$label = $existLabel;
                break;
            }
        }
        if (is_null($label)) {
            $service = new Google_Service_Gmail($this);
            $label = $service->users_labels->create($userEmail, $nLabel);
        }
        return $label;
    }
}