46 lines
1.8 KiB
PHP
46 lines
1.8 KiB
PHP
<?php
|
|
require_once __DIR__ . '/../config/config_enhanced.php';
|
|
require_once __DIR__ . '/../classes/Database.php';
|
|
|
|
try {
|
|
$db = Database::getInstance();
|
|
$rows = $db->fetchAll('SELECT id, request_body, created_at FROM webhook_logs ORDER BY created_at DESC LIMIT 50');
|
|
$missing = [];
|
|
foreach ($rows as $r) {
|
|
$data = json_decode($r['request_body'], true);
|
|
if (!$data) continue;
|
|
if (!empty($data['entry'])) {
|
|
foreach ($data['entry'] as $entry) {
|
|
if (!empty($entry['changes'])) {
|
|
foreach ($entry['changes'] as $change) {
|
|
$val = $change['value'] ?? [];
|
|
if (!empty($val['conversations'])) {
|
|
foreach ($val['conversations'] as $m) {
|
|
$mid = $m['id'] ?? null;
|
|
$from = $m['from'] ?? null;
|
|
if ($mid) {
|
|
$exists = $db->fetch("SELECT id FROM conversations WHERE message_id = ? LIMIT 1", [$mid]);
|
|
if (!$exists) {
|
|
$missing[] = ['message_id' => $mid, 'from' => $from, 'log_id' => $r['id'], 'log_time' => $r['created_at']];
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (empty($missing)) {
|
|
echo "All recent conversations found in conversations.\n";
|
|
} else {
|
|
echo "Missing conversations (not found in conversations):\n";
|
|
foreach ($missing as $m) {
|
|
echo json_encode($m) . PHP_EOL;
|
|
}
|
|
}
|
|
} catch (Exception $e) {
|
|
echo 'ERROR: ' . $e->getMessage() . PHP_EOL;
|
|
}
|