← All changes | includes/class-mxchat-integrator.php +1546 -3454 2.0.5 → 1.3 View file →

		@@ -1,3454 +1,1546 @@
1		-<?php
2		-if (!defined('ABSPATH')) {
3		- exit;
4		-}
5		-
6		-class MxChat_Integrator {
7		- private $options;
8		- private $prompts_options;
9		- private $chat_count;
10		- private $fallbackResponse;
11		- private $productCardHtml;
12		- private $word_handler;
13		-
14		-public function __construct() {
15		- $this->options = get_option('mxchat_options');
16		- $this->prompts_options = get_option('mxchat_prompts_options', array());
17		-
18		- $this->chat_count = get_option('mxchat_chat_count', 0);
19		- $this->word_handler = new MXChat_Word_Handler($this->options);
20		-
21		- add_action('wp_enqueue_scripts', array($this, 'mxchat_enqueue_scripts_styles'));
22		- add_action('wp_ajax_mxchat_handle_chat_request', array($this, 'mxchat_handle_chat_request'));
23		- add_action('wp_ajax_nopriv_mxchat_handle_chat_request', array($this, 'mxchat_handle_chat_request'));
24		-
25		- add_action('wp_ajax_mxchat_dismiss_pre_chat_message', array($this, 'mxchat_dismiss_pre_chat_message'));
26		- add_action('wp_ajax_nopriv_mxchat_dismiss_pre_chat_message', array($this, 'mxchat_dismiss_pre_chat_message'));
27		- // Add the AJAX actions for checking if the pre-chat message was dismissed
28		- add_action('wp_ajax_mxchat_check_pre_chat_message_status', array($this, 'mxchat_check_pre_chat_message_status'));
29		- add_action('wp_ajax_nopriv_mxchat_check_pre_chat_message_status', array($this, 'mxchat_check_pre_chat_message_status'));
30		-
31		- add_action('wp_ajax_mxchat_fetch_conversation_history', [$this, 'mxchat_fetch_conversation_history']);
32		- add_action('wp_ajax_nopriv_mxchat_fetch_conversation_history', [$this, 'mxchat_fetch_conversation_history']);
33		-
34		- add_action('wp_ajax_mxchat_add_to_cart', [$this, 'mxchat_add_to_cart']);
35		- add_action('wp_ajax_nopriv_mxchat_add_to_cart', [$this, 'mxchat_add_to_cart']);
36		-
37		- if (!wp_next_scheduled('mxchat_reset_rate_limits')) {
38		- wp_schedule_event(time(), 'daily', 'mxchat_reset_rate_limits');
39		- }
40		-
41		- // Add REST API routes registration
42		- add_action('rest_api_init', array($this, 'register_routes'));
43		-
44		- add_action('wp_ajax_mxchat_fetch_new_messages', array($this, 'mxchat_fetch_new_messages'));
45		- add_action('wp_ajax_nopriv_mxchat_fetch_new_messages', array($this, 'mxchat_fetch_new_messages'));
46		-
47		- add_action('mxchat_reset_rate_limits', array($this, 'mxchat_reset_rate_limits'));
48		-
49		- add_action('wp_ajax_mxchat_upload_pdf', [$this, 'handle_pdf_upload']);
50		- add_action('wp_ajax_nopriv_mxchat_upload_pdf', [$this, 'handle_pdf_upload']);
51		- add_action('wp_ajax_mxchat_remove_pdf', [$this, 'handle_pdf_remove']);
52		- add_action('wp_ajax_nopriv_mxchat_remove_pdf', [$this, 'handle_pdf_remove']);
53		-
54		- // Add these with your other add_action hooks
55		- add_action('wp_ajax_mxchat_upload_word', array($this, 'mxchat_handle_word_upload'));
56		- add_action('wp_ajax_nopriv_mxchat_upload_word', array($this, 'mxchat_handle_word_upload'));
57		- add_action('wp_ajax_mxchat_remove_word', array($this, 'mxchat_handle_word_remove'));
58		- add_action('wp_ajax_nopriv_mxchat_remove_word', array($this, 'mxchat_handle_word_remove'));
59		- add_action('wp_ajax_mxchat_check_word_status', array($this, 'mxchat_check_word_status'));
60		- add_action('wp_ajax_nopriv_mxchat_check_word_status', array($this, 'mxchat_check_word_status'));
61		-
62		- add_action('wp_ajax_nopriv_mxchat_handle_save_email_and_response', [$this, 'mxchat_handle_save_email_and_response']);
63		- add_action('wp_ajax_mxchat_handle_save_email_and_response', [$this, 'mxchat_handle_save_email_and_response']);
64		- add_action('wp_ajax_nopriv_mxchat_check_email_provided', [$this, 'mxchat_check_email_provided']);
65		- add_action('wp_ajax_mxchat_check_email_provided', [$this, 'mxchat_check_email_provided']);
66		-}
67		-
68		-
69		- private function mxchat_increment_chat_count() {
70		- $chat_count = get_option('mxchat_chat_count', 0);
71		- $chat_count++;
72		- update_option('mxchat_chat_count', $chat_count);
73		- }
74		-
75		-function mxchat_fetch_conversation_history() {
76		- if (empty($_POST['session_id'])) {
77		- wp_send_json_error(['message' => esc_html__('Session ID missing.', 'mxchat')]);
78		- wp_die();
79		- }
80		-
81		- $session_id = sanitize_text_field($_POST['session_id']);
82		- $history = get_option("mxchat_history_{$session_id}", []); // Retrieve stored history
83		- $chat_mode = get_option("mxchat_mode_{$session_id}", 'ai'); // Get current chat mode
84		-
85		- if (empty($history)) {
86		- // Even if history is empty, return the chat mode
87		- wp_send_json_success([
88		- 'conversation' => [],
89		- 'chat_mode' => $chat_mode
90		- ]);
91		- wp_die();
92		- }
93		-
94		- wp_send_json_success([
95		- 'conversation' => $history,
96		- 'chat_mode' => $chat_mode
97		- ]);
98		- wp_die();
99		-}
100		-private function mxchat_fetch_conversation_history_for_ajax($session_id) {
101		- $history = get_option("mxchat_history_{$session_id}", []); // Retrieve stored history based on session ID
102		- $formatted_history = [];
103		-
104		- // Format the history to align with the expected structure for OpenAI
105		- foreach ($history as $entry) {
106		- $formatted_history[] = [
107		- 'role' => $entry['role'], // Ensure this matches 'user' or 'assistant'
108		- 'content' => $entry['content']
109		- ];
110		- }
111		-
112		- return $formatted_history;
113		-}
114		-
115		-
116		-private function mxchat_fetch_conversation_history_for_ai($session_id) {
117		- $history = get_option("mxchat_history_{$session_id}", []);
118		- $formatted_history = [];
119		-
120		- // Adjusted for code-heavy conversations
121		- $max_tokens = 120000; // Context window size
122		- $reserved_tokens = 5000; // Space for system prompts + current query
123		- $current_token_count = 0;
124		-
125		- // Allowed HTML tags for content sanitization
126		- $allowed_tags = [
127		- 'pre' => ['class' => true],
128		- 'code' => ['class' => true],
129		- 'span' => ['class' => true],
130		- 'div' => ['class' => true],
131		- 'strong' => [],
132		- 'em' => []
133		- ];
134		-
135		- foreach (array_reverse($history) as $entry) {
136		- // Preserve code blocks while sanitizing other HTML
137		- $clean_content = wp_kses($entry['content'], $allowed_tags);
138		-
139		- // Detect code blocks in content
140		- $has_code = false;
141		-// Replace the HTML check with:
142		-// Allow messages that contain code blocks or are plain text
143		-if (strpos($clean_content, '<pre') === false &&
144		- strpos($clean_content, '<code') === false &&
145		- $clean_content !== strip_tags($entry['content'])) {
146		- continue;
147		-}
148		-
149		- // Skip entries that lost significant content during sanitization
150		- if (!$has_code && $clean_content !== strip_tags($entry['content'])) {
151		- continue;
152		- }
153		-
154		- // More accurate token estimation (1 token ≈ 4 characters)
155		- $token_estimate = ceil(mb_strlen($clean_content, 'UTF-8') / 4);
156		-
157		- // Check token budget with the new estimate
158		- if (($current_token_count + $token_estimate + $reserved_tokens) > $max_tokens) {
159		- // Try to fit partial content if it's the first entry
160		- if (empty($formatted_history)) {
161		- $clean_content = mb_substr($clean_content, 0, ($max_tokens - $reserved_tokens) * 4);
162		- $token_estimate = ceil(mb_strlen($clean_content, 'UTF-8') / 4);
163		- } else {
164		- break;
165		- }
166		- }
167		-
168		- // Add to formatted history
169		- $formatted_history[] = [
170		- 'role' => $entry['role'],
171		- 'content' => $clean_content
172		- ];
173		-
174		- $current_token_count += $token_estimate;
175		- }
176		-
177		- // Reverse back to maintain chronological order
178		- $formatted_history = array_reverse($formatted_history);
179		-
180		- // Add system message about code context
181		- array_unshift($formatted_history, [
182		- 'role' => 'system',
183		- 'content' => 'Preserved code blocks are marked with [CODE BLOCK PRESERVED]. '
184		- . 'Maintain formatting and syntax highlighting when referencing code.'
185		- ]);
186		-
187		- return $formatted_history;
188		-}
189		-
190		-public function register_routes() {
191		- //error_log(esc_html__('Registering MxChat REST routes', 'mxchat'));
192		-
193		- register_rest_route('mxchat/v1', '/stream', [
194		- 'methods' => 'GET',
195		- 'callback' => [$this, 'mxchat_stream_events'],
196		- 'permission_callback' => [$this, 'verify_chat_session'],
197		- ]);
198		-
199		- register_rest_route('mxchat/v1', '/agent-response', [
200		- 'methods' => 'POST',
201		- 'callback' => [$this, 'mxchat_handle_agent_response'],
202		- 'permission_callback' => [$this, 'verify_slack_request'],
203		- ]);
204		-
205		- register_rest_route('mxchat/v1', '/slack-interaction', [
206		- 'methods' => 'POST',
207		- 'callback' => [$this, 'handle_slack_interaction'],
208		- 'permission_callback' => [$this, 'verify_slack_request'],
209		- ]);
210		-
211		- //error_log(esc_html__('MxChat REST routes registered', 'mxchat'));
212		-}
213		-
214		-/**
215		- * Verify valid chat session
216		- */
217		-public function verify_chat_session($request) {
218		- $session_id = $request->get_param('session_id');
219		- if (empty($session_id)) {
220		- //error_log(esc_html__('Empty session ID in chat request', 'mxchat'));
221		- return false;
222		- }
223		-
224		- $chat_mode = get_option("mxchat_mode_{$session_id}", 'ai');
225		- return $chat_mode === 'agent';
226		-}
227		-
228		-/**
229		- * Verify request is coming from Slack.
230		- *
231		- * @param WP_REST_Request $request
232		- * @return bool True if valid, false otherwise.
233		- */
234		-public function verify_slack_request($request) {
235		- // Get the Slack signing secret from your plugin options
236		- $valid_key = $this->options['live_agent_secret_key'] ?? '';
237		-
238		- if (empty($valid_key)) {
239		- //error_log(esc_html__('Slack signing secret not configured', 'mxchat'));
240		- return false;
241		- }
242		-
243		- $timestamp = $request->get_header('X-Slack-Request-Timestamp');
244		- $slack_signature = $request->get_header('X-Slack-Signature');
245		-
246		- // Verify timestamp to prevent replay attacks
247		- if (abs(time() - intval($timestamp)) > 300) {
248		- //error_log(esc_html__('Slack request timestamp too old', 'mxchat'));
249		- return false;
250		- }
251		-
252		- // Get raw request body
253		- $request_body = file_get_contents('php://input');
254		-
255		- // Create the signature base string
256		- $sig_basestring = "v0:{$timestamp}:{$request_body}";
257		-
258		- // Calculate expected signature
259		- $my_signature = 'v0=' . hash_hmac('sha256', $sig_basestring, $valid_key);
260		-
261		- // Compare signatures
262		- return hash_equals($my_signature, $slack_signature);
263		-}
264		-public function mxchat_stream_events(WP_REST_Request $request) {
265		- header('Content-Type: text/event-stream');
266		- header('Cache-Control: no-cache');
267		- header('Connection: keep-alive');
268		-
269		- $session_id = sanitize_text_field($request->get_param('session_id'));
270		- $last_seen_id = sanitize_text_field($request->get_param('last_seen_id')) ?: '';
271		-
272		- if (empty($session_id)) {
273		- echo esc_html__("event: error\ndata: ", 'mxchat') . esc_html__('Missing session_id', 'mxchat') . "\n\n";
274		- flush();
275		- exit;
276		- }
277		-
278		- $history = get_option("mxchat_history_{$session_id}", []);
279		-
280		- // Filter only new messages
281		- $new_messages = array_filter($history, function ($message) use ($last_seen_id) {
282		- return !empty($message['id']) && $message['id'] > $last_seen_id;
283		- });
284		-
285		- // Send new messages if available
286		- if (!empty($new_messages)) {
287		- echo esc_html__("event: newMessages\ndata: ", 'mxchat') . json_encode(array_values($new_messages)) . "\n\n";
288		- } else {
289		- // Keep the connection alive
290		- echo esc_html__("event: keepAlive\ndata: ", 'mxchat') . "{}\n\n";
291		- }
292		- flush();
293		- exit;
294		-}
295		-
296		-
297		-
298		-
299		-private function mxchat_save_chat_message($session_id, $role, $message) {
300		- global $wpdb;
301		-
302		- $table_name = $wpdb->prefix . 'mxchat_chat_transcripts';
303		- //error_log("[DEBUG] mxchat_save_chat_message -> START for session_id: {$session_id}, role: {$role}");
304		-
305		- // 1) Extract agent name if present
306		- $agent_name = '';
307		- if (preg_match('/^Agent: (.*?) - /', $message, $matches)) {
308		- $agent_name = $matches[1];
309		- $message = str_replace("Agent: $agent_name - ", '', $message);
310		-
311		- $session_meta_key = "mxchat_agent_name_{$session_id}";
312		- if (empty(get_option($session_meta_key))) {
313		- update_option($session_meta_key, $agent_name);
314		- //error_log("[DEBUG] mxchat_save_chat_message -> Stored agent_name in option: {$session_meta_key} => {$agent_name}");
315		- }
316		- }
317		-
318		- // 2) Generate unique message_id
319		- $message_id = uniqid();
320		- //error_log("[DEBUG] mxchat_save_chat_message -> Generated message_id: {$message_id}");
321		-
322		- // 3) Determine user_id
323		- $user_id = is_user_logged_in() ? get_current_user_id() : 0;
324		-
325		- // 4) Determine user_identifier
326		- $user_identifier = $agent_name
327		- ? $agent_name
328		- : MxChat_User::mxchat_get_user_identifier();
329		-
330		- // 5) Determine displayed_name
331		- $user_email = MxChat_User::mxchat_get_user_email();
332		- $displayed_name = $agent_name ? $agent_name : ($user_email ?: $user_identifier);
333		-
334		- // 6) Check for a saved email in wp_options
335		- $email_option_key = "mxchat_email_{$session_id}";
336		- $saved_email = get_option($email_option_key);
337		- //error_log("[DEBUG] mxchat_save_chat_message -> Checking wp_options for email_option_key: {$email_option_key}, found: {$saved_email}");
338		-
339		- // If found, update DB user_email
340		- if ($saved_email) {
341		- $update_res = $wpdb->update(
342		- $table_name,
343		- ['user_email' => $saved_email],
344		- ['session_id' => $session_id],
345		- ['%s'],
346		- ['%s']
347		- );
348		- //error_log("[DEBUG] mxchat_save_chat_message -> Attempted DB user_email update for session_id {$session_id}. update_res: {$update_res}");
349		- }
350		-
351		- // 7) Save to session history in wp_options
352		- $history_key = "mxchat_history_{$session_id}";
353		- $history = get_option($history_key, []);
354		- $history[] = [
355		- 'id' => $message_id,
356		- 'role' => $role,
357		- 'content' => $message,
358		- 'timestamp' => round(microtime(true) * 1000),
359		- 'agent_name' => $displayed_name,
360		- ];
361		- update_option($history_key, $history);
362		- //error_log("[DEBUG] mxchat_save_chat_message -> Updated session history in option: {$history_key}");
363		-
364		- // 8) Save the message to DB (INSERT)
365		- $insert_data = [
366		- 'user_id' => $user_id,
367		- 'user_identifier'=> $user_identifier,
368		- 'user_email' => $saved_email ?: $user_email,
369		- 'session_id' => $session_id,
370		- 'role' => $role,
371		- 'message' => $message,
372		- 'timestamp' => current_time('mysql', 1),
373		- ];
374		- $wpdb->insert($table_name, $insert_data);
375		- //error_log("[DEBUG] mxchat_save_chat_message -> Inserted message into DB. row_id: {$wpdb->insert_id}, data: " . print_r($insert_data, true));
376		-
377		- //error_log("[DEBUG] mxchat_save_chat_message -> END for session_id: {$session_id}");
378		- return $message_id;
379		-}
380		-
381		-public function mxchat_handle_save_email_and_response() {
382		- //error_log('[DEBUG] ---------- mxchat_handle_save_email_and_response START ----------');
383		-
384		- // Validate nonce
385		- if (!isset($_POST['nonce']) || !wp_verify_nonce($_POST['nonce'], 'mxchat_chat_nonce')) {
386		- error_log(esc_html__('[ERROR] Invalid nonce in mxchat_handle_save_email_and_response', 'mxchat'));
387		- wp_send_json_error(['message' => esc_html__('Invalid nonce.', 'mxchat')]);
388		- wp_die();
389		- }
390		-
391		- $session_id = isset($_POST['session_id']) ? sanitize_text_field($_POST['session_id']) : '';
392		- $email = isset($_POST['email']) ? sanitize_email($_POST['email']) : '';
393		-
394		- //error_log("[DEBUG] handle_save_email_and_response -> session_id: {$session_id}, email: {$email}");
395		-
396		- if (empty($session_id) || empty($email)) {
397		- //error_log("[ERROR] Missing session_id or email: session_id={$session_id}, email={$email}");
398		- wp_send_json_error(['message' => esc_html__('Session ID or email is missing.', 'mxchat')]);
399		- wp_die();
400		- }
401		-
402		- // 1) Always store in wp_options
403		- $option_key = "mxchat_email_{$session_id}";
404		- update_option($option_key, $email);
405		- //error_log("[DEBUG] handle_save_email_and_response -> updated option: {$option_key} => {$email}");
406		-
407		- // 2) (Optional) Also store in DB if a row already exists
408		- global $wpdb;
409		- $table_name = $wpdb->prefix . 'mxchat_chat_transcripts';
410		-
411		- // Make sure we have a valid placeholder in prepare
412		- $sql = $wpdb->prepare("SELECT COUNT(*) FROM {$table_name} WHERE session_id = %s", $session_id);
413		- $session_count = $wpdb->get_var($sql);
414		-
415		- //error_log("[DEBUG] handle_save_email_and_response -> session_count for {$session_id}: {$session_count} (SQL: {$sql})");
416		-
417		- if ($session_count) {
418		- // Update user_email if row(s) exist
419		- $update_sql = $wpdb->prepare(
420		- "UPDATE {$table_name} SET user_email = %s WHERE session_id = %s",
421		- $email,
422		- $session_id
423		- );
424		- $wpdb->query($update_sql);
425		- //error_log("[DEBUG] handle_save_email_and_response -> DB updated: {$update_sql}");
426		- } else {
427		- //error_log("[INFO] handle_save_email_and_response -> No DB entry for {$session_id}, so email is only in wp_options.");
428		- }
429		-
430		- // Provide success response
431		- $bot_message = __('Thanks for providing your email! You can continue chatting now.', 'mxchat');
432		- //error_log("[DEBUG] handle_save_email_and_response -> success, returning bot_message: {$bot_message}");
433		- wp_send_json_success(['message' => $bot_message]);
434		- wp_die();
435		-}
436		-
437		-public function mxchat_check_email_provided() {
438		- //error_log('[DEBUG] ---------- mxchat_check_email_provided START ----------');
439		-
440		- if (!isset($_POST['nonce']) || !wp_verify_nonce($_POST['nonce'], 'mxchat_chat_nonce')) {
441		- //error_log('[ERROR] Invalid nonce in mxchat_check_email_provided');
442		- wp_send_json_error(['message' => esc_html__('Invalid nonce', 'mxchat')]);
443		- }
444		-
445		- $session_id = isset($_POST['session_id']) ? sanitize_text_field($_POST['session_id']) : '';
446		- if (empty($session_id)) {
447		- //error_log('[ERROR] No session ID provided in mxchat_check_email_provided');
448		- wp_send_json_error(['message' => esc_html__('No session ID provided', 'mxchat')]);
449		- }
450		-
451		- // Check if the user is logged in
452		- if (is_user_logged_in()) {
453		- $current_user = wp_get_current_user();
454		- //error_log("[DEBUG] User is logged in as {$current_user->user_email}");
455		- wp_send_json_success(['logged_in' => true, 'email' => $current_user->user_email]);
456		- }
457		-
458		- $option_key = "mxchat_email_{$session_id}";
459		- $stored_email = get_option($option_key, '');
460		-
461		- //error_log("[DEBUG] mxchat_check_email_provided -> Checking option: {$option_key}, found: {$stored_email}");
462		-
463		- if (!empty($stored_email)) {
464		- //error_log("[DEBUG] mxchat_check_email_provided -> Email found, returning success");
465		- wp_send_json_success(['email' => $stored_email]);
466		- } else {
467		- //error_log("[DEBUG] mxchat_check_email_provided -> No email found, returning error");
468		- wp_send_json_error(['message' => esc_html__('No email found', 'mxchat')]);
469		- }
470		-}
471		-
472		-
473		-// First, add this helper function to get the highest rate limit for a user's roles
474		-private function get_user_role_rate_limit($user_id) {
475		- //error_log(esc_html__("Checking rate limit for user ID: ", 'mxchat') . $user_id);
476		-
477		- if (!$user_id) {
478		- //error_log(esc_html__("No user ID provided, using logged-out limit: ", 'mxchat') . ($this->options['rate_limit_logged_out'] ?? '10'));
479		- return $this->options['rate_limit_logged_out'] ?? '10';
480		- }
481		-
482		- $user = get_userdata($user_id);
483		- if (!$user || !$user->roles) {
484		- //error_log(esc_html__("No user data or roles found, using logged-out limit: ", 'mxchat') . ($this->options['rate_limit_logged_out'] ?? '10'));
485		- return $this->options['rate_limit_logged_out'] ?? '10';
486		- }
487		-
488		- //error_log(esc_html__("User roles: ", 'mxchat') . print_r($user->roles, true));
489		- //error_log(esc_html__("Available role rate limits: ", 'mxchat') . print_r($this->options['role_rate_limits'] ?? [], true));
490		-
491		- $max_limit = 0;
492		- foreach ($user->roles as $role) {
493		- //error_log(esc_html__("Checking limit for role: ", 'mxchat') . $role);
494		- if (isset($this->options['role_rate_limits'][$role])) {
495		- $role_limit = $this->options['role_rate_limits'][$role];
496		- //error_log(esc_html__("Found limit for role ", 'mxchat') . $role . esc_html__(": ", 'mxchat') . $role_limit);
497		-
498		- if ($role_limit === 'unlimited') {
499		- //error_log(esc_html__("Returning unlimited for role: ", 'mxchat') . $role);
500		- return 'unlimited';
501		- }
502		-
503		- $max_limit = max($max_limit, (int)$role_limit);
504		- //error_log(esc_html__("Current max limit: ", 'mxchat') . $max_limit);
505		- } else {
506		- //error_log(esc_html__("No limit found for role: ", 'mxchat') . $role);
507		- }
508		- }
509		-
510		- $final_limit = $max_limit > 0 ? (string)$max_limit : '100';
511		- //error_log(esc_html__("Final rate limit: ", 'mxchat') . $final_limit);
512		- return $final_limit;
513		-}
514		-
515		-
516		-// Add this to your plugin's main PHP file
517		-public function mxchat_check_new_messages() {
518		- if (!isset($_POST['session_id']) || !isset($_POST['last_seen_id'])) {
519		- wp_send_json_error(['message' => 'Missing required parameters']);
520		- wp_die();
521		- }
522		-
523		- $session_id = sanitize_text_field($_POST['session_id']);
524		- $last_seen_id = sanitize_text_field($_POST['last_seen_id']);
525		-
526		- // Get chat history
527		- $history = get_option("mxchat_history_{$session_id}", []);
528		-
529		- if (empty($history)) {
530		- wp_send_json_success([
531		- 'hasNewMessages' => false,
532		- 'new_messages' => []
533		- ]);
534		- wp_die();
535		- }
536		-
537		- // Filter new messages
538		- $new_messages = array_filter($history, function($message) use ($last_seen_id) {
539		- return isset($message['id']) && $message['id'] > $last_seen_id;
540		- });
541		-
542		- // Sort by ID to ensure proper order
543		- usort($new_messages, function($a, $b) {
544		- return $a['id'] <=> $b['id'];
545		- });
546		-
547		- wp_send_json_success([
548		- 'hasNewMessages' => !empty($new_messages),
549		- 'new_messages' => array_values($new_messages),
550		- 'latestMessageId' => end($new_messages)['id'] ?? $last_seen_id
551		- ]);
552		- wp_die();
553		-}
554		-
555		-public function mxchat_handle_chat_request() {
556		- global $wpdb;
557		-
558		-
559		- // Check if MX Chat Moderation is active
560		- if (class_exists('MX_Chat_Moderation')) {
561		- // Get user email and IP
562		- $user_email = '';
563		- $user_ip = $_SERVER['REMOTE_ADDR'];
564		-
565		- // If user is logged in, get their email
566		- if (is_user_logged_in()) {
567		- $current_user = wp_get_current_user();
568		- $user_email = $current_user->user_email;
569		- }
570		-
571		- // Create ban handler instance
572		- $ban_handler = new MX_Chat_Ban_Handler();
573		-
574		- // Check if user is banned by IP
575		- if ($ban_handler->check_ban($user_ip, 'ip')) {
576		- wp_send_json([
577		- 'success' => false,
578		- 'message' => esc_html__('Access denied. Your IP address has been banned.', 'mxchat'),
579		- 'status' => 'banned'
580		- ]);
581		- wp_die();
582		- }
583		-
584		- // If user is logged in, also check email
585		- if (!empty($user_email) && $ban_handler->check_ban($user_email, 'email')) {
586		- wp_send_json([
587		- 'success' => false,
588		- 'message' => esc_html__('Access denied. Your email address has been banned.', 'mxchat'),
589		- 'status' => 'banned'
590		- ]);
591		- wp_die();
592		- }
593		- }
594		-
595		-
596		- // Reset fallback response at the start of each request
597		- $this->fallbackResponse = ['text' => '', 'html' => '', 'images' => []];
598		- $this->productCardHtml = '';
599		-
600		- // Get the actual WordPress user ID if logged in
601		- $is_logged_in = is_user_logged_in();
602		- if ($is_logged_in) {
603		- $user_id = get_current_user_id(); // This will get the actual WordPress user ID
604		- } else {
605		- // For logged-out users, use your existing identifier method
606		- $user_id = $this->mxchat_get_user_identifier();
607		- }
608		-
609		- // Get and sanitize the user identifier
610		- $user_id = sanitize_key($user_id);
611		-
612		- // Determine if user is logged in
613		- $is_logged_in = is_user_logged_in();
614		- //error_log("User logged in status: " . ($is_logged_in ? 'true' : 'false'));
615		-
616		- // Get rate limit based on user status
617		- // Get rate limit based on user status
618		- $rate_limit = $is_logged_in
619		- ? $this->get_user_role_rate_limit($user_id)
620		- : ($this->options['rate_limit_logged_out'] ?? '10');
621		-
622		- //error_log("Selected rate limit: " . $rate_limit);
623		-
624		- // Rest of your code remains the same
625		- // If rate limit is 'unlimited', skip rate limiting checks
626		- if ($rate_limit !== 'unlimited') {
627		- // Convert rate limit to integer
628		- $rate_limit = intval($rate_limit);
629		- // Setup rate limiting
630		- $rate_limit_transient_key = 'mxchat_chat_limit_' . $user_id;
631		- $chat_count = get_transient($rate_limit_transient_key);
632		- if ($chat_count === false) {
633		- // Initialize new counter if none exists
634		- $chat_count = 0;
635		- }
636		- // Check if user has exceeded their rate limit
637		- if ($chat_count >= $rate_limit) {
638		- // Get custom rate limit message or use default
639		- $rate_limit_message = isset($this->options['rate_limit_message'])
640		- ? $this->options['rate_limit_message']
641		- : esc_html__('Rate limit exceeded. Please try again later.', 'mxchat');
642		- // Replace placeholder if it exists in the message
643		- $rate_limit_message = str_replace(
644		- array('{limit}', '{count}', '{remaining}'),
645		- array($rate_limit, $chat_count, max(0, $rate_limit - $chat_count)),
646		- $rate_limit_message
647		- );
648		- wp_send_json([
649		- 'success' => false,
650		- 'message' => $rate_limit_message,
651		- 'status' => 'rate_limit_exceeded',
652		- 'limit' => $rate_limit,
653		- 'count' => $chat_count
654		- ]);
655		- wp_die();
656		- }
657		- // Increment the counter
658		- $chat_count++;
659		- // Store the updated count with 24-hour expiration
660		- set_transient($rate_limit_transient_key, $chat_count, DAY_IN_SECONDS);
661		- }
662		-
663		- // Rest of your existing code...
664		- $session_id = isset($_POST['session_id']) ? sanitize_text_field($_POST['session_id']) : '';
665		- //error_log("Session ID: $session_id");
666		-
667		- if (empty($session_id)) {
668		- //error_log("Error: Session ID is missing.");
669		- wp_send_json_error(esc_html__('Session ID is missing.', 'mxchat'));
670		- wp_die();
671		- }
672		-
673		- // Validate and sanitize the incoming message
674		- if (empty($_POST['message'])) {
675		- //error_log("Error: No message received.");
676		- wp_send_json_error(esc_html__('No message received.', 'mxchat'));
677		- wp_die();
678		- }
679		-
680		-
681		-// Modify the message sanitization to preserve PHP tags in code blocks
682		-$allowed_tags = [
683		- 'pre' => [],
684		- 'code' => ['class' => true],
685		- 'span' => ['class' => true],
686		- 'div' => ['class' => true],
687		-];
688		-
689		-// First preserve code blocks
690		-$message = preg_replace_callback('/<pre><code.*?>.*?<\/code><\/pre>/s', function($matches) {
691		- return htmlspecialchars_decode($matches[0]);
692		-}, $_POST['message']);
693		-
694		-// Then apply sanitization
695		-$message = wp_kses($message, $allowed_tags);
696		-
697		-// Decode code blocks
698		-$message = preg_replace_callback('/(&lt;pre&gt;&lt;code.*?&gt;.*?&lt;\/code&gt;&lt;\/pre&gt;)/s', function($matches) {
699		- return htmlspecialchars_decode($matches[1]);
700		-}, $message);
701		-
702		-$message = trim($message);
703		-
704		-// Preserve code blocks from markdown conversion
705		-$message = preg_replace('/```(\w+)?\s*([\s\S]+?)```/s', '<pre><code class="$1">$2</code></pre>', $message);
706		-
707		- // Save the user's message
708		- $this->mxchat_save_chat_message($session_id, 'user', $message);
709		-
710		- // Check if the message is an email address
711		- if (is_email($message)) {
712		- // Add the email to Loops
713		- $this->add_email_to_loops($message);
714		-
715		- // Send success response
716		- $response_message = $this->options['email_capture_response'] ??
717		- esc_html__('Thank you! Your coupon is on the way!', 'mxchat');
718		-
719		- wp_send_json([
720		- 'success' => true,
721		- 'status' => 'email_captured',
722		- 'message' => $response_message
723		- ]);
724		- wp_die();
725		- }
726		-
727		- $intent_info = '';
728		-
729		- // Check chat mode
730		- $chat_mode = get_option("mxchat_mode_{$session_id}", 'ai');
731		- //error_log("Chat Mode: $chat_mode");
732		-
733		- // Handle agent mode
734		- if ($chat_mode === 'agent') {
735		- // First, check for switch intent before doing anything else
736		- $intent_matched = $this->mxchat_check_intent_and_invoke_callback($message, $user_id, $session_id);
737		-
738		- // If we matched an intent and it's the switch intent, handle it
739		- if ($intent_matched && !empty($this->fallbackResponse['text'])) {
740		- //error_log("Switch to chatbot intent detected");
741		-
742		- // Update chat mode first
743		- update_option("mxchat_mode_{$session_id}", 'ai');
744		-
745		- // Clear any existing PDF context to start fresh
746		- $this->clear_pdf_transients($session_id);
747		-
748		- // Prepare clean switch response
749		- $response_data = [
750		- 'text' => $this->fallbackResponse['text'],
751		- 'html' => '',
752		- 'session_id' => $session_id,
753		- 'chat_mode' => 'ai'
754		- ];
755		-
756		- // Save the mode switch message
757		- $this->mxchat_save_chat_message($session_id, 'system', esc_html__('Switched to AI chat mode', 'mxchat'));
758		- $this->mxchat_save_chat_message($session_id, 'bot', $this->fallbackResponse['text']);
759		-
760		- // Send response and exit
761		- wp_send_json($response_data);
762		- wp_die();
763		- } elseif (!$intent_matched) {
764		- // No intent matched, handle live agent message
765		- try {
766		- $this->mxchat_send_user_message_to_agent($message, $user_id, $session_id);
767		- //error_log("Message sent to agent.");
768		-
769		- wp_send_json_success([
770		- 'status' => 'waiting_for_agent',
771		- 'message' => esc_html__('Message sent to live agent.', 'mxchat')
772		- ]);
773		- } catch (\Exception $e) {
774		- //error_log("Error sending message to agent: " . $e->getMessage());
775		- wp_send_json_error(esc_html__('Failed to send message to agent', 'mxchat'));
776		- }
777		- wp_die();
778		- }
779		- }
780		-
781		- // Step 1: Check for new PDF URL in the message
782		- if (preg_match('/https?:\/\/[^\s"]+/i', $message, $matches)) {
783		- $new_pdf_url = $matches[0];
784		-
785		- // Check if this is likely a PDF-related request
786		- $pdf_keywords = ['pdf', 'document', 'read', 'analyze'];
787		- $is_pdf_request = false;
788		-
789		- foreach ($pdf_keywords as $keyword) {
790		- if (stripos($message, $keyword) !== false) {
791		- $is_pdf_request = true;
792		- break;
793		- }
794		- }
795		-
796		- // If it looks like a PDF request or we're waiting for a PDF URL
797		- if ($is_pdf_request || get_transient('mxchat_waiting_for_pdf_url_' . $session_id)) {
798		- // Validate HTTPS
799		- if (wp_http_validate_url($new_pdf_url) && parse_url($new_pdf_url, PHP_URL_SCHEME) === 'https') {
800		- // Extract filename from URL
801		- $pdf_filename = basename(parse_url($new_pdf_url, PHP_URL_PATH));
802		-
803		- // Clear previous PDF transients
804		- $this->clear_pdf_transients($session_id);
805		-
806		- // Process new PDF
807		- $max_pages = $this->options['pdf_max_pages'] ?? 69;
808		- $embeddings = $this->fetch_and_split_pdf_pages($new_pdf_url, $max_pages);
809		-
810		- if ($embeddings === 'too_many_pages') {
811		- $error_text = sprintf(
812		- $this->options['pdf_intent_error_text'] ??
813		- esc_html__("The provided PDF exceeds the maximum allowed limit of %d pages. Please provide a smaller document.", 'mxchat'),
814		- $max_pages
815		- );
816		- $this->fallbackResponse['text'] = $error_text;
817		- } elseif ($embeddings) {
818		- // Store new PDF information
819		- // Create a more meaningful filename from URL
820		- $pdf_filename = basename(parse_url($new_pdf_url, PHP_URL_PATH));
821		-
822		- // If the filename is generic (like results_download.php), create a more descriptive one
823		- if (in_array($pdf_filename, ['results_download.php', 'download.php', 'view.php', 'pdf.php']) ||
824		- strpos($pdf_filename, '.php') !== false) {
825		- // Create a timestamp-based name
826		- $pdf_filename = 'Document_' . date('Y-m-d_H-i') . '.pdf';
827		- }
828		-
829		- set_transient('mxchat_pdf_url_' . $session_id, $new_pdf_url, HOUR_IN_SECONDS);
830		- set_transient('mxchat_pdf_filename_' . $session_id, $pdf_filename, HOUR_IN_SECONDS);
831		- set_transient('mxchat_pdf_embeddings_' . $session_id, $embeddings, HOUR_IN_SECONDS);
832		- set_transient('mxchat_include_pdf_in_context_' . $session_id, true, HOUR_IN_SECONDS);
833		-
834		- $success_text = $this->options['pdf_intent_success_text'] ??
835		- esc_html__("I've processed the new PDF '{$pdf_filename}'. What questions do you have about it?", 'mxchat');
836		-
837		- // Return success with filename for UI update
838		- wp_send_json([
839		- 'success' => true,
840		- 'message' => $success_text,
841		- 'data' => [
842		- 'filename' => $pdf_filename
843		- ]
844		- ]);
845		- wp_die();
846		- } else {
847		- $error_text = $this->options['pdf_intent_error_text'] ??
848		- esc_html__("Sorry, I couldn't process the PDF. Please ensure it's a valid file.", 'mxchat');
849		- $this->fallbackResponse['text'] = $error_text;
850		- }
851		-
852		- wp_send_json([
853		- 'success' => false,
854		- 'message' => $this->fallbackResponse['text']
855		- ]);
856		- wp_die();
857		- }
858		- }
859		- }
860		-
861		- // Step 2: Detect intent and handle intent-based responses
862		- $intent_matched = $this->mxchat_check_intent_and_invoke_callback($message, $user_id, $session_id);
863		- //error_log("Intent Matched: " . ($intent_matched ? "Yes" : "No"));
864		-
865		- // Step 3: If intent is matched and handled, respond immediately
866		- if ($intent_matched && (!empty($this->fallbackResponse['text']) || !empty($this->fallbackResponse['html']))) {
867		- //error_log("Intent response triggered.");
868		- $response_data = [
869		- 'text' => $this->fallbackResponse['text'],
870		- 'html' => $this->fallbackResponse['html'],
871		- 'session_id' => $session_id
872		- ];
873		- $this->mxchat_save_chat_message($session_id, 'bot', $this->fallbackResponse['text'] . $this->fallbackResponse['html']);
874		- wp_send_json($response_data);
875		- wp_die();
876		- }
877		-
878		- // If no intent matched or product not found, proceed with AI response
879		- //error_log("No matching intent or fallback. Generating AI response.");
880		-
881		- // Step 4: Generate AI response
882		- $conversation_history = $this->mxchat_fetch_conversation_history_for_ai($session_id);
883		- $this->mxchat_increment_chat_count();
884		-
885		- // Generate embedding for the user's query
886		- $user_message_embedding = $this->mxchat_generate_embedding($message, $this->options['api_key']);
887		- if (!is_array($user_message_embedding)) {
888		- //error_log("Failed to generate message embedding for session $session_id");
889		- wp_send_json_error(esc_html__('Error processing your message.', 'mxchat'));
890		- wp_die();
891		- }
892		-
893		- // Build context with both knowledge base and PDF content if available
894		- $context_content = "User asked: '{$message}'\n\n";
895		-
896		- // Get relevant content from knowledge base
897		- $relevant_content = $this->mxchat_find_relevant_content($user_message_embedding);
898		- if (!empty($relevant_content)) {
899		- $context_content .= "Relevant content from knowledge database:\n" . $relevant_content . "\n\n";
900		- }
901		-
902		-
903		- // Check for and include PDF content
904		- $pdf_url = get_transient('mxchat_pdf_url_' . $session_id);
905		- $pdf_embeddings = get_transient('mxchat_pdf_embeddings_' . $session_id);
906		- $pdf_filename = get_transient('mxchat_pdf_filename_' . $session_id);
907		- if ($pdf_url && $pdf_embeddings && get_transient('mxchat_include_pdf_in_context_' . $session_id)) {
908		- $relevant_pdf_pages = $this->find_relevant_pdf_pages($user_message_embedding, $pdf_embeddings);
909		- if (!empty($relevant_pdf_pages)) {
910		- $context_content .= "Relevant content from PDF document '{$pdf_filename}':\n";
911		- foreach ($relevant_pdf_pages as $page_data) {
912		- $context_content .= "Page {$page_data['page_number']} of '{$pdf_filename}': {$page_data['text']}\n";
913		- }
914		- $context_content .= "\n";
915		- }
916		- }
917		-
918		- // Check for and include Word content
919		- $word_url = get_transient('mxchat_word_url_' . $session_id);
920		- $word_embeddings = get_transient('mxchat_word_embeddings_' . $session_id);
921		- $word_filename = get_transient('mxchat_word_filename_' . $session_id);
922		- if ($word_url && $word_embeddings && get_transient('mxchat_include_word_in_context_' . $session_id)) {
923		- $relevant_word_chunks = $this->word_handler->mxchat_find_relevant_word_chunks($user_message_embedding, $word_embeddings);
924		- if (!empty($relevant_word_chunks)) {
925		- $context_content .= "Relevant content from Word document '{$word_filename}':\n";
926		- foreach ($relevant_word_chunks as $chunk_data) {
927		- $context_content .= "Section {$chunk_data['chunk_number']} of '{$word_filename}': {$chunk_data['text']}\n";
928		- }
929		- $context_content .= "\n";
930		- }
931		- }
932		- // Generate the response using the full context
933		- $response = $this->mxchat_generate_response(
934		- $context_content,
935		- $this->options['api_key'],
936		- $this->options['xai_api_key'],
937		- $this->options['claude_api_key'],
938		- $this->options['deepseek_api_key'],
939		- $conversation_history
940		- );
941		-
942		- $this->mxchat_save_chat_message($session_id, 'bot', $response);
943		-
944		- // Step 5: Save additional content if available
945		- if (!empty($this->productCardHtml)) {
946		- $this->mxchat_save_chat_message($session_id, 'bot', $this->productCardHtml);
947		- }
948		-
949		- if (!empty($this->fallbackResponse['html'])) {
950		- $this->mxchat_save_chat_message($session_id, 'bot', $this->fallbackResponse['html']);
951		- }
952		-
953		- // Step 6: Return the response
954		- $response_data = [
955		- 'text' => $response,
956		- 'html' => !empty($this->productCardHtml) ? $this->productCardHtml : ($this->fallbackResponse['html'] ?? ''),
957		- 'session_id' => $session_id
958		- ];
959		-
960		- wp_send_json($response_data);
961		- wp_die();
962		-}
963		-
964		-// New function to check intents and invoke the callback function
965		-private function mxchat_check_intent_and_invoke_callback($message, $user_id, $session_id) {
966		- global $wpdb;
967		- $chat_mode = get_option("mxchat_mode_{$session_id}", 'ai');
968		-
969		- //error_log('🔍 MXCHAT DEBUG: Intent Check Started ==================');
970		- //error_log("🔍 MXCHAT DEBUG: Message: '$message'");
971		- //error_log("🔍 MXCHAT DEBUG: Chat Mode: $chat_mode");
972		-
973		- // Generate the user embedding
974		- //error_log('🔄 MXCHAT DEBUG: Generating user embedding');
975		- $user_embedding = $this->mxchat_generate_embedding($message, $this->options['api_key']);
976		- if (!is_array($user_embedding)) {
977		- //error_log('❌ MXCHAT DEBUG: Failed to generate user embedding');
978		- return false;
979		- }
980		- //error_log('✅ MXCHAT DEBUG: User embedding generated successfully');
981		-
982		- // Fetch intents from the database
983		- $table_name = $wpdb->prefix . 'mxchat_intents';
984		- if ($chat_mode === 'agent') {
985		- //error_log('🔍 MXCHAT DEBUG: Agent mode - fetching only chatbot switch intent');
986		- $query = $wpdb->prepare(
987		- "SELECT * FROM $table_name WHERE callback_function = %s",
988		- 'mxchat_handle_switch_to_chatbot_intent'
989		- );
990		- $intents = $wpdb->get_results($query);
991		- } else {
992		- //error_log('🔍 MXCHAT DEBUG: AI mode - fetching all intents');
993		- $intents = $wpdb->get_results("SELECT * FROM $table_name");
994		- }
995		-
996		- //error_log('🔍 MXCHAT DEBUG: Found ' . count($intents) . ' intents to check');
997		-
998		- if (empty($intents)) {
999		- //error_log('❌ MXCHAT DEBUG: No intents found in database');
1000		- return false;
1001		- }
1002		-
1003		- $highest_similarity = -INF;
1004		- $matched_intent = null;
1005		-
1006		- //error_log('📊 MXCHAT DEBUG: Intent Similarity Scores ==================');
1007		- foreach ($intents as $intent) {
1008		- //error_log("🔄 MXCHAT DEBUG: Checking intent: '{$intent->intent_label}' (callback: {$intent->callback_function})");
1009		-
1010		- $intent_embedding_serialized = $intent->embedding_vector;
1011		- $intent_embedding = $intent_embedding_serialized
1012		- ? unserialize($intent_embedding_serialized, ['allowed_classes' => false])
1013		- : null;
1014		-
1015		- if (!is_array($intent_embedding)) {
1016		- //error_log("❌ MXCHAT DEBUG: Invalid embedding for intent: {$intent->intent_label}");
1017		- continue;
1018		- }
1019		-
1020		- $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $intent_embedding);
1021		- $intent_threshold = isset($intent->similarity_threshold) ? $intent->similarity_threshold : 0.85;
1022		-
1023		-
1024		- if ($similarity >= $intent_threshold && $similarity > $highest_similarity) {
1025		- $highest_similarity = $similarity;
1026		- $matched_intent = $intent;
1027		- //error_log("✅ MXCHAT DEBUG: New best match: '{$intent->intent_label}' with similarity {$similarity}");
1028		- }
1029		- }
1030		- //error_log('📊 MXCHAT DEBUG: End Intent Scores ==================');
1031		-
1032		- if ($matched_intent) {
1033		- //error_log("🎯 MXCHAT DEBUG: Final Intent Match: '{$matched_intent->intent_label}'");
1034		- //error_log("🔄 MXCHAT DEBUG: Invoking callback: {$matched_intent->callback_function}");
1035		-
1036		- // If the callback is a method on this instance (core callback), call it directly
1037		- if (method_exists($this, $matched_intent->callback_function)) {
1038		- //error_log('🔍 MXCHAT DEBUG: Using direct method call for core callback');
1039		- $callback_result = call_user_func(
1040		- [$this, $matched_intent->callback_function],
1041		- $message,
1042		- $user_id,
1043		- $session_id,
1044		- $matched_intent,
1045		- $user_context // Add user context
1046		- );
1047		- } else {
1048		- //error_log('🔍 MXCHAT DEBUG: Using apply_filters for add-on callback');
1049		- // Otherwise, use apply_filters for add-on callbacks
1050		- $callback_result = apply_filters(
1051		- $matched_intent->callback_function,
1052		- false, // default return value
1053		- $message,
1054		- $user_id,
1055		- $session_id,
1056		- $matched_intent
1057		- );
1058		- }
1059		-
1060		- //error_log('🔍 MXCHAT DEBUG: Callback result type: ' . gettype($callback_result));
1061		- if ($callback_result !== false) {
1062		- //error_log('✅ MXCHAT DEBUG: Intent handled successfully');
1063		- $this->fallbackResponse = $callback_result;
1064		- return true;
1065		- }
1066		- //error_log('❌ MXCHAT DEBUG: Callback returned false');
1067		- } else {
1068		- //error_log('❌ MXCHAT DEBUG: No matching intent found');
1069		- }
1070		-
1071		- //error_log('🔍 MXCHAT DEBUG: Intent Check Completed ==================');
1072		- return false;
1073		-}
1074		-
1075		-
1076		-// Helper function to clear PDF and Word document related transients
1077		-private function clear_pdf_transients($session_id) {
1078		- // PDF transients
1079		- delete_transient('mxchat_pdf_url_' . $session_id);
1080		- delete_transient('mxchat_pdf_embeddings_' . $session_id);
1081		- delete_transient('mxchat_include_pdf_in_context_' . $session_id);
1082		- delete_transient('mxchat_waiting_for_pdf_url_' . $session_id);
1083		-
1084		- // Word document transients
1085		- delete_transient('mxchat_word_url_' . $session_id);
1086		- delete_transient('mxchat_word_filename_' . $session_id);
1087		- delete_transient('mxchat_word_embeddings_' . $session_id);
1088		- delete_transient('mxchat_include_word_in_context_' . $session_id);
1089		- delete_transient('mxchat_waiting_for_word_' . $session_id);
1090		-}
1091		-
1092		-
1093		-
1094		-//verified good
1095		-public function mxchat_handle_email_capture($message, $user_id, $session_id) {
1096		- // Log the message safely
1097		- //error_log("Triggered email capture intent for message: " . sanitize_text_field($message));
1098		-
1099		- // Initiate email capture flow
1100		- $response = esc_html($this->options['triggered_phrase_response'] ?? esc_html__("Would you like to join our mailing list? Please provide your email below.", 'mxchat'));
1101		-
1102		- set_transient('mxchat_email_capture_' . $user_id, true, 5 * MINUTE_IN_SECONDS);
1103		- $this->mxchat_save_chat_message($session_id, 'bot', $response);
1104		-
1105		- // Respond to the user
1106		- wp_send_json(['message' => $response]);
1107		- wp_die();
1108		-}
1109		-
1110		-//very good
1111		-public function mxchat_generate_image($message, $user_id, $session_id) {
1112		- // Prepare a prompt for DALL-E
1113		- $prompt = esc_html__('Create an image of ', 'mxchat') . sanitize_text_field($message);
1114		-
1115		- // Use the existing OpenAI API key
1116		- $openai_api_key = sanitize_text_field($this->options['api_key']);
1117		-
1118		- // Call DALL-E to generate an image
1119		- $image_response = $this->mxchat_generate_dalle_image($prompt, $openai_api_key);
1120		-
1121		- // Check if the response contains an image URL
1122		- if (isset($image_response['imageUrl'])) {
1123		- $image_url = esc_url_raw($image_response['imageUrl']);
1124		-
1125		- // Construct the HTML with a CSS class instead of inline styles
1126		- $response_html = '<img src="' . esc_url($image_url) . '" alt="' . esc_attr__('Generated Image', 'mxchat') . '" class="mxchat-generated-image" />';
1127		-
1128		- $response_text = esc_html__('Here is the image I generated:', 'mxchat');
1129		- } else {
1130		- $response_text = esc_html__("I'm sorry, but I couldn't generate an image based on your request.", 'mxchat');
1131		- $response_html = '';
1132		- //error_log("DALL-E image generation error: " . esc_html($image_response['error'] ?? 'Unknown error.'));
1133		- }
1134		-
1135		- // Save both text and HTML responses
1136		- $this->mxchat_save_chat_message($session_id, 'bot', $response_text . "\n" . $response_html);
1137		-
1138		- // Prepare the response data
1139		- $response_data = [
1140		- 'message' => $response_text,
1141		- 'html' => $response_html,
1142		- 'image_url' => $image_url ?? '',
1143		- ];
1144		-
1145		- // Send the JSON response
1146		- header('Content-Type: application/json; charset=' . get_option('blog_charset'));
1147		- echo json_encode($response_data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
1148		- wp_die();
1149		-}
1150		-private function mxchat_generate_dalle_image($prompt, $api_key, $model = 'dall-e-3', $timeout = 60) {
1151		- $api_url = 'https://api.openai.com/v1/images/generations';
1152		- $body = json_encode([
1153		- 'prompt' => sanitize_text_field($prompt),
1154		- 'n' => 1,
1155		- 'size' => '1024x1024',
1156		- 'model' => sanitize_text_field($model),
1157		- ]);
1158		-
1159		- $args = [
1160		- 'body' => $body,
1161		- 'headers' => [
1162		- 'Content-Type' => 'application/json',
1163		- 'Authorization' => 'Bearer ' . sanitize_text_field($api_key),
1164		- ],
1165		- 'method' => 'POST',
1166		- 'timeout' => absint($timeout),
1167		- ];
1168		-
1169		- $response = wp_remote_post($api_url, $args);
1170		-
1171		- if (is_wp_error($response)) {
1172		- //error_log("DALL-E request failed: " . $response->get_error_message());
1173		- return ['error' => esc_html__('Error generating image: ', 'mxchat') . $response->get_error_message()];
1174		- }
1175		-
1176		- $response_body = json_decode(wp_remote_retrieve_body($response), true);
1177		-
1178		- if (isset($response_body['data'][0]['url'])) {
1179		- return ['imageUrl' => esc_url_raw($response_body['data'][0]['url'])];
1180		- } else {
1181		- //error_log("DALL-E response error: " . wp_remote_retrieve_body($response));
1182		- return ['error' => esc_html__('Failed to generate image.', 'mxchat')];
1183		- }
1184		-}
1185		-
1186		-/**
1187		- * Handle web search requests.
1188		- *
1189		- * Sends the refined search query to the Brave Search API and displays neatly formatted,
1190		- * styled search results. Results are cached for performance.
1191		- *
1192		- * @since 1.0.0
1193		- * @param string $message The user's search query.
1194		- * @param string $user_id The user identifier.
1195		- * @param string $session_id The current session ID.
1196		- * @return void
1197		- */
1198		-public function mxchat_handle_search_request( $message, $user_id, $session_id ) {
1199		- // Step 1: Interpret and refine the search query
1200		- $refined_search_query = $this->mxchat_interpret_search_query( $message );
1201		-
1202		- if ( empty( $refined_search_query ) ) {
1203		- $this->fallbackResponse = array(
1204		- 'text' => esc_html__( 'I apologize, but could you please rephrase your search request?', 'mxchat' ),
1205		- );
1206		- return;
1207		- }
1208		-
1209		- // Retrieve and validate API settings
1210		- $options = get_option( 'mxchat_options' );
1211		- $api_key = isset( $options['brave_api_key'] ) ? sanitize_text_field( $options['brave_api_key'] ) : '';
1212		- $results_count = isset( $options['brave_results_count'] ) ? absint( $options['brave_results_count'] ) : 5;
1213		-
1214		- if ( empty( $api_key ) ) {
1215		- $this->fallbackResponse = array(
1216		- 'text' => esc_html__( 'Search functionality is temporarily unavailable. Please try again later.', 'mxchat' ),
1217		- );
1218		- return;
1219		- }
1220		-
1221		- // Build the API request URL
1222		- $api_url = add_query_arg(
1223		- array(
1224		- 'q' => rawurlencode( $refined_search_query ),
1225		- 'count' => $results_count,
1226		- 'text_decorations' => 'true',
1227		- 'rich_data' => 'true',
1228		- ),
1229		- 'https://api.search.brave.com/res/v1/web/search'
1230		- );
1231		-
1232		- // Attempt to retrieve cached results first
1233		- $transient_key = 'mxchat_search_' . md5( $refined_search_query );
1234		- $results = get_transient( $transient_key );
1235		-
1236		- if ( false === $results ) {
1237		- // Fetch new results from the Brave Search API
1238		- $response = wp_remote_get(
1239		- $api_url,
1240		- array(
1241		- 'headers' => array(
1242		- 'Accept' => 'application/json',
1243		- 'Accept-Encoding' => 'gzip',
1244		- 'X-Subscription-Token'=> $api_key,
1245		- ),
1246		- 'timeout' => 10,
1247		- )
1248		- );
1249		-
1250		- if ( is_wp_error( $response ) ) {
1251		- $this->fallbackResponse = array(
1252		- 'text' => esc_html__( 'I encountered an error while searching. Please try again.', 'mxchat' ),
1253		- );
1254		- return;
1255		- }
1256		-
1257		- $results = json_decode( wp_remote_retrieve_body( $response ), true );
1258		-
1259		- if ( json_last_error() !== JSON_ERROR_NONE ) {
1260		- $this->fallbackResponse = array(
1261		- 'text' => esc_html__( 'I received an invalid response from the search service.', 'mxchat' ),
1262		- );
1263		- return;
1264		- }
1265		-
1266		- // Cache results for one hour
1267		- set_transient( $transient_key, $results, HOUR_IN_SECONDS );
1268		- }
1269		-
1270		- // Process and display results
1271		- if ( ! empty( $results['web']['results'] ) && is_array( $results['web']['results'] ) ) {
1272		- $html = $this->generate_search_results_html( $results['web']['results'], $refined_search_query );
1273		-
1274		- // Only return HTML (no large text summary)
1275		- $this->fallbackResponse = array(
1276		- 'html' => $html,
1277		- );
1278		-
1279		- // Save to chat history
1280		- $this->mxchat_save_chat_message( $session_id, 'bot', $html );
1281		- } else {
1282		- $this->fallbackResponse = array(
1283		- 'text' => sprintf(
1284		- esc_html__( 'I couldn\'t find any relevant results for "%s". Would you like to try different search terms?', 'mxchat' ),
1285		- esc_html( $refined_search_query )
1286		- ),
1287		- );
1288		- }
1289		-}
1290		-
1291		-
1292		-/**
1293		- * Format search results into a natural text summary.
1294		- *
1295		- * @since 1.0.0
1296		- * @param array $results The search results from the API.
1297		- * @param string $query The original search query.
1298		- * @return string The text summary of the top results.
1299		- */
1300		-private function format_search_results( $results, $query ) {
1301		- $summary = sprintf(
1302		- esc_html__( 'Here are the most relevant results for "%s":', 'mxchat' ),
1303		- esc_html( $query )
1304		- ) . "\n\n";
1305		-
1306		- $max_results = min( count( $results ), 3 );
1307		- for ( $i = 0; $i < $max_results; $i++ ) {
1308		- $result = $results[ $i ];
1309		- $title = isset( $result['title'] ) ? wp_strip_all_tags( $result['title'] ) : '';
1310		- $description = isset( $result['description'] ) ? wp_strip_all_tags( $result['description'] ) : '';
1311		-
1312		- // Append title and description to the summary
1313		- $summary .= sprintf(
1314		- "%s\n%s\n\n",
1315		- esc_html( $title ),
1316		- esc_html( $description )
1317		- );
1318		- }
1319		-
1320		- return $summary;
1321		-}
1322		-
1323		-/**
1324		- * Generate HTML markup for search results.
1325		- *
1326		- * @since 1.0.0
1327		- * @param array $results The search results from the API.
1328		- * @param string $query The user-refined query.
1329		- * @return string The HTML markup for displaying the results.
1330		- */
1331		-private function generate_search_results_html( $results, $query ) {
1332		- ob_start();
1333		- ?>
1334		- <div class="mxchat-search-results">
1335		- <?php foreach ( $results as $result ) :
1336		- $title = isset( $result['title'] ) ? wp_strip_all_tags( $result['title'] ) : '';
1337		- $url = isset( $result['url'] ) ? esc_url( $result['url'] ) : '#';
1338		- $description = isset( $result['description'] ) ? wp_strip_all_tags( $result['description'] ) : '';
1339		- $favicon = isset( $result['meta_url']['favicon'] ) ? esc_url( $result['meta_url']['favicon'] ) : '';
1340		- $thumbnail = isset( $result['thumbnail']['src'] ) ? esc_url( $result['thumbnail']['src'] ) : '';
1341		- $domain = parse_url( $url, PHP_URL_HOST );
1342		- ?>
1343		- <div class="mxchat-search-item">
1344		- <div class="mxchat-search-header">
1345		- <?php if ( $favicon ) : ?>
1346		- <img
1347		- src="<?php echo esc_url( $favicon ); ?>"
1348		- class="mxchat-site-icon"
1349		- alt="<?php echo esc_attr__( 'Site icon', 'mxchat' ); ?>"
1350		- width="16"
1351		- height="16"
1352		- />
1353		- <?php endif; ?>
1354		- <div class="mxchat-site-url"><?php echo esc_html( $domain ); ?></div>
1355		- </div>
1356		-
1357		- <div class="mxchat-search-content">
1358		- <h3 class="mxchat-search-title">
1359		- <a href="<?php echo esc_url( $url ); ?>"
1360		- target="_blank"
1361		- rel="noopener noreferrer"
1362		- >
1363		- <?php echo esc_html( $title ); ?>
1364		- </a>
1365		- </h3>
1366		-
1367		- <?php if ( $thumbnail ) : ?>
1368		- <div class="mxchat-search-thumbnail">
1369		- <img
1370		- src="<?php echo esc_url( $thumbnail ); ?>"
1371		- alt="<?php echo esc_attr__( 'Thumbnail image', 'mxchat' ); ?>"
1372		- loading="lazy"
1373		- />
1374		- </div>
1375		- <?php endif; ?>
1376		-
1377		- <div class="mxchat-search-description">
1378		- <?php echo esc_html( $description ); ?>
1379		- </div>
1380		- </div>
1381		- </div>
1382		- <?php endforeach; ?>
1383		- </div>
1384		- <?php
1385		- return ob_get_clean();
1386		-}
1387		-
1388		-
1389		-//very good
1390		-public function mxchat_handle_image_search_request($message, $user_id, $session_id) {
1391		-
1392		- // Step 1: Interpret the search query for better results
1393		- $refined_search_query = $this->mxchat_interpret_search_query($message);
1394		-
1395		-
1396		- // If no query was interpreted, return a fallback message
1397		- if (empty($refined_search_query)) {
1398		- $this->fallbackResponse = [
1399		- 'text' => __("I'm sorry, I couldn't interpret your search query. Please specify what you'd like to see images of.", 'mxchat'),
1400		- 'html' => "",
1401		- ];
1402		- return;
1403		- }
1404		-
1405		- // Brave API URL
1406		- $api_url = 'https://api.search.brave.com/res/v1/images/search';
1407		-
1408		- // Retrieve Brave API settings
1409		- $options = get_option('mxchat_options');
1410		- $api_key = isset($options['brave_api_key']) ? sanitize_text_field($options['brave_api_key']) : '';
1411		-
1412		- if (empty($api_key)) {
1413		-/*
1414		- if (defined('WP_DEBUG') && WP_DEBUG) {
1415		- error_log("Brave API key is missing.");
1416		- }
1417		-*/
1418		-
1419		- $this->fallbackResponse = [
1420		- 'text' => __("API key is not configured. Please set it in the Brave Search Settings.", 'mxchat'),
1421		- 'html' => "",
1422		- ];
1423		- return;
1424		- }
1425		-
1426		- $image_count = isset($options['brave_image_count']) ? intval($options['brave_image_count']) : 4;
1427		- $safe_search = isset($options['brave_safe_search']) ? sanitize_text_field($options['brave_safe_search']) : 'strict';
1428		-
1429		- // Append query parameters based on settings
1430		- $api_url = add_query_arg([
1431		- 'q' => rawurlencode($refined_search_query),
1432		- 'count' => $image_count,
1433		- 'safesearch' => $safe_search,
1434		- ], $api_url);
1435		-
1436		-/*
1437		- // Log the final API URL for the search
1438		- if (defined('WP_DEBUG') && WP_DEBUG) {
1439		- error_log("Final API URL for Brave Image Search: " . esc_url_raw($api_url));
1440		- }
1441		-*/
1442		-
1443		-
1444		- // Implement caching
1445		- $transient_key = 'mxchat_image_search_' . md5($refined_search_query);
1446		- $body = get_transient($transient_key);
1447		-
1448		- if (false === $body) {
1449		- $args = [
1450		- 'headers' => [
1451		- 'Accept' => 'application/json',
1452		- 'Accept-Encoding' => 'gzip',
1453		- 'X-Subscription-Token' => $api_key,
1454		- ],
1455		- 'timeout' => 10,
1456		- ];
1457		-
1458		- $response = wp_remote_get($api_url, $args);
1459		-
1460		- if (is_wp_error($response)) {
1461		-/*
1462		- if (defined('WP_DEBUG') && WP_DEBUG) {
1463		- error_log("Brave Image API request failed: " . $response->get_error_message());
1464		- }
1465		-*/
1466		-
1467		- $this->fallbackResponse = [
1468		- 'text' => __("I'm sorry, I couldn't retrieve any images based on your request.", 'mxchat'),
1469		- 'html' => "",
1470		- ];
1471		- return;
1472		- }
1473		-
1474		- $body = json_decode(wp_remote_retrieve_body($response), true);
1475		- set_transient($transient_key, $body, HOUR_IN_SECONDS);
1476		- }
1477		-
1478		- // Process the API response
1479		- if (isset($body['results']) && is_array($body['results']) && count($body['results']) > 0) {
1480		- $html_output = '<div class="mxchat-image-gallery">';
1481		-
1482		- foreach ($body['results'] as $image) {
1483		- $image_url = isset($image['url']) ? esc_url($image['url']) : '';
1484		- $thumbnail_url = isset($image['thumbnail']['src']) ? esc_url($image['thumbnail']['src']) : '';
1485		- $title = isset($image['title']) ? esc_html($image['title']) : esc_html__('Image', 'mxchat');
1486		-
1487		- if ($image_url && $thumbnail_url) {
1488		- $html_output .= '<div class="mxchat-image-item">';
1489		- $html_output .= '<strong class="mxchat-image-title">' . $title . '</strong>';
1490		- $html_output .= '<a href="' . $image_url . '" target="_blank" rel="noopener noreferrer" class="mxchat-image-link">';
1491		- $html_output .= '<img src="' . $thumbnail_url . '" alt="' . $title . '" class="mxchat-image-thumbnail">';
1492		- $html_output .= '</a></div>';
1493		- }
1494		- }
1495		-
1496		- $html_output .= '</div>';
1497		-
1498		- $this->fallbackResponse = [
1499		- 'text' => "",
1500		- 'html' => $html_output,
1501		- ];
1502		-
1503		- // Save response in chat history
1504		- $this->mxchat_save_chat_message($session_id, 'bot', $html_output);
1505		-
1506		- } else {
1507		-/*
1508		- if (defined('WP_DEBUG') && WP_DEBUG) {
1509		- error_log("Brave Image API response did not contain expected data structure or was empty: " . print_r($body, true));
1510		- }
1511		-*/
1512		-
1513		- $this->fallbackResponse = [
1514		- 'text' => __("I'm sorry, I couldn't retrieve any images based on your request.", 'mxchat'),
1515		- 'html' => "",
1516		- ];
1517		- }
1518		-}
1519		-public function mxchat_interpret_search_query($user_query) {
1520		- $system_prompt = esc_html__("Interpret the user's request to provide only the essential keywords or phrases for image searching. Remove conversational language, politeness, or extra context. Return a concise search query that doesn't lose any of the original meaning.", 'mxchat');
1521		-
1522		- // Retrieve OpenAI API key using 'api_key' as the option key
1523		- $api_key = isset($this->options['api_key']) ? sanitize_text_field($this->options['api_key']) : sanitize_text_field(get_option('mxchat_options')['api_key']);
1524		-
1525		- /*
1526		- // Log the API key check, without exposing the key
1527		- if (defined('WP_DEBUG') && WP_DEBUG) {
1528		- error_log("Retrieved OpenAI API Key: " . ($api_key ? "Present" : "Missing"));
1529		- }
1530		- */
1531		-
1532		- if (empty($api_key)) {
1533		- //error_log("OpenAI API key is missing.");
1534		- return sanitize_text_field($user_query); // Default to the original query if API key is missing
1535		- }
1536		-
1537		- $url = 'https://api.openai.com/v1/chat/completions';
1538		- $args = [
1539		- 'headers' => [
1540		- 'Authorization' => 'Bearer ' . $api_key,
1541		- 'Content-Type' => 'application/json',
1542		- ],
1543		- 'body' => wp_json_encode([
1544		- 'model' => 'gpt-3.5-turbo',
1545		- 'messages' => [
1546		- ['role' => 'system', 'content' => $system_prompt],
1547		- ['role' => 'user', 'content' => sanitize_text_field($user_query)],
1548		- ],
1549		- 'temperature' => 0.2,
1550		- 'max_tokens' => 20,
1551		- ]),
1552		- 'method' => 'POST',
1553		- ];
1554		-
1555		- $response = wp_remote_post($url, $args);
1556		-
1557		- if (is_wp_error($response)) {
1558		- //error_log("OpenAI request failed: " . $response->get_error_message());
1559		- return sanitize_text_field($user_query); // Fallback to the original query if there's an error
1560		- }
1561		-
1562		- $body = json_decode(wp_remote_retrieve_body($response), true);
1563		-
1564		- // Check for a valid response and sanitize output
1565		- if (isset($body['choices'][0]['message']['content'])) {
1566		- $interpreted_query = sanitize_text_field(trim($body['choices'][0]['message']['content']));
1567		-
1568		- /*
1569		- // Log the interpreted query for debugging
1570		- if (defined('WP_DEBUG') && WP_DEBUG) {
1571		- error_log("Interpreted search query: " . $interpreted_query);
1572		- }
1573		- */
1574		-
1575		- return $interpreted_query;
1576		- } else {
1577		- //error_log("Unexpected API response format: " . print_r($body, true));
1578		- return sanitize_text_field($user_query);
1579		- }
1580		-}
1581		-
1582		-
1583		-
1584		-private function find_product_in_message($message) {
1585		- global $wpdb;
1586		-
1587		- // Get embedding for the search query
1588		- $query_embedding = $this->mxchat_generate_embedding($message, $this->options['api_key']);
1589		- if (!is_array($query_embedding)) {
1590		- return null;
1591		- }
1592		-
1593		- // Get relevant content as string
1594		- $relevant_content = $this->mxchat_find_relevant_products($query_embedding);
1595		- if (empty($relevant_content)) {
1596		- // Return null to indicate no results and set fallback response
1597		- $this->fallbackResponse['text'] = esc_html__("I couldn't find any relevant products based on your query. Could you please be more specific about the product you're looking for?", 'mxchat');
1598		- return null;
1599		- }
1600		-
1601		- // Extract product URLs from the content
1602		- preg_match_all('/https?:\/\/[^\s<>"\']+?\/product\/[^\s<>"\']+/', $relevant_content, $matches);
1603		-
1604		- if (!empty($matches[0])) {
1605		- // Try each URL found
1606		- foreach ($matches[0] as $url) {
1607		- // Clean the URL
1608		- $url = rtrim($url, '/."\']');
1609		-
1610		- // Get the product slug
1611		- $path = parse_url($url, PHP_URL_PATH);
1612		- $slug = basename(rtrim($path, '/'));
1613		-
1614		- // Find product by slug
1615		- $args = array(
1616		- 'post_type' => 'product',
1617		- 'post_status' => 'publish',
1618		- 'name' => $slug,
1619		- 'posts_per_page' => 1
1620		- );
1621		-
1622		- $products = get_posts($args);
1623		-
1624		- if (!empty($products)) {
1625		- $product_id = $products[0]->ID;
1626		- $product = wc_get_product($product_id);
1627		-
1628		- if ($product && $product->is_purchasable()) {
1629		- return $product_id;
1630		- }
1631		- }
1632		- }
1633		- }
1634		-
1635		- // Fallback: Look for product names in the content
1636		- $products = wc_get_products([
1637		- 'status' => 'publish',
1638		- 'limit' => -1,
1639		- 'return' => 'all'
1640		- ]);
1641		-
1642		- foreach ($products as $product) {
1643		- $name = $product->get_name();
1644		- if (stripos($relevant_content, $name) !== false) {
1645		- if ($product->is_purchasable()) {
1646		- return $product->get_id();
1647		- }
1648		- }
1649		- }
1650		-
1651		- // If no product is found after all checks, set the fallback response
1652		- $this->fallbackResponse['text'] = esc_html__("I couldn't find any relevant products based on your query. Try to be more specific", 'mxchat');
1653		- return null;
1654		-}
1655		-
1656		-// New method to handle intent responses
1657		-private function generate_intent_response($context_content, $session_id) {
1658		- // Convert the context array to a structured string for the AI
1659		- $context_string = $this->format_intent_context($context_content);
1660		-
1661		- // Generate AI response using the context
1662		- $response = $this->mxchat_generate_response(
1663		- $context_string,
1664		- $this->options['api_key'],
1665		- $this->options['xai_api_key'],
1666		- $this->options['claude_api_key'],
1667		- $this->options['deepseek_api_key'],
1668		- $this->mxchat_fetch_conversation_history_for_ai($session_id)
1669		- );
1670		-
1671		- $this->fallbackResponse['text'] = $response;
1672		- return true;
1673		-}
1674		-// Helper method to format intent context
1675		-private function format_intent_context($context) {
1676		- $context_string = esc_html__("INTENT CONTEXT:\n", 'mxchat');
1677		-
1678		- switch ($context['intent']) {
1679		- case 'add_to_cart':
1680		- if ($context['status'] === 'success') {
1681		- $context_string .= esc_html__("Action: Successfully added product to cart\n", 'mxchat');
1682		- $context_string .= sprintf(esc_html__("Product: %s\n", 'mxchat'), $context['product']['name']);
1683		- $context_string .= esc_html__("Available actions: ", 'mxchat') . implode(', ', $context['available_actions']) . "\n";
1684		- $context_string .= sprintf(esc_html__("Cart URL: %s\n", 'mxchat'), $context['cart_url']);
1685		- $context_string .= esc_html__("\nPlease inform the user of the successful addition and their available options.", 'mxchat');
1686		- } else {
1687		- $context_string .= esc_html__("Action: Failed to add product to cart\n", 'mxchat');
1688		- $context_string .= sprintf(esc_html__("Reason: %s\n", 'mxchat'), $context['reason']);
1689		- switch ($context['reason']) {
1690		- case 'woocommerce_not_available':
1691		- $context_string .= esc_html__("\nPlease inform the user that shopping features are not available.", 'mxchat');
1692		- break;
1693		- case 'no_product_context':
1694		- $context_string .= esc_html__("\nPlease ask the user to specify which product they want to add.", 'mxchat');
1695		- break;
1696		- case 'product_not_found':
1697		- $context_string .= esc_html__("\nPlease inform the user that the product couldn't be found and ask them to try again.", 'mxchat');
1698		- break;
1699		- case 'add_to_cart_failed':
1700		- $context_string .= esc_html__("\nPlease apologize to the user and suggest they try again or ask for assistance.", 'mxchat');
1701		- break;
1702		- }
1703		- }
1704		- break;
1705		- }
1706		-
1707		- return $context_string;
1708		-}
1709		-
1710		-
1711		-//very good
1712		-private function add_email_to_loops($email) {
1713		- // Sanitize the email
1714		- $email = sanitize_email($email);
1715		-
1716		- // Retrieve and sanitize options
1717		- $api_key = isset($this->options['loops_api_key']) ? sanitize_text_field($this->options['loops_api_key']) : '';
1718		- $mailing_list_id = isset($this->options['loops_mailing_list']) ? sanitize_text_field($this->options['loops_mailing_list']) : '';
1719		-
1720		- // Check for missing API key or mailing list ID
1721		- if (empty($api_key) || empty($mailing_list_id)) {
1722		- //error_log(esc_html__('Loops API key or mailing list ID is missing.', 'mxchat'));
1723		- return;
1724		- }
1725		-
1726		- $data = array(
1727		- 'email' => $email,
1728		- 'subscribed' => true,
1729		- 'source' => __('MxChat AI Chatbot', 'mxchat'),
1730		- 'mailingLists' => array($mailing_list_id => true),
1731		- );
1732		-
1733		- $url = 'https://app.loops.so/api/v1/contacts/create';
1734		- $args = array(
1735		- 'body' => wp_json_encode($data),
1736		- 'headers' => array(
1737		- 'Authorization' => 'Bearer ' . $api_key,
1738		- 'Content-Type' => 'application/json',
1739		- ),
1740		- 'method' => 'POST',
1741		- 'timeout' => 45,
1742		- );
1743		-
1744		- $response = wp_remote_post($url, $args);
1745		-
1746		- // Handle errors in the API request
1747		- if (is_wp_error($response)) {
1748		- //error_log(esc_html__('Error adding email to Loops: ', 'mxchat') . $response->get_error_message());
1749		- return;
1750		- }
1751		-
1752		- // Check for non-200 HTTP responses
1753		- $response_code = wp_remote_retrieve_response_code($response);
1754		- if ($response_code != 200) {
1755		- $response_body = wp_remote_retrieve_body($response);
1756		- //error_log(esc_html__('Loops API responded with code ', 'mxchat') . $response_code . ': ' . $response_body);
1757		- }
1758		-}
1759		-
1760		-public function mxchat_handle_pdf_discussion($message, $user_id, $session_id) {
1761		- // Get the maximum number of pages allowed from admin settings
1762		- $max_pages = isset($this->options['pdf_max_pages']) ? intval($this->options['pdf_max_pages']) : 69;
1763		-
1764		- // Retrieve options for dynamic texts
1765		- $trigger_text = $this->options['pdf_intent_trigger_text'] ?? __("Please provide the URL to the PDF you'd like to discuss.", 'mxchat');
1766		- $success_text = $this->options['pdf_intent_success_text'] ?? __("I've processed the PDF. What questions do you have about it?", 'mxchat');
1767		- $error_text = $this->options['pdf_intent_error_text'] ?? __("Sorry, I couldn't process the PDF. Please ensure it's a valid file.", 'mxchat');
1768		-
1769		- // Check for explicit request for new PDF
1770		- $new_pdf_requested = stripos($message, 'new') !== false ||
1771		- stripos($message, 'another') !== false ||
1772		- stripos($message, 'different') !== false;
1773		-
1774		- // If user mentions adding/reading a PDF, set waiting flag
1775		- if (stripos($message, 'pdf') !== false ||
1776		- stripos($message, 'document') !== false ||
1777		- stripos($message, 'read') !== false) {
1778		- set_transient('mxchat_waiting_for_pdf_url_' . $session_id, true, HOUR_IN_SECONDS);
1779		- $this->fallbackResponse['text'] = $trigger_text;
1780		- return;
1781		- }
1782		-
1783		- // If we're waiting for a URL or user requested new PDF
1784		- if ($new_pdf_requested || get_transient('mxchat_waiting_for_pdf_url_' . $session_id)) {
1785		- if (preg_match('/https?:\/\/[^\s"]+/i', $message, $matches)) {
1786		- // Process URL... (rest of your existing URL processing code)
1787		- } else {
1788		- $this->fallbackResponse['text'] = $trigger_text;
1789		- }
1790		- return;
1791		- }
1792		-
1793		- // Default to proceeding with conversation if no specific PDF action is needed
1794		- $this->fallbackResponse['text'] = '';
1795		-}
1796		-private function fetch_and_split_pdf_pages($pdf_source, $max_pages) {
1797		- $upload_dir = wp_upload_dir();
1798		- $temp_file = null;
1799		-
1800		- try {
1801		- // Handle URL vs local file
1802		- if (filter_var($pdf_source, FILTER_VALIDATE_URL)) {
1803		- // Validate and download the file from URL
1804		- $temp_file = wp_tempnam($pdf_source); // Safe temporary file name
1805		- $response = wp_remote_get($pdf_source, ['timeout' => 60]);
1806		-
1807		- if (is_wp_error($response) || wp_remote_retrieve_response_code($response) !== 200) {
1808		- //error_log(esc_html__("Failed to download PDF. Error: ", 'mxchat') . print_r($response, true));
1809		- return false;
1810		- }
1811		-
1812		- file_put_contents($temp_file, wp_remote_retrieve_body($response));
1813		-
1814		- // Validate that the downloaded file is a PDF
1815		- $mime_type = mime_content_type($temp_file);
1816		- if ($mime_type !== 'application/pdf') {
1817		- //error_log(esc_html__("Invalid MIME type detected for PDF: ", 'mxchat') . $mime_type);
1818		- unlink($temp_file);
1819		- return false;
1820		- }
1821		- } else {
1822		- // For local files, use the provided path directly
1823		- $temp_file = $pdf_source;
1824		- }
1825		-
1826		- // Parse and process the PDF
1827		- $parser = new \Smalot\PdfParser\Parser();
1828		- $pdf = $parser->parseFile($temp_file);
1829		- $pages = $pdf->getPages();
1830		-
1831		- if (count($pages) > $max_pages) {
1832		- //error_log(esc_html__("PDF exceeds the maximum allowed pages: ", 'mxchat') . count($pages));
1833		- if (filter_var($pdf_source, FILTER_VALIDATE_URL)) {
1834		- unlink($temp_file);
1835		- }
1836		- return esc_html__('too_many_pages', 'mxchat');
1837		- }
1838		-
1839		- $embeddings = [];
1840		- foreach ($pages as $page_number => $page) {
1841		- $text = $page->getText();
1842		-
1843		- // Ensure text is non-empty before generating embeddings
1844		- if (empty(trim($text))) {
1845		- //error_log(esc_html__("Skipping empty page: ", 'mxchat') . ($page_number + 1));
1846		- continue;
1847		- }
1848		-
1849		- $embedding = $this->mxchat_generate_embedding(
1850		- esc_html__("Page ", 'mxchat') . ($page_number + 1) . ": " . $text,
1851		- $this->options['api_key']
1852		- );
1853		-
1854		- if ($embedding) {
1855		- $embeddings[] = [
1856		- 'page_number' => $page_number + 1,
1857		- 'embedding' => $embedding,
1858		- 'text' => $text,
1859		- ];
1860		- } else {
1861		- //error_log(esc_html__("Failed to generate embedding for page ", 'mxchat') . ($page_number + 1));
1862		- }
1863		- }
1864		-
1865		- // Clean up downloaded file if it was from URL
1866		- if (filter_var($pdf_source, FILTER_VALIDATE_URL) && $temp_file) {
1867		- unlink($temp_file);
1868		- }
1869		-
1870		- return $embeddings;
1871		-
1872		- } catch (\Exception $e) {
1873		- // error_log(esc_html__("Error parsing or processing PDF: ", 'mxchat') . $e->getMessage());
1874		-
1875		- // Cleanup in case of exception
1876		- if (filter_var($pdf_source, FILTER_VALIDATE_URL) && $temp_file && file_exists($temp_file)) {
1877		- unlink($temp_file);
1878		- }
1879		-
1880		- return false;
1881		- }
1882		-}
1883		-private function find_relevant_pdf_pages($query_embedding, $embeddings) {
1884		- //error_log(esc_html__("find_relevant_pdf_pages called.", 'mxchat'));
1885		-
1886		- $most_relevant = null;
1887		- $highest_similarity = -INF;
1888		-
1889		- foreach ($embeddings as $page_data) {
1890		- $similarity = $this->mxchat_calculate_cosine_similarity($query_embedding, $page_data['embedding']);
1891		-
1892		- if ($similarity > $highest_similarity) {
1893		- $highest_similarity = $similarity;
1894		- $most_relevant = $page_data['page_number'];
1895		- }
1896		- }
1897		-
1898		- if (!is_null($most_relevant)) {
1899		- $page_numbers = range(max(1, $most_relevant - 1), min(count($embeddings), $most_relevant + 1));
1900		- return array_filter($embeddings, function ($page) use ($page_numbers) {
1901		- return in_array($page['page_number'], $page_numbers);
1902		- });
1903		- }
1904		-
1905		- return [];
1906		-}
1907		-// Add this to your class
1908		-public function handle_pdf_upload() {
1909		- check_ajax_referer('mxchat_chat_nonce', 'nonce');
1910		-
1911		- if (!isset($_FILES['pdf_file']) || !isset($_POST['session_id'])) {
1912		- wp_send_json_error(esc_html__('Missing required parameters.', 'mxchat'));
1913		- return;
1914		- }
1915		-
1916		- $file = $_FILES['pdf_file'];
1917		- $session_id = sanitize_text_field($_POST['session_id']);
1918		- $original_filename = sanitize_text_field($file['name']);
1919		-
1920		- $file_type = wp_check_filetype($file['name'], ['pdf' => 'application/pdf']);
1921		- if ($file_type['type'] !== 'application/pdf') {
1922		- wp_send_json_error(esc_html__('Invalid file type. Only PDF files are allowed.', 'mxchat'));
1923		- return;
1924		- }
1925		-
1926		- $upload_dir = wp_upload_dir();
1927		- $pdf_filename = 'mxchat_' . $session_id . '_' . time() . '.pdf';
1928		- $pdf_path = $upload_dir['path'] . '/' . $pdf_filename;
1929		-
1930		- if (!move_uploaded_file($file['tmp_name'], $pdf_path)) {
1931		- wp_send_json_error(esc_html__('Failed to upload file.', 'mxchat'));
1932		- return;
1933		- }
1934		-
1935		- $this->clear_pdf_transients($session_id);
1936		-
1937		- $max_pages = isset($this->options['pdf_max_pages']) ? intval($this->options['pdf_max_pages']) : 69;
1938		- $embeddings = $this->fetch_and_split_pdf_pages($pdf_path, $max_pages);
1939		-
1940		- if ($embeddings === 'too_many_pages') {
1941		- unlink($pdf_path);
1942		- $error_message = sprintf(
1943		- $this->options['pdf_intent_error_text'] ??
1944		- esc_html__("The provided PDF exceeds the maximum allowed limit of %d pages. Please provide a smaller document.", 'mxchat'),
1945		- $max_pages
1946		- );
1947		- wp_send_json_error($error_message);
1948		- return;
1949		- }
1950		-
1951		- if ($embeddings === false || empty($embeddings)) {
1952		- unlink($pdf_path);
1953		- $error_message = $this->options['pdf_intent_error_text'] ??
1954		- esc_html__('The uploaded PDF appears to be empty or contains unsupported content.', 'mxchat');
1955		- wp_send_json_error($error_message);
1956		- return;
1957		- }
1958		-
1959		- if (!empty($embeddings)) {
1960		- set_transient('mxchat_pdf_url_' . $session_id, $pdf_path, HOUR_IN_SECONDS);
1961		- set_transient('mxchat_pdf_filename_' . $session_id, $original_filename, HOUR_IN_SECONDS);
1962		- set_transient('mxchat_pdf_embeddings_' . $session_id, $embeddings, HOUR_IN_SECONDS);
1963		- set_transient('mxchat_include_pdf_in_context_' . $session_id, true, HOUR_IN_SECONDS);
1964		-
1965		- $success_message = $this->options['pdf_intent_success_text'] ??
1966		- esc_html__("I've processed the PDF. What questions do you have about it?", 'mxchat');
1967		-
1968		- wp_send_json_success([
1969		- 'message' => $success_message,
1970		- 'filename' => $original_filename
1971		- ]);
1972		- return;
1973		- }
1974		-
1975		- unlink($pdf_path);
1976		- $error_message = $this->options['pdf_intent_error_text'] ??
1977		- esc_html__('Sorry, I couldn\'t process the PDF. Please ensure it\'s a valid file.', 'mxchat');
1978		- wp_send_json_error($error_message);
1979		- return;
1980		-}
1981		-public function handle_pdf_remove() {
1982		- check_ajax_referer('mxchat_chat_nonce', 'nonce');
1983		-
1984		- if (empty($_POST['session_id'])) {
1985		- wp_send_json_error(esc_html__('Session ID missing.', 'mxchat'));
1986		- wp_die();
1987		- }
1988		-
1989		- $session_id = sanitize_text_field($_POST['session_id']);
1990		- $pdf_path = get_transient('mxchat_pdf_url_' . $session_id);
1991		-
1992		- if ($pdf_path && file_exists($pdf_path)) {
1993		- unlink($pdf_path);
1994		- }
1995		-
1996		- $this->clear_pdf_transients($session_id);
1997		-
1998		- wp_send_json_success([
1999		- 'message' => esc_html__('PDF removed successfully.', 'mxchat')
2000		- ]);
2001		- wp_die();
2002		-}
2003		-
2004		-
2005		-
2006		-
2007		-function mxchat_fetch_new_messages() {
2008		- $session_id = sanitize_text_field($_POST['session_id']);
2009		- $last_seen_id = sanitize_text_field($_POST['last_seen_id']);
2010		- $persistence_enabled = $_POST['persistence_enabled'] === 'true';
2011		- $initial_timestamp = isset($_POST['initial_timestamp']) ? intval($_POST['initial_timestamp']) : 0;
2012		-
2013		- if (empty($session_id)) {
2014		- //error_log(esc_html__('Fetch new messages error: Session ID missing.', 'mxchat'));
2015		- wp_send_json_error(['message' => esc_html__('Session ID missing.', 'mxchat')]);
2016		- wp_die();
2017		- }
2018		-
2019		- $history = get_option("mxchat_history_{$session_id}", []);
2020		-
2021		- $new_messages = array_filter($history, function ($message) use ($last_seen_id, $persistence_enabled, $initial_timestamp) {
2022		- // If persistence is enabled, show all new messages
2023		- if ($persistence_enabled) {
2024		- return !empty($message['id']) &&
2025		- strcmp($message['id'], $last_seen_id) > 0 &&
2026		- $message['role'] === 'agent';
2027		- }
2028		-
2029		- // If persistence is disabled, only show messages after initial timestamp
2030		- return !empty($message['id']) &&
2031		- $message['role'] === 'agent' &&
2032		- $message['timestamp'] > $initial_timestamp;
2033		- });
2034		-
2035		- //error_log(esc_html__("New agent messages fetched for session $session_id. Last seen ID: $last_seen_id", 'mxchat'));
2036		-
2037		- wp_send_json_success([
2038		- 'new_messages' => array_values($new_messages)
2039		- ]);
2040		- wp_die();
2041		-}
2042		-
2043		-
2044		-public function mxchat_live_agent_handover($message, $user_id, $session_id) {
2045		- // First check if live agents are available
2046		- $live_agent_available = $this->options['live_agent_status'] ?? 'off';
2047		- if ($live_agent_available !== 'on') {
2048		- $away_message = $this->options['live_agent_away_message'] ?? 'Sorry, live agents are currently unavailable. I can continue helping you as an AI assistant.';
2049		- $this->fallbackResponse = [
2050		- 'text' => $away_message,
2051		- 'html' => '',
2052		- 'images' => [],
2053		- 'chat_mode' => 'ai'
2054		- ];
2055		- wp_send_json([
2056		- 'text' => $away_message,
2057		- 'html' => '',
2058		- 'chat_mode' => 'ai',
2059		- 'session_id' => $session_id
2060		- ]);
2061		- wp_die();
2062		- }
2063		-
2064		- $slack_webhook_url = $this->options['live_agent_webhook_url'] ?? '';
2065		- if (empty($slack_webhook_url)) {
2066		- return false;
2067		- }
2068		-
2069		- // Get recent chat history (last 5 messages)
2070		- $history = get_option("mxchat_history_{$session_id}", []);
2071		- $recent_history = array_slice($history, -5); // Get last 5 messages
2072		-
2073		- // Format conversation history
2074		- $conversation_context = "";
2075		- if (!empty($recent_history)) {
2076		- $conversation_context = "*Recent Conversation:*\n";
2077		- foreach ($recent_history as $hist_message) {
2078		- $role_display = $hist_message['role'] === 'user' ? 'User' : 'AI';
2079		- $conversation_context .= ">{$role_display}: {$hist_message['content']}\n";
2080		- }
2081		- $conversation_context .= "\n";
2082		- }
2083		-
2084		- update_option("mxchat_mode_{$session_id}", 'agent');
2085		-
2086		- $webhook_data = [
2087		- 'blocks' => [
2088		- [
2089		- 'type' => 'header',
2090		- 'text' => [
2091		- 'type' => 'plain_text',
2092		- 'text' => '🔔 New Live Agent Request',
2093		- 'emoji' => true
2094		- ]
2095		- ],
2096		- [
2097		- 'type' => 'section',
2098		- 'fields' => [
2099		- [
2100		- 'type' => 'mrkdwn',
2101		- 'text' => sprintf('*User ID:*\n`%s`', $user_id)
2102		- ],
2103		- [
2104		- 'type' => 'mrkdwn',
2105		- 'text' => sprintf('*Session ID:*\n`%s`', $session_id)
2106		- ]
2107		- ]
2108		- ]
2109		- ]
2110		- ];
2111		-
2112		- // Add conversation history if exists
2113		- if (!empty($conversation_context)) {
2114		- $webhook_data['blocks'][] = [
2115		- 'type' => 'section',
2116		- 'text' => [
2117		- 'type' => 'mrkdwn',
2118		- 'text' => $conversation_context
2119		- ]
2120		- ];
2121		- }
2122		-
2123		- // Add the current message
2124		- $webhook_data['blocks'][] = [
2125		- 'type' => 'section',
2126		- 'text' => [
2127		- 'type' => 'mrkdwn',
2128		- 'text' => sprintf('*Current Message:*\n%s', $message)
2129		- ]
2130		- ];
2131		-
2132		- // Add the reply button
2133		- $webhook_data['blocks'][] = [
2134		- 'type' => 'actions',
2135		- 'elements' => [
2136		- [
2137		- 'type' => 'button',
2138		- 'text' => [
2139		- 'type' => 'plain_text',
2140		- 'text' => '✍️ Reply',
2141		- 'emoji' => true
2142		- ],
2143		- 'value' => $session_id,
2144		- 'action_id' => 'reply_to_user',
2145		- 'style' => 'primary'
2146		- ]
2147		- ]
2148		- ];
2149		-
2150		- $response = wp_remote_post($slack_webhook_url, [
2151		- 'body' => json_encode($webhook_data),
2152		- 'headers' => [
2153		- 'Content-Type' => 'application/json',
2154		- ],
2155		- ]);
2156		-
2157		- if (is_wp_error($response)) {
2158		- return false;
2159		- }
2160		-
2161		- $success_message = $this->options['live_agent_notification_message'] ?? 'Live agent has been notified.';
2162		- $this->mxchat_save_chat_message($session_id, 'bot', $success_message);
2163		-
2164		- $this->fallbackResponse = [
2165		- 'text' => $success_message,
2166		- 'html' => '',
2167		- 'images' => [],
2168		- 'chat_mode' => 'agent'
2169		- ];
2170		-
2171		- wp_send_json([
2172		- 'success' => true,
2173		- 'text' => $success_message,
2174		- 'html' => '',
2175		- 'chat_mode' => 'agent',
2176		- 'session_id' => $session_id,
2177		- 'fallbackResponse' => $this->fallbackResponse
2178		- ]);
2179		- wp_die();
2180		-}
2181		-public function mxchat_send_user_message_to_agent($message, $user_id, $session_id) {
2182		- $slack_webhook_url = $this->options['live_agent_webhook_url'] ?? '';
2183		-
2184		- if (empty($slack_webhook_url)) {
2185		- //error_log(esc_html__('Slack Webhook URL is not configured.', 'mxchat'));
2186		- return false;
2187		- }
2188		-
2189		- $webhook_data = [
2190		- 'blocks' => [
2191		- [
2192		- 'type' => 'header',
2193		- 'text' => [
2194		- 'type' => 'plain_text',
2195		- 'text' => esc_html__('📩 New Chat Message', 'mxchat'),
2196		- 'emoji' => true
2197		- ]
2198		- ],
2199		- [
2200		- 'type' => 'section',
2201		- 'fields' => [
2202		- [
2203		- 'type' => 'mrkdwn',
2204		- 'text' => sprintf(esc_html__('*User ID:*\n`%s`', 'mxchat'), $user_id)
2205		- ],
2206		- [
2207		- 'type' => 'mrkdwn',
2208		- 'text' => sprintf(esc_html__('*Session ID:*\n`%s`', 'mxchat'), $session_id)
2209		- ]
2210		- ]
2211		- ],
2212		- [
2213		- 'type' => 'section',
2214		- 'text' => [
2215		- 'type' => 'mrkdwn',
2216		- 'text' => sprintf(esc_html__('*Message:*\n%s', 'mxchat'), $message)
2217		- ]
2218		- ],
2219		- [
2220		- 'type' => 'actions',
2221		- 'elements' => [
2222		- [
2223		- 'type' => 'button',
2224		- 'text' => [
2225		- 'type' => 'plain_text',
2226		- 'text' => esc_html__('✍️ Reply', 'mxchat'),
2227		- 'emoji' => true
2228		- ],
2229		- 'value' => $session_id,
2230		- 'action_id' => 'reply_to_user',
2231		- 'style' => 'primary'
2232		- ]
2233		- ]
2234		- ]
2235		- ]
2236		- ];
2237		-
2238		- $response = wp_remote_post($slack_webhook_url, [
2239		- 'body' => json_encode($webhook_data),
2240		- 'headers' => [
2241		- 'Content-Type' => 'application/json',
2242		- ],
2243		- ]);
2244		-
2245		- if (is_wp_error($response)) {
2246		- //error_log(esc_html__('Error sending message to Slack: ', 'mxchat') . $response->get_error_message());
2247		- return false;
2248		- }
2249		-
2250		- //error_log(esc_html__('Message sent to Slack successfully.', 'mxchat'));
2251		- return true;
2252		-}
2253		-public function handle_slack_interaction(WP_REST_Request $request) {
2254		- //error_log('Received Slack interaction');
2255		-
2256		- $payload = json_decode($request->get_param('payload'), true);
2257		- //error_log('Payload: ' . print_r($payload, true));
2258		-
2259		- // Handle button click
2260		- if ($payload['type'] === 'block_actions' && $payload['actions'][0]['action_id'] === 'reply_to_user') {
2261		- $session_id = $payload['actions'][0]['value'];
2262		- $trigger_id = $payload['trigger_id'];
2263		-
2264		- // Get Bot Token from settings
2265		- $slack_token = $this->options['live_agent_bot_token'] ?? '';
2266		-
2267		- if (empty($slack_token)) {
2268		- //error_log('Slack Bot Token not configured');
2269		- return new WP_REST_Response(['error' => esc_html__('Bot token not configured', 'mxchat')], 400);
2270		- }
2271		- $response = wp_remote_post('https://slack.com/api/views.open', [
2272		- 'headers' => [
2273		- 'Content-Type' => 'application/json',
2274		- 'Authorization' => 'Bearer ' . $slack_token
2275		- ],
2276		- 'body' => json_encode([
2277		- 'trigger_id' => $trigger_id,
2278		- 'view' => [
2279		- 'type' => 'modal',
2280		- 'callback_id' => 'reply_modal',
2281		- 'title' => [
2282		- 'type' => 'plain_text',
2283		- 'text' => __('Reply to User', 'mxchat')
2284		- ],
2285		- 'submit' => [
2286		- 'type' => 'plain_text',
2287		- 'text' => __('Send', 'mxchat')
2288		- ],
2289		- 'close' => [
2290		- 'type' => 'plain_text',
2291		- 'text' => __('Cancel', 'mxchat')
2292		- ],
2293		- 'blocks' => [
2294		- [
2295		- 'type' => 'input',
2296		- 'block_id' => 'reply_block',
2297		- 'label' => [
2298		- 'type' => 'plain_text',
2299		- 'text' => sprintf(__('Reply to session: %s', 'mxchat'), $session_id)
2300		- ],
2301		- 'element' => [
2302		- 'type' => 'plain_text_input',
2303		- 'action_id' => 'message',
2304		- 'multiline' => true,
2305		- 'placeholder' => [
2306		- 'type' => 'plain_text',
2307		- 'text' => __('Type your message here...', 'mxchat')
2308		- ]
2309		- ]
2310		- ]
2311		- ],
2312		- 'private_metadata' => $session_id
2313		- ]
2314		- ])
2315		- ]);
2316		-
2317		- //error_log('Views.open response: ' . print_r($response, true));
2318		-
2319		- // Return immediate acknowledgment
2320		- return new WP_REST_Response(['ok' => true]);
2321		- }
2322		-
2323		- // Handle modal submission
2324		-// Handle modal submission
2325		-if ($payload['type'] === 'view_submission') {
2326		- $session_id = $payload['view']['private_metadata'];
2327		- $message = $payload['view']['state']['values']['reply_block']['message']['value'];
2328		-
2329		- // Save the message (keep the message_id but don't include in response)
2330		- $this->mxchat_save_chat_message($session_id, 'agent', $message);
2331		-
2332		- // Keep the original response format for Slack
2333		- return new WP_REST_Response([
2334		- 'response_action' => 'clear'
2335		- ]);
2336		-}
2337		-
2338		- // Default acknowledgment
2339		- return new WP_REST_Response(['ok' => true]);
2340		-}
2341		-
2342		-public function mxchat_handle_agent_response(WP_REST_Request $request) {
2343		- //error_log('Received agent response request');
2344		- //error_log('Request data: ' . print_r($request->get_params(), true));
2345		- // error_log('Raw body: ' . file_get_contents('php://input'));
2346		-
2347		- // Get the data from Slack's slash command format
2348		- $command_text = $request->get_param('text');
2349		- // error_log('Command text: ' . $command_text);
2350		-
2351		- if (empty($command_text)) {
2352		- //error_log(esc_html__('Agent response error: No command text received', 'mxchat'));
2353		- return new WP_REST_Response([
2354		- 'error' => esc_html__('Command text is required. Format: /reply session_id message', 'mxchat')
2355		- ], 400);
2356		- }
2357		-
2358		- // Split the command text into session_id and message
2359		- $parts = explode(' ', $command_text, 2);
2360		- if (count($parts) !== 2) {
2361		- //error_log('Agent response error: Invalid command format');
2362		- return new WP_REST_Response([
2363		- 'error' => esc_html__('Invalid format. Use: /reply session_id message', 'mxchat')
2364		- ], 400);
2365		- }
2366		-
2367		- $session_id = sanitize_text_field($parts[0]);
2368		- $message = sanitize_text_field($parts[1]);
2369		-
2370		- //error_log("Processing agent response - Session ID: $session_id, Message: $message");
2371		-
2372		- // Save the message
2373		- $message_id = $this->mxchat_save_chat_message($session_id, 'agent', $message);
2374		-
2375		- if (!$message_id) {
2376		- // error_log('Failed to save agent message');
2377		- return new WP_REST_Response([
2378		- 'error' => esc_html__('Failed to save message', 'mxchat')
2379		- ], 500);
2380		- }
2381		-
2382		- // Return success response in Slack's expected format
2383		- return new WP_REST_Response([
2384		- 'response_type' => 'in_channel',
2385		- 'text' => esc_html__("Message sent successfully to session $session_id", 'mxchat')
2386		- ], 200);
2387		-}
2388		-
2389		-
2390		-public function mxchat_handle_switch_to_chatbot_intent($message, $user_id, $session_id) {
2391		- //error_log(esc_html__("Switching back to chatbot mode via intent.", 'mxchat'));
2392		-
2393		- // Just update mode to AI
2394		- update_option("mxchat_mode_{$session_id}", 'ai');
2395		-
2396		- // Initialize states
2397		- $this->fallbackResponse = ['text' => '', 'html' => '', 'images' => []];
2398		- $this->productCardHtml = '';
2399		-
2400		- // Set the response message
2401		- $this->fallbackResponse['text'] = esc_html__('You are now chatting with the AI chatbot.', 'mxchat');
2402		-
2403		- return true; // Intent was handled
2404		-}
2405		-
2406		-
2407		-
2408		-
2409		-// For the word upload handler
2410		-public function mxchat_handle_word_upload() {
2411		- // Delegate to word handler
2412		- $this->word_handler->mxchat_handle_word_upload();
2413		-}
2414		-
2415		-// For the word removal handler
2416		-public function mxchat_handle_word_remove() {
2417		- // Delegate to word handler
2418		- $this->word_handler->mxchat_handle_word_remove();
2419		-}
2420		-
2421		-// For the word status check
2422		-public function mxchat_check_word_status() {
2423		- // Delegate to word handler
2424		- $this->word_handler->mxchat_check_word_status();
2425		-}
2426		-
2427		-
2428		-private function mxchat_get_user_identifier() {
2429		- return MxChat_User::mxchat_get_user_identifier();
2430		-}
2431		-
2432		-private function mxchat_generate_embedding($text, $api_key) {
2433		- $endpoint = 'https://api.openai.com/v1/embeddings';
2434		-
2435		- $body = wp_json_encode([
2436		- 'input' => $text,
2437		- 'model' => 'text-embedding-ada-002'
2438		- ]);
2439		-
2440		- $args = [
2441		- 'body' => $body,
2442		- 'headers' => [
2443		- 'Content-Type' => 'application/json',
2444		- 'Authorization' => 'Bearer ' . $api_key,
2445		- ],
2446		- 'timeout' => 60,
2447		- 'redirection' => 5,
2448		- 'blocking' => true,
2449		- 'httpversion' => '1.0',
2450		- 'sslverify' => true,
2451		- ];
2452		-
2453		- $response = wp_remote_post($endpoint, $args);
2454		-
2455		- if (is_wp_error($response)) {
2456		- return null;
2457		- }
2458		-
2459		- $response_body = json_decode(wp_remote_retrieve_body($response), true);
2460		-
2461		- if (isset($response_body['data'][0]['embedding']) && is_array($response_body['data'][0]['embedding'])) {
2462		- return $response_body['data'][0]['embedding'];
2463		- } else {
2464		- return null;
2465		- }
2466		- }
2467		-
2468		-
2469		-private function mxchat_find_relevant_content($user_embedding) {
2470		- //error_log('MXChat Vector Search: Starting content search...');
2471		-
2472		- // Retrieve the add-on settings from the database.
2473		- $addon_options = get_option('mxchat_pinecone_addon_options', array());
2474		-
2475		- // Determine whether Pinecone is enabled.
2476		- // We expect the sanitized setting to be a string '1' if enabled, otherwise '0'.
2477		- $use_pinecone = (isset($addon_options['mxchat_use_pinecone']) && $addon_options['mxchat_use_pinecone'] === '1') ? 1 : 0;
2478		-
2479		- //error_log('Pinecone enabled flag: ' . $use_pinecone);
2480		-
2481		- if ($use_pinecone === 1) {
2482		- //error_log('MXChat Vector Search: Using Pinecone database');
2483		- return $this->find_relevant_content_pinecone($user_embedding);
2484		- } else {
2485		- //error_log('MXChat Vector Search: Using WordPress database');
2486		- return $this->find_relevant_content_wordpress($user_embedding);
2487		- }
2488		-}
2489		-
2490		-private function find_relevant_content_wordpress($user_embedding) {
2491		- global $wpdb;
2492		- $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
2493		- $cache_key = 'mxchat_system_prompt_embeddings';
2494		- $batch_size = 500;
2495		-
2496		- // Retrieve embeddings from cache or database
2497		- $embeddings = wp_cache_get($cache_key, 'mxchat_system_prompts');
2498		- if ($embeddings === false) {
2499		- $embeddings = [];
2500		- $offset = 0;
2501		-
2502		- // Load in batches and build cache
2503		- do {
2504		- $query = $wpdb->prepare(
2505		- "SELECT id, embedding_vector
2506		- FROM {$system_prompt_table}
2507		- LIMIT %d OFFSET %d",
2508		- $batch_size,
2509		- $offset
2510		- );
2511		-
2512		- $batch = $wpdb->get_results($query);
2513		- if (empty($batch)) {
2514		- break;
2515		- }
2516		-
2517		- $embeddings = array_merge($embeddings, $batch);
2518		- $offset += $batch_size;
2519		-
2520		- // Free memory
2521		- unset($batch);
2522		-
2523		- } while (true);
2524		-
2525		- if (empty($embeddings)) {
2526		- return ''; // Return an empty string if no embeddings found
2527		- }
2528		- wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600);
2529		- }
2530		-
2531		- // Initialize array to store relevant results with similarity scores
2532		- $relevant_results = [];
2533		- // Iterate through embeddings to calculate similarity
2534		- foreach ($embeddings as $embedding) {
2535		- $database_embedding = $embedding->embedding_vector
2536		- ? unserialize($embedding->embedding_vector, ['allowed_classes' => false])
2537		- : null;
2538		- if (is_array($database_embedding) && is_array($user_embedding)) {
2539		- $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $database_embedding);
2540		- $relevant_results[] = [
2541		- 'id' => $embedding->id,
2542		- 'similarity' => $similarity
2543		- ];
2544		- }
2545		- // Free memory
2546		- unset($database_embedding);
2547		- }
2548		-
2549		- // Retrieve the similarity threshold
2550		- $similarity_threshold = ((int) get_option('mxchat_similarity_threshold', 80)) / 100;
2551		-
2552		- // Filter and sort relevant results by similarity
2553		- $relevant_results = array_filter($relevant_results, function ($result) use ($similarity_threshold) {
2554		- return $result['similarity'] >= $similarity_threshold;
2555		- });
2556		- usort($relevant_results, function ($a, $b) {
2557		- return $b['similarity'] <=> $a['similarity'];
2558		- });
2559		-
2560		- // Limit to the top 5 results
2561		- $top_results = array_slice($relevant_results, 0, 5);
2562		-
2563		- // Initialize the final content
2564		- $content = '';
2565		-
2566		- // Fetch and combine content for the top results
2567		- foreach ($top_results as $result) {
2568		- $chunk_content = $this->fetch_content_with_product_links($result['id']);
2569		- // Check if the content is PDF-related and add surrounding pages
2570		- if (strpos($chunk_content, '{"document_type":"pdf"') !== false) {
2571		- $surrounding_content = $wpdb->get_results($wpdb->prepare(
2572		- "SELECT article_content FROM {$system_prompt_table}
2573		- WHERE id IN (
2574		- (SELECT id FROM {$system_prompt_table} WHERE id < %d ORDER BY id DESC LIMIT 1),
2575		- (SELECT id FROM {$system_prompt_table} WHERE id > %d ORDER BY id ASC LIMIT 1)
2576		- )",
2577		- $result['id'],
2578		- $result['id']
2579		- ));
2580		- // Add previous content if it exists
2581		- if (!empty($surrounding_content[0])) {
2582		- $content .= $surrounding_content[0]->article_content . "\n\n";
2583		- }
2584		- // Add the main chunk content
2585		- $content .= $chunk_content . "\n\n";
2586		- // Add next content if it exists
2587		- if (!empty($surrounding_content[1])) {
2588		- $content .= $surrounding_content[1]->article_content . "\n\n";
2589		- }
2590		- } else {
2591		- // For non-PDF content, add directly
2592		- $content .= $chunk_content . "\n\n";
2593		- }
2594		- }
2595		-
2596		- return trim($content);
2597		-}
2598		-/**
2599		- * Find relevant content in Pinecone vector database
2600		- */
2601		-private function find_relevant_content_pinecone($user_embedding) {
2602		- $options = get_option('mxchat_pinecone_addon_options', array());
2603		- $api_key = $options['mxchat_pinecone_api_key'] ?? '';
2604		- $host = $options['mxchat_pinecone_host'] ?? '';
2605		-
2606		- if (empty($host) || empty($api_key)) {
2607		- //error_log('Pinecone credentials not properly configured');
2608		- return '';
2609		- }
2610		-
2611		- // Get similarity threshold from WordPress settings
2612		- $similarity_threshold = ((int) get_option('mxchat_similarity_threshold', 80)) / 100;
2613		-
2614		- // Prepare the query request for Pinecone
2615		- $api_endpoint = "https://{$host}/query";
2616		-
2617		- $request_body = array(
2618		- 'vector' => $user_embedding,
2619		- 'topK' => 5,
2620		- 'includeMetadata' => true,
2621		- 'includeValues' => true
2622		- );
2623		-
2624		- $response = wp_remote_post($api_endpoint, array(
2625		- 'headers' => array(
2626		- 'Api-Key' => $api_key,
2627		- 'accept' => 'application/json',
2628		- 'content-type' => 'application/json'
2629		- ),
2630		- 'body' => wp_json_encode($request_body),
2631		- 'timeout' => 30
2632		- ));
2633		-
2634		- if (is_wp_error($response)) {
2635		- //error_log('Pinecone query error: ' . $response->get_error_message());
2636		- return '';
2637		- }
2638		-
2639		- $response_code = wp_remote_retrieve_response_code($response);
2640		- if ($response_code !== 200) {
2641		- //error_log('Pinecone API error: ' . wp_remote_retrieve_body($response));
2642		- return '';
2643		- }
2644		-
2645		- $results = json_decode(wp_remote_retrieve_body($response), true);
2646		- if (empty($results['matches'])) {
2647		- return '';
2648		- }
2649		-
2650		- // Initialize the final content
2651		- $content = '';
2652		-
2653		- // Process each match
2654		- foreach ($results['matches'] as $match) {
2655		- // Skip if similarity is below threshold
2656		- if ($match['score'] < $similarity_threshold) {
2657		- continue;
2658		- }
2659		-
2660		- if (!empty($match['metadata']['text']) && !empty($match['metadata']['source_url'])) {
2661		- // Add content with citation
2662		- $content .= $match['metadata']['text'] . "\n";
2663		- $content .= "Source: " . $match['metadata']['source_url'] . "\n\n";
2664		- }
2665		- }
2666		-
2667		- return trim($content);
2668		-}
2669		-
2670		-
2671		-private function mxchat_find_relevant_products($user_embedding) {
2672		- //error_log('MXChat Vector Search: Starting product search...');
2673		-
2674		- // Retrieve the add-on settings from the database
2675		- $addon_options = get_option('mxchat_pinecone_addon_options', array());
2676		-
2677		- // Determine whether Pinecone is enabled
2678		- $use_pinecone = (isset($addon_options['mxchat_use_pinecone']) && $addon_options['mxchat_use_pinecone'] === '1') ? 1 : 0;
2679		-
2680		- //error_log('Pinecone enabled flag: ' . $use_pinecone);
2681		-
2682		- if ($use_pinecone === 1) {
2683		- //error_log('MXChat Vector Search: Using Pinecone database for products');
2684		- return $this->find_relevant_products_pinecone($user_embedding);
2685		- } else {
2686		- //error_log('MXChat Vector Search: Using WordPress database for products');
2687		- return $this->find_relevant_products_wordpress($user_embedding);
2688		- }
2689		-}
2690		-
2691		-private function find_relevant_products_wordpress($user_embedding) {
2692		- global $wpdb;
2693		- $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
2694		- $cache_key = 'mxchat_system_prompt_embeddings';
2695		- $batch_size = 500;
2696		-
2697		- // Original WordPress database search logic
2698		- // [Previous implementation remains the same]
2699		- $embeddings = wp_cache_get($cache_key, 'mxchat_system_prompts');
2700		- if ($embeddings === false) {
2701		- $embeddings = [];
2702		- $offset = 0;
2703		-
2704		- do {
2705		- $query = $wpdb->prepare(
2706		- "SELECT id, embedding_vector
2707		- FROM {$system_prompt_table}
2708		- LIMIT %d OFFSET %d",
2709		- $batch_size,
2710		- $offset
2711		- );
2712		-
2713		- $batch = $wpdb->get_results($query);
2714		- if (empty($batch)) {
2715		- break;
2716		- }
2717		-
2718		- $embeddings = array_merge($embeddings, $batch);
2719		- $offset += $batch_size;
2720		-
2721		- unset($batch);
2722		-
2723		- } while (true);
2724		-
2725		- if (empty($embeddings)) {
2726		- return '';
2727		- }
2728		- wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600);
2729		- }
2730		-
2731		- $relevant_results = [];
2732		- foreach ($embeddings as $embedding) {
2733		- $database_embedding = $embedding->embedding_vector
2734		- ? unserialize($embedding->embedding_vector, ['allowed_classes' => false])
2735		- : null;
2736		- if (is_array($database_embedding) && is_array($user_embedding)) {
2737		- $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $database_embedding);
2738		- $relevant_results[] = [
2739		- 'id' => $embedding->id,
2740		- 'similarity' => $similarity
2741		- ];
2742		- }
2743		- unset($database_embedding);
2744		- }
2745		-
2746		- // Use fixed threshold for products
2747		- $similarity_threshold = 0.85;
2748		-
2749		- $relevant_results = array_filter($relevant_results, function ($result) use ($similarity_threshold) {
2750		- return $result['similarity'] >= $similarity_threshold;
2751		- });
2752		- usort($relevant_results, function ($a, $b) {
2753		- return $b['similarity'] <=> $a['similarity'];
2754		- });
2755		-
2756		- $top_results = array_slice($relevant_results, 0, 5);
2757		- $content = '';
2758		-
2759		- foreach ($top_results as $result) {
2760		- $chunk_content = $this->fetch_content_with_product_links($result['id']);
2761		- $content .= $chunk_content . "\n\n";
2762		- }
2763		-
2764		- return trim($content);
2765		-}
2766		-
2767		-// Modified search function with correct filter syntax
2768		-private function find_relevant_products_pinecone($user_embedding) {
2769		- //error_log('Starting Pinecone product search...');
2770		-
2771		- $options = get_option('mxchat_pinecone_addon_options', array());
2772		- $api_key = $options['mxchat_pinecone_api_key'] ?? '';
2773		- $host = $options['mxchat_pinecone_host'] ?? '';
2774		-
2775		- if (empty($host) || empty($api_key)) {
2776		- //error_log('Pinecone credentials not properly configured for product search');
2777		- return '';
2778		- }
2779		-
2780		- $similarity_threshold = 0.85;
2781		- $api_endpoint = "https://{$host}/query";
2782		-
2783		- $request_body = array(
2784		- 'vector' => $user_embedding,
2785		- 'topK' => 5,
2786		- 'includeMetadata' => true,
2787		- 'includeValues' => true,
2788		- 'filter' => array(
2789		- 'type' => 'product'
2790		- )
2791		- );
2792		-
2793		- //error_log('Sending request to Pinecone with body: ' . wp_json_encode($request_body));
2794		-
2795		- $response = wp_remote_post($api_endpoint, array(
2796		- 'headers' => array(
2797		- 'Api-Key' => $api_key,
2798		- 'accept' => 'application/json',
2799		- 'content-type' => 'application/json'
2800		- ),
2801		- 'body' => wp_json_encode($request_body),
2802		- 'timeout' => 30
2803		- ));
2804		-
2805		- if (is_wp_error($response)) {
2806		- //error_log('Pinecone product query error: ' . $response->get_error_message());
2807		- return '';
2808		- }
2809		-
2810		- $response_code = wp_remote_retrieve_response_code($response);
2811		- //error_log('Pinecone response code: ' . $response_code);
2812		-
2813		- if ($response_code !== 200) {
2814		- //error_log('Pinecone API error during product search: ' . wp_remote_retrieve_body($response));
2815		- return '';
2816		- }
2817		-
2818		- $results = json_decode(wp_remote_retrieve_body($response), true);
2819		- //error_log('Pinecone raw response: ' . wp_remote_retrieve_body($response));
2820		-
2821		- if (empty($results['matches'])) {
2822		- //error_log('No matches found in Pinecone response');
2823		- return '';
2824		- }
2825		-
2826		- $content = '';
2827		- foreach ($results['matches'] as $match) {
2828		- if ($match['score'] < $similarity_threshold) {
2829		- //error_log("Match below threshold: " . $match['score']);
2830		- continue;
2831		- }
2832		-
2833		- if (!empty($match['metadata']['text'])) {
2834		- $content .= $match['metadata']['text'];
2835		- if (!empty($match['metadata']['source_url'])) {
2836		- $content .= "\n\nFor more details, check out this product: " . esc_url($match['metadata']['source_url']);
2837		- }
2838		- $content .= "\n\n";
2839		- }
2840		- }
2841		-
2842		- return trim($content);
2843		-}
2844		-
2845		-
2846		-private function fetch_content_with_product_links($most_relevant_id) {
2847		- global $wpdb;
2848		- $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
2849		-
2850		- // Fetch the article content and associated product URL
2851		- $query = $wpdb->prepare("SELECT article_content, source_url FROM {$system_prompt_table} WHERE id = %d", $most_relevant_id);
2852		- $result = $wpdb->get_row($query);
2853		-
2854		- if ($result) {
2855		- // Append the product link to the content if available
2856		- $content = $result->article_content;
2857		- if (!empty($result->source_url)) {
2858		- $content .= "\n\nFor more details, check out this product: " . esc_url($result->source_url);
2859		- }
2860		- return $content;
2861		- }
2862		-
2863		- return null;
2864		-}
2865		-
2866		-// Function definition
2867		-private function mxchat_generate_response($relevant_content, $api_key, $xai_api_key, $claude_api_key, $deepseek_api_key, $conversation_history) {
2868		- try {
2869		- if (!$relevant_content) {
2870		- return esc_html__("I'm sorry, I couldn't find relevant information on that topic.", 'mxchat');
2871		- }
2872		-
2873		- // Ensure conversation_history is an array
2874		- if (!is_array($conversation_history)) {
2875		- $conversation_history = array();
2876		- }
2877		-
2878		- // Get selected model with default fallback
2879		- $selected_model = isset($this->options['model']) ? $this->options['model'] : 'gpt-4o';
2880		-
2881		- // Extract model prefix to determine the provider
2882		- $model_parts = explode('-', $selected_model);
2883		- $provider = strtolower($model_parts[0]);
2884		-
2885		- // Handle model selection based on provider prefix
2886		- switch ($provider) {
2887		- case 'claude':
2888		- if (empty($claude_api_key)) {
2889		- throw new Exception(esc_html__('Claude API key is not configured', 'mxchat'));
2890		- }
2891		- return $this->mxchat_generate_response_claude(
2892		- $selected_model,
2893		- $claude_api_key,
2894		- $conversation_history,
2895		- $relevant_content
2896		- );
2897		-
2898		- case 'grok':
2899		- if (empty($xai_api_key)) {
2900		- throw new Exception(esc_html__('X.AI API key is not configured', 'mxchat'));
2901		- }
2902		- return $this->mxchat_generate_response_xai(
2903		- $selected_model,
2904		- $xai_api_key,
2905		- $conversation_history,
2906		- $relevant_content
2907		- );
2908		-
2909		- case 'deepseek':
2910		- if (empty($deepseek_api_key)) {
2911		- throw new Exception(esc_html__('DeepSeek API key is not configured', 'mxchat'));
2912		- }
2913		- return $this->mxchat_generate_response_deepseek(
2914		- $selected_model,
2915		- $deepseek_api_key,
2916		- $conversation_history,
2917		- $relevant_content
2918		- );
2919		-
2920		- case 'gpt':
2921		- if (empty($api_key)) {
2922		- throw new Exception(esc_html__('OpenAI API key is not configured', 'mxchat'));
2923		- }
2924		- return $this->mxchat_generate_response_openai(
2925		- $selected_model,
2926		- $api_key,
2927		- $conversation_history,
2928		- $relevant_content
2929		- );
2930		-
2931		- default:
2932		- // Default to OpenAI for custom models or unrecognized prefixes
2933		- if (empty($api_key)) {
2934		- throw new Exception(esc_html__('OpenAI API key is not configured', 'mxchat'));
2935		- }
2936		- return $this->mxchat_generate_response_openai(
2937		- $selected_model,
2938		- $api_key,
2939		- $conversation_history,
2940		- $relevant_content
2941		- );
2942		- }
2943		- } catch (Exception $e) {
2944		- //error_log('MXChat Error: ' . $e->getMessage());
2945		- return sprintf(
2946		- esc_html__('An error occurred: %s', 'mxchat'),
2947		- esc_html($e->getMessage())
2948		- );
2949		- }
2950		-}
2951		-
2952		-
2953		-private function mxchat_generate_response_deepseek($selected_model, $deepseek_api_key, $conversation_history, $relevant_content) {
2954		- // Ensure conversation_history is an array
2955		- if (!is_array($conversation_history)) {
2956		- $conversation_history = array();
2957		- }
2958		-
2959		- // Get system prompt instructions from options
2960		- $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
2961		-
2962		- // Create a new array for the formatted conversation
2963		- $formatted_conversation = array();
2964		-
2965		- // Add system message first
2966		- $formatted_conversation[] = array(
2967		- 'role' => 'system',
2968		- 'content' => $system_prompt_instructions . " " . $relevant_content
2969		- );
2970		-
2971		- // Add the rest of the conversation history
2972		- foreach ($conversation_history as $message) {
2973		- if (is_array($message) && isset($message['role']) && isset($message['content'])) {
2974		- $role = $message['role'];
2975		-
2976		- // Convert roles to supported format
2977		- if ($role === 'bot' || $role === 'agent') {
2978		- $role = 'assistant';
2979		- }
2980		- if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
2981		- $role = 'user';
2982		- }
2983		-
2984		- $formatted_conversation[] = array(
2985		- 'role' => $role,
2986		- 'content' => $message['content']
2987		- );
2988		- }
2989		- }
2990		-
2991		- $body = json_encode([
2992		- 'model' => $selected_model,
2993		- 'messages' => $formatted_conversation,
2994		- 'temperature' => 0.8,
2995		- 'stream' => false
2996		- ]);
2997		-
2998		- $args = [
2999		- 'body' => $body,
3000		- 'headers' => [
3001		- 'Content-Type' => 'application/json',
3002		- 'Authorization' => 'Bearer ' . $deepseek_api_key,
3003		- ],
3004		- 'timeout' => 60,
3005		- 'redirection' => 5,
3006		- 'blocking' => true,
3007		- 'httpversion' => '1.0',
3008		- 'sslverify' => true,
3009		- ];
3010		-
3011		- $response = wp_remote_post('https://api.deepseek.com/v1/chat/completions', $args);
3012		-
3013		- if (is_wp_error($response)) {
3014		- //error_log('DeepSeek API Error: ' . $response->get_error_message());
3015		- return "Sorry, there was an error processing your request.";
3016		- }
3017		-
3018		- $response_body = wp_remote_retrieve_body($response);
3019		- $decoded_response = json_decode($response_body, true);
3020		-
3021		- if (isset($decoded_response['choices'][0]['message']['content'])) {
3022		- return trim($decoded_response['choices'][0]['message']['content']);
3023		- } else {
3024		- //error_log('DeepSeek API Response Format Error: ' . print_r($decoded_response, true));
3025		- return "Sorry, I couldn't process that request.";
3026		- }
3027		-}
3028		-
3029		-private function mxchat_generate_response_openai($selected_model, $api_key, $conversation_history, $relevant_content) {
3030		- // Ensure conversation_history is an array
3031		- if (!is_array($conversation_history)) {
3032		- $conversation_history = array();
3033		- }
3034		-
3035		- // Get system prompt instructions from options
3036		- $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3037		-
3038		- // Create a new array for the formatted conversation
3039		- $formatted_conversation = array();
3040		-
3041		- // Add system message first
3042		- $formatted_conversation[] = array(
3043		- 'role' => 'system',
3044		- 'content' => $system_prompt_instructions . " " . $relevant_content
3045		- );
3046		-
3047		- // Add the rest of the conversation history
3048		- foreach ($conversation_history as $message) {
3049		- if (is_array($message) && isset($message['role']) && isset($message['content'])) {
3050		- $role = $message['role'];
3051		-
3052		- // Convert roles to supported format
3053		- if ($role === 'bot' || $role === 'agent') {
3054		- $role = 'assistant';
3055		- }
3056		- if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
3057		- $role = 'user';
3058		- }
3059		-
3060		- $formatted_conversation[] = array(
3061		- 'role' => $role,
3062		- 'content' => $message['content']
3063		- );
3064		- }
3065		- }
3066		-
3067		- $body = json_encode([
3068		- 'model' => $selected_model,
3069		- 'messages' => $formatted_conversation,
3070		- 'temperature' => 0.8,
3071		- 'stream' => false
3072		- ]);
3073		-
3074		- $args = [
3075		- 'body' => $body,
3076		- 'headers' => [
3077		- 'Content-Type' => 'application/json',
3078		- 'Authorization' => 'Bearer ' . $api_key,
3079		- ],
3080		- 'timeout' => 60,
3081		- 'redirection' => 5,
3082		- 'blocking' => true,
3083		- 'httpversion' => '1.0',
3084		- 'sslverify' => true,
3085		- ];
3086		-
3087		- $response = wp_remote_post('https://api.openai.com/v1/chat/completions', $args);
3088		-
3089		- if (is_wp_error($response)) {
3090		- //error_log('OpenAI API Error: ' . $response->get_error_message());
3091		- return "Sorry, there was an error processing your request.";
3092		- }
3093		-
3094		- $response_body = wp_remote_retrieve_body($response);
3095		- $decoded_response = json_decode($response_body, true);
3096		-
3097		- if (isset($decoded_response['choices'][0]['message']['content'])) {
3098		- return trim($decoded_response['choices'][0]['message']['content']);
3099		- } else {
3100		- //error_log('OpenAI API Response Format Error: ' . print_r($decoded_response, true));
3101		- return "Sorry, I couldn't process that request.";
3102		- }
3103		-}
3104		-private function mxchat_generate_response_xai($selected_model, $xai_api_key, $conversation_history, $relevant_content) {
3105		- // Get system prompt instructions from options
3106		- $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3107		-
3108		- // Add system prompt to relevant content
3109		- $content_with_instructions = $system_prompt_instructions . " " . $relevant_content;
3110		-
3111		- // Prepend system instructions to the conversation history
3112		- array_unshift($conversation_history, [
3113		- 'role' => 'system',
3114		- 'content' => "Here are your instructions: " . $content_with_instructions
3115		- ]);
3116		-
3117		- // Ensure consistency: Replace 'bot' and 'agent' roles with supported values
3118		- foreach ($conversation_history as &$message) {
3119		- if ($message['role'] === 'bot') {
3120		- $message['role'] = 'assistant';
3121		- } elseif ($message['role'] === 'agent') {
3122		- // Tag the message as coming from a live agent
3123		- $message['role'] = 'assistant';
3124		- if (!isset($message['metadata'])) {
3125		- $message['metadata'] = ['source' => 'live_agent'];
3126		- }
3127		- }
3128		-
3129		- // Ensure all roles are valid
3130		- if (!in_array($message['role'], ['system', 'assistant', 'user', 'function', 'tool'])) {
3131		- $message['role'] = 'user'; // Default to 'user'
3132		- }
3133		- }
3134		-
3135		-
3136		- // Build the request body
3137		- $body = json_encode([
3138		- 'model' => $selected_model,
3139		- 'messages' => $conversation_history,
3140		- 'temperature' => 0.8,
3141		- 'stream' => false
3142		- ]);
3143		-
3144		- // Set up the API request
3145		- $args = [
3146		- 'body' => $body,
3147		- 'headers' => [
3148		- 'Content-Type' => 'application/json',
3149		- 'Authorization' => 'Bearer ' . $xai_api_key,
3150		- ],
3151		- 'timeout' => 60,
3152		- 'redirection' => 5,
3153		- 'blocking' => true,
3154		- 'httpversion' => '1.0',
3155		- 'sslverify' => true,
3156		- ];
3157		-
3158		- // Make the API request
3159		- $response = wp_remote_post('https://api.x.ai/v1/chat/completions', $args);
3160		-
3161		- // Process the response
3162		- if (is_wp_error($response)) {
3163		- return "Sorry, there was an error processing your request.";
3164		- }
3165		-
3166		- $response_body = json_decode(wp_remote_retrieve_body($response), true);
3167		-
3168		- if (isset($response_body['choices'][0]['message']['content'])) {
3169		- return trim($response_body['choices'][0]['message']['content']);
3170		- } else {
3171		- return "Sorry, I couldn't process that request.";
3172		- }
3173		-}
3174		-
3175		-private function mxchat_generate_response_claude($selected_model, $claude_api_key, $conversation_history, $relevant_content) {
3176		- // Get system prompt instructions from options
3177		- $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3178		-
3179		- // Clean and validate conversation history
3180		- foreach ($conversation_history as &$message) {
3181		- // Convert bot and agent roles to assistant
3182		- if ($message['role'] === 'bot' || $message['role'] === 'agent') {
3183		- $message['role'] = 'assistant';
3184		- }
3185		-
3186		- // Remove unsupported roles - Claude only supports 'assistant' and 'user'
3187		- if (!in_array($message['role'], ['assistant', 'user'])) {
3188		- $message['role'] = 'user';
3189		- }
3190		-
3191		- // Ensure content field exists
3192		- if (!isset($message['content']) || empty($message['content'])) {
3193		- $message['content'] = '';
3194		- }
3195		-
3196		- // Remove any unsupported fields
3197		- $message = array_intersect_key($message, array_flip(['role', 'content']));
3198		- }
3199		-
3200		- // Add relevant content as the latest user message
3201		- $conversation_history[] = [
3202		- 'role' => 'user',
3203		- 'content' => $relevant_content
3204		- ];
3205		-
3206		- // Build request body
3207		- $body = json_encode([
3208		- 'model' => $selected_model,
3209		- 'max_tokens' => 1000,
3210		- 'temperature' => 0.8,
3211		- 'messages' => $conversation_history,
3212		- 'system' => $system_prompt_instructions
3213		- ]);
3214		-
3215		- // Set up API request
3216		- $args = [
3217		- 'body' => $body,
3218		- 'headers' => [
3219		- 'Content-Type' => 'application/json',
3220		- 'x-api-key' => $claude_api_key,
3221		- 'anthropic-version' => '2023-06-01'
3222		- ],
3223		- 'timeout' => 60,
3224		- 'redirection' => 5,
3225		- 'blocking' => true,
3226		- 'httpversion' => '1.0',
3227		- 'sslverify' => true,
3228		- ];
3229		-
3230		- // Make API request
3231		- $response = wp_remote_post('https://api.anthropic.com/v1/messages', $args);
3232		-
3233		- // Check for WordPress errors
3234		- if (is_wp_error($response)) {
3235		- //error_log("Claude API request error: " . $response->get_error_message());
3236		- return "Sorry, there was an error connecting to the API.";
3237		- }
3238		-
3239		- // Check HTTP response code
3240		- $http_code = wp_remote_retrieve_response_code($response);
3241		- if ($http_code !== 200) {
3242		- $error_body = wp_remote_retrieve_body($response);
3243		- //error_log("Claude API HTTP error: " . $http_code . " - " . $error_body);
3244		-
3245		- // Try to extract error message from response
3246		- $error_data = json_decode($error_body, true);
3247		- $error_message = isset($error_data['error']['message']) ?
3248		- $error_data['error']['message'] :
3249		- "HTTP error " . $http_code;
3250		-
3251		- return "Sorry, the API returned an error: " . $error_message;
3252		- }
3253		-
3254		- // Parse response
3255		- $response_body = json_decode(wp_remote_retrieve_body($response), true);
3256		-
3257		- // Check for JSON decode errors
3258		- if (json_last_error() !== JSON_ERROR_NONE) {
3259		- //error_log("Claude API JSON decode error: " . json_last_error_msg());
3260		- return "Sorry, there was an error processing the API response.";
3261		- }
3262		-
3263		- // Extract and validate response content
3264		- if (isset($response_body['content']) &&
3265		- is_array($response_body['content']) &&
3266		- !empty($response_body['content']) &&
3267		- isset($response_body['content'][0]['text'])) {
3268		- return trim($response_body['content'][0]['text']);
3269		- }
3270		-
3271		- // Log unexpected response format
3272		- //error_log("Claude API unexpected response format: " . print_r($response_body, true));
3273		- return "Sorry, I received an unexpected response format from the API.";
3274		-}
3275		-public function mxchat_dismiss_pre_chat_message() {
3276		- // Get and sanitize the user identifier
3277		- $user_id = $this->mxchat_get_user_identifier();
3278		- $user_id = sanitize_key($user_id);
3279		-
3280		- // Set a transient to track that the user has dismissed the pre-chat message
3281		- $transient_key = 'mxchat_pre_chat_message_dismissed_' . $user_id;
3282		- set_transient($transient_key, true, DAY_IN_SECONDS);
3283		-
3284		- wp_send_json_success();
3285		-}
3286		-
3287		-public function mxchat_check_pre_chat_message_status() {
3288		- // Get and sanitize the user identifier
3289		- $user_id = $this->mxchat_get_user_identifier();
3290		- $user_id = sanitize_key($user_id);
3291		-
3292		- // Check if the transient exists (i.e., if the message was dismissed)
3293		- $transient_key = 'mxchat_pre_chat_message_dismissed_' . $user_id;
3294		- $dismissed = get_transient($transient_key);
3295		-
3296		- // Log the result to see if it's being set correctly
3297		- //error_log("Check pre-chat message dismissed for $user_id: " . ($dismissed ? 'Yes' : 'No'));
3298		-
3299		- if ($dismissed) {
3300		- wp_send_json_success(['dismissed' => true]);
3301		- } else {
3302		- wp_send_json_success(['dismissed' => false]);
3303		- }
3304		-
3305		- wp_die();
3306		-}
3307		-
3308		-private function mxchat_calculate_cosine_similarity($vectorA, $vectorB) {
3309		- if (!is_array($vectorA) || !is_array($vectorB) || empty($vectorA) || empty($vectorB)) {
3310		- return 0;
3311		- }
3312		-
3313		- $dotProduct = array_sum(array_map(function ($a, $b) {
3314		- return $a * $b;
3315		- }, $vectorA, $vectorB));
3316		- $normA = sqrt(array_sum(array_map(function ($a) {
3317		- return $a * $a;
3318		- }, $vectorA)));
3319		- $normB = sqrt(array_sum(array_map(function ($b) {
3320		- return $b * $b;
3321		- }, $vectorB)));
3322		-
3323		- if ($normA == 0 || $normB == 0) {
3324		- return 0;
3325		- }
3326		-
3327		- return $dotProduct / ($normA * $normB);
3328		- }
3329		-
3330		-public function mxchat_enqueue_scripts_styles() {
3331		- // Define version numbers for the styles and scripts
3332		- $chat_style_version = '2.0.5'; // Replace with your actual version
3333		- $chat_script_version = '2.0.5'; // Replace with your actual version
3334		-
3335		- // Enqueue the script
3336		- wp_enqueue_script(
3337		- 'mxchat-chat-js',
3338		- plugin_dir_url(__FILE__) . '../js/chat-script.js',
3339		- array('jquery'),
3340		- $chat_script_version,
3341		- true
3342		- );
3343		-
3344		- // Enqueue the CSS
3345		- wp_enqueue_style(
3346		- 'mxchat-chat-css',
3347		- plugin_dir_url(__FILE__) . '../css/chat-style.css',
3348		- array(),
3349		- $chat_style_version
3350		- );
3351		-
3352		- // Fetch options from the database
3353		- $this->options = get_option('mxchat_options');
3354		- $prompts_options = get_option('mxchat_prompts_options', array());
3355		-
3356		- // Prepare settings for JavaScript
3357		- $style_settings = array(
3358		- 'ajax_url' => admin_url('admin-ajax.php'),
3359		- 'nonce' => wp_create_nonce('mxchat_chat_nonce'),
3360		- 'link_target_toggle' => $this->options['link_target_toggle'] ?? 'off',
3361		- 'rate_limit_message' => $this->options['rate_limit_message'] ?? 'Rate limit exceeded. Please try again later.',
3362		- 'complianz_toggle' => isset($this->options['complianz_toggle']) && $this->options['complianz_toggle'] === 'on',
3363		- 'user_message_bg_color' => $this->options['user_message_bg_color'] ?? '#fff',
3364		- 'user_message_font_color' => $this->options['user_message_font_color'] ?? '#212121',
3365		- 'bot_message_bg_color' => $this->options['bot_message_bg_color'] ?? '#212121',
3366		- 'bot_message_font_color' => $this->options['bot_message_font_color'] ?? '#fff',
3367		- 'top_bar_bg_color' => $this->options['top_bar_bg_color'] ?? '#212121',
3368		- 'send_button_font_color' => $this->options['send_button_font_color'] ?? '#212121',
3369		- 'close_button_color' => $this->options['close_button_color'] ?? '#fff',
3370		- 'chatbot_background_color' => $this->options['chatbot_background_color'] ?? '#212121',
3371		- 'chatbot_bg_color' => $this->options['chatbot_bg_color'] ?? '#fff',
3372		- 'icon_color' => $this->options['icon_color'] ?? '#fff',
3373		- 'chat_input_font_color' => $this->options['chat_input_font_color'] ?? '#212121',
3374		- 'chat_persistence_toggle' => $this->options['chat_persistence_toggle'] ?? 'off',
3375		- 'appendWidgetToBody' => $this->options['append_to_body'] ?? 'off', // Example for consistency
3376		-
3377		- 'live_agent_message_bg_color' => $this->options['live_agent_message_bg_color'] ?? '#ffffff',
3378		- 'live_agent_message_font_color' => $this->options['live_agent_message_font_color'] ?? '#333333',
3379		- 'chat_toolbar_toggle' => $this->options['chat_toolbar_toggle'] ?? 'off',
3380		- 'mode_indicator_bg_color' => $this->options['mode_indicator_bg_color'] ?? '#767676',
3381		- 'mode_indicator_font_color' => $this->options['mode_indicator_font_color'] ?? '#ffffff',
3382		- 'toolbar_icon_color' => $this->options['toolbar_icon_color'] ?? '#212121',
3383		-
3384		- 'use_pinecone' => $prompts_options['mxchat_use_pinecone'] ?? '0',
3385		- 'pinecone_enabled' => isset($prompts_options['mxchat_use_pinecone']) && $prompts_options['mxchat_use_pinecone'] === '1'
3386		- );
3387		-
3388		- // Pass the settings to the script
3389		- wp_localize_script('mxchat-chat-js', 'mxchatChat', $style_settings);
3390		-}
3391		-
3392		-
3393		-public function mxchat_reset_rate_limits() {
3394		- global $wpdb;
3395		-
3396		- // Define a cache key pattern for rate limits
3397		- $cache_key_pattern = 'mxchat_chat_limit_%';
3398		-
3399		- // Retrieve all option names matching the pattern
3400		- // phpcs:ignore WordPress.DB.DirectDatabaseQuery.NoCaching, WordPress.DB.DirectDatabaseQuery.DirectQuery
3401		- $option_names = $wpdb->get_col("SELECT option_name FROM {$wpdb->options} WHERE option_name LIKE 'mxchat_chat_limit_%'");
3402		-
3403		- // db call ok; no-cache ok
3404		- // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery -- db call ok
3405		- $wpdb->query("DELETE FROM {$wpdb->options} WHERE option_name LIKE 'mxchat_chat_limit_%'");
3406		-
3407		- // Clear the relevant cache entries
3408		- foreach ($option_names as $option_name) {
3409		- wp_cache_delete($option_name, 'options');
3410		- }
3411		-
3412		- // Optionally, clear a general cache if you have one
3413		- wp_cache_delete('mxchat_all_chat_limits', 'options');
3414		- }
3415		-
3416		-private function mxchat_fetch_woocommerce_products() {
3417		- // Ensure WooCommerce is active
3418		- if (!class_exists('WooCommerce')) {
3419		- return [];
3420		- }
3421		-
3422		- $args = array(
3423		- 'post_type' => 'product',
3424		- 'post_status' => 'publish',
3425		- 'posts_per_page' => -1,
3426		- );
3427		-
3428		- $products = get_posts($args);
3429		- $product_data = [];
3430		-
3431		- foreach ($products as $product) {
3432		- $product_id = $product->ID;
3433		- $product_obj = wc_get_product($product_id);
3434		-
3435		- $product_data[] = array(
3436		- 'id' => $product_id,
3437		- 'name' => $product_obj->get_name(),
3438		- 'description' => $product_obj->get_description(),
3439		- 'short_description' => $product_obj->get_short_description(),
3440		- 'url' => get_permalink($product_id),
3441		- 'price' => $product_obj->get_regular_price(),
3442		- 'sale_price' => $product_obj->get_sale_price(),
3443		- 'stock_status' => $product_obj->get_stock_status(),
3444		- 'sku' => $product_obj->get_sku(),
3445		- 'in_stock' => $product_obj->is_in_stock(),
3446		- 'total_sales' => $product_obj->get_total_sales(),
3447		- );
3448		- }
3449		-
3450		- return $product_data;
3451		-}
3452		-
3453		-}
3454		-?>
	1	+<?php
	2	+if (!defined('ABSPATH')) {
	3	+ exit;
	4	+}
	5	+
	6	+class MxChat_Integrator {
	7	+ private $options;
	8	+ private $chat_count;
	9	+
	10	+public function __construct() {
	11	+ $this->options = get_option('mxchat_options');
	12	+ $this->chat_count = get_option('mxchat_chat_count', 0);
	13	+
	14	+ // Add WooCommerce hooks
	15	+ add_action('wp_insert_post', array($this, 'mxchat_handle_product_change'), 10, 3);
	16	+
	17	+ // Ensure embeddings are removed when a product is moved to trash or permanently deleted
	18	+ add_action('wp_trash_post', array($this, 'mxchat_handle_product_delete'));
	19	+ add_action('before_delete_post', array($this, 'mxchat_handle_product_delete'));
	20	+
	21	+ add_action('wp_enqueue_scripts', array($this, 'mxchat_enqueue_scripts_styles'));
	22	+ add_action('wp_ajax_mxchat_handle_chat_request', array($this, 'mxchat_handle_chat_request'));
	23	+ add_action('wp_ajax_nopriv_mxchat_handle_chat_request', array($this, 'mxchat_handle_chat_request'));
	24	+
	25	+ add_action('wp_ajax_mxchat_dismiss_pre_chat_message', array($this, 'mxchat_dismiss_pre_chat_message'));
	26	+ add_action('wp_ajax_nopriv_mxchat_dismiss_pre_chat_message', array($this, 'mxchat_dismiss_pre_chat_message'));
	27	+ // Add the AJAX actions for checking if the pre-chat message was dismissed
	28	+ add_action('wp_ajax_mxchat_check_pre_chat_message_status', array($this, 'mxchat_check_pre_chat_message_status'));
	29	+ add_action('wp_ajax_nopriv_mxchat_check_pre_chat_message_status', array($this, 'mxchat_check_pre_chat_message_status'));
	30	+
	31	+ add_action('wp_ajax_mxchat_fetch_conversation_history', [$this, 'mxchat_fetch_conversation_history']);
	32	+ add_action('wp_ajax_nopriv_mxchat_fetch_conversation_history', [$this, 'mxchat_fetch_conversation_history']);
	33	+
	34	+
	35	+ add_action('wp_ajax_mxchat_add_to_cart', [$this, 'mxchat_add_to_cart']);
	36	+ add_action('wp_ajax_nopriv_mxchat_add_to_cart', [$this, 'mxchat_add_to_cart']);
	37	+
	38	+ if (!wp_next_scheduled('mxchat_reset_rate_limits')) {
	39	+ wp_schedule_event(time(), 'daily', 'mxchat_reset_rate_limits');
	40	+ }
	41	+
	42	+ add_action('mxchat_reset_rate_limits', array($this, 'mxchat_reset_rate_limits'));
	43	+}
	44	+
	45	+public function mxchat_handle_product_change($post_id, $post, $update) {
	46	+ // Ensure this is a product post type
	47	+ if ($post->post_type !== 'product') {
	48	+ return;
	49	+ }
	50	+
	51	+ // Only generate embeddings if the product is published
	52	+ if ($post->post_status === 'publish') {
	53	+ // Delay the embedding slightly to ensure all product data is available
	54	+ add_action('shutdown', function() use ($post_id) {
	55	+ $product = wc_get_product($post_id);
	56	+ if ($product && $product->get_price() !== '') {
	57	+ $this->mxchat_store_product_embedding($product);
	58	+ } else {
	59	+ // Optionally, log or handle the case where product data is incomplete
	60	+ // error_log("Product {$post_id} does not have complete data. Embedding not generated.");
	61	+ }
	62	+ });
	63	+ }
	64	+}
	65	+
	66	+public function mxchat_handle_product_delete($post_id) {
	67	+ if (get_post_type($post_id) !== 'product') {
	68	+ return;
	69	+ }
	70	+
	71	+ global $wpdb;
	72	+ $table_name = $wpdb->prefix . 'mxchat_system_prompt_content';
	73	+
	74	+ // Delete the embedding associated with this product
	75	+ $wpdb->delete($table_name, array('source_url' => get_permalink($post_id)), array('%s'));
	76	+}
	77	+
	78	+private function mxchat_store_product_embedding($product) {
	79	+ if (isset($this->options['enable_woocommerce_integration']) && $this->options['enable_woocommerce_integration'] === '1') {
	80	+
	81	+ $source_url = get_permalink($product->get_id());
	82	+ $regular_price = $product->get_regular_price();
	83	+ $sale_price = $product->get_sale_price();
	84	+ $price = $sale_price ?: $regular_price;
	85	+
	86	+ $description = $product->get_description() . "\n\n" .
	87	+ "Short Description: " . $product->get_short_description() . "\n" .
	88	+ "Price: " . $regular_price . "\n" .
	89	+ "Sale Price: " . ($sale_price ?: 'N/A') . "\n" .
	90	+ "SKU: " . $product->get_sku();
	91	+
	92	+ global $wpdb;
	93	+ $table_name = $wpdb->prefix . 'mxchat_system_prompt_content';
	94	+
	95	+ // Delete any existing embedding for this product
	96	+ $wpdb->delete($table_name, array('source_url' => $source_url), array('%s'));
	97	+
	98	+ // Submit the new content and embedding to the database
	99	+ MxChat_Utils::submit_content_to_db($description, $source_url, $this->options['api_key']);
	100	+ }
	101	+}
	102	+
	103	+
	104	+
	105	+
	106	+
	107	+ private function mxchat_increment_chat_count() {
	108	+ $chat_count = get_option('mxchat_chat_count', 0);
	109	+ $chat_count++;
	110	+ update_option('mxchat_chat_count', $chat_count);
	111	+ }
	112	+
	113	+function mxchat_fetch_conversation_history() {
	114	+ if (empty($_POST['session_id'])) {
	115	+ wp_send_json_error(['message' => 'Session ID missing.']);
	116	+ wp_die();
	117	+ }
	118	+
	119	+ $session_id = sanitize_text_field($_POST['session_id']);
	120	+ $history = get_option("mxchat_history_{$session_id}", []); // Retrieve stored history
	121	+
	122	+ if (empty($history)) {
	123	+ wp_send_json_error(['message' => 'No history found.']);
	124	+ wp_die();
	125	+ }
	126	+
	127	+ wp_send_json_success(['conversation' => $history]);
	128	+ wp_die();
	129	+}
	130	+private function mxchat_fetch_conversation_history_for_ajax($session_id) {
	131	+ $history = get_option("mxchat_history_{$session_id}", []); // Retrieve stored history based on session ID
	132	+ $formatted_history = [];
	133	+
	134	+ // Format the history to align with the expected structure for OpenAI
	135	+ foreach ($history as $entry) {
	136	+ $formatted_history[] = [
	137	+ 'role' => $entry['role'], // Ensure this matches 'user' or 'assistant'
	138	+ 'content' => $entry['content']
	139	+ ];
	140	+ }
	141	+
	142	+ return $formatted_history;
	143	+}
	144	+private function mxchat_fetch_conversation_history_for_ai($session_id) {
	145	+ $history = get_option("mxchat_history_{$session_id}", []);
	146	+
	147	+ $formatted_history = [];
	148	+
	149	+ foreach ($history as $entry) {
	150	+ // Skip messages containing HTML
	151	+ if ($entry['content'] !== strip_tags($entry['content'])) {
	152	+ continue;
	153	+ }
	154	+
	155	+ $formatted_history[] = [
	156	+ 'role' => $entry['role'],
	157	+ 'content' => $entry['content']
	158	+ ];
	159	+ }
	160	+
	161	+ return $formatted_history;
	162	+}
	163	+
	164	+
	165	+private function mxchat_save_chat_message($session_id, $role, $message) {
	166	+ global $wpdb;
	167	+ $table_name = $wpdb->prefix . 'mxchat_chat_transcripts';
	168	+
	169	+ $user_id = is_user_logged_in() ? get_current_user_id() : 0;
	170	+ $user_identifier = MxChat_User::mxchat_get_user_identifier();
	171	+ $user_email = MxChat_User::mxchat_get_user_email();
	172	+
	173	+ $history = get_option("mxchat_history_{$session_id}", []);
	174	+ $history[] = ['role' => $role, 'content' => $message];
	175	+ update_option("mxchat_history_{$session_id}", $history);
	176	+
	177	+ $wpdb->insert($table_name, [
	178	+ 'user_id' => $user_id,
	179	+ 'user_identifier' => $user_identifier,
	180	+ 'user_email' => $user_email,
	181	+ 'session_id' => $session_id,
	182	+ 'role' => $role,
	183	+ 'message' => $message,
	184	+ 'timestamp' => current_time('mysql', 1)
	185	+ ]);
	186	+}
	187	+
	188	+
	189	+public function mxchat_handle_chat_request() {
	190	+ global $wpdb;
	191	+
	192	+ // Get and sanitize the user identifier
	193	+ $user_id = $this->mxchat_get_user_identifier();
	194	+ $user_id = sanitize_key($user_id);
	195	+
	196	+ // Setup rate limiting
	197	+ $rate_limit_transient_key = 'mxchat_chat_limit_' . $user_id;
	198	+ $chat_count = get_transient($rate_limit_transient_key) ?: 0;
	199	+
	200	+ // Retrieve the session ID from the client's POST data
	201	+ $session_id = isset($_POST['session_id']) ? sanitize_text_field($_POST['session_id']) : '';
	202	+
	203	+ if (empty($session_id)) {
	204	+ wp_send_json_error('Session ID is missing.');
	205	+ wp_die();
	206	+ }
	207	+
	208	+ // Check rate limit
	209	+ $rate_limit_option = $this->options['rate_limit'] ?? 'unlimited';
	210	+ if ($rate_limit_option !== 'unlimited' && $chat_count >= intval($rate_limit_option)) {
	211	+ wp_send_json_error(['message' => $this->options['rate_limit_message'] ?? 'Rate limit exceeded. Please try again later.']);
	212	+ wp_die();
	213	+ }
	214	+
	215	+ // Increment chat count only if limit is not 'unlimited'
	216	+ if ($rate_limit_option !== 'unlimited') {
	217	+ set_transient($rate_limit_transient_key, $chat_count + 1, DAY_IN_SECONDS);
	218	+ }
	219	+
	220	+ // Validate and sanitize the incoming message
	221	+ if (empty($_POST['message'])) {
	222	+ wp_send_json_error('No message received');
	223	+ wp_die();
	224	+ }
	225	+
	226	+ $message = sanitize_text_field($_POST['message']);
	227	+ $this->mxchat_save_chat_message($session_id, 'user', $message);
	228	+
	229	+ // Track email capture and WooCommerce flows
	230	+ $email_capture_prompt = get_transient('mxchat_email_capture_' . $user_id);
	231	+ $interaction_count = get_transient('mxchat_email_interaction_count_' . $user_id) ?: 0;
	232	+ $woocommerce_prompt = get_transient('mxchat_woocommerce_prompt_' . $user_id);
	233	+
	234	+ // Handle email capture flow
	235	+ if ($email_capture_prompt) {
	236	+ if (preg_match('/[a-z0-9._%+-]+@[a-z0-9.-]+\.[a-z]{2,}/i', $message, $matches)) {
	237	+ $email = $matches[0];
	238	+ $this->add_email_to_loops($email);
	239	+ $response = $this->options['email_capture_response'] ?? 'Thank you for providing your email! You\'ve been added to our list.';
	240	+
	241	+ delete_transient('mxchat_email_capture_' . $user_id);
	242	+ delete_transient('mxchat_email_interaction_count_' . $user_id);
	243	+ delete_transient('mxchat_woocommerce_prompt_' . $user_id);
	244	+
	245	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	246	+ wp_send_json(['message' => $response]);
	247	+ wp_die();
	248	+ } else {
	249	+ if ($interaction_count >= 3) {
	250	+ delete_transient('mxchat_email_capture_' . $user_id);
	251	+ delete_transient('mxchat_email_interaction_count_' . $user_id);
	252	+ } else {
	253	+ set_transient('mxchat_email_interaction_count_' . $user_id, ++$interaction_count, 5 * MINUTE_IN_SECONDS);
	254	+ }
	255	+ }
	256	+ }
	257	+
	258	+
	259	+ // Initialize variables for storing intent and fallback response data
	260	+ $this->fallbackResponse = [
	261	+ 'text' => '',
	262	+ 'html' => '',
	263	+ 'images' => [],
	264	+ ];
	265	+ $this->productCardHtml = ''; // Initialize product card HTML
	266	+ $intent_info = '';
	267	+
	268	+ // Step 1: Detect intent and handle intent-based responses if applicable
	269	+ $intent_matched = $this->mxchat_check_intent_and_invoke_callback($message, $user_id, $session_id);
	270	+
	271	+/*
	272	+ // Log the intent match and fallback response
	273	+ if (defined('WP_DEBUG') && WP_DEBUG) {
	274	+ error_log("Intent matched: " . ($intent_matched ? 'Yes' : 'No'));
	275	+ error_log("Fallback response after intent handling: " . print_r($this->fallbackResponse['text'], true));
	276	+ }
	277	+*/
	278	+
	279	+
	280	+ // Store any intent-based info from fallbackResponse for use in context
	281	+ if (!empty($this->fallbackResponse['text'])) {
	282	+ $intent_info = $this->fallbackResponse['text'];
	283	+ }
	284	+
	285	+ // Step 2: Check for relevant knowledge database content based on user message embedding
	286	+ $user_message_embedding = $this->mxchat_generate_embedding($message, $this->options['api_key']);
	287	+ if (!is_array($user_message_embedding)) {
	288	+ wp_send_json_error('Error processing your message.');
	289	+ wp_die();
	290	+ }
	291	+
	292	+ // Fetch relevant content from the knowledge base using the embedding
	293	+ $relevant_content = $this->mxchat_find_relevant_content($user_message_embedding);
	294	+
	295	+ // Step 3: Prepare context for AI by combining user query, intent-based info, and knowledge base content
	296	+ $context_content = "User asked: '{$message}'\n\n";
	297	+
	298	+ // Append intent-based information if any
	299	+ if (!empty($intent_info)) {
	300	+ $context_content .= "Relevant intent-based information:\n" . $intent_info . "\n\n";
	301	+ }
	302	+
	303	+ // Append relevant knowledge base content if any
	304	+ if (!empty($relevant_content)) {
	305	+ $context_content .= "Relevant content from knowledge database:\n" . $relevant_content . "\n\n";
	306	+ }
	307	+
	308	+ // Step 4: Generate AI response based on context and conversation history
	309	+ $conversation_history = $this->mxchat_fetch_conversation_history_for_ai($session_id);
	310	+ $this->mxchat_increment_chat_count();
	311	+
	312	+ // Call AI to generate a response with the full context
	313	+ $response = $this->mxchat_generate_response(
	314	+ $context_content,
	315	+ $this->options['api_key'],
	316	+ $this->options['xai_api_key'],
	317	+ $this->options['claude_api_key'],
	318	+ $conversation_history
	319	+ );
	320	+
	321	+
	322	+ // Step 5: Save the response in chat history and prepare to send it back to the user
	323	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	324	+
	325	+ // Step 4: Then save any intent content
	326	+ if (!empty($this->productCardHtml)) {
	327	+ $this->mxchat_save_chat_message($session_id, 'bot', $this->productCardHtml);
	328	+ }
	329	+
	330	+ if (!empty($this->fallbackResponse['html'])) {
	331	+ $this->mxchat_save_chat_message($session_id, 'bot', $this->fallbackResponse['html']);
	332	+ }
	333	+
	334	+ $response_data = [
	335	+ 'text' => $response,
	336	+ 'html' => !empty($this->productCardHtml) ? $this->productCardHtml : (isset($this->fallbackResponse['html']) ? $this->fallbackResponse['html'] : ''),
	337	+ 'session_id' => $session_id
	338	+ ];
	339	+
	340	+
	341	+ //error_log("Response Data Sent to Frontend: " . print_r($response_data, true));
	342	+
	343	+ // Send response to the user
	344	+ wp_send_json($response_data);
	345	+ wp_die();
	346	+}
	347	+
	348	+// New function to check intents and invoke the callback function
	349	+private function mxchat_check_intent_and_invoke_callback($message, $user_id, $session_id) {
	350	+ global $wpdb;
	351	+
	352	+ // Log that we are starting the intent check
	353	+ //error_log("Starting intent check for message: " . $message);
	354	+
	355	+ // Embed the user message
	356	+ $user_embedding = $this->mxchat_generate_embedding($message, $this->options['api_key']);
	357	+ if (!is_array($user_embedding)) {
	358	+ // error_log('Error generating embedding for the message.');
	359	+ wp_send_json_error('Error generating embedding for the message.');
	360	+ return false;
	361	+ }
	362	+
	363	+ // Fetch all intents from the database
	364	+ $table_name = $wpdb->prefix . 'mxchat_intents';
	365	+ $intents = $wpdb->get_results("SELECT * FROM $table_name");
	366	+
	367	+ // Log if no intents are found
	368	+ if (empty($intents)) {
	369	+ //error_log("No intents found in the database.");
	370	+ }
	371	+
	372	+ $highest_similarity = -INF;
	373	+ $matched_intent = null;
	374	+
	375	+ // Calculate similarity for each intent
	376	+ foreach ($intents as $intent) {
	377	+ // Use unserialize with allowed_classes parameter for enhanced security
	378	+ $intent_embedding = $intent->embedding_vector
	379	+ ? unserialize($intent->embedding_vector, ['allowed_classes' => false])
	380	+ : null;
	381	+
	382	+ if (!is_array($intent_embedding)) {
	383	+ //error_log("Invalid embedding for intent: " . $intent->intent_label);
	384	+ continue; // Skip if the embedding is invalid
	385	+ }
	386	+
	387	+ $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $intent_embedding);
	388	+ //error_log("Similarity for intent '{$intent->intent_label}': " . $similarity);
	389	+
	390	+ if ($similarity > $highest_similarity) {
	391	+ $highest_similarity = $similarity;
	392	+ $matched_intent = $intent;
	393	+ }
	394	+ }
	395	+
	396	+ // Define the similarity threshold for matching
	397	+ $similarity_threshold = 0.80;
	398	+
	399	+ // If a match is found above the threshold, call the associated callback
	400	+ if ($highest_similarity >= $similarity_threshold && $matched_intent) {
	401	+ //error_log("Matched intent: " . $matched_intent->intent_label . " with similarity: " . $highest_similarity);
	402	+
	403	+ // Ensure the callback function exists before calling it
	404	+ if (method_exists($this, $matched_intent->callback_function)) {
	405	+ // Call the intent handler function
	406	+ call_user_func([$this, $matched_intent->callback_function], $message, $user_id, $session_id);
	407	+ return true; // Indicate that an intent was matched and handled
	408	+ } else {
	409	+ //error_log("Callback function not found: " . $matched_intent->callback_function);
	410	+ }
	411	+ } else {
	412	+ //error_log("No intent matched above the threshold.");
	413	+ }
	414	+
	415	+ return false; // No intent was matched above the threshold
	416	+}
	417	+
	418	+//verified good
	419	+public function mxchat_handle_order_history($message, $user_id, $session_id) {
	420	+ // Check if WooCommerce is active
	421	+ if (!class_exists('WooCommerce')) {
	422	+ $this->fallbackResponse['text'] = "Order functionality is currently unavailable.";
	423	+ return; // No need to proceed further
	424	+ }
	425	+
	426	+ // Determine if the user is asking for the "last order" or "all orders"
	427	+ $queryType = (stripos($message, 'last order') !== false || stripos($message, 'recent order') !== false) ? 'last' : 'all';
	428	+
	429	+ // Fetch the relevant order details
	430	+ $orderDetails = MxChat_WooCommerce::mxchat_fetch_user_orders_details($queryType);
	431	+
	432	+ // Set the fallback response to order details, which will be used if needed
	433	+ $this->fallbackResponse['text'] = $orderDetails ?: "No previous orders found.";
	434	+}
	435	+
	436	+
	437	+//verified good
	438	+public function mxchat_handle_product_inquiry( $message, $user_id, $session_id ) {
	439	+ // Attempt to retrieve the product ID from the message
	440	+ $product_id = MxChat_WooCommerce::mxchat_extract_product_id_from_message( $message );
	441	+
	442	+ // Check if there's a previously discussed product for follow-up queries
	443	+ if ( ! $product_id ) {
	444	+ $product_id = get_transient( 'mxchat_last_discussed_product_' . $user_id );
	445	+ }
	446	+
	447	+ if ( $product_id && class_exists( 'WooCommerce' ) ) {
	448	+ $product = wc_get_product( $product_id );
	449	+ if ( $product ) {
	450	+ // Escape and prepare product data
	451	+ $product_name = esc_html( $product->get_name() );
	452	+ $product_price = $product->get_price_html(); // Assuming this is safe HTML
	453	+ $product_image_url = esc_url( wp_get_attachment_url( $product->get_image_id() ) );
	454	+ $product_url = esc_url( get_permalink( $product_id ) );
	455	+ $product_id_attr = esc_attr( $product_id );
	456	+
	457	+ // Generate the product card HTML using HEREDOC syntax
	458	+ $product_card_html = <<<HTML
	459	+<div class="mxchat-product-card">
	460	+ <a href="{$product_url}" target="_blank">
	461	+ <img src="{$product_image_url}" alt="{$product_name}" class="mxchat-product-image" />
	462	+ <h3 class="mxchat-product-name">{$product_name}</h3>
	463	+ </a>
	464	+ <div class="mxchat-product-price">{$product_price}</div>
	465	+ <button class="mxchat-add-to-cart-button" data-product-id="{$product_id_attr}">Add to Cart</button>
	466	+</div>
	467	+HTML;
	468	+
	469	+ // Save the last discussed product
	470	+ set_transient( 'mxchat_last_discussed_product_' . $user_id, $product_id, HOUR_IN_SECONDS );
	471	+
	472	+ // Save the product card HTML to be appended later
	473	+ $this->productCardHtml = $product_card_html;
	474	+
	475	+ // Do not send a response here; allow execution to continue
	476	+ return;
	477	+ }
	478	+ }
	479	+
	480	+ // If no product found, set a fallback response
	481	+ $this->fallbackResponse = __( "I couldn't find details for that product. Could you specify the product name?", 'mxchat' );
	482	+ return;
	483	+}
	484	+
	485	+//verified good
	486	+public function mxchat_handle_email_capture($message, $user_id, $session_id) {
	487	+ // Log the message safely
	488	+ //error_log("Triggered email capture intent for message: " . sanitize_text_field($message));
	489	+
	490	+ // Initiate email capture flow
	491	+ $response = esc_html($this->options['triggered_phrase_response'] ?? "Would you like to join our mailing list? Please provide your email below.");
	492	+
	493	+ set_transient('mxchat_email_capture_' . $user_id, true, 5 * MINUTE_IN_SECONDS);
	494	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	495	+
	496	+ // Respond to the user
	497	+ wp_send_json(['message' => $response]);
	498	+ wp_die();
	499	+}
	500	+
	501	+//very good
	502	+public function mxchat_generate_image($message, $user_id, $session_id) {
	503	+ // Prepare a prompt for DALL-E
	504	+ $prompt = "Create an image of " . sanitize_text_field($message);
	505	+
	506	+ // Use the existing OpenAI API key
	507	+ $openai_api_key = sanitize_text_field($this->options['api_key']);
	508	+
	509	+ // Call DALL-E to generate an image
	510	+ $image_response = $this->mxchat_generate_dalle_image($prompt, $openai_api_key);
	511	+
	512	+ // Check if the response contains an image URL
	513	+ if (isset($image_response['imageUrl'])) {
	514	+ $image_url = esc_url_raw($image_response['imageUrl']);
	515	+
	516	+ // Construct the HTML with a CSS class instead of inline styles
	517	+ $response_html = '<img src="' . esc_url($image_url) . '" alt="Generated Image" class="mxchat-generated-image" />';
	518	+
	519	+ $response_text = "Here is the image I generated:";
	520	+ } else {
	521	+ $response_text = "I'm sorry, but I couldn't generate an image based on your request.";
	522	+ $response_html = '';
	523	+ //error_log("DALL-E image generation error: " . esc_html($image_response['error'] ?? 'Unknown error.'));
	524	+ }
	525	+
	526	+ // Save both text and HTML responses
	527	+ $this->mxchat_save_chat_message($session_id, 'bot', $response_text . "\n" . $response_html);
	528	+
	529	+ // Prepare the response data
	530	+ $response_data = [
	531	+ 'message' => $response_text,
	532	+ 'html' => $response_html,
	533	+ 'image_url' => $image_url ?? '',
	534	+ ];
	535	+
	536	+ // Send the JSON response
	537	+ header('Content-Type: application/json; charset=' . get_option('blog_charset'));
	538	+ echo json_encode($response_data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
	539	+ wp_die();
	540	+}
	541	+private function mxchat_generate_dalle_image($prompt, $api_key, $model = 'dall-e-3', $timeout = 60) {
	542	+ $api_url = 'https://api.openai.com/v1/images/generations';
	543	+ $body = json_encode([
	544	+ 'prompt' => sanitize_text_field($prompt),
	545	+ 'n' => 1,
	546	+ 'size' => '1024x1024',
	547	+ 'model' => sanitize_text_field($model),
	548	+ ]);
	549	+
	550	+ $args = [
	551	+ 'body' => $body,
	552	+ 'headers' => [
	553	+ 'Content-Type' => 'application/json',
	554	+ 'Authorization' => 'Bearer ' . sanitize_text_field($api_key),
	555	+ ],
	556	+ 'method' => 'POST',
	557	+ 'timeout' => absint($timeout),
	558	+ ];
	559	+
	560	+ $response = wp_remote_post($api_url, $args);
	561	+
	562	+ if (is_wp_error($response)) {
	563	+ //error_log("DALL-E request failed: " . $response->get_error_message());
	564	+ return ['error' => "Error generating image: " . $response->get_error_message()];
	565	+ }
	566	+
	567	+ $response_body = json_decode(wp_remote_retrieve_body($response), true);
	568	+
	569	+ if (isset($response_body['data'][0]['url'])) {
	570	+ return ['imageUrl' => esc_url_raw($response_body['data'][0]['url'])];
	571	+ } else {
	572	+ //error_log("DALL-E response error: " . wp_remote_retrieve_body($response));
	573	+ return ['error' => "Failed to generate image."];
	574	+ }
	575	+}
	576	+
	577	+//very good
	578	+public function mxchat_handle_search_request($message, $user_id, $session_id) {
	579	+ // Sanitize user input
	580	+ $search_query = preg_replace('/^search the web for\s+/i', '', $message);
	581	+ $search_query = preg_replace('/^show me the latest news about\s+/i', '', $message);
	582	+ $search_query = preg_replace('/^what\'?s the news in\s+/i', '', $message);
	583	+ $search_query = preg_replace('/^news about\s+/i', '', $message);
	584	+ $search_query = trim(sanitize_text_field($search_query));
	585	+
	586	+ if (empty($search_query)) {
	587	+ $this->fallbackResponse = [
	588	+ 'text' => __("Please provide a valid search query.", 'mxchat'),
	589	+ ];
	590	+ return;
	591	+ }
	592	+
	593	+ // Check if the query is likely related to news
	594	+ $is_news_search = preg_match("/\bnews\b/i", $message);
	595	+
	596	+ // Retrieve settings
	597	+ $options = get_option('mxchat_options');
	598	+
	599	+ $api_key = isset($options['brave_api_key']) ? sanitize_text_field($options['brave_api_key']) : '';
	600	+ $news_count = isset($options['brave_news_count']) ? intval($options['brave_news_count']) : 3;
	601	+ $country = isset($options['brave_country']) ? sanitize_text_field($options['brave_country']) : 'us';
	602	+ $language = isset($options['brave_language']) ? sanitize_text_field($options['brave_language']) : 'en';
	603	+
	604	+ if (empty($api_key)) {
	605	+
	606	+ $this->fallbackResponse = [
	607	+ 'text' => __("API key is not configured. Please set it in the Brave Search Settings.", 'mxchat'),
	608	+ ];
	609	+ return;
	610	+ }
	611	+
	612	+ // Set API endpoint and parameters based on search type
	613	+ $api_url = $is_news_search
	614	+ ? 'https://api.search.brave.com/res/v1/news/search'
	615	+ : 'https://api.search.brave.com/res/v1/web/search';
	616	+
	617	+ $query_args = [
	618	+ 'q' => urlencode($search_query),
	619	+ ];
	620	+
	621	+ if ($is_news_search) {
	622	+ $query_args['count'] = $news_count;
	623	+ $query_args['country'] = $country;
	624	+ $query_args['search_lang'] = $language;
	625	+ }
	626	+
	627	+ $api_url = add_query_arg($query_args, $api_url);
	628	+
	629	+ // Implement caching
	630	+ $transient_key = 'mxchat_search_' . md5($api_url);
	631	+ $body = get_transient($transient_key);
	632	+
	633	+ if (false === $body) {
	634	+ $args = [
	635	+ 'headers' => [
	636	+ 'Accept' => 'application/json',
	637	+ 'Accept-Encoding' => 'gzip',
	638	+ 'Authorization' => 'Bearer ' . $api_key,
	639	+ 'x-subscription-token' => $api_key,
	640	+ ],
	641	+ 'timeout' => 10,
	642	+ ];
	643	+
	644	+ $response = wp_remote_get($api_url, $args);
	645	+
	646	+ if (is_wp_error($response)) {
	647	+
	648	+ $this->fallbackResponse = [
	649	+ 'text' => __("I'm sorry, I couldn't retrieve any information based on your request.", 'mxchat'),
	650	+ ];
	651	+ return;
	652	+ }
	653	+
	654	+ $body = json_decode(wp_remote_retrieve_body($response), true);
	655	+ set_transient($transient_key, $body, HOUR_IN_SECONDS);
	656	+ }
	657	+
	658	+ // Process the API response and build a more informative summary
	659	+ $text_summary = "";
	660	+
	661	+ if ($is_news_search && isset($body['results']) && is_array($body['results']) && count($body['results']) > 0) {
	662	+ $text_summary = "Here are some recent news articles:\n\n";
	663	+
	664	+ foreach ($body['results'] as $news) {
	665	+ $title = isset($news['title']) ? esc_html($news['title']) : __('No Title', 'mxchat');
	666	+ $url = isset($news['url']) ? esc_url($news['url']) : '#';
	667	+ $description = isset($news['description']) ? esc_html(strip_tags($news['description'])) : __('No description available.', 'mxchat');
	668	+ $age = isset($news['age']) ? esc_html($news['age']) : '';
	669	+ $hostname = isset($news['meta_url']['hostname']) ? esc_html($news['meta_url']['hostname']) : '';
	670	+ $thumbnail = isset($news['thumbnail']['src']) ? esc_url($news['thumbnail']['src']) : '';
	671	+
	672	+ // Build text-only news item summary
	673	+ $text_summary .= "Title: {$title}\nURL: {$url}\nDescription: {$description}\nPublished: {$age}\n";
	674	+ if (!empty($hostname)) {
	675	+ $text_summary .= "Source: {$hostname}\n";
	676	+ }
	677	+ if (!empty($thumbnail)) {
	678	+ $text_summary .= "Thumbnail: \n";
	679	+ }
	680	+ if (!empty($news['extra_snippets'])) {
	681	+ $extra_snippet_text = implode(" ", $news['extra_snippets']);
	682	+ $text_summary .= "Additional Info: {$extra_snippet_text}\n";
	683	+ }
	684	+ $text_summary .= "\n"; // Separate entries
	685	+ }
	686	+ } elseif (!$is_news_search && isset($body['web']['results']) && is_array($body['web']['results']) && count($body['web']['results']) > 0) {
	687	+ $text_summary = "Here are some relevant articles based on your query:\n\n";
	688	+
	689	+ foreach ($body['web']['results'] as $result) {
	690	+ $title = isset($result['title']) ? esc_html($result['title']) : __('No Title', 'mxchat');
	691	+ $url = isset($result['url']) ? esc_url($result['url']) : '#';
	692	+ $description = isset($result['description']) ? esc_html(strip_tags($result['description'])) : __('No description available.', 'mxchat');
	693	+ $hostname = isset($result['meta_url']['hostname']) ? esc_html($result['meta_url']['hostname']) : '';
	694	+ $thumbnail = isset($result['thumbnail']['src']) ? esc_url($result['thumbnail']['src']) : '';
	695	+
	696	+ // Build text-only web item summary
	697	+ $text_summary .= "Title: {$title}\nURL: {$url}\nDescription: {$description}\n";
	698	+ if (!empty($hostname)) {
	699	+ $text_summary .= "Source: {$hostname}\n";
	700	+ }
	701	+ if (!empty($thumbnail)) {
	702	+ $text_summary .= "Thumbnail: \n";
	703	+ }
	704	+ if (!empty($result['extra_snippets'])) {
	705	+ $extra_snippet_text = implode(" ", $result['extra_snippets']);
	706	+ $text_summary .= "Additional Info: {$extra_snippet_text}\n";
	707	+ }
	708	+ $text_summary .= "\n"; // Separate entries
	709	+ }
	710	+ } else {
	711	+
	712	+ $this->fallbackResponse = [
	713	+ 'text' => __("I'm sorry, I couldn't retrieve any information based on your request.", 'mxchat'),
	714	+ ];
	715	+ return;
	716	+ }
	717	+
	718	+ $this->fallbackResponse = [
	719	+ 'text' => $text_summary,
	720	+ ];
	721	+
	722	+
	723	+}
	724	+
	725	+//very good
	726	+public function mxchat_handle_image_search_request($message, $user_id, $session_id) {
	727	+
	728	+ // Step 1: Interpret the search query for better results
	729	+ $refined_search_query = $this->mxchat_interpret_search_query($message);
	730	+
	731	+
	732	+ // If no query was interpreted, return a fallback message
	733	+ if (empty($refined_search_query)) {
	734	+ $this->fallbackResponse = [
	735	+ 'text' => __("I'm sorry, I couldn't interpret your search query. Please specify what you'd like to see images of.", 'mxchat'),
	736	+ 'html' => "",
	737	+ ];
	738	+ return;
	739	+ }
	740	+
	741	+ // Brave API URL
	742	+ $api_url = 'https://api.search.brave.com/res/v1/images/search';
	743	+
	744	+ // Retrieve Brave API settings
	745	+ $options = get_option('mxchat_options');
	746	+ $api_key = isset($options['brave_api_key']) ? sanitize_text_field($options['brave_api_key']) : '';
	747	+
	748	+ if (empty($api_key)) {
	749	+/*
	750	+ if (defined('WP_DEBUG') && WP_DEBUG) {
	751	+ error_log("Brave API key is missing.");
	752	+ }
	753	+*/
	754	+
	755	+ $this->fallbackResponse = [
	756	+ 'text' => __("API key is not configured. Please set it in the Brave Search Settings.", 'mxchat'),
	757	+ 'html' => "",
	758	+ ];
	759	+ return;
	760	+ }
	761	+
	762	+ $image_count = isset($options['brave_image_count']) ? intval($options['brave_image_count']) : 4;
	763	+ $safe_search = isset($options['brave_safe_search']) ? sanitize_text_field($options['brave_safe_search']) : 'strict';
	764	+
	765	+ // Append query parameters based on settings
	766	+ $api_url = add_query_arg([
	767	+ 'q' => rawurlencode($refined_search_query),
	768	+ 'count' => $image_count,
	769	+ 'safesearch' => $safe_search,
	770	+ ], $api_url);
	771	+
	772	+/*
	773	+ // Log the final API URL for the search
	774	+ if (defined('WP_DEBUG') && WP_DEBUG) {
	775	+ error_log("Final API URL for Brave Image Search: " . esc_url_raw($api_url));
	776	+ }
	777	+*/
	778	+
	779	+
	780	+ // Implement caching
	781	+ $transient_key = 'mxchat_image_search_' . md5($refined_search_query);
	782	+ $body = get_transient($transient_key);
	783	+
	784	+ if (false === $body) {
	785	+ $args = [
	786	+ 'headers' => [
	787	+ 'Accept' => 'application/json',
	788	+ 'Accept-Encoding' => 'gzip',
	789	+ 'X-Subscription-Token' => $api_key,
	790	+ ],
	791	+ 'timeout' => 10,
	792	+ ];
	793	+
	794	+ $response = wp_remote_get($api_url, $args);
	795	+
	796	+ if (is_wp_error($response)) {
	797	+/*
	798	+ if (defined('WP_DEBUG') && WP_DEBUG) {
	799	+ error_log("Brave Image API request failed: " . $response->get_error_message());
	800	+ }
	801	+*/
	802	+
	803	+ $this->fallbackResponse = [
	804	+ 'text' => __("I'm sorry, I couldn't retrieve any images based on your request.", 'mxchat'),
	805	+ 'html' => "",
	806	+ ];
	807	+ return;
	808	+ }
	809	+
	810	+ $body = json_decode(wp_remote_retrieve_body($response), true);
	811	+ set_transient($transient_key, $body, HOUR_IN_SECONDS);
	812	+ }
	813	+
	814	+ // Process the API response
	815	+ if (isset($body['results']) && is_array($body['results']) && count($body['results']) > 0) {
	816	+ $html_output = '<div class="mxchat-image-gallery">';
	817	+
	818	+ foreach ($body['results'] as $image) {
	819	+ $image_url = isset($image['url']) ? esc_url($image['url']) : '';
	820	+ $thumbnail_url = isset($image['thumbnail']['src']) ? esc_url($image['thumbnail']['src']) : '';
	821	+ $title = isset($image['title']) ? esc_html($image['title']) : __('Image', 'mxchat');
	822	+
	823	+ if ($image_url && $thumbnail_url) {
	824	+ $html_output .= '<div class="mxchat-image-item">';
	825	+ $html_output .= '<strong class="mxchat-image-title">' . $title . '</strong>';
	826	+ $html_output .= '<a href="' . $image_url . '" target="_blank" rel="noopener noreferrer" class="mxchat-image-link">';
	827	+ $html_output .= '<img src="' . $thumbnail_url . '" alt="' . $title . '" class="mxchat-image-thumbnail">';
	828	+ $html_output .= '</a></div>';
	829	+ }
	830	+ }
	831	+
	832	+ $html_output .= '</div>';
	833	+
	834	+ $this->fallbackResponse = [
	835	+ 'text' => "",
	836	+ 'html' => $html_output,
	837	+ ];
	838	+
	839	+ // Save response in chat history
	840	+ $this->mxchat_save_chat_message($session_id, 'bot', $html_output);
	841	+
	842	+ } else {
	843	+/*
	844	+ if (defined('WP_DEBUG') && WP_DEBUG) {
	845	+ error_log("Brave Image API response did not contain expected data structure or was empty: " . print_r($body, true));
	846	+ }
	847	+*/
	848	+
	849	+ $this->fallbackResponse = [
	850	+ 'text' => __("I'm sorry, I couldn't retrieve any images based on your request.", 'mxchat'),
	851	+ 'html' => "",
	852	+ ];
	853	+ }
	854	+}
	855	+public function mxchat_interpret_search_query($user_query) {
	856	+ $system_prompt = "Interpret the user's request to provide only the essential keywords or phrases for image searching. Remove conversational language, politeness, or extra context. Return a concise search query that doesn't lose any of the original meaning.";
	857	+
	858	+ // Retrieve OpenAI API key using 'api_key' as the option key
	859	+ $api_key = isset($this->options['api_key']) ? sanitize_text_field($this->options['api_key']) : sanitize_text_field(get_option('mxchat_options')['api_key']);
	860	+
	861	+/*
	862	+ // Log the API key check, without exposing the key
	863	+ if (defined('WP_DEBUG') && WP_DEBUG) {
	864	+ error_log("Retrieved OpenAI API Key: " . ($api_key ? "Present" : "Missing"));
	865	+ }
	866	+*/
	867	+
	868	+
	869	+ if (empty($api_key)) {
	870	+ //error_log("OpenAI API key is missing.");
	871	+ return sanitize_text_field($user_query); // Default to the original query if API key is missing
	872	+ }
	873	+
	874	+ $url = 'https://api.openai.com/v1/chat/completions';
	875	+ $args = [
	876	+ 'headers' => [
	877	+ 'Authorization' => 'Bearer ' . $api_key,
	878	+ 'Content-Type' => 'application/json',
	879	+ ],
	880	+ 'body' => wp_json_encode([
	881	+ 'model' => 'gpt-3.5-turbo',
	882	+ 'messages' => [
	883	+ ['role' => 'system', 'content' => $system_prompt],
	884	+ ['role' => 'user', 'content' => sanitize_text_field($user_query)],
	885	+ ],
	886	+ 'temperature' => 0.2,
	887	+ 'max_tokens' => 20,
	888	+ ]),
	889	+ 'method' => 'POST',
	890	+ ];
	891	+
	892	+ $response = wp_remote_post($url, $args);
	893	+
	894	+ if (is_wp_error($response)) {
	895	+ //error_log("OpenAI request failed: " . $response->get_error_message());
	896	+ return sanitize_text_field($user_query); // Fallback to the original query if there's an error
	897	+ }
	898	+
	899	+ $body = json_decode(wp_remote_retrieve_body($response), true);
	900	+
	901	+ // Check for a valid response and sanitize output
	902	+ if (isset($body['choices'][0]['message']['content'])) {
	903	+ $interpreted_query = sanitize_text_field(trim($body['choices'][0]['message']['content']));
	904	+
	905	+/*
	906	+ // Log the interpreted query for debugging
	907	+ if (defined('WP_DEBUG') && WP_DEBUG) {
	908	+ error_log("Interpreted search query: " . $interpreted_query);
	909	+ }
	910	+*/
	911	+
	912	+ return $interpreted_query;
	913	+ } else {
	914	+ //error_log("Unexpected API response format: " . print_r($body, true));
	915	+ return sanitize_text_field($user_query);
	916	+ }
	917	+}
	918	+
	919	+//very good
	920	+public function mxchat_handle_add_to_cart_intent($message, $user_id, $session_id) {
	921	+ // Check if WooCommerce is active before proceeding
	922	+ if (!class_exists('WooCommerce')) {
	923	+ // error_log("WooCommerce is not active. Add-to-cart intent cannot be processed.");
	924	+ return false;
	925	+ }
	926	+
	927	+ // Sanitize user ID for transient key
	928	+ $sanitized_user_id = sanitize_key($user_id);
	929	+
	930	+ // Retrieve the last discussed product ID from the transient
	931	+ $last_product_id = get_transient('mxchat_last_discussed_product_' . $sanitized_user_id);
	932	+ if ($last_product_id) {
	933	+ // Attempt to add the product to the WooCommerce cart
	934	+ $added = WC()->cart->add_to_cart($last_product_id);
	935	+ $product = wc_get_product($last_product_id);
	936	+
	937	+ if ($added && $product) {
	938	+ // Escape product name for safety
	939	+ $product_name = esc_html($product->get_name());
	940	+
	941	+ // Success response if the product is added to the cart
	942	+ $response = "The product '{$product_name}' has been added to your cart. To proceed to checkout, please type 'checkout'.";
	943	+ set_transient('mxchat_checkout_prompt_' . $sanitized_user_id, true, 5 * MINUTE_IN_SECONDS);
	944	+
	945	+ // Save the response in chat history and send a JSON response
	946	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	947	+ wp_send_json(['message' => $response]);
	948	+ wp_die();
	949	+ } else {
	950	+ // Failure response if the product could not be added
	951	+ $response = "Sorry, I couldn't add the product to your cart. Please try again.";
	952	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	953	+ wp_send_json(['message' => $response]);
	954	+ wp_die();
	955	+ }
	956	+ } else {
	957	+ // Prompt the user to specify the product name if no product was found
	958	+ $response = "I couldn't find the product to add. Please mention the product name again.";
	959	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	960	+ wp_send_json(['message' => $response]);
	961	+ wp_die();
	962	+ }
	963	+}
	964	+public function mxchat_handle_checkout_intent($message, $user_id, $session_id) {
	965	+ // Ensure WooCommerce is available and perform checkout actions
	966	+ if (class_exists('WooCommerce')) {
	967	+ // Sanitize user ID for transient key
	968	+ $sanitized_user_id = sanitize_key($user_id);
	969	+
	970	+ $checkout_prompt = get_transient('mxchat_checkout_prompt_' . $sanitized_user_id);
	971	+
	972	+ // Check if there is an active checkout prompt and if the cart has items
	973	+ if ($checkout_prompt && WC()->cart->get_cart_contents_count() > 0) {
	974	+ // Get and escape the checkout URL
	975	+ $checkout_url = wc_get_checkout_url();
	976	+ $checkout_url = esc_url_raw($checkout_url);
	977	+
	978	+ $response = "Great! Redirecting you to the checkout page...";
	979	+
	980	+ // Clear the checkout prompt transient to avoid duplicate responses
	981	+ delete_transient('mxchat_checkout_prompt_' . $sanitized_user_id);
	982	+
	983	+ // Save and send the response with the checkout URL for redirection
	984	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	985	+ wp_send_json(['message' => $response, 'redirect_url' => $checkout_url]);
	986	+ wp_die();
	987	+ } else {
	988	+ // If no active checkout prompt or empty cart, prompt user to add items first
	989	+ $response = "It seems like there is no active checkout prompt or no items in your cart. Please add a product to the cart first.";
	990	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	991	+ wp_send_json(['message' => $response]);
	992	+ wp_die();
	993	+ }
	994	+ } else {
	995	+ // WooCommerce is not available, send an error message
	996	+ $response = "WooCommerce is not active on this site, so checkout is not possible.";
	997	+ $this->mxchat_save_chat_message($session_id, 'bot', $response);
	998	+ wp_send_json(['message' => $response]);
	999	+ wp_die();
	1000	+ }
	1001	+}
	1002	+
	1003	+//very good
	1004	+public static function mxchat_extract_product_id_from_message($message) {
	1005	+ // Sanitize the message input
	1006	+ $message = sanitize_text_field($message);
	1007	+
	1008	+ // Convert Markdown links to plain URLs
	1009	+ $message = preg_replace('/\[(.*?)\]\((.*?)\)/', '$2', $message);
	1010	+
	1011	+ // Match all URLs in the message
	1012	+ preg_match_all('/https?:\/\/[^\s]+/', $message, $matches);
	1013	+
	1014	+ if (!empty($matches[0])) {
	1015	+ foreach ($matches[0] as $url) {
	1016	+ // Sanitize the URL
	1017	+ $url = esc_url_raw($url);
	1018	+
	1019	+ // Try to get the post ID from the URL
	1020	+ $post_id = url_to_postid($url);
	1021	+
	1022	+ if ($post_id) {
	1023	+ // Check if the post type is 'product'
	1024	+ if (get_post_type($post_id) === 'product') {
	1025	+ return $post_id;
	1026	+ }
	1027	+ }
	1028	+ }
	1029	+ }
	1030	+ return false;
	1031	+}
	1032	+
	1033	+
	1034	+//very good
	1035	+private function add_email_to_loops($email) {
	1036	+ // Sanitize the email
	1037	+ $email = sanitize_email($email);
	1038	+
	1039	+ // Retrieve and sanitize options
	1040	+ $api_key = isset($this->options['loops_api_key']) ? sanitize_text_field($this->options['loops_api_key']) : '';
	1041	+ $mailing_list_id = isset($this->options['loops_mailing_list']) ? sanitize_text_field($this->options['loops_mailing_list']) : '';
	1042	+
	1043	+ // Check for missing API key or mailing list ID
	1044	+ if (empty($api_key) || empty($mailing_list_id)) {
	1045	+ //error_log('Loops API key or mailing list ID is missing.');
	1046	+ return;
	1047	+ }
	1048	+
	1049	+ $data = array(
	1050	+ 'email' => $email,
	1051	+ 'subscribed' => true,
	1052	+ 'source' => 'MxChat AI Chatbot',
	1053	+ 'mailingLists' => array($mailing_list_id => true),
	1054	+ );
	1055	+
	1056	+ $url = 'https://app.loops.so/api/v1/contacts/create';
	1057	+ $args = array(
	1058	+ 'body' => wp_json_encode($data),
	1059	+ 'headers' => array(
	1060	+ 'Authorization' => 'Bearer ' . $api_key,
	1061	+ 'Content-Type' => 'application/json',
	1062	+ ),
	1063	+ 'method' => 'POST',
	1064	+ 'timeout' => 45,
	1065	+ );
	1066	+
	1067	+ $response = wp_remote_post($url, $args);
	1068	+
	1069	+ // Handle errors in the API request
	1070	+ if (is_wp_error($response)) {
	1071	+ //error_log('Error adding email to Loops: ' . $response->get_error_message());
	1072	+ return;
	1073	+ }
	1074	+
	1075	+ // Check for non-200 HTTP responses
	1076	+ $response_code = wp_remote_retrieve_response_code($response);
	1077	+ if ($response_code != 200) {
	1078	+ $response_body = wp_remote_retrieve_body($response);
	1079	+ //error_log('Loops API responded with code ' . $response_code . ': ' . $response_body);
	1080	+ }
	1081	+}
	1082	+
	1083	+private function mxchat_get_user_identifier() {
	1084	+ return MxChat_User::mxchat_get_user_identifier();
	1085	+}
	1086	+
	1087	+private function mxchat_generate_embedding($text, $api_key) {
	1088	+ $endpoint = 'https://api.openai.com/v1/embeddings';
	1089	+
	1090	+ $body = wp_json_encode([
	1091	+ 'input' => $text,
	1092	+ 'model' => 'text-embedding-ada-002'
	1093	+ ]);
	1094	+
	1095	+ $args = [
	1096	+ 'body' => $body,
	1097	+ 'headers' => [
	1098	+ 'Content-Type' => 'application/json',
	1099	+ 'Authorization' => 'Bearer ' . $api_key,
	1100	+ ],
	1101	+ 'timeout' => 60,
	1102	+ 'redirection' => 5,
	1103	+ 'blocking' => true,
	1104	+ 'httpversion' => '1.0',
	1105	+ 'sslverify' => true,
	1106	+ ];
	1107	+
	1108	+ $response = wp_remote_post($endpoint, $args);
	1109	+
	1110	+ if (is_wp_error($response)) {
	1111	+ return null;
	1112	+ }
	1113	+
	1114	+ $response_body = json_decode(wp_remote_retrieve_body($response), true);
	1115	+
	1116	+ if (isset($response_body['data'][0]['embedding']) && is_array($response_body['data'][0]['embedding'])) {
	1117	+ return $response_body['data'][0]['embedding'];
	1118	+ } else {
	1119	+ return null;
	1120	+ }
	1121	+ }
	1122	+
	1123	+private function mxchat_find_relevant_content($user_embedding) {
	1124	+ global $wpdb;
	1125	+ $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
	1126	+
	1127	+ // Define a cache key for embeddings
	1128	+ $cache_key = 'mxchat_system_prompt_embeddings';
	1129	+
	1130	+ // Attempt to get the embeddings from the cache
	1131	+ $embeddings = wp_cache_get($cache_key, 'mxchat_system_prompts');
	1132	+
	1133	+ if ($embeddings === false) {
	1134	+ // Cache miss, query the database and cache the results
	1135	+ $query = "SELECT id, embedding_vector FROM {$system_prompt_table}";
	1136	+ $embeddings = $wpdb->get_results($query);
	1137	+
	1138	+ if ($embeddings === null || empty($embeddings)) {
	1139	+ return null; // Return null to handle no embeddings gracefully
	1140	+ }
	1141	+
	1142	+ // Cache the results if successful
	1143	+ wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600); // Cache for 1 hour
	1144	+ }
	1145	+
	1146	+ $most_relevant_id = null;
	1147	+ $highest_similarity = -INF;
	1148	+
	1149	+ foreach ($embeddings as $embedding) {
	1150	+ $database_embedding = $embedding->embedding_vector
	1151	+ ? unserialize($embedding->embedding_vector, ['allowed_classes' => false])
	1152	+ : null;
	1153	+
	1154	+ if (is_array($database_embedding) && is_array($user_embedding)) {
	1155	+ $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $database_embedding);
	1156	+
	1157	+ if ($similarity > $highest_similarity) {
	1158	+ $highest_similarity = $similarity;
	1159	+ $most_relevant_id = $embedding->id;
	1160	+ }
	1161	+ }
	1162	+ }
	1163	+
	1164	+ if ($most_relevant_id !== null) {
	1165	+ // Fetch content with product links
	1166	+ return $this->fetch_content_with_product_links($most_relevant_id);
	1167	+ }
	1168	+
	1169	+ return null; // Return null if no relevant content is found
	1170	+}
	1171	+
	1172	+private function fetch_content_with_product_links($most_relevant_id) {
	1173	+ global $wpdb;
	1174	+ $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
	1175	+
	1176	+ // Fetch the article content and associated product URL
	1177	+ $query = $wpdb->prepare("SELECT article_content, source_url FROM {$system_prompt_table} WHERE id = %d", $most_relevant_id);
	1178	+ $result = $wpdb->get_row($query);
	1179	+
	1180	+ if ($result) {
	1181	+ // Append the product link to the content if available
	1182	+ $content = $result->article_content;
	1183	+ if (!empty($result->source_url)) {
	1184	+ $content .= "\n\nFor more details, check out this product: " . esc_url($result->source_url);
	1185	+ }
	1186	+ return $content;
	1187	+ }
	1188	+
	1189	+ return null;
	1190	+}
	1191	+
	1192	+private function mxchat_generate_response($relevant_content, $api_key, $xai_api_key, $claude_api_key, $conversation_history) {
	1193	+ if (!$relevant_content) {
	1194	+ return "I'm sorry, I couldn't find relevant information on that topic.";
	1195	+ }
	1196	+
	1197	+ // Check the selected model
	1198	+ $selected_model = isset($this->options['model']) ? $this->options['model'] : 'gpt-3.5-turbo';
	1199	+
	1200	+ // Call the appropriate function based on the selected model
	1201	+ if (strpos($selected_model, 'claude') !== false) {
	1202	+ return $this->mxchat_generate_response_claude($selected_model, $claude_api_key, $conversation_history, $relevant_content);
	1203	+ } elseif ($selected_model === 'grok-beta') {
	1204	+ return $this->mxchat_generate_response_xai($selected_model, $xai_api_key, $conversation_history, $relevant_content);
	1205	+ } else {
	1206	+ return $this->mxchat_generate_response_openai($selected_model, $api_key, $conversation_history, $relevant_content);
	1207	+ }
	1208	+}
	1209	+
	1210	+private function mxchat_generate_response_openai($selected_model, $api_key, $conversation_history, $relevant_content) {
	1211	+ // Get system prompt instructions from options
	1212	+ $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
	1213	+
	1214	+ // Add system prompt to relevant content
	1215	+ $content_with_instructions = $system_prompt_instructions . " " . $relevant_content;
	1216	+
	1217	+ // Prepend system instructions to the conversation history
	1218	+ array_unshift($conversation_history, [
	1219	+ 'role' => 'system',
	1220	+ 'content' => "Here are your instructions: " . $content_with_instructions
	1221	+ ]);
	1222	+
	1223	+ // Ensure consistency: Replace 'bot' role with 'assistant' in conversation history
	1224	+ foreach ($conversation_history as &$message) {
	1225	+ if ($message['role'] === 'bot') {
	1226	+ $message['role'] = 'assistant';
	1227	+ }
	1228	+ }
	1229	+
	1230	+ // Build the request body
	1231	+ $body = json_encode([
	1232	+ 'model' => $selected_model,
	1233	+ 'messages' => $conversation_history,
	1234	+ 'temperature' => 0.8,
	1235	+ 'stream' => false
	1236	+ ]);
	1237	+
	1238	+ // Set up the API request
	1239	+ $args = [
	1240	+ 'body' => $body,
	1241	+ 'headers' => [
	1242	+ 'Content-Type' => 'application/json',
	1243	+ 'Authorization' => 'Bearer ' . $api_key,
	1244	+ ],
	1245	+ 'timeout' => 60,
	1246	+ 'redirection' => 5,
	1247	+ 'blocking' => true,
	1248	+ 'httpversion' => '1.0',
	1249	+ 'sslverify' => true,
	1250	+ ];
	1251	+
	1252	+ // Make the API request
	1253	+ $response = wp_remote_post('https://api.openai.com/v1/chat/completions', $args);
	1254	+
	1255	+ // Process the response
	1256	+ if (is_wp_error($response)) {
	1257	+ return "Sorry, there was an error processing your request.";
	1258	+ }
	1259	+
	1260	+ $response_body = json_decode(wp_remote_retrieve_body($response), true);
	1261	+
	1262	+ if (isset($response_body['choices'][0]['message']['content'])) {
	1263	+ return trim($response_body['choices'][0]['message']['content']);
	1264	+ } else {
	1265	+ return "Sorry, I couldn't process that request.";
	1266	+ }
	1267	+}
	1268	+
	1269	+private function mxchat_generate_response_xai($selected_model, $xai_api_key, $conversation_history, $relevant_content) {
	1270	+ // Get system prompt instructions from options
	1271	+ $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
	1272	+
	1273	+ // Add system prompt to relevant content
	1274	+ $content_with_instructions = $system_prompt_instructions . " " . $relevant_content;
	1275	+
	1276	+ // Prepend system instructions to the conversation history
	1277	+ array_unshift($conversation_history, [
	1278	+ 'role' => 'system',
	1279	+ 'content' => "Here are your instructions: " . $content_with_instructions
	1280	+ ]);
	1281	+
	1282	+ // Ensure consistency: Replace 'bot' role with 'assistant' in conversation history
	1283	+ foreach ($conversation_history as &$message) {
	1284	+ if ($message['role'] === 'bot') {
	1285	+ $message['role'] = 'assistant';
	1286	+ }
	1287	+ }
	1288	+
	1289	+ // Build the request body
	1290	+ $body = json_encode([
	1291	+ 'model' => $selected_model,
	1292	+ 'messages' => $conversation_history,
	1293	+ 'temperature' => 0.8,
	1294	+ 'stream' => false
	1295	+ ]);
	1296	+
	1297	+ // Set up the API request
	1298	+ $args = [
	1299	+ 'body' => $body,
	1300	+ 'headers' => [
	1301	+ 'Content-Type' => 'application/json',
	1302	+ 'Authorization' => 'Bearer ' . $xai_api_key,
	1303	+ ],
	1304	+ 'timeout' => 60,
	1305	+ 'redirection' => 5,
	1306	+ 'blocking' => true,
	1307	+ 'httpversion' => '1.0',
	1308	+ 'sslverify' => true,
	1309	+ ];
	1310	+
	1311	+ // Make the API request
	1312	+ $response = wp_remote_post('https://api.x.ai/v1/chat/completions', $args);
	1313	+
	1314	+ // Process the response
	1315	+ if (is_wp_error($response)) {
	1316	+ return "Sorry, there was an error processing your request.";
	1317	+ }
	1318	+
	1319	+ $response_body = json_decode(wp_remote_retrieve_body($response), true);
	1320	+
	1321	+ if (isset($response_body['choices'][0]['message']['content'])) {
	1322	+ return trim($response_body['choices'][0]['message']['content']);
	1323	+ } else {
	1324	+ return "Sorry, I couldn't process that request.";
	1325	+ }
	1326	+}
	1327	+
	1328	+private function mxchat_generate_response_claude($selected_model, $claude_api_key, $conversation_history, $relevant_content) {
	1329	+ // Get system prompt instructions from options for Claude's top-level system parameter
	1330	+ $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
	1331	+
	1332	+ // Ensure consistency: Replace 'bot' role with 'assistant' in conversation history
	1333	+ foreach ($conversation_history as &$message) {
	1334	+ if ($message['role'] === 'bot') {
	1335	+ $message['role'] = 'assistant';
	1336	+ }
	1337	+ }
	1338	+
	1339	+ // Add relevant content as the latest user message in conversation history
	1340	+ $conversation_history[] = [
	1341	+ 'role' => 'user',
	1342	+ 'content' => $relevant_content
	1343	+ ];
	1344	+
	1345	+ // Build the request body with Claude's expected structure, using system instructions as a top-level parameter
	1346	+ $body = json_encode([
	1347	+ 'model' => $selected_model,
	1348	+ 'max_tokens' => 1000,
	1349	+ 'temperature' => 0.8,
	1350	+ 'system' => $system_prompt_instructions, // Set the system prompt at the top level as required
	1351	+ 'messages' => $conversation_history
	1352	+ ]);
	1353	+
	1354	+ // Set up the API request with the necessary headers
	1355	+ $args = [
	1356	+ 'body' => $body,
	1357	+ 'headers' => [
	1358	+ 'Content-Type' => 'application/json',
	1359	+ 'x-api-key' => $claude_api_key,
	1360	+ 'anthropic-version' => '2023-06-01',
	1361	+ ],
	1362	+ 'timeout' => 60,
	1363	+ 'redirection' => 5,
	1364	+ 'blocking' => true,
	1365	+ 'httpversion' => '1.0',
	1366	+ 'sslverify' => true,
	1367	+ ];
	1368	+
	1369	+ // Make the API request
	1370	+ $response = wp_remote_post('https://api.anthropic.com/v1/messages', $args);
	1371	+
	1372	+/*
	1373	+ // Check for errors and log the response for debugging
	1374	+ if (is_wp_error($response)) {
	1375	+ error_log("Claude API request error: " . print_r($response->get_error_message(), true));
	1376	+ return "Sorry, there was an error processing your request.";
	1377	+ }
	1378	+*/
	1379	+
	1380	+
	1381	+ // Decode the response and parse according to the expected Claude response structure
	1382	+ $response_body = json_decode(wp_remote_retrieve_body($response), true);
	1383	+ //error_log("Claude API response: " . print_r($response_body, true));
	1384	+
	1385	+ // Check if the response has the expected 'content' array with 'text' blocks
	1386	+ if (isset($response_body['content'][0]['text'])) {
	1387	+ return trim($response_body['content'][0]['text']);
	1388	+ } else {
	1389	+ return "Sorry, I couldn't process that request.";
	1390	+ }
	1391	+}
	1392	+
	1393	+public function mxchat_dismiss_pre_chat_message() {
	1394	+ // Get and sanitize the user identifier
	1395	+ $user_id = $this->mxchat_get_user_identifier();
	1396	+ $user_id = sanitize_key($user_id);
	1397	+
	1398	+ // Set a transient to track that the user has dismissed the pre-chat message
	1399	+ $transient_key = 'mxchat_pre_chat_message_dismissed_' . $user_id;
	1400	+ set_transient($transient_key, true, DAY_IN_SECONDS);
	1401	+
	1402	+ wp_send_json_success();
	1403	+}
	1404	+
	1405	+public function mxchat_check_pre_chat_message_status() {
	1406	+ // Get and sanitize the user identifier
	1407	+ $user_id = $this->mxchat_get_user_identifier();
	1408	+ $user_id = sanitize_key($user_id);
	1409	+
	1410	+ // Check if the transient exists (i.e., if the message was dismissed)
	1411	+ $transient_key = 'mxchat_pre_chat_message_dismissed_' . $user_id;
	1412	+ $dismissed = get_transient($transient_key);
	1413	+
	1414	+ // Log the result to see if it's being set correctly
	1415	+ //error_log("Check pre-chat message dismissed for $user_id: " . ($dismissed ? 'Yes' : 'No'));
	1416	+
	1417	+ if ($dismissed) {
	1418	+ wp_send_json_success(['dismissed' => true]);
	1419	+ } else {
	1420	+ wp_send_json_success(['dismissed' => false]);
	1421	+ }
	1422	+
	1423	+ wp_die();
	1424	+}
	1425	+
	1426	+private function mxchat_calculate_cosine_similarity($vectorA, $vectorB) {
	1427	+ if (!is_array($vectorA) || !is_array($vectorB) || empty($vectorA) || empty($vectorB)) {
	1428	+ return 0;
	1429	+ }
	1430	+
	1431	+ $dotProduct = array_sum(array_map(function ($a, $b) {
	1432	+ return $a * $b;
	1433	+ }, $vectorA, $vectorB));
	1434	+ $normA = sqrt(array_sum(array_map(function ($a) {
	1435	+ return $a * $a;
	1436	+ }, $vectorA)));
	1437	+ $normB = sqrt(array_sum(array_map(function ($b) {
	1438	+ return $b * $b;
	1439	+ }, $vectorB)));
	1440	+
	1441	+ if ($normA == 0 || $normB == 0) {
	1442	+ return 0;
	1443	+ }
	1444	+
	1445	+ return $dotProduct / ($normA * $normB);
	1446	+ }
	1447	+
	1448	+public function mxchat_enqueue_scripts_styles() {
	1449	+ // Define version numbers for the styles and scripts
	1450	+ $chat_style_version = '1.3'; // Replace with your actual version
	1451	+ $chat_script_version = '1.3'; // Replace with your actual version
	1452	+
	1453	+ // Correct path to the script file
	1454	+ wp_enqueue_script(
	1455	+ 'mxchat-chat-js', // Handle for the script
	1456	+ plugin_dir_url(__FILE__) . '../js/chat-script.js', // Correct path using __FILE__
	1457	+ array('jquery'), // Dependencies
	1458	+ $chat_script_version, // Version for cache busting
	1459	+ true // Load script in footer
	1460	+ );
	1461	+
	1462	+ // Enqueue the CSS file similarly
	1463	+ wp_enqueue_style(
	1464	+ 'mxchat-chat-css', // Handle for the style
	1465	+ plugin_dir_url(__FILE__) . '../css/chat-style.css', // Correct path using __FILE__
	1466	+ array(), // No dependencies
	1467	+ $chat_style_version // Version for cache busting
	1468	+ );
	1469	+
	1470	+ // Fetch options from the database
	1471	+ $this->options = get_option('mxchat_options');
	1472	+
	1473	+ // Prepare settings to pass to JavaScript
	1474	+ $style_settings = array(
	1475	+ 'ajax_url' => admin_url('admin-ajax.php'),
	1476	+ 'nonce' => wp_create_nonce('mxchat_chat_nonce'), // Nonce for security
	1477	+ 'rate_limit_message' => $this->options['rate_limit_message'] ?? 'Rate limit exceeded. Please try again later.',
	1478	+ 'appendWidgetToBody' => $this->options['append_to_body'] ?? 'off'
	1479	+ );
	1480	+
	1481	+ // Localize the script with necessary data
	1482	+ wp_localize_script('mxchat-chat-js', 'mxchatChat', $style_settings);
	1483	+ }
	1484	+
	1485	+public function mxchat_reset_rate_limits() {
	1486	+ global $wpdb;
	1487	+
	1488	+ // Define a cache key pattern for rate limits
	1489	+ $cache_key_pattern = 'mxchat_chat_limit_%';
	1490	+
	1491	+ // Retrieve all option names matching the pattern
	1492	+ // phpcs:ignore WordPress.DB.DirectDatabaseQuery.NoCaching, WordPress.DB.DirectDatabaseQuery.DirectQuery
	1493	+ $option_names = $wpdb->get_col("SELECT option_name FROM {$wpdb->options} WHERE option_name LIKE 'mxchat_chat_limit_%'");
	1494	+
	1495	+ // db call ok; no-cache ok
	1496	+ // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery -- db call ok
	1497	+ $wpdb->query("DELETE FROM {$wpdb->options} WHERE option_name LIKE 'mxchat_chat_limit_%'");
	1498	+
	1499	+ // Clear the relevant cache entries
	1500	+ foreach ($option_names as $option_name) {
	1501	+ wp_cache_delete($option_name, 'options');
	1502	+ }
	1503	+
	1504	+ // Optionally, clear a general cache if you have one
	1505	+ wp_cache_delete('mxchat_all_chat_limits', 'options');
	1506	+ }
	1507	+
	1508	+private function mxchat_fetch_woocommerce_products() {
	1509	+ // Ensure WooCommerce is active
	1510	+ if (!class_exists('WooCommerce')) {
	1511	+ return [];
	1512	+ }
	1513	+
	1514	+ $args = array(
	1515	+ 'post_type' => 'product',
	1516	+ 'post_status' => 'publish',
	1517	+ 'posts_per_page' => -1,
	1518	+ );
	1519	+
	1520	+ $products = get_posts($args);
	1521	+ $product_data = [];
	1522	+
	1523	+ foreach ($products as $product) {
	1524	+ $product_id = $product->ID;
	1525	+ $product_obj = wc_get_product($product_id);
	1526	+
	1527	+ $product_data[] = array(
	1528	+ 'id' => $product_id,
	1529	+ 'name' => $product_obj->get_name(),
	1530	+ 'description' => $product_obj->get_description(),
	1531	+ 'short_description' => $product_obj->get_short_description(),
	1532	+ 'url' => get_permalink($product_id),
	1533	+ 'price' => $product_obj->get_regular_price(),
	1534	+ 'sale_price' => $product_obj->get_sale_price(),
	1535	+ 'stock_status' => $product_obj->get_stock_status(),
	1536	+ 'sku' => $product_obj->get_sku(),
	1537	+ 'in_stock' => $product_obj->is_in_stock(),
	1538	+ 'total_sales' => $product_obj->get_total_sales(),
	1539	+ );
	1540	+ }
	1541	+
	1542	+ return $product_data;
	1543	+}
	1544	+
	1545	+}
	1546	+?>