Update ScheduledEventRepository.php

Author: valzargaming

src/Discord/Repository/Guild/ScheduledEventRepository.php

@@ -16,8 +16,10 @@
 
 use Discord\Http\Endpoint;
 use Discord\Parts\Guild\ScheduledEvent;
+use Discord\Parts\User\User;
 use Discord\Repository\AbstractRepository;
 use React\Promise\PromiseInterface;
+use Symfony\Component\OptionsResolver\OptionsResolver;
 
 use function React\Promise\resolve;
 
@@ -85,4 +87,79 @@ public function fetch(string $id, bool $fresh = false, bool $with_user_count = f
             return $this->cache->set($id, $part)->then(fn ($success) => $part);
         });
     }
+
+    /**
+     * Get the counts for users subscribed to a scheduled event.
+     *
+     * @param string $id The scheduled event id.
+     *
+     * @return PromiseInterface<int> The count of users subscribed to the scheduled event.
+     * 
+     * @since 10.46.0
+     */
+    public function getUsersCount(string $id): PromiseInterface
+    {
+        return $this->http->get(Endpoint::bind(Endpoint::GUILD_SCHEDULED_EVENT_USERS_COUNT, $this->vars['guild_id'], $id));
+    }
+
+    /**
+     * Get users for a specific scheduled event exception.
+     *
+     * Mirrors the query options of ScheduledEvent::getUsers.
+     *
+     * @param string $scheduledEventId
+     * @param string $exceptionId
+     * @param array  $options
+     *
+     * @return PromiseInterface<ExCollectionInterface<User>>
+     * 
+     * @since 10.46.0
+     */
+    public function getExceptionUsers(string $scheduledEventId, string $exceptionId, array $options = []): PromiseInterface
+    {
+        $resolver = new OptionsResolver();
+        $resolver->setDefaults(['limit' => 100, 'with_member' => false]);
+        $resolver->setDefined(['before', 'after']);
+        $resolver->setAllowedTypes('before', [User::class, 'string']);
+        $resolver->setAllowedTypes('after', [User::class, 'string']);
+        $resolver->setAllowedTypes('with_member', 'bool');
+        $resolver->setAllowedValues('limit', fn ($value) => ($value >= 1 && $value <= 100));
+
+        $options = $resolver->resolve($options);
+        if (isset($options['before'], $options['after'])) {
+            return \React\Promise\reject(new \RangeException('Can only specify one of before after.'));
+        }
+
+        $endpoint = Endpoint::bind(Endpoint::GUILD_SCHEDULED_EVENT_EXCEPTION_USERS, $this->vars['guild_id'], $scheduledEventId, $exceptionId);
+        $endpoint->addQuery('limit', $options['limit']);
+        $endpoint->addQuery('with_member', $options['with_member']);
+
+        if (isset($options['before'])) {
+            $endpoint->addQuery('before', $options['before'] instanceof User ? $options['before']->id : $options['before']);
+        }
+        if (isset($options['after'])) {
+            $endpoint->addQuery('after', $options['after'] instanceof User ? $options['after']->id : $options['after']);
+        }
+
+        return $this->http->get($endpoint)->then(function ($responses) {
+            /** @var ExCollectionInterface<User> $users */
+            $users = new ($this->discord->getCollectionClass());
+
+            $guild = $this->discord->guilds->get('id', $this->vars['guild_id']);
+
+            foreach ($responses as $response) {
+                if (isset($response->member) && ! $user = $guild->members->get('id', $response->user->id)) {
+                    $user = $guild->members->create($response->member, true);
+                    $guild->members->pushItem($user);
+                } elseif (! $user = $this->discord->users->get('id', $response->user->id)) {
+                    $user = $this->discord->users->create($response->user, true);
+                    $this->discord->users->pushItem($user);
+                }
+
+                $users->pushItem($user);
+            }
+
+            return $users;
+        });
+    }
 }