Add 'Elastica\Client::closePointInTime()' for closing a PiT

CHANGELOG.md

@@ -16,6 +16,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 * Added exposure of Point-In-Time ID for search responses in `Elastica\ResultSet::getPointInTimeId()` [#1991](https://github.com/ruflin/Elastica/pull/1991)
 * Added `Elastica\Index::openPointInTime()` for opening a PiT on the index [#1994](https://github.com/ruflin/Elastica/pull/1994)
 * Added possibility to specify PointInTime on `Elastica\Query::setPointInTime()` [#1992](https://github.com/ruflin/Elastica/pull/1992)
+* Added `Elastica\Client::closePointInTime()` for closing a PiT [#1995](https://github.com/ruflin/Elastica/pull/1995)
 ### Changed
 * Updated `php-cs-fixer` to `2.18.6` [#1955](https://github.com/ruflin/Elastica/pull/1955)
 * Updated `php-cs-fixer` to `3.0.0` [#1959](https://github.com/ruflin/Elastica/pull/1959)

src/Client.php

@@ -8,6 +8,7 @@
 use Elastica\Exception\InvalidException;
 use Elastica\Script\AbstractScript;
 use Elasticsearch\Endpoints\AbstractEndpoint;
+use Elasticsearch\Endpoints\ClosePointInTime;
 use Elasticsearch\Endpoints\Indices\ForceMerge;
 use Elasticsearch\Endpoints\Indices\Refresh;
 use Elasticsearch\Endpoints\Update;
@@ -563,6 +564,19 @@ public function forcemergeAll($args = []): Response
         return $this->requestEndpoint($endpoint);
     }
 
+    /**
+     * Closes the given PointInTime.
+     *
+     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/point-in-time-api.html#close-point-in-time-api
+     */
+    public function closePointInTime(string $pointInTimeId): Response
+    {
+        $endpoint = new ClosePointInTime();
+        $endpoint->setBody(['id' => $pointInTimeId]);
+
+        return $this->requestEndpoint($endpoint);
+    }
+
     /**
      * Refreshes all search indices.
      *

tests/PointInTimeTest.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace Elastica\Test;
+
+use Elastica\Test\Base as BaseTest;
+
+/**
+ * @internal
+ */
+class PointInTimeTest extends BaseTest
+{
+    /**
+     * @group functional
+     */
+    public function testOpenClosePointInTime(): void
+    {
+        $index = $this->_createIndex();
+        $pitOpenResponse = $index->openPointInTime('10s');
+        $this->assertTrue($pitOpenResponse->isOk());
+
+        $pitId = $pitOpenResponse->getData()['id'];
+
+        $client = $index->getClient();
+        $pitCloseResponse = $client->closePointInTime($pitId);
+        $this->assertTrue($pitCloseResponse->isOk());
+
+        $this->assertArrayHasKey('num_freed', $pitCloseResponse->getData());
+    }
+}