Add DeleteCommandSet factories

snowio · Oct 31, 2017 · 6de68d1 · 6de68d1
1 parent d963bfe
commit 6de68d1
Show file tree

Hide file tree

Showing 5 changed files with 41 additions and 0 deletions.
diff --git a/src/AttributeDataSet.php b/src/AttributeDataSet.php
@@ -1,6 +1,7 @@
 <?php
 namespace SnowIO\FredhopperDataModel;
 
+use SnowIO\FredhopperDataModel\Command\DeleteAttributeCommand;
 use SnowIO\FredhopperDataModel\Command\SaveAttributeCommand;
 
 final class AttributeDataSet implements \IteratorAggregate
@@ -21,6 +22,13 @@ public function mapToSaveCommands(float $timestamp): array
         }, $this->items);
     }
 
+    public function mapToDeleteCommands(float $timestamp): array
+    {
+        return \array_map(function (AttributeData $attributeData) use ($timestamp) {
+            return DeleteAttributeCommand::of($attributeData->getId())->withTimestamp($timestamp);
+        }, $this->items);
+    }
+
     private static function getKey(AttributeData $attributeData): string
     {
         return $attributeData->getId();

diff --git a/src/AttributeOptionSet.php b/src/AttributeOptionSet.php
@@ -2,6 +2,7 @@
 declare(strict_types=1);
 namespace SnowIO\FredhopperDataModel;
 
+use SnowIO\FredhopperDataModel\Command\DeleteAttributeOptionCommand;
 use SnowIO\FredhopperDataModel\Command\SaveAttributeOptionCommand;
 
 final class AttributeOptionSet implements \IteratorAggregate
@@ -23,6 +24,14 @@ public function mapToSaveCommands(float $timestamp): array
         }, $this->items);
     }
 
+    public function mapToDeleteCommands(float $timestamp): array
+    {
+        return \array_map(function (AttributeOption $attributeOption) use ($timestamp) {
+            return DeleteAttributeOptionCommand::of($attributeOption->getAttributeId(), $attributeOption->getValueId())
+                ->withTimestamp($timestamp);
+        }, $this->items);
+    }
+
     private static function getKey(AttributeOption $attributeOption): string
     {
         return "{$attributeOption->getAttributeId()}-{$attributeOption->getValueId()}";

diff --git a/src/CategoryDataSet.php b/src/CategoryDataSet.php
@@ -1,6 +1,7 @@
 <?php
 namespace SnowIO\FredhopperDataModel;
 
+use SnowIO\FredhopperDataModel\Command\DeleteCategoryCommand;
 use SnowIO\FredhopperDataModel\Command\SaveCategoryCommand;
 
 final class CategoryDataSet implements \IteratorAggregate
@@ -21,6 +22,13 @@ public function mapToSaveCommands(float $timestamp): array
         }, $this->items);
     }
 
+    public function mapToDeleteCommands(float $timestamp): array
+    {
+        return \array_map(function (CategoryData $categoryData) use ($timestamp) {
+            return DeleteCategoryCommand::of($categoryData->getId())->withTimestamp($timestamp);
+        }, $this->items);
+    }
+
     private static function getKey(CategoryData $categoryData): string
     {
         return $categoryData->getId();

diff --git a/src/ProductDataSet.php b/src/ProductDataSet.php
@@ -1,6 +1,7 @@
 <?php
 namespace SnowIO\FredhopperDataModel;
 
+use SnowIO\FredhopperDataModel\Command\DeleteProductCommand;
 use SnowIO\FredhopperDataModel\Command\SaveProductCommand;
 
 final class ProductDataSet implements \IteratorAggregate
@@ -21,6 +22,13 @@ public function mapToSaveCommands(float $timestamp): array
         }, $this->items);
     }
 
+    public function mapToDeleteCommands(float $timestamp): array
+    {
+        return \array_map(function (ProductData $productData) use ($timestamp) {
+            return DeleteProductCommand::of($productData->getId())->withTimestamp($timestamp);
+        }, $this->items);
+    }
+
     private static function getKey(ProductData $productData): string
     {
         return $productData->getId();

diff --git a/src/VariantDataSet.php b/src/VariantDataSet.php
@@ -1,6 +1,7 @@
 <?php
 namespace SnowIO\FredhopperDataModel;
 
+use SnowIO\FredhopperDataModel\Command\DeleteVariantCommand;
 use SnowIO\FredhopperDataModel\Command\SaveVariantCommand;
 
 final class VariantDataSet implements \IteratorAggregate
@@ -21,6 +22,13 @@ public function mapToSaveCommands(float $timestamp): array
         }, $this->items);
     }
 
+    public function mapToDeleteCommands(float $timestamp): array
+    {
+        return \array_map(function (VariantData $variantData) use ($timestamp) {
+            return DeleteVariantCommand::of($variantData->getId())->withTimestamp($timestamp);
+        }, $this->items);
+    }
+
     private static function getKey(VariantData $variantData): string
     {
         return $variantData->getId();