Использование GMAIL API с Symfony4

Question

Я пытаюсь использовать Gmail API с моим сайтом symfony4.Цель состоит в том, чтобы регулярно выполнять команду через cron, которая будет извлекать всю непрочитанную электронную почту, получать содержимое и обрабатывать некоторые вещи, а затем помечать их как прочитанные.

У меня есть (хотя официальныйдокументация ):

• Установил библиотеку через composer
• Для этого была создана одна новая учетная запись gmail, активирован API gmail и загружен мой "credentials.json"

• Рабочая команда от symfony (приложение: upload-from-unread-emails) с этим кодом:

  $client = new \Google_Client();
  $client->setApplicationName('Gmail API PHP Quickstart');
  $client->addScope(\Google_Service_Gmail::GMAIL_READONLY);
  $client->setAuthConfig('credentials.json');
  $client->setAccessType('offline');
  $client->setPrompt('select_account consent');
  
  $gmail = new \Google_Service_Gmail($client);
  $list = $gmail->users_messages->listUsersMessages('me', ['maxResults' => 1000]);
  
  while ($list->getMessages() != null) {
      foreach ($list->getMessages() as $mlist) {
  
          $message_id = $mlist->id;
          var_dump($message_id);
  
      }
  
      if ($list->getNextPageToken() != null) {
          $pageToken = $list->getNextPageToken();
          $list = $gmail->users_messages->listUsersMessages('me', ['pageToken' => $pageToken, 'maxResults' => 1000]);
      } else {
          break;
      }
  } 
  

Я на правильном пути для аутентификации?Куда мне положить мой credential.json в symfony?

Answer 1

Куда я должен добавить свой credential.json в symfony?

Я думаю, что лучшим местом для этого файла будет папка config.Но вы можете установить любой путь (кроме, возможно, не в public =)).

Допустим, путь для этого файла будет config/gmail/credentials.json.Итак, следующий шаг - получить путь к файлу в команде.Для этого вам нужно получить параметр kernel.project_dir из сервисного контейнера и объединить kernel.project_dir и /config/gmail/credentials.json

Для использования сервисного контейнера в команде вам необходимо:

• внедрить ContainerAwareInterface
• использовать ContainerAwareTrait (для свойства $container и setContainer метода)
• подсказка типа ContainerInterface $container в конструкторе команд, вызывать parent::__construct и setContainer($container)

-

// ...
use Symfony\Component\DependencyInjection\ContainerAwareInterface;
use Symfony\Component\DependencyInjection\ContainerAwareTrait;
use Symfony\Component\DependencyInjection\ContainerInterface;

class UploadFromUnreadEmailsCommand extends Command implements ContainerAwareInterface
{
    use ContainerAwareTrait;

    public function __construct(ContainerInterface $container)
    {
        parent::__construct();
        $this->setContainer($container);
    }

    // ...

}

Также документация, на которую вы ссылаетесь, имеет пример с функцией getClient.Просто отредактируйте его с некоторыми изменениями:

private function getClient()
{
    $projectDir = $this->container->getParameter('kernel.project_dir');
    $credentialsFilePath = sprintf('%s/config/gmail/credentials.json', $projectDir);
    $tokenFilePath = sprintf('%s/config/gmail/token.json', $projectDir);

    // ...
}

и в execute метод:

$client = $this->getClient();
$gmail = new \Google_Service_Gmail($client);

Выполните команду и следуйте инструкциям (сгенерируйте токен).

Полная командакласс:

<?php

namespace App\Command;

use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
use Symfony\Component\DependencyInjection\ContainerAwareInterface;
use Symfony\Component\DependencyInjection\ContainerAwareTrait;
use Symfony\Component\DependencyInjection\ContainerInterface;

class UploadFromUnreadEmailsCommand extends Command implements ContainerAwareInterface
{

    use ContainerAwareTrait;

    protected static $defaultName = 'app:upload-from-unread-emails';

    /**
    * UploadFromUnreadEmailsCommand constructor.
    * @param $container
    */
    public function __construct(ContainerInterface $container)
    {
        parent::__construct();
        $this->setContainer($container);
    }

    protected function configure()
    {
        $this
            ->setDescription('Add a short description for your command')
        ;
    }

    private function getClient()
    {
        $projectDir = $this->container->getParameter('kernel.project_dir');
        $credentialsFilePath = sprintf('%s/config/gmail/credentials.json', $projectDir);
        $tokenFilePath = sprintf('%s/config/gmail/token.json', $projectDir);

        $client = new \Google_Client();
        $client->setApplicationName('Gmail API PHP Quickstart');
        $client->setScopes(\Google_Service_Gmail::GMAIL_READONLY);
        $client->setAuthConfig($credentialsFilePath);
        $client->setAccessType('offline');
        $client->setPrompt('select_account consent');

        // Load previously authorized token from a file, if it exists.
        if (file_exists($tokenFilePath)) {
            $accessToken = json_decode(file_get_contents($tokenFilePath), true);
            $client->setAccessToken($accessToken);
        }

        // If there is no previous token or it's expired.
        if ($client->isAccessTokenExpired()) {
            // Refresh the token if possible, else fetch a new one.
            if ($client->getRefreshToken()) {
                $client->fetchAccessTokenWithRefreshToken($client->getRefreshToken());
            } else {
                // Request authorization from the user.
                $authUrl = $client->createAuthUrl();
                printf("Open the following link in your browser:\n%s\n", $authUrl);
                print 'Enter verification code: ';
                $authCode = trim(fgets(STDIN));

                // Exchange authorization code for an access token.
                $accessToken = $client->fetchAccessTokenWithAuthCode($authCode);
                $client->setAccessToken($accessToken);

                // Check to see if there was an error.
                if (array_key_exists('error', $accessToken)) {
                    throw new Exception(join(', ', $accessToken));
                }
            }
            // Save the token to a file.
            if (!file_exists(dirname($tokenFilePath))) {
                mkdir(dirname($tokenFilePath), 0700, true);
            }
            file_put_contents($tokenFilePath, json_encode($client->getAccessToken()));
        }
        return $client;
    }


    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $io = new SymfonyStyle($input, $output);

        $client = $this->getClient();

        $gmail = new \Google_Service_Gmail($client);
        $list = $gmail->users_messages->listUsersMessages('me', ['maxResults' => 10]);

        while ($list->getMessages() != null) {
            foreach ($list->getMessages() as $mlist) {

                $message_id = $mlist->id;
                $io->text($message_id);

            }

            if ($list->getNextPageToken() != null) {
                $pageToken = $list->getNextPageToken();
                $list = $gmail->users_messages->listUsersMessages('me', ['pageToken' => $pageToken, 'maxResults' => 1000]);
            } else {
                break;
            }
        }

        $io->success('Success');
    }
}

Также я думаю, что лучшее решение - переместить функцию getClient в службу, где получить параметр контейнера, init \Google_Service_Gmail и подсказку типа GmailService в конструкторе команд:

# /src/Command/UploadFromUnreadEmailsCommand.php
private $gmailService;
public function __construct(GmailService $gmailService)
{
    $this->gmailService = $gmailService;
}