1. <?php
  3. /**
  4. * Mirrors data from API endpoints with retry logic for hypothesis validation.
  5. *
  6. * @param array $endpoints An array of API endpoint details. Each element
  7. * should be an associative array with 'url', 'method',
  8. * 'data' (optional), and 'retries' (number of retries).
  9. * @param string $outputFile The file to write the mirrored data to.
  10. * @return bool True on success, false on failure.
  11. */
  12. function mirrorApiEndpoints(array $endpoints, string $outputFile): bool
  13. {
  14. $successful = true; // Track overall success
  16. foreach ($endpoints as $endpoint) {
  17. $url = $endpoint['url'];
  18. $method = $endpoint['method'] ?? 'GET'; // Default to GET if not specified
  19. $data = $endpoint['data'] ?? null;
  20. $retries = $endpoint['retries'] ?? 3; // Default to 3 retries
  22. $data_sent = [];
  23. if ($data !== null) {
  24. $data_sent = json_encode($data);
  25. }
  28. $success = false;
  29. for ($i = 0; $i < $retries; $i++) {
  30. try {
  31. $response = apiRequest($url, $method, $data_sent);
  33. if ($response && $response->http_code == 200) {
  34. $data_to_write = json_decode($response->body, true); // Decode JSON
  35. file_put_contents($outputFile, json_encode($data_to_write, JSON_PRETTY_PRINT) . "\n", FILE_APPEND);
  36. $success = true;
  37. break; // Exit retry loop on success
  38. } else {
  39. error_log("API request failed for $url (attempt $i+1): HTTP code " . $response ? $response->http_code : 'Unknown');
  40. }
  41. } catch (Exception $e) {
  42. error_log("API request failed for $url (attempt $i+1): " . $e->getMessage());
  43. }
  44. }
  46. if (!$success) {
  47. $successful = false;
  48. error_log("Failed to mirror data from $url after $retries attempts.");
  49. }
  50. }
  52. return $successful;
  53. }
  56. /**
  57. * Performs an API request with retry logic.
  58. *
  59. * @param string $url The API endpoint URL.
  60. * @param string $method The HTTP method (GET, POST, PUT, DELETE, etc.).
  61. * @param string $data The request body (optional).
  62. * @return object|null The API response object, or null on failure.
  63. * @throws Exception If an unexpected error occurs.
  64. */
  65. function apiRequest(string $url, string $method, string $data = null): ?object
  66. {
  67. $options = [
  68. 'http' => [
  69. 'method' => $method,
  70. 'header' => "Content-type: application/json; charset=UTF-8",
  71. 'content' => $data ? $data : '',
  72. 'timeout' => 10 //seconds
  73. ],
  74. ];
  76. $context = stream_context_create($options);
  77. $response = file_get_contents($url, false, $context);
  79. if ($response === false) {
  80. throw new Exception("API request failed: " . error_get_last()['message']);
  81. }
  83. $response_obj = json_decode($response, true); // Decode JSON
  84. if (json_last_error() !== JSON_ERROR_NONE) {
  85. throw new Exception("JSON decoding error: " . json_last_error_msg());
  86. }
  88. return $response_obj;
  89. }
  93. // Example Usage (replace with your actual endpoints and output file)
  94. $endpoints = [
  95. [
  96. 'url' => 'https://jsonplaceholder.typicode.com/todos/1',
  97. 'method' => 'GET',
  98. 'retries' => 5,
  99. ],
  100. [
  101. 'url' => 'https://jsonplaceholder.typicode.com/posts',
  102. 'method' => 'GET',
  103. 'data' => ['title' => 'My New Post', 'body' => 'This is the content of my post.'],
  104. 'retries' => 3,
  105. ],
  106. ];
  108. $outputFile = 'mirrored_data.json';
  110. if (mirrorApiEndpoints($endpoints, $output

Add your comment