src/Authenticator/XeroAuthenticator.php line 48

Open in your IDE?
  1. <?php
  2. // src/Authenticator/XeroAuthenticator.php
  3. namespace App\Authenticator;
  5. use App\Repository\XeroStorageRepository;
  6. use App\String\Constant;
  7. use Doctrine\Persistence\ManagerRegistry;
  8. use League\OAuth2\Client\Provider\Exception\IdentityProviderException;
  9. use League\OAuth2\Client\Provider\GenericProvider;
  10. use Symfony\Component\DependencyInjection\ParameterBag\ContainerBagInterface;
  11. use Symfony\Component\HttpFoundation\JsonResponse;
  12. use Symfony\Component\HttpFoundation\RedirectResponse;
  13. use Symfony\Component\HttpFoundation\RequestStack;
  14. use Symfony\Component\HttpFoundation\Response;
  15. class XeroAuthenticator
  16. {
  17.     private $provider;
  18.     private $requestStack;
  19.     private $entityManager;
  20.     private $xeroEm;
  22.     public function __construct(RequestStack $requestStack, ContainerBagInterface $params,
  23.         ManagerRegistry $doctrine, XeroStorageRepository $xeroStorageRepository)
  24.     {
  25.         $this->provider = new GenericProvider([
  26.             'clientId'                => $params->get('app.xero_client_id'),
  27.             'clientSecret'            => $params->get('app.xero_client_secret'),
  28.             'redirectUri'             => Constant::XERO_REDIRECT_URL,
  29.             'urlAuthorize'            => Constant::XERO_URL_AUTHORIZE,
  30.             'urlAccessToken'          => Constant::XERO_URL_ACCESS_TOKEN,
  31.             'urlResourceOwnerDetails' => Constant::XERO_URL_RESOURCE,
  32.         ]);
  33.         $this->requestStack = $requestStack;
  34.         $this->entityManager = $doctrine->getManager();
  35.         $this->xeroEm = $xeroStorageRepository;
  36.     }
  38.     /**
  39.      * Return semantic Xero provider
  40.      *
  41.      * @return GenericProvider
  42.      */
  43.     public function getProvider(): GenericProvider
  44.     {
  45.         return $this->provider;
  46.     }
  48.     public function getStorage()
  49.     {
  50.         // New way of storing storage through DB
  51.         $storage = $this->xeroEm->findOneBy(['tag' => 'primary']);
  53.         if ($storage){
  54.             $xeroTenantId = $storage->getTenantId();
  55.             if ($storage->getHasExpired()) {
  56.                 $newAccessToken = $this->provider->getAccessToken('refresh_token', [
  57.                     'refresh_token' => $storage->getRefreshToken()
  58.                 ]);
  60.                 $storage->setAccessToken($newAccessToken->getToken())
  61.                     ->setExpires($newAccessToken->getExpires())
  62.                     ->setTenantId($xeroTenantId)
  63.                     ->setRefreshToken($newAccessToken->getRefreshToken())
  64.                     ->setIdToken($newAccessToken->getValues()["id_token"]);
  65.             
  66.                 $this->entityManager->persist($storage);
  67.                 $this->entityManager->flush();
  68.             }
  70.             return $storage;
  71.         }
  73.         return new JsonResponse('Storage is empty', 400);
  74.     }
  76.     public function authenticate(): Response {
  77.         $session = $this->requestStack->getSession();
  78.         try {
  79.             $options = [
  80.                 'scope' => ['openid email profile offline_access accounting.settings accounting.transactions accounting.contacts accounting.journals.read accounting.reports.read accounting.attachments']
  81.             ];
  82.             $authorizationUrl = $this->provider->getAuthorizationUrl($options); // get authentication url before getting state
  83.             $session->set('oauth2state', $this->provider->getState()); // Set authentication state
  84.             return new RedirectResponse($authorizationUrl, 301);
  85.         } catch (IdentityProviderException $e) {
  86.             return new JsonResponse($e->getMessage(), 400);
  87.         }
  88.     }
  89. }