102 lines
2.9 KiB
PHP
102 lines
2.9 KiB
PHP
<?php
|
|
/**
|
|
* API - Obtener registros de webhooks
|
|
* Fecha: 20 de enero de 2026
|
|
*/
|
|
|
|
require_once '../config/config_enhanced.php';
|
|
|
|
// Suprimir errores para obtener JSON limpio
|
|
error_reporting(E_ERROR | E_PARSE);
|
|
|
|
// Modo debug: desactivar autenticación si existe el parámetro debug
|
|
$debugMode = isset($_GET['debug']) && $_GET['debug'] === 'true';
|
|
|
|
if (!$debugMode) {
|
|
requireAuthentication();
|
|
}
|
|
|
|
header('Content-Type: application/json; charset=utf-8');
|
|
header('Access-Control-Allow-Origin: *');
|
|
header('Access-Control-Allow-Methods: GET, OPTIONS');
|
|
header('Access-Control-Allow-Headers: Content-Type');
|
|
|
|
if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') {
|
|
http_response_code(200);
|
|
exit;
|
|
}
|
|
|
|
if ($_SERVER['REQUEST_METHOD'] !== 'GET') {
|
|
http_response_code(405);
|
|
echo json_encode(['error' => 'Método no permitido. Use GET.']);
|
|
exit;
|
|
}
|
|
|
|
try {
|
|
$db = Database::getInstance();
|
|
|
|
$limit = max(1, min(200, intval($_GET['limit'] ?? 50)));
|
|
$page = max(1, intval($_GET['page'] ?? 1));
|
|
$offset = ($page - 1) * $limit;
|
|
$sinceId = isset($_GET['since_id']) ? intval($_GET['since_id']) : null;
|
|
$search = trim($_GET['search'] ?? '');
|
|
$filter = trim($_GET['filter'] ?? ''); // e.g., HAS_conversations
|
|
|
|
$where = [];
|
|
$params = [];
|
|
|
|
if ($sinceId) {
|
|
$where[] = 'id > ?';
|
|
$params[] = $sinceId;
|
|
}
|
|
|
|
if ($search !== '') {
|
|
$where[] = '(request_body LIKE ?)';
|
|
$params[] = "%{$search}%";
|
|
}
|
|
|
|
if ($filter === 'HAS_conversations') {
|
|
$where[] = 'request_body LIKE ?';
|
|
$params[] = '%"conversations"%';
|
|
}
|
|
|
|
$whereClause = empty($where) ? '' : 'WHERE ' . implode(' AND ', $where);
|
|
|
|
if ($sinceId) {
|
|
// Return newer logs only in ascending order for incremental updates
|
|
$rows = $db->fetchAll(
|
|
"SELECT id, SUBSTRING(request_body, 1, 1000) as snippet, status_code, ip_address, created_at FROM webhook_logs {$whereClause} ORDER BY id ASC LIMIT ?",
|
|
array_merge($params, [$limit])
|
|
);
|
|
echo json_encode(['success' => true, 'data' => $rows]);
|
|
exit;
|
|
}
|
|
|
|
$rows = $db->fetchAll(
|
|
"SELECT id, SUBSTRING(request_body, 1, 500) as snippet, status_code, ip_address, created_at FROM webhook_logs {$whereClause} ORDER BY created_at DESC LIMIT ? OFFSET ?",
|
|
array_merge($params, [$limit, $offset])
|
|
);
|
|
|
|
$total = $db->fetch(
|
|
"SELECT COUNT(*) as cnt FROM webhook_logs {$whereClause}",
|
|
$params
|
|
);
|
|
$totalCount = intval($total['cnt'] ?? 0);
|
|
|
|
echo json_encode([
|
|
'success' => true,
|
|
'data' => $rows,
|
|
'pagination' => [
|
|
'page' => $page,
|
|
'limit' => $limit,
|
|
'total' => $totalCount,
|
|
'pages' => $totalCount > 0 ? ceil($totalCount / $limit) : 0
|
|
]
|
|
]);
|
|
|
|
} catch (Exception $e) {
|
|
error_log("Error in get_webhook_logs.php: " . $e->getMessage());
|
|
http_response_code(500);
|
|
echo json_encode(['error' => 'Error interno del servidor']);
|
|
}
|