+ ${replyHtml}
${content}
+ ${reactionHtml}
@@ -773,6 +847,51 @@
}
}
+ async loadQuickReplies() {
+ const container = document.getElementById('quick-replies');
+ container.innerHTML = '';
+ try {
+ const resp = await fetch('api/get_templates.php?approved_only=1&limit=6');
+ const json = await resp.json();
+ if (json && json.success && Array.isArray(json.data)) {
+ json.data.forEach(t => {
+ const btn = document.createElement('button');
+ btn.className = 'btn btn-outline-primary btn-sm';
+ btn.style.marginRight = '6px';
+ btn.textContent = t.name;
+ btn.addEventListener('click', () => this.sendTemplateQuick(t.template_name, t.language_code || 'es'));
+ container.appendChild(btn);
+ });
+ }
+ } catch (e) {
+ console.error('Error loading quick replies', e);
+ }
+ }
+
+ async sendTemplateQuick(templateName, language) {
+ if (!this.currentUserId) return;
+ const conv = this.conversations.find(c => c.user_id === this.currentUserId);
+ const phone = conv ? conv.user_phone : document.getElementById('chat-phone').textContent;
+
+ try {
+ const resp = await fetch('api/send_message.php', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ recipient: phone, type: 'template', template_name: templateName, language })
+ });
+ const result = await resp.json();
+ if (result.success) {
+ await this.loadMessages(this.currentUserId, false);
+ await this.loadConversations();
+ } else {
+ alert('Error al enviar plantilla: ' + (result.error || JSON.stringify(result)));
+ }
+ } catch (e) {
+ console.error('Error sending template quick', e);
+ alert('Error al enviar plantilla');
+ }
+ }
+
scrollToBottom() {
const container = document.getElementById('chat-messages');
container.scrollTop = container.scrollHeight;
@@ -812,6 +931,8 @@
await this.loadMessages(this.currentUserId, false);
// Actualizar lista de conversaciones
this.loadConversations();
+ // Actualizar respuestas rápidas
+ await this.loadQuickReplies();
} else {
alert('Error al enviar mensaje: ' + (result.error || 'Error desconocido'));
}
@@ -825,6 +946,79 @@
}
}
+ async loadQuickReplies() {
+ try {
+ const resp = await fetch('api/get_templates.php?approved_only=1&limit=10');
+ const json = await resp.json();
+ const container = document.getElementById('quick-replies');
+ if (!container) return;
+ container.innerHTML = '';
+ if (json && json.success && Array.isArray(json.data)) {
+ const templates = json.data.slice(0,5);
+ templates.forEach(t => {
+ const text = (t.body_text || t.name || t.template_name || '').replace(/\n/g,' ');
+ const btn = document.createElement('button');
+ btn.className = 'btn btn-sm btn-outline-secondary';
+ btn.dataset.qr = text;
+ btn.textContent = text.length > 30 ? text.substring(0,30) + '...' : text;
+ container.appendChild(btn);
+ });
+ }
+ } catch (err) {
+ console.error('loadQuickReplies error', err);
+ }
+ }
+
+ async promptEditUser() {
+ const currentName = document.getElementById('chat-name').textContent || '';
+ const newName = prompt('Nombre del usuario:', currentName);
+ if (!newName) return;
+
+ try {
+ const resp = await fetch('api/update_user.php', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ user_id: this.currentUserId, name: newName })
+ });
+ const json = await resp.json();
+ if (json && json.success) {
+ document.getElementById('chat-name').textContent = newName;
+ this.showSuccess('Usuario actualizado');
+ this.loadConversations();
+ } else {
+ this.showError('No se pudo actualizar usuario');
+ }
+ } catch (err) {
+ console.error(err);
+ this.showError('Error actualizando usuario');
+ }
+ }
+
+ async deleteCurrentConversation() {
+ if (!confirm('¿Eliminar esta conversación? Se borrará todo el historial.')) return;
+ try {
+ const resp = await fetch('api/delete_conversation.php', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ user_id: this.currentUserId })
+ });
+ const json = await resp.json();
+ if (json && json.success) {
+ this.showSuccess('Conversación eliminada');
+ // reset UI
+ document.getElementById('chat-area').style.display = 'none';
+ document.getElementById('no-conversation').style.display = 'block';
+ this.currentUserId = null;
+ this.loadConversations();
+ } else {
+ this.showError('No se pudo eliminar la conversación');
+ }
+ } catch (err) {
+ console.error(err);
+ this.showError('Error eliminando la conversación');
+ }
+ }
+
searchConversations(query) {
const items = document.querySelectorAll('.conversation-item');
items.forEach(item => {
diff --git a/logs/system.log b/logs/system.log
index 6798d57..8d0b8aa 100644
--- a/logs/system.log
+++ b/logs/system.log
@@ -6,3 +6,15 @@ Stack trace:
#0 C:\laragon\www\whatsapp\scripts\send_template_test.php(18): WhatsAppService->__construct()
#1 {main}
thrown in C:\laragon\www\whatsapp\services\WhatsAppService.php on line 18
+[20-Jan-2026 23:53:41 America/Bogota] [webhook] __construct start
+[20-Jan-2026 23:53:42 America/Bogota] [webhook] __construct end
+[20-Jan-2026 23:53:42 America/Bogota] [webhook] handleRequest start, method=GET
+[20-Jan-2026 23:53:47 America/Bogota] [webhook] __construct start
+[20-Jan-2026 23:53:47 America/Bogota] [webhook] __construct end
+[20-Jan-2026 23:53:47 America/Bogota] [webhook] handleRequest start, method=GET
+[20-Jan-2026 23:53:55 America/Bogota] [webhook] __construct start
+[20-Jan-2026 23:53:55 America/Bogota] [webhook] __construct end
+[20-Jan-2026 23:53:55 America/Bogota] [webhook] handleRequest start, method=GET
+[20-Jan-2026 23:54:02 America/Bogota] [webhook] __construct start
+[20-Jan-2026 23:54:03 America/Bogota] [webhook] __construct end
+[20-Jan-2026 23:54:03 America/Bogota] [webhook] handleRequest start, method=GET
diff --git a/scripts/add_conversation_fields.php b/scripts/add_conversation_fields.php
new file mode 100644
index 0000000..d796017
--- /dev/null
+++ b/scripts/add_conversation_fields.php
@@ -0,0 +1,36 @@
+fetchAll("SHOW COLUMNS FROM conversations");
+ $colNames = array_column($columns, 'Field');
+
+ if (!in_array('reply_to_message_id', $colNames)) {
+ $db->query("ALTER TABLE conversations ADD COLUMN reply_to_message_id INT NULL AFTER message_id");
+ echo "Added column reply_to_message_id\n";
+ } else {
+ echo "reply_to_message_id exists\n";
+ }
+
+ if (!in_array('reaction_to_message_id', $colNames)) {
+ $db->query("ALTER TABLE conversations ADD COLUMN reaction_to_message_id INT NULL AFTER reply_to_message_id");
+ echo "Added column reaction_to_message_id\n";
+ } else {
+ echo "reaction_to_message_id exists\n";
+ }
+
+ if (!in_array('reaction_emoji', $colNames)) {
+ $db->query("ALTER TABLE conversations ADD COLUMN reaction_emoji VARCHAR(32) NULL AFTER reaction_to_message_id");
+ echo "Added column reaction_emoji\n";
+ } else {
+ echo "reaction_emoji exists\n";
+ }
+
+} catch (Exception $e) {
+ echo "Error: " . $e->getMessage() . "\n";
+}
diff --git a/scripts/add_message_is_read.php b/scripts/add_message_is_read.php
new file mode 100644
index 0000000..f8f3a85
--- /dev/null
+++ b/scripts/add_message_is_read.php
@@ -0,0 +1,15 @@
+fetch("SHOW COLUMNS FROM conversations LIKE 'is_read'");
+if ($col) {
+ echo "Column is_read already exists\n";
+ exit(0);
+}
+try {
+ $db->query("ALTER TABLE conversations ADD COLUMN is_read TINYINT(1) NULL DEFAULT 0 AFTER status");
+ echo "Added column is_read\n";
+} catch (Exception $e) {
+ echo "Failed to add is_read: " . $e->getMessage() . "\n";
+ exit(1);
+}
diff --git a/scripts/add_reaction_to_message_type.php b/scripts/add_reaction_to_message_type.php
new file mode 100644
index 0000000..d323193
--- /dev/null
+++ b/scripts/add_reaction_to_message_type.php
@@ -0,0 +1,26 @@
+fetch("SHOW COLUMNS FROM conversations LIKE 'message_type'");
+if (!$col) {
+ echo "Column message_type not found\n";
+ exit(1);
+}
+
+$type = $col['Type'];
+if (strpos($type, "'reaction'") !== false) {
+ echo "reaction already present in message_type enum\n";
+ exit(0);
+}
+
+// Construir nuevo enum
+$newEnum = "ENUM('text','image','audio','video','document','template','reaction') NOT NULL DEFAULT 'text'";
+try {
+ $db->query("ALTER TABLE conversations MODIFY COLUMN message_type $newEnum");
+ echo "Added reaction to message_type enum\n";
+} catch (Exception $e) {
+ echo "Failed to alter table: " . $e->getMessage() . "\n";
+ exit(1);
+}
diff --git a/scripts/add_user_avatar_column.php b/scripts/add_user_avatar_column.php
new file mode 100644
index 0000000..5fbf5f1
--- /dev/null
+++ b/scripts/add_user_avatar_column.php
@@ -0,0 +1,15 @@
+fetch("SHOW COLUMNS FROM users LIKE 'avatar_url'");
+if ($col) {
+ echo "Column avatar_url already exists\n";
+ exit(0);
+}
+try {
+ $db->query("ALTER TABLE users ADD COLUMN avatar_url VARCHAR(255) NULL AFTER name");
+ echo "Added column avatar_url\n";
+} catch (Exception $e) {
+ echo "Failed to add avatar_url: " . $e->getMessage() . "\n";
+ exit(1);
+}
diff --git a/scripts/db_debug.php b/scripts/db_debug.php
new file mode 100644
index 0000000..aa4171b
--- /dev/null
+++ b/scripts/db_debug.php
@@ -0,0 +1,10 @@
+fetch('SELECT * FROM conversations WHERE message_type = :mt ORDER BY id DESC LIMIT 5', ['mt' => 'reaction']);
+var_export($r);
+echo "\nAll recent rows:\n";
+$rows = $db->fetchAll('SELECT id,message_id,message_type,direction,content,reaction_to_message_id,reaction_emoji,reply_to_message_id FROM conversations ORDER BY id DESC LIMIT 10');
+foreach ($rows as $row) {
+ echo json_encode($row) . "\n";
+}
diff --git a/scripts/db_test.php b/scripts/db_test.php
new file mode 100644
index 0000000..19610d8
--- /dev/null
+++ b/scripts/db_test.php
@@ -0,0 +1,13 @@
+getMessage() . "\n";
+ echo $t->getTraceAsString() . "\n";
+}
diff --git a/scripts/debug_init_service.php b/scripts/debug_init_service.php
new file mode 100644
index 0000000..7f04c89
--- /dev/null
+++ b/scripts/debug_init_service.php
@@ -0,0 +1,24 @@
+getMessage() . "\n";
+ echo $t->getTraceAsString() . "\n";
+}
+
+try {
+ $b = new BotService();
+ echo "BotService OK\n";
+} catch (Throwable $t) {
+ echo "BotService ERR: " . $t->getMessage() . "\n";
+ echo $t->getTraceAsString() . "\n";
+}
diff --git a/scripts/describe_conversations.php b/scripts/describe_conversations.php
new file mode 100644
index 0000000..976a1a5
--- /dev/null
+++ b/scripts/describe_conversations.php
@@ -0,0 +1,7 @@
+fetchAll('DESCRIBE conversations');
+foreach ($cols as $c) {
+ echo $c['Field'] . ' => ' . $c['Type'] . PHP_EOL;
+}
diff --git a/scripts/describe_users.php b/scripts/describe_users.php
new file mode 100644
index 0000000..9299ade
--- /dev/null
+++ b/scripts/describe_users.php
@@ -0,0 +1,7 @@
+fetchAll('DESCRIBE users');
+foreach ($cols as $c) {
+ echo $c['Field'] . ' => ' . $c['Type'] . PHP_EOL;
+}
diff --git a/scripts/run_webhook_get.php b/scripts/run_webhook_get.php
new file mode 100644
index 0000000..1b4ddf7
--- /dev/null
+++ b/scripts/run_webhook_get.php
@@ -0,0 +1,24 @@
+handleRequest();
+ $out = ob_get_clean();
+ echo "Output:\n" . $out . "\n";
+} catch (Throwable $t) {
+ echo "Throwable: " . $t->getMessage() . "\n";
+ echo $t->getTraceAsString() . "\n";
+}
diff --git a/scripts/run_webhook_out.txt b/scripts/run_webhook_out.txt
new file mode 100644
index 0000000..e69de29
diff --git a/scripts/test_reaction_and_reply.php b/scripts/test_reaction_and_reply.php
new file mode 100644
index 0000000..8a3e38e
--- /dev/null
+++ b/scripts/test_reaction_and_reply.php
@@ -0,0 +1,121 @@
+insert('users', ['phone_number' => $testPhone, 'name' => 'Reactor', 'status' => 'active']);
+$origMsgId = '1001';
+$db->insert('conversations', [
+ 'user_id' => $userId,
+ 'message_id' => $origMsgId,
+ 'direction' => 'incoming',
+ 'message_type' => 'text',
+ 'content' => 'Original msg',
+ 'status' => 'received',
+ 'created_at' => date('Y-m-d H:i:s')
+]);
+
+$payload = [
+ 'object' => 'whatsapp_business_account',
+ 'entry' => [
+ [
+ 'changes' => [
+ [
+ 'field' => 'messages',
+ 'value' => [
+ 'messaging_product' => 'whatsapp',
+ 'metadata' => [
+ 'display_phone_number' => '16505551111',
+ 'phone_number_id' => '123'
+ ],
+ 'contacts' => [
+ [ 'profile' => ['name' => 'reactor'], 'wa_id' => $testPhone ]
+ ],
+ 'messages' => [
+ [
+ 'from' => $testPhone,
+ 'id' => '2001',
+ 'timestamp' => time(),
+ 'type' => 'reaction',
+ 'reaction' => ['message_id' => $origMsgId, 'emoji' => '👍']
+ ]
+ ]
+ ]
+ ]
+ ]
+ ]
+ ]
+];
+
+$r = $webhook->processPayload($payload);
+$conv = $db->fetch('SELECT * FROM conversations WHERE message_id = :mid', ['mid' => '2001']);
+if ($conv) {
+ echo "Reaction saved: reaction_to_message_id={$conv['reaction_to_message_id']}, reaction_emoji={$conv['reaction_emoji']}\n";
+} else {
+ echo "Reaction not saved\n";
+}
+
+// Cleanup reaction test
+$db->execute('DELETE FROM conversations WHERE message_id = :mid', ['mid' => '2001']);
+$db->execute('DELETE FROM conversations WHERE message_id = :mid', ['mid' => $origMsgId]);
+$db->execute('DELETE FROM users WHERE id = :id', ['id' => $userId]);
+
+// Test reply/context
+$testPhone2 = '573007777111';
+$userId2 = $db->insert('users', ['phone_number' => $testPhone2, 'name' => 'Replier', 'status' => 'active']);
+$origMsgId2 = '1002';
+$db->insert('conversations', [
+ 'user_id' => $userId2,
+ 'message_id' => $origMsgId2,
+ 'direction' => 'incoming',
+ 'message_type' => 'text',
+ 'content' => 'Original for reply',
+ 'status' => 'received',
+ 'created_at' => date('Y-m-d H:i:s')
+]);
+
+$payload2 = [
+ 'object' => 'whatsapp_business_account',
+ 'entry' => [
+ [
+ 'changes' => [
+ [
+ 'field' => 'messages',
+ 'value' => [
+ 'messages' => [
+ [
+ 'from' => $testPhone2,
+ 'id' => '2002',
+ 'timestamp' => time(),
+ 'type' => 'text',
+ 'text' => ['body' => 'Reply message'],
+ 'context' => ['id' => $origMsgId2]
+ ]
+ ]
+ ]
+ ]
+ ]
+ ]
+ ]
+];
+
+$r2 = $webhook->processPayload($payload2);
+$conv2 = $db->fetch('SELECT * FROM conversations WHERE message_id = :mid', ['mid' => '2002']);
+if ($conv2) {
+ echo "Reply saved: reply_to_message_id={$conv2['reply_to_message_id']}\n";
+} else {
+ echo "Reply not saved\n";
+}
+
+// Cleanup reply test
+$db->execute('DELETE FROM conversations WHERE message_id = :mid', ['mid' => '2002']);
+$db->execute('DELETE FROM conversations WHERE message_id = :mid', ['mid' => $origMsgId2]);
+$db->execute('DELETE FROM users WHERE id = :id', ['id' => $userId2]);
+
+echo "Done\n";
diff --git a/scripts/test_require.php b/scripts/test_require.php
new file mode 100644
index 0000000..05ffaf0
--- /dev/null
+++ b/scripts/test_require.php
@@ -0,0 +1,12 @@
+getMessage() . "\n";
+ echo $t->getTraceAsString() . "\n";
+}
diff --git a/scripts/wa_out.txt b/scripts/wa_out.txt
new file mode 100644
index 0000000000000000000000000000000000000000..609a2fd4696698179ca6be5f7ece4b9ee846924a
GIT binary patch
literal 1670
zcmeH|!A`%G_@&nDIdNT%ozZ$^8KO)W&l#JdYEKT(P3R3BYmaKS
zCx5Rw^i{<~kEvLm75T&GK25#Ch#E(#Q*(PJzyGJjo^9q#PPS*Vh8>$dlhcYbF{_
uO`UTew7C@my{#MF>%vFo?S3({3HfHeKi~I7(6uf-OIueuBSSSoE#n7AT`+(E
literal 0
HcmV?d00001
diff --git a/scripts/wa_service_test.php b/scripts/wa_service_test.php
new file mode 100644
index 0000000..7f043b6
--- /dev/null
+++ b/scripts/wa_service_test.php
@@ -0,0 +1,16 @@
+getMessage() . "\n";
+ echo $t->getTraceAsString() . "\n";
+}
+echo "END wa_service_test\n";
diff --git a/scripts/webhook_test_cli.php b/scripts/webhook_test_cli.php
new file mode 100644
index 0000000..bb4556d
--- /dev/null
+++ b/scripts/webhook_test_cli.php
@@ -0,0 +1,13 @@
+getMessage() . "\n";
+ echo $t->getTraceAsString() . "\n";
+}
diff --git a/services/BotService.php b/services/BotService.php
index a836e93..8f00e3a 100644
--- a/services/BotService.php
+++ b/services/BotService.php
@@ -35,7 +35,13 @@ class BotService {
if ($this->processSpecialCommands($phoneNumber, $messageText)) {
return;
}
-
+ // Si el asesor ya respondió después del último mensaje del usuario, frenar al bot
+ $lastIncoming = $this->db->fetch("SELECT created_at FROM conversations WHERE user_id = :uid AND direction = 'incoming' ORDER BY created_at DESC LIMIT 1", ['uid' => $user['id']]);
+ $lastOutgoing = $this->db->fetch("SELECT created_at FROM conversations WHERE user_id = :uid AND direction = 'outgoing' ORDER BY created_at DESC LIMIT 1", ['uid' => $user['id']]);
+ if ($lastOutgoing && $lastIncoming && strtotime($lastOutgoing['created_at']) >= strtotime($lastIncoming['created_at'])) {
+ // El asesor ya respondió, no enviar respuestas automáticas
+ return;
+ }
// Verificar si el usuario está en un menú
if ($user['current_menu_id']) {
$this->processMenuSelection($user, $messageText);
@@ -85,7 +91,7 @@ class BotService {
$this->exitMenu($phoneNumber);
return true;
- case 'help':
+ case 'asesor':
case 'ayuda':
$this->showHelp($phoneNumber);
return true;
diff --git a/services/WhatsAppService.php b/services/WhatsAppService.php
index a5bf3e9..3ba4bb1 100644
--- a/services/WhatsAppService.php
+++ b/services/WhatsAppService.php
@@ -514,6 +514,17 @@ class WhatsAppService
'created_at' => date('Y-m-d H:i:s')
];
+ // Si es reply (context)
+ if (isset($data['context']['message_id'])) {
+ $messageData['reply_to_message_id'] = is_numeric($data['context']['message_id']) ? intval($data['context']['message_id']) : null;
+ }
+
+ // Si es reaction
+ if ($data['type'] === 'reaction' && isset($data['reaction'])) {
+ $messageData['reaction_to_message_id'] = is_numeric($data['reaction']['message_id'] ?? null) ? intval($data['reaction']['message_id']) : null;
+ $messageData['reaction_emoji'] = $data['reaction']['emoji'] ?? null;
+ }
+
$this->db->insert('conversations', $messageData);
}
} catch (Exception $e) {
diff --git a/tests/webhook_tests.php b/tests/webhook_tests.php
index c4ac2f1..a6c86ed 100644
--- a/tests/webhook_tests.php
+++ b/tests/webhook_tests.php
@@ -306,6 +306,117 @@ class WebhookTestSuite {
return "Conversación guardada correctamente";
});
+
+ $this->webhookTest("Procesamiento de reacción entrante", function() {
+ $testPhone = '573007777000';
+ // Crear usuario y mensaje referenciado
+ $userId = $this->db->insert('users', ['phone_number' => $testPhone, 'name' => 'Reactor', 'status' => 'active']);
+ $origMsgId = '1001';
+ $this->db->insert('conversations', [
+ 'user_id' => $userId,
+ 'message_id' => $origMsgId,
+ 'direction' => 'incoming',
+ 'message_type' => 'text',
+ 'content' => 'Original msg',
+ 'status' => 'received',
+ 'created_at' => date('Y-m-d H:i:s')
+ ]);
+
+ $payload = [
+ 'object' => 'whatsapp_business_account',
+ 'entry' => [
+ [
+ 'changes' => [
+ [
+ 'field' => 'messages',
+ 'value' => [
+ 'messages' => [
+ [
+ 'from' => $testPhone,
+ 'id' => '2001',
+ 'timestamp' => time(),
+ 'type' => 'reaction',
+ 'reaction' => ['message_id' => $origMsgId, 'emoji' => '👍']
+ ]
+ ]
+ ]
+ ]
+ ]
+ ]
+ ]
+ ];
+
+ $webhook = new WhatsAppWebhook();
+ $result = $webhook->processPayload($payload);
+
+ $conv = $this->db->fetch("SELECT * FROM conversations WHERE message_id = :mid", ['mid' => '2001']);
+
+ // Limpiar
+ $this->db->execute("DELETE FROM conversations WHERE message_id = :mid", ['mid' => '2001']);
+ $this->db->execute("DELETE FROM conversations WHERE message_id = :mid", ['mid' => $origMsgId]);
+ $this->db->execute("DELETE FROM users WHERE id = :id", ['id' => $userId]);
+
+ if (!$conv) throw new Exception("Reacción no se guardó");
+ if (intval($conv['reaction_to_message_id']) !== intval($origMsgId)) throw new Exception("reaction_to_message_id no guardado correctamente");
+ if ($conv['reaction_emoji'] !== '👍') throw new Exception("reaction_emoji incorrecto");
+
+ return "Reacción procesada y guardada correctamente";
+ });
+
+ $this->webhookTest("Procesamiento de reply/context entrante", function() {
+ $testPhone = '573007777111';
+ $userId = $this->db->insert('users', ['phone_number' => $testPhone, 'name' => 'Replier', 'status' => 'active']);
+ $origMsgId = '1002';
+ $this->db->insert('conversations', [
+ 'user_id' => $userId,
+ 'message_id' => $origMsgId,
+ 'direction' => 'incoming',
+ 'message_type' => 'text',
+ 'content' => 'Original for reply',
+ 'status' => 'received',
+ 'created_at' => date('Y-m-d H:i:s')
+ ]);
+
+ $payload = [
+ 'object' => 'whatsapp_business_account',
+ 'entry' => [
+ [
+ 'changes' => [
+ [
+ 'field' => 'messages',
+ 'value' => [
+ 'messages' => [
+ [
+ 'from' => $testPhone,
+ 'id' => '2002',
+ 'timestamp' => time(),
+ 'type' => 'text',
+ 'text' => ['body' => 'Reply message'],
+ 'context' => ['id' => $origMsgId]
+ ]
+ ]
+ ]
+ ]
+ ]
+ ]
+ ]
+ ];
+
+ $webhook = new WhatsAppWebhook();
+ $result = $webhook->processPayload($payload);
+
+ $conv = $this->db->fetch("SELECT * FROM conversations WHERE message_id = :mid", ['mid' => '2002']);
+
+ // Limpiar
+ $this->db->execute("DELETE FROM conversations WHERE message_id = :mid", ['mid' => '2002']);
+ $this->db->execute("DELETE FROM conversations WHERE message_id = :mid", ['mid' => $origMsgId]);
+ $this->db->execute("DELETE FROM users WHERE id = :id", ['id' => $userId]);
+
+ if (!$conv) throw new Exception("Reply no se guardó");
+ if ($conv['reply_to_message_id'] != $origMsgId) throw new Exception("reply_to_message_id no guardado correctamente");
+
+ return "Reply/context procesado y guardado correctamente";
+ });
}
private function testWebhookSecurity() {
@@ -524,12 +635,20 @@ class WebhookTestSuite {
}
// No ejecutar si es incluido por el runner principal
-if (basename($_SERVER['PHP_SELF']) === 'webhook_tests.php') {
+if (basename($_SERVER['PHP_SELF']) === 'webhook_tests.php' || php_sapi_name() === 'cli') {
$configPath = __DIR__ . '/../config/config.php';
if (file_exists($configPath)) {
require_once $configPath;
}
+
+ // Asegurar que la clase WhatsAppWebhook esté disponible cuando se ejecutan tests desde CLI
+ $webhookPath = __DIR__ . '/../api/webhook.php';
+ if (file_exists($webhookPath)) {
+ require_once $webhookPath;
+ }
+
$suite = new WebhookTestSuite();
+ echo "RUNNING WEBHOOK TESTS\n";
$suite->runAllWebhookTests();
}
?>
\ No newline at end of file
diff --git a/tests/webhook_tests_out.txt b/tests/webhook_tests_out.txt
new file mode 100644
index 0000000000000000000000000000000000000000..58528b7b3f51c72a5648daf53c27ce99e0f84384
GIT binary patch
literal 264
zcmZ{f%?bfw6owy`${kqDX4Yc1vQR>bGJcj5t(iymIFDL;N_$@^6V)C_?c=y(KsA#@hbR&X}p3*>!getMethod('saveOutgoingMessage');
+$method->setAccessible(true);
+
+// Test reaction save
+$phone = '573001234999';
+$db->execute('DELETE FROM users WHERE phone_number = :p', ['p' => $phone]);
+$userId = $db->insert('users', ['phone_number' => $phone, 'name' => 'Outgoing Reactor', 'status' => 'active']);
+
+$data = [
+ 'to' => $phone,
+ 'type' => 'reaction',
+ 'reaction' => ['message_id' => '5001', 'emoji' => '❤️']
+];
+$response = ['messages' => [['id' => 'out_msg_1']]];
+
+$foundUser = $db->fetch('SELECT * FROM users WHERE phone_number = :p', ['p' => $phone]);
+echo "User found for outgoing reaction? " . ($foundUser ? 'yes' : 'no') . "\n";
+
+$method->invokeArgs($service, [$data, $response]);
+$conv = $db->fetch('SELECT * FROM conversations WHERE message_id = :mid', ['mid' => 'out_msg_1']);
+if ($conv) {
+ echo "Outgoing reaction saved: id={$conv['id']} reaction_to={$conv['reaction_to_message_id']} emoji={$conv['reaction_emoji']}\n";
+} else {
+ echo "Outgoing reaction NOT saved\n";
+ $recent = $db->fetchAll('SELECT id,message_id,message_type,direction,content,created_at FROM conversations WHERE user_id = :uid ORDER BY id DESC LIMIT 5', ['uid' => $userId]);
+ echo "Recent rows for user:\n";
+ foreach ($recent as $r) echo json_encode($r) . "\n";
+
+ echo "Trying direct DB insert to see if constraints block it...\n";
+ $msg = [
+ 'user_id' => $userId,
+ 'message_id' => 'direct_out_msg_1',
+ 'direction' => 'outgoing',
+ 'message_type' => 'reaction',
+ 'content' => '❤️',
+ 'status' => 'sent',
+ 'created_at' => date('Y-m-d H:i:s')
+ ];
+ try {
+ $res = $db->insert('conversations', $msg);
+ echo "Direct insert result: " . ($res ? 'ok id=' . $res : 'failed') . "\n";
+ $r2 = $db->fetch('SELECT * FROM conversations WHERE message_id = :mid', ['mid' => 'direct_out_msg_1']);
+ echo "Fetched direct row: " . json_encode($r2) . "\n";
+ $db->execute('DELETE FROM conversations WHERE message_id = :mid', ['mid' => 'direct_out_msg_1']);
+ } catch (Exception $e) {
+ echo "Direct insert threw: " . $e->getMessage() . "\n";
+ }
+}
+// cleanup
+$db->execute('DELETE FROM conversations WHERE message_id = :mid', ['mid' => 'out_msg_1']);
+$db->execute('DELETE FROM users WHERE id = :id', ['id' => $userId]);
+
+// Test text reply save
+$phone2 = '573001234998';
+$db->execute('DELETE FROM users WHERE phone_number = :p', ['p' => $phone2]);
+$userId2 = $db->insert('users', ['phone_number' => $phone2, 'name' => 'Outgoing Replier', 'status' => 'active']);
+
+$data2 = [
+ 'to' => $phone2,
+ 'type' => 'text',
+ 'context' => ['message_id' => '5002'],
+ 'text' => ['body' => 'Gracias']
+];
+$response2 = ['messages' => [['id' => 'out_msg_2']]];
+$method->invokeArgs($service, [$data2, $response2]);
+$conv2 = $db->fetch('SELECT * FROM conversations WHERE message_id = :mid', ['mid' => 'out_msg_2']);
+if ($conv2) {
+ echo "Outgoing reply saved: id={$conv2['id']} reply_to={$conv2['reply_to_message_id']}\n";
+} else {
+ echo "Outgoing reply NOT saved\n";
+}
+// cleanup
+$db->execute('DELETE FROM conversations WHERE message_id = :mid', ['mid' => 'out_msg_2']);
+$db->execute('DELETE FROM users WHERE id = :id', ['id' => $userId2]);
+
+echo "Done tests\n";
diff --git a/tests/whatsapp_service_tests_out.txt b/tests/whatsapp_service_tests_out.txt
new file mode 100644
index 0000000000000000000000000000000000000000..b0a1ade167685cbe9a671dc28161c83e5ae58112
GIT binary patch
literal 318
zcmaivJqp4=6okK8@D4db45%Ok8+$8j31$r|nnI_D9OXSWi4?OnpR37Qp=sO5VfKuW3hu+LzfQIzy3(hjJ-B;M%uNS
zDG4!y57+0)sigO%$MobdY(!StOSy36#)%{6AL(1x`r-H7VaR>?-V+mlcjB8G`J8X+
GLfa>1C^}jI
literal 0
HcmV?d00001