Raphaël G. Git Repositories - airbundle/blob - Command/Calendar2Command.php

   1 <?php declare(strict_types=1);
   2
   3 /*
   4  * This file is part of the Rapsys AirBundle package.
   5  *
   6  * (c) Raphaël Gertz <symfony@rapsys.eu>
   7  *
   8  * For the full copyright and license information, please view the LICENSE
   9  * file that was distributed with this source code.
  10  */
  11
  12 namespace Rapsys\AirBundle\Command;
  13
  14 use Doctrine\Persistence\ManagerRegistry;
  15
  16 use Google\Client;
  17 use Google\Service\Calendar;
  18 use Google\Service\Oauth2;
  19
  20 use Symfony\Component\Cache\Adapter\FilesystemAdapter;
  21 use Symfony\Component\Console\Input\InputInterface;
  22 use Symfony\Component\Console\Output\OutputInterface;
  23 use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  24 use Symfony\Component\Routing\RouterInterface;
  25 use Symfony\Contracts\Translation\TranslatorInterface;
  26
  27 use Twig\Extra\Markdown\DefaultMarkdown;
  28
  29 use Rapsys\AirBundle\Command;
  30 use Rapsys\AirBundle\Entity\GoogleCalendar;
  31 use Rapsys\AirBundle\Entity\GoogleToken;
  32 use Rapsys\AirBundle\Entity\Session;
  33
  34 use Rapsys\PackBundle\Util\SluggerUtil;
  35
  36 class Calendar2Command extends Command {
  37         /**
  38          * Set google client scopes
  39          */
  40         private array $scopes = [
  41                 Calendar::CALENDAR_EVENTS,
  42                 Calendar::CALENDAR,
  43                 Oauth2::USERINFO_EMAIL
  44         ];
  45
  46         /**
  47          * Set google client instance
  48          */
  49         private Client $client;
  50
  51         /**
  52          * Set markdown instance
  53          */
  54         private DefaultMarkdown $markdown;
  55
  56         /**
  57          * Set date period instance
  58          */
  59         private \DatePeriod $period;
  60
  61         /**
  62          * {@inheritdoc}
  63          */
  64         public function __construct(ManagerRegistry $doctrine, string $locale, RouterInterface $router, SluggerUtil $slugger, TranslatorInterface $translator) {
  65                 //Call parent constructor
  66                 parent::__construct($doctrine, $locale, $router, $slugger, $translator);
  67
  68                 //Set google client
  69                 $this->client = new Client(
  70                         [
  71                                 'application_name' => $_ENV['RAPSYSAIR_GOOGLE_PROJECT'],
  72                                 'client_id' => $_ENV['GOOGLE_CLIENT_ID'],
  73                                 'client_secret' => $_ENV['GOOGLE_CLIENT_SECRET'],
  74                                 'redirect_uri' => $this->router->generate('rapsysair_google_callback', [], UrlGeneratorInterface::ABSOLUTE_URL),
  75                                 'scopes' => $this->scopes,
  76                                 'access_type' => 'offline',
  77                                 #'login_hint' => $user->getMail(),
  78                                 //XXX: see https://stackoverflow.com/questions/10827920/not-receiving-google-oauth-refresh-token
  79                                 #'approval_prompt' => 'force'
  80                                 'prompt' => 'consent'
  81                         ]
  82                 );
  83
  84                 //Set Markdown instance
  85                 $this->markdown = new DefaultMarkdown;
  86         }
  87
  88         /**
  89          * Configure attribute command
  90          */
  91         protected function configure() {
  92                 //Configure the class
  93                 $this
  94                         //Set name
  95                         ->setName('rapsysair:calendar2')
  96                         //Set description shown with bin/console list
  97                         ->setDescription('Synchronize sessions in users\' calendar')
  98                         //Set description shown with bin/console --help airlibre:attribute
  99                         ->setHelp('This command synchronize sessions in users\' google calendar');
 100         }
 101
 102         /**
 103          * Process the attribution
 104          */
 105         protected function execute(InputInterface $input, OutputInterface $output): int {
 106                 //Iterate on google tokens
 107                 foreach($tokens = $this->doctrine->getRepository(GoogleToken::class)->findAllIndexed() as $tid => $token) {
 108                         //Iterate on google calendars
 109                         foreach($calendars = $token['calendars'] as $cid => $calendar) {
 110                                 //Set period
 111                                 $this->period = new \DatePeriod(
 112                                         //Start from last week
 113                                         new \DateTime('-1 week'),
 114                                         //Iterate on each day
 115                                         new \DateInterval('P1D'),
 116                                         //End with next 2 week
 117                                         new \DateTime('+2 week')
 118                                 );
 119
 120                                 #$calendar['synchronized']
 121                                 var_dump($token);
 122
 123                                 //TODO: see if we may be smarter here ?
 124
 125                                 //TODO: load all calendar events here ?
 126
 127                                 //Iterate on sessions to update
 128                                 foreach($sessions = $this->doctrine->getRepository(Session::class)->findAllByUserIdSynchronized($token['uid'], $calendar['synchronized']) as $session) {
 129                                         //TODO: insert/update/delete events here ?
 130                                 }
 131
 132                                 //TODO: delete remaining events here ?
 133                         }
 134                 }
 135
 136                 //TODO: get user filter ? (users_subscriptions+users_dances)
 137
 138                 //TODO: XXX: or fetch directly the events updated since synchronized + matching rubscriptions and/or dances
 139
 140                 #var_dump($tokens);
 141                 exit;
 142
 143                 //Set sql request
 144                 $sql =<<<SQL
 145 SELECT
 146         b.*,
 147         GROUP_CONCAT(us.user_id) AS users
 148 FROM (
 149         SELECT
 150                 a.*,
 151                 GROUP_CONCAT(ud.dance_id) AS dances
 152         FROM (
 153                 SELECT
 154                         t.id AS tid,
 155                         t.mail AS gmail,
 156                         t.user_id,
 157                         t.access,
 158                         t.refresh,
 159                         t.expired,
 160                         GROUP_CONCAT(c.id) AS cids,
 161                         GROUP_CONCAT(c.mail) AS cmails,
 162                         GROUP_CONCAT(c.summary) AS csummaries,
 163                         GROUP_CONCAT(c.synchronized) AS csynchronizeds
 164                 FROM google_tokens AS t
 165                 JOIN google_calendars AS c ON (c.google_token_id = t.id)
 166                 GROUP BY t.id
 167                 ORDER BY NULL
 168                 LIMIT 100000
 169         ) AS a
 170         LEFT JOIN users_dances AS ud ON (ud.user_id = a.user_id)
 171         GROUP BY a.tid
 172         ORDER BY NULL
 173         LIMIT 100000
 174 ) AS b
 175 LEFT JOIN users_subscriptions AS us ON (us.subscriber_id = b.user_id)
 176 GROUP BY b.tid
 177 ORDER BY NULL
 178 SQL;
 179                 #$sessions = $this->doctrine->getRepository(Session::class)->findAllByDanceUserModified($filter['dance'], $filter['user'], $calendar['synchronized']);
 180                 //Iterate on google tokens
 181                 foreach($tokens as $token) {
 182                         //TODO: clear google client cache
 183                         //TODO: set google token
 184                         //Iterate on google calendars
 185                         foreach($calendars as $calendar) {
 186                                 //Fetch sessions to sync
 187                                 $sessions = $this->doctrine->getRepository(Session::class)->findAllByDanceUserModified($filter['dance'], $filter['user'], $calendar['synchronized']);
 188                         }
 189                 }
 190
 191                 //Return success
 192                 return self::SUCCESS;
 193         }
 194 }