Add Authentication401Exception for failed HTTP Authentication

src/Elasticsearch/Common/Exceptions/Authentication401Exception.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Elasticsearch\Common\Exceptions;
+
+/**
+ * Authentication401Exception, thrown on 401 authentication http error
+ *
+ * @category Elasticsearch
+ * @package  Elasticsearch\Common\Exceptions
+ * @author   Zachary Tong <[email protected]>
+ * @license  http://www.apache.org/licenses/LICENSE-2.0 Apache2
+ * @link     http://elasticsearch.org
+ */
+class Authentication401Exception extends \Exception implements ElasticsearchException
+{
+}

src/Elasticsearch/Connections/CurlMultiConnection.php

@@ -8,6 +8,7 @@
 namespace Elasticsearch\Connections;
 
 use Elasticsearch\Common\Exceptions\AlreadyExpiredException;
+use Elasticsearch\Common\Exceptions\Authentication401Exception;
 use Elasticsearch\Common\Exceptions\BadRequest400Exception;
 use Elasticsearch\Common\Exceptions\Conflict409Exception;
 use Elasticsearch\Common\Exceptions\Forbidden403Exception;
@@ -278,6 +279,8 @@ private function process4xxError($method, $uri, $request, $response)
 
         if ($statusCode === 400 && strpos($responseBody, "AlreadyExpiredException") !== false) {
             throw new AlreadyExpiredException($responseBody, $statusCode);
+        } elseif ($statusCode === 401) {
+            throw new Authentication401Exception($responseBody, $statusCode);
         } elseif ($statusCode === 403) {
             throw new Forbidden403Exception($responseBody, $statusCode);
         } elseif ($statusCode === 404) {

src/Elasticsearch/Connections/GuzzleConnection.php

@@ -9,6 +9,7 @@
 
 
 use Elasticsearch\Common\Exceptions\AlreadyExpiredException;
+use Elasticsearch\Common\Exceptions\Authentication401Exception;
 use Elasticsearch\Common\Exceptions\BadRequest400Exception;
 use Elasticsearch\Common\Exceptions\Conflict409Exception;
 use Elasticsearch\Common\Exceptions\Forbidden403Exception;
@@ -253,6 +254,8 @@ private function process4xxError(Request $request, ClientErrorResponseException
 
         if ($statusCode === 400 && strpos($responseBody, "AlreadyExpiredException") !== false) {
             throw new AlreadyExpiredException($responseBody, $statusCode, $exception);
+        } elseif ($statusCode === 401) {
+            throw new Authentication401Exception($responseBody, $statusCode, $exception);
         } elseif ($statusCode === 403) {
             throw new Forbidden403Exception($responseBody, $statusCode, $exception);
         } elseif ($statusCode === 404) {