src/WellCommerce/Bundle/AppBundle/EventListener/FacebookConversionEventSubscriber.php line 28

Open in your IDE?
  1. <?php
  3. namespace WellCommerce\Bundle\AppBundle\EventListener;
  5. use FacebookAds\Api;
  6. use FacebookAds\Logger\CurlLogger;
  7. use FacebookAds\Object\ServerSide\Event;
  8. use FacebookAds\Object\ServerSide\EventRequest;
  9. use FacebookAds\Object\ServerSide\UserData;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  13. use WellCommerce\Bundle\AppBundle\Entity\Client;
  14. use WellCommerce\Bundle\AppBundle\Entity\Shop;
  15. use WellCommerce\Bundle\CoreBundle\DependencyInjection\AbstractServiceSubscriber;
  16. use WellCommerce\Bundle\OrderBundle\Event\CartAddEvent;
  18. class FacebookConversionEventSubscriber extends AbstractServiceSubscriber implements EventSubscriberInterface
  19. {
  20.     public static function getSubscribedEvents()
  21.     {
  22.         return [
  23.             KernelEvents::CONTROLLER => 'onKernelController',
  24.             CartAddEvent::class      => 'onCartAdd',
  25.         ];
  26.     }
  28.     public function onCartAdd(CartAddEvent $event)
  29.     {
  31.     }
  33.     public function onKernelController(ControllerEvent $event)
  34.     {
  35.         if (false === $event->isMasterRequest()) {
  36.             return;
  37.         }
  39.         if ($this->getSecurityHelper()->isActiveAdminFirewall()) {
  40.             return;
  41.         }
  43.         if ($this->getRequestHelper()->isGraphQLRequest()) {
  44.             return;
  45.         }
  47.         $shop   = $this->getShopStorage()->getCurrentShop();
  48.         $client = $this->getSecurityHelper()->getCurrentClient();
  50.         if (true === $event->isMasterRequest() && true === $this->isConfigured($shop) && $client instanceof Client) {
  51.             $pixelId = $shop->getFacebookPixelIdentifier();
  52.             $api     = $this->createApi($shop);
  53.             $events  = [];
  55.             $userData = new UserData();
  56.             $userData->setEmail($client->getContactDetails()->getEmail());
  57.             $userData->setPhone($client->getContactDetails()->getPhone());
  59.             $event = (new Event())
  60.                 ->setEventName("PageView")
  61.                 ->setEventTime(time())
  62.                 ->setUserData($userData);
  64.             array_push($events, $event);
  66.             $request = (new EventRequest($pixelId))->setEvents($events);
  68.             try {
  69.                 $response = $request->execute();
  70.             } catch (\Exception $exception) {
  71.                 if ($this->getKernel()->isDebug()) {
  72.                     throw $exception;
  73.                 }
  74.             }
  75.         }
  76.     }
  78.     protected function createApi(Shop $shop): Api
  79.     {
  80.         $appId       = !empty($shop->getFacebookConversionAppId()) ? $shop->getFacebookConversionAppId() : null;
  81.         $appSecret   = !empty($shop->getFacebookConversionAppSecret()) ? $shop->getFacebookConversionAppSecret() : null;
  82.         $accessToken = $this->getAccessToken($shop);
  84.         Api::init($appId, $appSecret, $accessToken);
  85.         $api = Api::instance();
  86.         $api->setLogger(new CurlLogger());
  88.         return $api;
  89.     }
  91.     protected function isConfigured(Shop $shop): bool
  92.     {
  93.         return
  94.             true === $shop->isFacebookConversionEnabled() &&
  95.             !empty($shop->getFacebookPixelIdentifier());
  96.     }
  98.     protected function getAccessToken(Shop $shop): string
  99.     {
  100.         if (empty($shop->getFacebookConversionAccessToken())) {
  101.             $url = sprintf(
  102.                 'https://graph.facebook.com/oauth/access_token?client_id=%s&client_secret=%s&grant_type=client_credentials',
  103.                 $shop->getFacebookConnectAppId(),
  104.                 $shop->getFacebookConnectAppSecret(),
  105.             );
  107.             $client   = new Client();
  108.             $response = $client->request('GET', $url);
  109.             $result   = json_decode($response->getBody()->getContents());
  111.             if (!empty($result->access_token)) {
  112.                 $shop->setFacebookConversionAccessToken($result->access_token);
  113.                 $this->getEntityManager()->flush();
  114.             }
  115.         }
  117.         return $shop->getFacebookConversionAccessToken();
  118.     }
  119. }