Add check_remote_abdm_fetch.php diagnostic script for ABDM data_fetch troubleshooting on remote servers
This commit is contained in:
parent
becff35929
commit
2c9e5755d2
116
check_remote_abdm_fetch.php
Normal file
116
check_remote_abdm_fetch.php
Normal file
|
|
@ -0,0 +1,116 @@
|
|||
<?php
|
||||
/**
|
||||
* One-off diagnostic: run this from the CI4 project root on the SERVER
|
||||
* (e.g. /var/www/html/hms_etria) to inspect why a "Completed" ABDM data_fetch
|
||||
* produced zero rows in abdm_hiu_documents.
|
||||
*
|
||||
* Usage:
|
||||
* php check_remote_abdm_fetch.php -> shows last 5 data_fetch workflow rows
|
||||
* php check_remote_abdm_fetch.php REQ-xxxxxxxxx -> shows detail for that request_id
|
||||
*
|
||||
* Reads DB credentials from the app's own .env (does not print them).
|
||||
*/
|
||||
|
||||
$envPath = __DIR__ . '/.env';
|
||||
if (! is_file($envPath)) {
|
||||
fwrite(STDERR, "Could not find .env at {$envPath}\n");
|
||||
exit(1);
|
||||
}
|
||||
|
||||
$lines = file($envPath, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
|
||||
$env = [];
|
||||
foreach ($lines as $line) {
|
||||
$line = trim($line);
|
||||
if ($line === '' || $line[0] === '#' || strpos($line, '=') === false) {
|
||||
continue;
|
||||
}
|
||||
[$k, $v] = explode('=', $line, 2);
|
||||
$env[trim($k)] = trim($v, " \t\n\r\0\x0B\"'");
|
||||
}
|
||||
|
||||
$host = $env['database.default.hostname'] ?? 'localhost';
|
||||
$db = $env['database.default.database'] ?? '';
|
||||
$user = $env['database.default.username'] ?? '';
|
||||
$pass = $env['database.default.password'] ?? '';
|
||||
$port = (int) ($env['database.default.port'] ?? 3306);
|
||||
|
||||
if ($db === '' || $user === '') {
|
||||
fwrite(STDERR, "Could not resolve DB credentials from .env (looked for database.default.* keys)\n");
|
||||
exit(1);
|
||||
}
|
||||
|
||||
$mysqli = @new mysqli($host, $user, $pass, $db, $port ?: 3306);
|
||||
if ($mysqli->connect_errno) {
|
||||
fwrite(STDERR, "DB connect failed: " . $mysqli->connect_error . "\n");
|
||||
exit(1);
|
||||
}
|
||||
|
||||
echo "Connected to DB '{$db}' on {$host}.\n\n";
|
||||
|
||||
$requestId = trim($argv[1] ?? '');
|
||||
|
||||
if ($requestId !== '') {
|
||||
$stmt = $mysqli->prepare("SELECT id, operation, workflow_state, status, http_code, is_retryable, retry_count,
|
||||
consent_id, abdm_consent_artifact_id, abha_address, transaction_id,
|
||||
last_error, created_at, updated_at, completed_at,
|
||||
LENGTH(response_json) AS response_len, LENGTH(request_json) AS request_len
|
||||
FROM abdm_hiu_workflows WHERE request_id = ? ORDER BY id ASC");
|
||||
$stmt->bind_param('s', $requestId);
|
||||
$stmt->execute();
|
||||
$res = $stmt->get_result();
|
||||
if ($res->num_rows === 0) {
|
||||
echo "No abdm_hiu_workflows rows found for request_id={$requestId}\n";
|
||||
}
|
||||
while ($row = $res->fetch_assoc()) {
|
||||
echo "--- workflow id={$row['id']} op={$row['operation']} ---\n";
|
||||
foreach ($row as $k => $v) {
|
||||
echo " {$k}: " . (is_null($v) ? 'NULL' : $v) . "\n";
|
||||
}
|
||||
echo "\n";
|
||||
}
|
||||
|
||||
// Try to show a snippet of response_json for the data_fetch op specifically,
|
||||
// to see if the bridge actually returned any careContexts/entries.
|
||||
$stmt2 = $mysqli->prepare("SELECT id, response_json FROM abdm_hiu_workflows WHERE request_id = ? AND operation = 'data_fetch' ORDER BY id DESC LIMIT 1");
|
||||
$stmt2->bind_param('s', $requestId);
|
||||
$stmt2->execute();
|
||||
$r2 = $stmt2->get_result()->fetch_assoc();
|
||||
if ($r2 && $r2['response_json']) {
|
||||
$json = json_decode($r2['response_json'], true);
|
||||
echo "=== data_fetch response_json summary (id={$r2['id']}) ===\n";
|
||||
if (is_array($json)) {
|
||||
echo "Top-level keys: " . implode(', ', array_keys($json)) . "\n";
|
||||
// Common shapes to look for
|
||||
foreach (['careContexts', 'entries', 'records', 'bundles', 'data', 'result'] as $key) {
|
||||
if (isset($json[$key]) && is_array($json[$key])) {
|
||||
echo " {$key}: " . count($json[$key]) . " item(s)\n";
|
||||
}
|
||||
}
|
||||
echo "Raw length: " . strlen($r2['response_json']) . " bytes\n";
|
||||
} else {
|
||||
echo "response_json could not be decoded as JSON. Length: " . strlen($r2['response_json']) . "\n";
|
||||
}
|
||||
} else {
|
||||
echo "No data_fetch response_json stored for this request_id.\n";
|
||||
}
|
||||
|
||||
// Check whether any documents got persisted for this request_id / transaction_id
|
||||
$stmt3 = $mysqli->prepare("SELECT COUNT(*) AS c FROM abdm_hiu_documents WHERE request_id = ?");
|
||||
$stmt3->bind_param('s', $requestId);
|
||||
$stmt3->execute();
|
||||
$c = $stmt3->get_result()->fetch_assoc();
|
||||
echo "\nabdm_hiu_documents rows with this exact request_id: {$c['c']}\n";
|
||||
} else {
|
||||
echo "=== Last 5 data_fetch workflow rows ===\n";
|
||||
$res = $mysqli->query("SELECT id, request_id, workflow_state, status, http_code, last_error, created_at
|
||||
FROM abdm_hiu_workflows WHERE operation = 'data_fetch' ORDER BY id DESC LIMIT 5");
|
||||
while ($row = $res->fetch_assoc()) {
|
||||
print_r($row);
|
||||
}
|
||||
echo "\nTotal abdm_hiu_documents rows: ";
|
||||
print_r($mysqli->query("SELECT COUNT(*) c FROM abdm_hiu_documents")->fetch_assoc());
|
||||
echo "\nRun again with the request_id as an argument for full detail, e.g.:\n";
|
||||
echo " php check_remote_abdm_fetch.php REQ-20260728043833-7c0d9947\n";
|
||||
}
|
||||
|
||||
$mysqli->close();
|
||||
Loading…
Reference in New Issue
Block a user