vendor/launchpad/backend/src/Base/EventSubscriber/Transaction/TransactionEventSubscriber.php line 36

Open in your IDE?
  1. <?php
  2. namespace LaunchPad\Bundle\LaunchPadBundle\Base\EventSubscriber\Transaction;
  4. use Psr\Container\ContainerInterface;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Symfony\Component\EventDispatcher\GenericEvent;
  8. class TransactionEventSubscriber implements EventSubscriberInterface
  9. {
  11.     const EVENT_TRANSACTIONS_PARSED     = 'lp.event.transactions.parsed';
  12.     const EVENT_TRANSACTION_PROCESSED   = 'lp.event.transaction.processed';
  14.     private $container;
  16.     public function __construct(ContainerInterface $container)
  17.     {
  18.         $this->container = $container;
  19.     }
  21.     public static function getSubscribedEvents()
  22.     {
  23.         return array(
  24.             self::EVENT_TRANSACTIONS_PARSED => 'transactionsParsed',
  25.             self::EVENT_TRANSACTION_PROCESSED => 'transactionsProcessed'
  26.         );
  27.     }
  29.     /**
  30.      * Transactions parsed
  31.      *
  32.      * @param GenericEvent $event
  33.      * @throws \Doctrine\ORM\NonUniqueResultException
  34.      * @throws \GuzzleHttp\Exception\GuzzleException
  35.      */
  36.     public function transactionsParsed(GenericEvent $event)
  37.     {
  38.         $subject = $event->getSubject();
  39.         $transactions = $subject['transactions'];
  40.         $isRealTime = @$subject['isRealTime'];
  42.         if($isRealTime) {
  43.             $this->container->get('lp.transaction')->sendNotifications($transactions);
  44.         }
  45.     }
  47.     /**
  48.      * Transactions processed
  49.      *
  50.      * @param GenericEvent $event
  51.      * @throws \Doctrine\ORM\NonUniqueResultException
  52.      * @throws \GuzzleHttp\Exception\GuzzleException
  53.      */
  54.     public function transactionsProcessed(GenericEvent $event)
  55.     {
  56.         $subject = $event->getSubject();
  57.         $transaction = $subject;
  59.         // Handle exchange for the transaction
  60.         $this->container->get('lp.transaction')->handleTransactionExchange($transaction);
  61.     }
  63.     /**
  64.      * Document requested
  65.      *
  66.      * @param GenericEvent $event
  67.      */
  68.     public function onImportDone(GenericEvent $event)
  69.     {
  70.     }
  71. }