1. <?php
  3. /**
  4. * Throttles JSON request responses for dry-run scenarios.
  5. *
  6. * @param callable $callback The function to execute for each request. Should return the JSON response.
  7. * @param int $requestsPerSecond The maximum number of requests allowed per second.
  8. * @return callable A throttled version of the callback function.
  9. */
  10. function throttleJsonRequests(callable $callback, int $requestsPerSecond): callable
  11. {
  12. $lastExecutionTime = 0;
  13. $requestQueue = [];
  15. return function () use ($callback, $lastExecutionTime, $requestsPerSecond, &$requestQueue) {
  16. $now = time();
  18. // Calculate time since last execution
  19. $timeSinceLastExecution = $now - $lastExecutionTime;
  21. // Check if enough time has passed to allow a new request
  22. if ($timeSinceLastExecution < (1 / $requestsPerSecond)) {
  23. // Wait until enough time has passed
  24. $sleepTime = (1 / $requestsPerSecond) - $timeSinceLastExecution;
  25. usleep($sleepTime * 1000000); // Convert seconds to microseconds
  26. }
  28. // Execute the callback
  29. $result = call_user_func($callback);
  31. // Update the last execution time
  32. $lastExecutionTime = $now;
  34. // Optionally, process the result here (e.g. log, validate)
  35. // echo "Request processed. Result: " . json_encode($result) . "\n";
  37. return $result;
  38. };
  39. }

Add your comment