1. <?php
  3. class QueueGrouper {
  5. private $queue_entries = []; // Array to store queue entries
  6. private $rate_limit = 10; // Maximum number of entries per interval
  7. private $interval = 1; // Time interval in seconds
  8. private $last_reset = 0; // Timestamp of last reset
  10. /**
  11. * Adds a queue entry to the queue.
  12. *
  13. * @param mixed $entry The queue entry.
  14. */
  15. public function addEntry(mixed $entry) {
  16. $this->queue_entries[] = $entry;
  17. }
  19. /**
  20. * Gets grouped entries based on rate limiting.
  21. *
  22. * @return array An array of grouped entries.
  23. */
  24. public function getGroupedEntries(): array {
  25. $current_time = time();
  27. // Reset rate limit if interval has passed
  28. if ($current_time - $this->last_reset >= $this->interval) {
  29. $this->queue_entries = []; // Clear the queue
  30. $this->last_reset = $current_time;
  31. }
  33. $grouped_entries = [];
  34. $current_group = [];
  35. $count = 0;
  37. foreach ($this->queue_entries as $entry) {
  38. if ($count < $this->rate_limit) {
  39. $current_group[] = $entry;
  40. $count++;
  41. } else {
  42. $grouped_entries[] = $current_group; // Add the current group
  43. $current_group = [$entry]; // Start a new group
  44. $count = 1;
  45. }
  46. }
  48. if (!empty($current_group)) {
  49. $grouped_entries[] = $current_group; // Add the last group
  50. }
  52. $this->queue_entries = []; // Clear the queue after processing
  53. return $grouped_entries;
  54. }
  56. /**
  57. * Resets the rate limit.
  58. */
  59. public function resetRateLimit() {
  60. $this->last_reset = time();
  61. }
  62. }
  64. ?>

Add your comment