Resolve https://github.com/ruflin/Elastica/issues/1737: handle 413 response

CHANGELOG.md

@@ -9,7 +9,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Added
 * Added explicit return annotation to `Elastica\Multi\ResultSet::current()` and `Elastica\Multi\ResultSet::offsetGet()` by @franmomu
   [2056](https://github.com/ruflin/Elastica/pull/2056)
-
+* Add throwing `\Elastica\Exception\RequestEntityTooLargeException` on HTTP-413 responses in `\Elastica\Bulk`
 ### Changed
 ### Deprecated
 ### Removed

src/Bulk.php

@@ -9,6 +9,7 @@
 use Elastica\Exception\Bulk\ResponseException;
 use Elastica\Exception\Bulk\ResponseException as BulkResponseException;
 use Elastica\Exception\InvalidException;
+use Elastica\Exception\RequestEntityTooLargeException;
 use Elastica\Script\AbstractScript;
 
 class Bulk
@@ -296,6 +297,10 @@ public function send(): ResponseSet
      */
     protected function _processResponse(Response $response): ResponseSet
     {
+        switch ($response->getStatus()) {
+            case 413: throw new RequestEntityTooLargeException();
+        }
+
         $responseData = $response->getData();
 
         $actions = $this->getActions();

src/Exception/RequestEntityTooLargeException.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Elastica\Exception;
+
+use Throwable;
+
+class RequestEntityTooLargeException extends \RuntimeException implements ExceptionInterface
+{
+    /**
+     * @param Throwable|null $previous
+     */
+    public function __construct(Throwable $previous = null)
+    {
+        parent::__construct('Request entity is too large.', 0, $previous);
+    }
+}

tests/BulkTest.php

@@ -9,12 +9,16 @@
 use Elastica\Bulk\Action\IndexDocument;
 use Elastica\Bulk\Action\UpdateDocument;
 use Elastica\Bulk\Response;
+use Elastica\Client;
 use Elastica\Document;
 use Elastica\Exception\Bulk\ResponseException;
 use Elastica\Exception\InvalidException;
 use Elastica\Exception\NotFoundException;
+use Elastica\Exception\RequestEntityTooLargeException;
+use Elastica\Response as ElasticaResponse;
 use Elastica\Script\Script;
 use Elastica\Test\Base as BaseTest;
+use PHPUnit\Framework\MockObject\MockObject;
 
 /**
  * @internal
@@ -765,4 +769,32 @@ public function testHasIndex(): void
         $bulk->setIndex('unittest');
         $this->assertTrue($bulk->hasIndex());
     }
+
+    /**
+     * @group unit
+     */
+    public function testSendRequestEntityTooLargeExceptionIf413Response(): void
+    {
+        $response = new ElasticaResponse('', 413);
+
+        /** @var Client|MockObject $clientMock */
+        $clientMock = $this->createMock(Client::class);
+        $clientMock
+            ->method('request')
+            ->willReturn($response);
+
+        $index = $this->_createIndex();
+
+        $documents = [
+            new Document(1, ['name' => 'Mister Fantastic'], $index),
+            new Document(2, ['name' => 'Invisible Woman'], $index),
+            new Document(2, ['name' => 'The Human Torch'], $index),
+        ];
+
+        $bulk = new Bulk($clientMock);
+        $bulk->addDocuments($documents);
+
+        $this->expectException(RequestEntityTooLargeException::class);
+        $bulk->send();
+    }
 }

tests/Exception/RequestEntityTooLargeExceptionTest.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Elastica\Test\Exception;
+
+use Elastica\Exception\RequestEntityTooLargeException;
+
+/**
+ * @internal
+ */
+class RequestEntityTooLargeExceptionTest extends AbstractExceptionTest
+{
+    /**
+     * @group unit
+     */
+    public function testInstanceDefaultMessage(): void
+    {
+        $message = 'Request entity is too large.';
+        $exception = new RequestEntityTooLargeException();
+        $this->assertEquals($message, $exception->getMessage());
+    }
+}