Add bytes processor

CHANGELOG.md

@@ -11,6 +11,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 * Added `ignore_failure` option to suitable ingest processors [#2003](https://github.com/ruflin/Elastica/pull/2003)
 * Added `ignore_missing` option to `lowercase`, `remove`, `trim` and `uppercase` processors [#2001](https://github.com/ruflin/Elastica/pull/2001)
 * Added `allow_duplicates` option to `append` processor [#2004](https://github.com/ruflin/Elastica/pull/2004)
+* Added `bytes` processor [#2008](https://github.com/ruflin/Elastica/pull/2008)
 ### Changed
 ### Deprecated
 ### Removed

src/Processor/BytesProcessor.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace Elastica\Processor;
+
+/**
+ * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/bytes-processor.html
+ */
+class BytesProcessor extends AbstractProcessor
+{
+    use Traits\IgnoreFailureTrait;
+    use Traits\IgnoreMissingTrait;
+
+    public function __construct(string $field)
+    {
+        $this->setField($field);
+    }
+
+    /**
+     * Set field.
+     *
+     * @return $this
+     */
+    public function setField(string $field): self
+    {
+        return $this->setParam('field', $field);
+    }
+
+    /**
+     * Set target_field.
+     *
+     * @return $this
+     */
+    public function setTargetField(string $targetField): self
+    {
+        return $this->setParam('target_field', $targetField);
+    }
+}

tests/Processor/BytesProcessorTest.php

@@ -0,0 +1,68 @@
+<?php
+
+namespace Elastica\Test\Processor;
+
+use Elastica\Processor\BytesProcessor;
+use Elastica\Test\BasePipeline as BasePipelineTest;
+
+/**
+ * @internal
+ */
+class BytesProcessorTest extends BasePipelineTest
+{
+    /**
+     * @group unit
+     */
+    public function testBytes(): void
+    {
+        $processor = new BytesProcessor('foo');
+
+        $expected = [
+            'bytes' => [
+                'field' => 'foo',
+            ],
+        ];
+
+        $this->assertEquals($expected, $processor->toArray());
+    }
+
+    /**
+     * @group unit
+     */
+    public function testBytesWithTargetField(): void
+    {
+        $processor = (new BytesProcessor('foo'))
+            ->setTargetField('bar')
+        ;
+
+        $expected = [
+            'bytes' => [
+                'field' => 'foo',
+                'target_field' => 'bar',
+            ],
+        ];
+
+        $this->assertEquals($expected, $processor->toArray());
+    }
+
+    /**
+     * @group unit
+     */
+    public function testBytesWithNonDefaultOptions(): void
+    {
+        $processor = (new BytesProcessor('foo'))
+            ->setIgnoreFailure(true)
+            ->setIgnoreMissing(true)
+        ;
+
+        $expected = [
+            'bytes' => [
+                'field' => 'foo',
+                'ignore_failure' => true,
+                'ignore_missing' => true,
+            ],
+        ];
+
+        $this->assertEquals($expected, $processor->toArray());
+    }
+}