From c040a9ef98482e1887c4aecbe9beb6a387d207d5 Mon Sep 17 00:00:00 2001
From: RomanApunts <62882223+RomanApunts@users.noreply.github.com>
Date: Wed, 3 Jul 2024 08:21:39 +0200
Subject: [PATCH] Update Reader.php to include filter by user

---
 src/Provider/Doctrine/Persistence/Reader/Reader.php | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/Provider/Doctrine/Persistence/Reader/Reader.php b/src/Provider/Doctrine/Persistence/Reader/Reader.php
index f6f20d22..e9d21ede 100644
--- a/src/Provider/Doctrine/Persistence/Reader/Reader.php
+++ b/src/Provider/Doctrine/Persistence/Reader/Reader.php
@@ -67,6 +67,10 @@ public function createQuery(string $entity, array $options = []): Query
             $query->addFilter(new SimpleFilter(Query::OBJECT_ID, $config['object_id']));
         }
 
+        if (null !== $config['user_id']) {
+            $query->addFilter(new SimpleFilter(Query::USER_ID, $config['user_id']));
+        }
+
         if (null !== $config['transaction_hash']) {
             $query->addFilter(new SimpleFilter(Query::TRANSACTION_HASH, $config['transaction_hash']));
         }
@@ -181,6 +185,7 @@ private function configureOptions(OptionsResolver $resolver): void
             ->setDefaults([
                 'type' => null,
                 'object_id' => null,
+                'user_id' => null,
                 'transaction_hash' => null,
                 'page' => 1,
                 'page_size' => self::PAGE_SIZE,
@@ -188,6 +193,7 @@ private function configureOptions(OptionsResolver $resolver): void
             ])
             ->setAllowedTypes('type', ['null', 'string', 'array'])
             ->setAllowedTypes('object_id', ['null', 'int', 'string', 'array'])
+            ->setAllowedTypes('user_id', ['null', 'int', 'string', 'array'])
             ->setAllowedTypes('transaction_hash', ['null', 'string', 'array'])
             ->setAllowedTypes('page', ['null', 'int'])
             ->setAllowedTypes('page_size', ['null', 'int'])