1. <?php
  3. class TaskMetadata {
  4. private $user_id;
  5. private $request_id;
  6. private $timestamp;
  8. public function __construct($user_id, $request_id) {
  9. $this->user_id = $user_id;
  10. $this->request_id = $request_id;
  11. $this->timestamp = time();
  12. }
  14. public function getUserID() {
  15. return $this->user_id;
  16. }
  18. public function getRequestID() {
  19. return $this->request_id;
  20. }
  22. public function getTimestamp() {
  23. return $this->timestamp;
  24. }
  25. }
  27. class RateLimiter {
  28. private $limits = []; // Array to store rate limits for each user/request_id
  30. public function __construct() {}
  32. public function initialize() {
  33. // Initialize rate limits for each user/request_id
  34. }
  36. public function isAllowed($user_id, $request_id) {
  37. $key = $this->getKey($user_id, $request_id);
  39. if (!isset($this->limits[$key])) {
  40. $this->limits[$key] = []; // Initialize limit array if not exists
  41. }
  43. if (count($this->limits[$key]) >= 10) { // Example limit: 10 requests per minute
  44. return false; // Rate limit exceeded
  45. }
  47. $this->limits[$key][] = time(); // Add timestamp of the request
  48. return true; // Request allowed
  49. }
  51. private function getKey($user_id, $request_id) {
  52. return $user_id . '_' . $request_id;
  53. }
  55. public function resetLimits($user_id, $request_id) {
  56. $key = $this->getKey($user_id, $request_id);
  57. if(isset($this->limits[$key])){
  58. unset($this->limits[$key]);
  59. }
  60. }
  62. }
  65. function processTask($user_id, $request_id, $task_data, $rate_limiter) {
  66. // Attach metadata
  67. $metadata = new TaskMetadata($user_id, $request_id);
  69. // Check rate limit
  70. if (!$rate_limiter->isAllowed($user_id, $request_id)) {
  71. return ['success' => false, 'message' => 'Rate limit exceeded'];
  72. }
  74. // Process the task
  75. try {
  76. // Your task processing logic here
  77. echo "Processing task for user " . $user_id . " with request ID " . $request_id . "\n";
  78. // Simulate some work
  79. sleep(1);
  81. // Example: Do something with $task_data
  82. // echo "Task data: " . json_encode($task_data) . "\n";
  85. return ['success' => true, 'metadata' => $metadata]; // Return success with metadata
  86. } catch (Exception $e) {
  87. return ['success' => false, 'message' => $e->getMessage()];
  88. }
  89. }
  92. // Example Usage (for testing)
  93. $rate_limiter = new RateLimiter();
  94. $rate_limiter->initialize();
  96. $user_id = 123;
  97. $request_id = 456;
  98. $task_data = ['key' => 'value'];
  101. for ($i = 0; $i < 12; $i++) {
  102. $result = processTask($user_id, $request_id, $task_data, $rate_limiter);
  104. if ($result['success']) {
  105. echo "Task completed successfully.\n";
  106. } else {
  107. echo "Task failed: " . $result['message'] . "\n";
  108. }
  109. sleep(0.1);
  110. }
  112. //Reset limits after testing
  113. $rate_limiter->resetLimits($user_id, $request_id);
  115. ?>

Add your comment