1. <?php
  3. /**
  4. * Encodes queue output with a timeout for hypothesis validation.
  5. *
  6. * @param callable $queue_callback A callable representing the queue processing function.
  7. * @param int $timeout Timeout in seconds.
  8. * @return array|false An array containing the output or false on timeout.
  9. */
  10. function encodeQueueOutputWithTimeout(callable $queue_callback, int $timeout): array|false
  11. {
  12. $handle = proc_open(
  13. 'php ' . escapeshellarg(__FILE__) . ' encode_queue_output', // Execute this script as a separate process
  14. [
  15. 0 => ['pipe', 'r'], // stdin
  16. 1 => ['pipe', 'w'], // stdout
  17. 2 => ['pipe', 'w'], // stderr
  18. ],
  19. $pipes
  20. );
  22. if ($handle === false) {
  23. return false; // Error creating process
  24. }
  26. // Send the queue processing arguments to the subprocess
  27. fwrite($pipes[0], serialize($queue_callback)); // Pass the queue callback as a serialized string
  28. fclose($pipes[0]);
  30. $startTime = time();
  32. $output = '';
  33. while ($line = fgets($pipes[1])) {
  34. $output .= $line;
  35. if (time() - $startTime > $timeout) {
  36. fclose($pipes[1]);
  37. break; // Timeout reached
  38. }
  39. }
  41. fclose($pipes[1]);
  42. fclose($pipes[2]);
  44. $return_value = proc_close($handle);
  46. if ($return_value !== 0) {
  47. return false; //Process failed
  48. }
  50. return unserialize($output); // Return the decoded output
  51. }
  54. /**
  55. * Helper function to encode queue output.
  56. * This function is executed in a separate process.
  57. *
  58. * @param mixed $queue_callback The queue processing function (serialized).
  59. * @return string|false The encoded output or false on error.
  60. */
  61. function encode_queue_output($queue_callback)
  62. {
  63. // Execute the queue callback. Capture output.
  64. $result = $queue_callback();
  66. if ($result === false) {
  67. return false;
  68. }
  70. // Encode the result to JSON
  71. $encoded_output = json_encode($result, JSON_PRETTY_PRINT);
  73. if ($encoded_output === false) {
  74. return false; //JSON encoding error
  75. }
  77. return $encoded_output;
  78. }
  80. ?>

Add your comment