1. <?php
  3. /**
  4. * Aggregates values from multiple HTTP responses.
  5. *
  6. * @param array $responses An array of HTTP response objects. Each object should have a 'body' property.
  7. * @return array An associative array where keys are unique identifiers and values are aggregated values.
  8. */
  9. function aggregateResponses(array $responses): array
  10. {
  11. $aggregatedData = [];
  13. foreach ($responses as $response) {
  14. // Assuming each response has a 'body' property containing the data.
  15. $body = $response['body'];
  17. // Check if body exists and is an array. Important for resilience.
  18. if (is_array($body)) {
  19. foreach ($body as $item) {
  20. // Check if the item has a unique identifier (e.g., 'id').
  21. if (isset($item['id'])) {
  22. $id = $item['id'];
  24. // Initialize the aggregated value if it doesn't exist.
  25. if (!isset($aggregatedData[$id])) {
  26. $aggregatedData[$id] = [];
  27. }
  29. // Add the item's value to the corresponding array.
  30. $aggregatedData[$id][] = $item['value']; //assuming each item has a 'value' property
  31. }
  32. }
  33. } else {
  34. //Handle the case where the body is not an array. Log, warn, or skip.
  35. error_log("Warning: Response body is not an array. Skipping.");
  36. }
  37. }
  39. return $aggregatedData;
  40. }
  42. // Example usage (assuming you have some HTTP response objects)
  43. /*
  44. $response1 = ['body' => [
  45. ['id' => 1, 'value' => 10],
  46. ['id' => 2, 'value' => 20],
  47. ]];
  49. $response2 = ['body' => [
  50. ['id' => 1, 'value' => 15],
  51. ['id' => 3, 'value' => 30],
  52. ]];
  54. $responses = [$response1, $response2];
  56. $aggregatedResult = aggregateResponses($responses);
  58. print_r($aggregatedResult);
  59. */
  61. ?>

Add your comment