KnownUserHandler.php

<?php

namespace Queueit\KnownUser;

use Magento\Framework\App\ObjectManager;
use Magento\Framework\App\Request\Http;
use Magento\Framework\App\RequestInterface;
use Magento\Framework\App\ResponseInterface;
use Psr\Log\LoggerInterface;
use Queueit\KnownUser\Model\IntegrationInfoProvider;
use QueueIT\KnownUserV3\SDK\KnownUser;

class KnownUserHandler
{
    const MAGENTO_SDK_VERSION = "1.3.5";

    /**
     * @var LoggerInterface
     */
    protected $logger;

    public function __construct(LoggerInterface $logger = null)
    {
        if ($logger == null) {
            $objectManager = ObjectManager::getInstance(); // Instance of object manager
            $logger = $objectManager->get("Psr\Log\LoggerInterface");
        }
        $this->logger = $logger;
    }

    /**
     * @param $customerId
     * @param $secretKey
     * @param $observer
     * @param Http|RequestInterface $request
     * @param ResponseInterface $response
     */
    public function handleRequest($customerId, $secretKey, $request, $response)
    {
        try {
            $queueittoken = $request->getQuery('queueittoken', '');
            $configProvider = new IntegrationInfoProvider();
            $configText = $configProvider->getIntegrationInfo(true);

            $fullUrl = $this->getFullRequestUri();
            $currentUrlWithoutQueueitToken = preg_replace("/([\\?&])(" . "queueittoken" . "=[^&]*)/i", "", $fullUrl);

            $result = KnownUser::validateRequestByIntegrationConfig(
                $currentUrlWithoutQueueitToken,
                $queueittoken,
                $configText,
                $customerId,
                $secretKey);

            if ($result->doRedirect()) {
                $response->setHeader('Expires', 'Fri, 01 Jan 1990 00:00:00 GMT');
                $response->setHeader('Cache-Control', 'no-store, no-cache, must-revalidate, max-age=0');
                $response->setHeader('Pragma', 'no-cache');

                if (!$result->isAjaxResult) {
                    $response->setRedirect($result->redirectUrl . $this->getPluginVersion())->sendResponse();
                } else {
                    $response->setHeader($result->getAjaxQueueRedirectHeaderKey(), $result->getAjaxRedirectUrl() . urlencode($this->getPluginVersion()));
                    $response->sendResponse();
                }

                return;
            }

            if (!empty($queueittoken) && $result->actionType == "Queue") {
                //Request can continue - we remove queueittoken form querystring parameter to avoid sharing of user specific token
                $response->setRedirect($currentUrlWithoutQueueitToken)->sendResponse();
                return;
            }
        } catch (\Exception $e) {
            $this->logger->error("Queueit-knownUser: Exception while validating user request: " . $e);
            //log the exception
        }
    }

    private function getPluginVersion()
    {
        return '&kupver=magento2_' . KnownUserHandler::MAGENTO_SDK_VERSION;
    }

    private function getFullRequestUri()
    {
        // Get HTTP/HTTPS (the possible values for this vary from server to server)
        $myUrl = (isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] && !in_array(strtolower($_SERVER['HTTPS']), array('off', 'no'))) ? 'https' : 'http';
        // Get domain portion
        $myUrl .= '://' . $_SERVER['HTTP_HOST'];
        // Get path to script
        $myUrl .= $_SERVER['REQUEST_URI'];
        // Add path info, if any
        if (!empty($_SERVER['PATH_INFO'])) $myUrl .= $_SERVER['PATH_INFO'];
        return $myUrl;
    }


}