1. <?php
  3. class TaskQueueDeserializer {
  5. private $rateLimit = 10; // Max tasks per second
  6. private $rateLimitWindow = 1; // Time window for rate limiting (seconds)
  7. private $taskCount = 0;
  8. private $lastReset = 0;
  10. /**
  11. * Deserializes task queue input with rate limiting.
  12. *
  13. * @param string $input The JSON encoded task input.
  14. * @return array|null The deserialized task data, or null on rate limit exceed.
  15. */
  16. public function deserialize(string $input): ?array {
  18. // Rate limiting check
  19. $now = time();
  20. if ($now - $this->lastReset < $this->rateLimitWindow) {
  21. if ($this->taskCount >= $this->rateLimit) {
  22. error_log("Rate limit exceeded."); // Log the event
  23. return null; // Reject the task
  24. }
  25. }
  27. // Increment task count
  28. $this->taskCount++;
  29. $this->lastReset = $now;
  31. try {
  32. $task = json_decode($input, true); // Decode JSON to associative array
  34. if (json_last_error() !== JSON_ERROR_NONE) {
  35. error_log("JSON decode error: " . json_last_error_msg()); // Log JSON decode errors
  36. return null; // Return null if decoding fails
  37. }
  39. //Basic validation, add more as needed.
  40. if (!isset($task['task_id']) || !is_string($task['task_id'])) {
  41. error_log("Invalid task format: missing or invalid task_id");
  42. return null;
  43. }
  45. return $task; // Return the deserialized task
  46. } catch (\Exception $e) {
  47. error_log("Deserialization error: " . $e->getMessage()); // Log any other exceptions
  48. return null;
  49. }
  50. }
  51. }
  53. // Example usage (for testing):
  54. /*
  55. $deserializer = new TaskQueueDeserializer();
  57. $taskData = '{"task_id": "123", "data": "some data"}';
  58. $task = $deserializer->deserialize($taskData);
  60. if ($task) {
  61. echo "Task data: " . json_encode($task) . "\n";
  62. } else {
  63. echo "Task rejected.\n";
  64. }
  65. */
  67. ?>

Add your comment