src/Cms/CoreBundle/EventSubscriber/OneRoster/OneRosterInitSubscriber.php line 52

Open in your IDE?
  1. <?php
  3. namespace Cms\CoreBundle\EventSubscriber\OneRoster;
  5. use Cms\CoreBundle\Entity\OneRosterJob;
  6. use Cms\CoreBundle\Events\OneRosterEvents;
  7. use Platform\QueueBundle\Event\AsyncEvent;
  9. /**
  10.  * Class OneRosterInitSubscriber
  11.  * @package Cms\CoreBundle\EventSubscriber\OneRoster
  12.  */
  13. final class OneRosterInitSubscriber extends AbstractOneRosterSubscriber
  14. {
  15.     /**
  16.      * {@inheritDoc}
  17.      */
  18.     public static function getSubscribedEvents(): array
  19.     {
  20.         return [
  21.             OneRosterEvents::EVENT__INIT => [
  22.                 ['discardableDisable', self::PRIORITY__FIRST],
  23.                 ['phaseStart', self::PRIORITY__FIRST],
  24.                 ['refreshApiToken', 0],
  25.                 ['phaseFin', self::PRIORITY__LAST],
  26.                 ['phaseTrigger', self::PRIORITY__LAST],
  27.                 ['discardableEnable', self::PRIORITY__LAST],
  28.             ],
  29.         ];
  30.     }
  32.     /**
  33.      * {@inheritDoc}
  34.      */
  35.     public function phase(): int
  36.     {
  37.         return OneRosterJob::PHASES__INIT;
  38.     }
  40.     /**
  41.      * {@inheritDoc}
  42.      */
  43.     public function next(): ?int
  44.     {
  45.         return OneRosterJob::PHASES__STASH;
  46.     }
  48.     /**
  49.      * @param AsyncEvent $event
  50.      * @return void
  51.      */
  52.     public function refreshApiToken(AsyncEvent $event)
  53.     {
  54.         // get the sync
  55.         $sync = $this->loadJob($event)->getSync();
  57.         $event->getOutput()->writeln(sprintf(
  58.             'DBG:  OR PRE TOKEN  |  TENANT: %s  |  SYNC: %s  |  VENDOR: %s',
  59.             $sync->getTenant()->getId(),
  60.             $sync->getId(),
  61.             $sync->getVendor()
  62.         ));
  64.         // obtain the api token
  65.         $span = microtime(true);
  66.         try {
  67.             $token = $this->oneroster->api($sync)->token(true);
  68.         } catch (\Exception $e) {
  69.             $event->getOutput()->writeln(sprintf(
  70.                 'DBG:  OR TOKEN FAIL:  %s',
  71.                 $e->getMessage(),
  72.             ));
  73.             $this->em->save(
  74.                 $sync->setApiToken([]),
  75.             );
  76.             return;
  77.         }
  78.         $span = intval(ceil((microtime(true) - $span) * 1000));
  80.         $event->getOutput()->writeln(sprintf(
  81.             'DBG:  OR POST TOKEN  |  %s ms',
  82.             $span
  83.         ));
  85.         // force updating of the api token
  86.         $this->em->save(
  87.             $sync->setApiToken(
  88.                 $token
  89.             )
  90.         );
  92.         $event->getOutput()->writeln('DBG:  OR SAVE TOKEN');
  93.     }
  94. }