1,
"_source" => ["sku"],
"query" => [
"term" => [
"reftag" => $reftag
]
]
];
$results = [];
foreach ($hosts as $host) {
$url = "https://$host:9200/$index/_search";
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_USERPWD, "$username:$password");
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
curl_setopt($ch, CURLOPT_HTTPHEADER, [
"Content-Type: application/json"
]);
// allow self-signed TLS
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
$response = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
$err = curl_error($ch);
curl_close($ch);
// store results for this host
$results[] = [
"host" => $host,
"success" => ($response !== false && $httpCode >= 200 && $httpCode < 300),
"http_code" => $httpCode,
"error" => $err ?: null,
"raw_response" => $response,
"decoded" => json_decode($response, true)
];
}
// ========== OUTPUT SECTION ==========
echo "Search results for reftag: $reftag
";
foreach ($results as $r) {
echo "Host: {$r['host']}
";
if ($r['success']) {
echo "Status: ✔️ Success (HTTP {$r['http_code']})
";
echo "";
print_r($r['decoded']);
echo "";
} else {
echo "Status: ❌ Failed
";
echo "HTTP Code: {$r['http_code']}
";
if ($r['error']) {
echo "Curl Error: {$r['error']}
";
}
echo "Raw response:\n{$r['raw_response']}";
}
echo "
";
}