From 21016aed2fec0f0e9127322281334a91b860cb26 Mon Sep 17 00:00:00 2001
From: antonioturdo <antonio.turdo@gmail.com>
Date: Wed, 3 Apr 2024 08:44:19 +0200
Subject: [PATCH] feat(users): add email to MergeIdentifier object

---
 src/Object/Users/MergeIdentifier.php       | 29 +++++++++++--
 tests/Object/Users/MergeIdentifierTest.php | 50 ++++++++++++++++++++++
 2 files changed, 75 insertions(+), 4 deletions(-)

diff --git a/src/Object/Users/MergeIdentifier.php b/src/Object/Users/MergeIdentifier.php
index 84be15b..65938b4 100644
--- a/src/Object/Users/MergeIdentifier.php
+++ b/src/Object/Users/MergeIdentifier.php
@@ -12,16 +12,37 @@ class MergeIdentifier extends BaseObject
 
     public ?UserAlias $user_alias = null;
 
+    public ?string $email = null;
+
+    /** @var ?string[] */
+    public ?array $prioritization = null;
+
     public function validate(bool $strict): void
     {
         parent::validate($strict);
 
-        if (null === $this->external_id && null === $this->user_alias) {
-            throw new ValidationException('One of "external_id" or "user_alias" fields is required');
+        if (null === $this->external_id && null === $this->user_alias && null === $this->email) {
+            throw new ValidationException('One of "external_id", "user_alias" or "email" fields is required');
+        }
+
+        if (\count(array_filter([$this->external_id, $this->user_alias, $this->email])) > 1) {
+            throw new ValidationException('Only one of "external_id", "user_alias" and "email" fields must be set');
         }
 
-        if (null !== $this->external_id && null !== $this->user_alias) {
-            throw new ValidationException('Only one of "external_id" and "user_alias" fields must be set');
+        if (null !== $this->email && null === $this->prioritization) {
+            throw new ValidationException('If an "email" is specified as an identifier, an additional "prioritization" value is required');
+        }
+
+        if (null !== $this->prioritization) {
+            foreach ($this->prioritization as $prioritizationItem) {
+                if (!in_array($prioritizationItem, ['identified', 'unidentified', 'most_recently_updated'])) {
+                    throw new ValidationException('The allowed values for the "prioritization" array are: "identified", "unidentified", "most_recently_updated"');
+                }
+            }
+
+            if (\count(array_intersect($this->prioritization, ['identified', 'unidentified'])) > 1) {
+                throw new ValidationException('Only one of "identified" and "unidentified" options may exist in the prioritization array');
+            }
         }
 
         $this->user_alias?->validate($strict);
diff --git a/tests/Object/Users/MergeIdentifierTest.php b/tests/Object/Users/MergeIdentifierTest.php
index d2727ce..875cdcf 100644
--- a/tests/Object/Users/MergeIdentifierTest.php
+++ b/tests/Object/Users/MergeIdentifierTest.php
@@ -52,4 +52,54 @@ public function validProvider(): array
             [$mergeIdentifier],
         ];
     }
+
+    /**
+     * @dataProvider validEmailIdentifierProvider
+     * @doesNotPerformAssertions
+     */
+    public function testValidEmailIdentifier(MergeIdentifier $mergeIdentifier): void
+    {
+        $mergeIdentifier->validate(true);
+    }
+
+    public function validEmailIdentifierProvider(): array
+    {
+        $mergeIdentifier = new MergeIdentifier();
+        $mergeIdentifier->email = 'email@email.it';
+        $mergeIdentifier->prioritization = ['unidentified', 'most_recently_updated'];
+
+        return [
+            [$mergeIdentifier],
+        ];
+    }
+
+    /**
+     * @dataProvider invalidEmailIdentifierProvider
+     */
+    public function testInvalidEmailIdentifier(MergeIdentifier $mergeIdentifier): void
+    {
+        $this->expectException(ValidationException::class);
+
+        $mergeIdentifier->validate(false);
+    }
+
+    public function invalidEmailIdentifierProvider(): array
+    {
+        $mergeIdentifier1 = new MergeIdentifier();
+        $mergeIdentifier1->email = 'email@email.it';
+
+        $mergeIdentifier2 = new MergeIdentifier();
+        $mergeIdentifier2->email = 'email@email.it';
+        $mergeIdentifier2->prioritization = ['email'];
+
+        $mergeIdentifier3 = new MergeIdentifier();
+        $mergeIdentifier3->email = 'email@email.it';
+        $mergeIdentifier3->prioritization = ['identified', 'unidentified'];
+
+        return [
+            [$mergeIdentifier1],
+            [$mergeIdentifier2],
+            [$mergeIdentifier3],
+        ];
+    }
 }