Supporting Ajax calls

Author: sarooghi

IntegrationInfoProvider.php

@@ -59,6 +59,11 @@ public function updateIntegrationInfo($integrationInfo,$hash)
             $sql = "Insert Into " . $tableName . " (info) Values ('" . $integrationInfo ."')";
             $connection->query($sql);
         }
+        else
+		{
+			 $response->setStatusCode(\Magento\Framework\App\Response\Http::STATUS_CODE_401);
+			 $response->sendResponse();
+		}
    }
 
    private function isValidRequest($integrationInfo,$hash)

KnownUserHandler.php

@@ -20,18 +20,33 @@ public function handleRequest($customerId, $secretKey,  $observer)
             $configProvider = new IntegrationInfoProvider();
             $configText =  $configProvider->getIntegrationInfo(true);
             $fullUrl = $this->getFullRequestUri();
-            $result = \QueueIT\KnownUserV3\SDK\KnownUser::validateRequestByIntegrationConfig($fullUrl, 
-                                                                  $queueittoken, $configText,$customerId, $secretKey);
-
+            $currentUrlWithoutQueueitToken =  preg_replace ( "/([\\?&])(" ."queueittoken". "=[^&]*)/i" , "" ,  $fullUrl);
+            
+            $result = \QueueIT\KnownUserV3\SDK\KnownUser::validateRequestByIntegrationConfig(
+				$currentUrlWithoutQueueitToken, 
+				$queueittoken, 
+				$configText,
+				$customerId, 
+				$secretKey);
 
             if($result->doRedirect())
             {
-                $response = $action->getResponse();
-              
+                $response = $action->getResponse(); 
+				
                 $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');
-				$response->setRedirect($result->redirectUrl)->sendResponse();
+
+                if(!$result->isAjaxResult)
+                {
+                    $response->setRedirect($result->redirectUrl)->sendResponse();
+                }
+                else
+                {
+                    $response->setHeader($result->getAjaxQueueRedirectHeaderKey(), $result->getAjaxRedirectUrl());
+                    $response->sendResponse();
+                }
+				
                 return;
             }
 

composer.json

@@ -11,7 +11,7 @@
         }
   },
   "require": {
-    "queueit/knownuserv3": "*"
+     "queueit/knownuserv3": "^3.5.1"
 
   }
 }