PluginProbe
MxChat – AI Chatbot & Content Generation for WordPress / 1.0.8
MxChat – AI Chatbot & Content Generation for WordPress v1.0.8
3.2.21 3.2.20 3.2.19 3.2.18 3.2.17 3.2.16 3.2.15 3.2.14 3.2.12 3.2.13 3.2.11 3.2.10 3.2.9 3.2.8 3.2.7 3.2.6 3.2.5 3.2.4 3.2.3 3.2.2 3.2.1 2.0.3 2.0.4 2.0.5 2.0.6 All 152 releases
← All changes | includes/class-mxchat-integrator.php +232 -3141 2.0.6 → 1.0.8 View file →
@@ -4,2868 +4,344 @@
4 4 }
5 5
6 6 class MxChat_Integrator {
7 7 private $options;
8 - private $prompts_options;
9 8 private $chat_count;
10 - private $fallbackResponse;
11 - private $productCardHtml;
12 - private $word_handler;
13 9
14 10 public function __construct() {
15 11 $this->options = get_option('mxchat_options');
16 - $this->prompts_options = get_option('mxchat_prompts_options', array());
12 + $this->chat_count = get_option('mxchat_chat_count', 0);
17 13
18 - $this->chat_count = get_option('mxchat_chat_count', 0);
19 - $this->word_handler = new MXChat_Word_Handler($this->options);
14 + // Add WooCommerce hooks
15 + add_action('wp_insert_post', array($this, 'mxchat_handle_product_change'), 10, 3);
20 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 21 add_action('wp_enqueue_scripts', array($this, 'mxchat_enqueue_scripts_styles'));
22 22 add_action('wp_ajax_mxchat_handle_chat_request', array($this, 'mxchat_handle_chat_request'));
23 23 add_action('wp_ajax_nopriv_mxchat_handle_chat_request', array($this, 'mxchat_handle_chat_request'));
24 -
25 24 add_action('wp_ajax_mxchat_dismiss_pre_chat_message', array($this, 'mxchat_dismiss_pre_chat_message'));
26 25 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 26
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 27 if (!wp_next_scheduled('mxchat_reset_rate_limits')) {
38 28 wp_schedule_event(time(), 'daily', 'mxchat_reset_rate_limits');
39 29 }
40 30
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 31 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 32 }
67 33
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);
34 +public function mxchat_handle_product_change($post_id, $post, $update) {
35 + // Ensure this is a product post type
36 + if ($post->post_type !== 'product') {
37 + return;
73 38 }
74 39
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();
40 + // Only generate embeddings if the product is published
41 + if ($post->post_status === 'publish') {
42 + // Delay the embedding slightly to ensure all product data is available
43 + add_action('shutdown', function() use ($post_id) {
44 + $product = wc_get_product($post_id);
45 + if ($product && $product->get_price() !== '') {
46 + $this->mxchat_store_product_embedding($product);
47 + } else {
48 + // Optionally, log or handle the case where product data is incomplete
49 + error_log("Product {$post_id} does not have complete data. Embedding not generated.");
50 + }
51 + });
79 52 }
53 +}
80 54
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();
55 +public function mxchat_handle_product_delete($post_id) {
56 + if (get_post_type($post_id) !== 'product') {
57 + return;
92 58 }
93 59
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 = [];
60 + global $wpdb;
61 + $table_name = $wpdb->prefix . 'mxchat_system_prompt_content';
103 62
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;
63 + // Delete the embedding associated with this product
64 + $wpdb->delete($table_name, array('source_url' => get_permalink($post_id)), array('%s'));
113 65 }
114 66
67 +private function mxchat_store_product_embedding($product) {
68 + if (isset($this->options['enable_woocommerce_integration']) && $this->options['enable_woocommerce_integration'] === '1') {
115 69
116 -private function mxchat_fetch_conversation_history_for_ai($session_id) {
117 - $history = get_option("mxchat_history_{$session_id}", []);
118 - $formatted_history = [];
70 + $source_url = get_permalink($product->get_id());
71 + $regular_price = $product->get_regular_price();
72 + $sale_price = $product->get_sale_price();
73 + $price = $sale_price ?: $regular_price;
119 74
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;
75 + $description = $product->get_description() . "\n\n" .
76 + "Short Description: " . $product->get_short_description() . "\n" .
77 + "Price: " . $regular_price . "\n" .
78 + "Sale Price: " . ($sale_price ?: 'N/A') . "\n" .
79 + "SKU: " . $product->get_sku();
124 80
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 - ];
81 + global $wpdb;
82 + $table_name = $wpdb->prefix . 'mxchat_system_prompt_content';
134 83
135 - foreach (array_reverse($history) as $entry) {
136 - // Preserve code blocks while sanitizing other HTML
137 - $clean_content = wp_kses($entry['content'], $allowed_tags);
84 + // Delete any existing embedding for this product
85 + $wpdb->delete($table_name, array('source_url' => $source_url), array('%s'));
138 86
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;
87 + // Submit the new content and embedding to the database
88 + MxChat_Utils::submit_content_to_db($description, $source_url, $this->options['api_key']);
175 89 }
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 90 }
189 91
190 -public function register_routes() {
191 - //error_log(esc_html__('Registering MxChat REST routes', 'mxchat'));
192 92
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 93
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 94
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 95
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;
96 + private function mxchat_increment_chat_count() {
97 + $chat_count = get_option('mxchat_chat_count', 0);
98 + $chat_count++;
99 + update_option('mxchat_chat_count', $chat_count);
222 100 }
223 101
224 - $chat_mode = get_option("mxchat_mode_{$session_id}", 'ai');
225 - return $chat_mode === 'agent';
226 -}
102 +public function mxchat_fetch_conversation_history_for_ajax($session_id) {
103 + global $wpdb;
104 + $table_name = $wpdb->prefix . 'mxchat_chat_transcripts';
227 105
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'] ?? '';
106 + // Prepare and execute the query safely
107 + $chat_transcripts = $wpdb->get_results(
108 + $wpdb->prepare("SELECT * FROM $table_name WHERE session_id = %s ORDER BY timestamp ASC", sanitize_text_field($session_id))
109 + );
237 110
238 - if (empty($valid_key)) {
239 - //error_log(esc_html__('Slack signing secret not configured', 'mxchat'));
240 - return false;
111 + // Check if results are empty
112 + if (empty($chat_transcripts)) {
113 + return [];
241 114 }
242 115
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;
116 + // Build the conversation history
117 + $conversation_history = [];
118 + foreach ($chat_transcripts as $transcript) {
119 + $conversation_history[] = [
120 + 'role' => $transcript->role,
121 + 'content' => $transcript->message
122 + ];
250 123 }
251 124
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);
125 + return $conversation_history;
263 126 }
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 127
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 128
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 129 private function mxchat_save_chat_message($session_id, $role, $message) {
300 130 global $wpdb;
301 -
302 131 $table_name = $wpdb->prefix . 'mxchat_chat_transcripts';
303 - //error_log("[DEBUG] mxchat_save_chat_message -> START for session_id: {$session_id}, role: {$role}");
304 132
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 133 $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
134 + $user_identifier = MxChat_User::mxchat_get_user_identifier();
331 135 $user_email = MxChat_User::mxchat_get_user_email();
332 - $displayed_name = $agent_name ? $agent_name : ($user_email ?: $user_identifier);
333 136
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,
137 + $wpdb->insert($table_name, [
138 + 'user_id' => $user_id,
139 + 'user_identifier' => $user_identifier,
140 + 'user_email' => $user_email,
141 + 'session_id' => $session_id,
356 142 '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
143 + 'message' => $message,
144 + 'timestamp' => current_time('mysql', 1)
551 145 ]);
552 - wp_die();
553 146 }
554 147
555 148 public function mxchat_handle_chat_request() {
556 149 global $wpdb;
557 150
151 + // Get and sanitize the user identifier
152 + $user_id = $this->mxchat_get_user_identifier();
153 + $user_id = sanitize_key($user_id);
558 154
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'];
155 + // Manage rate limiting
156 + $rate_limit_transient_key = 'mxchat_chat_limit_' . $user_id;
157 + $chat_count = get_transient($rate_limit_transient_key);
158 + $session_transient_key = 'mxchat_chat_session_' . $user_id;
159 + $session_id = get_transient($session_transient_key);
564 160
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 - }
161 + if ($chat_count === false) {
162 + $chat_count = 0;
593 163 }
594 164
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();
165 + if ($session_id === false) {
166 + $session_id = uniqid('mxchat_chat_', true);
167 + set_transient($session_transient_key, $session_id, DAY_IN_SECONDS); // Store session ID for a day
607 168 }
608 169
609 - // Get and sanitize the user identifier
610 - $user_id = sanitize_key($user_id);
170 + $rate_limit_option = isset($this->options['rate_limit']) ? $this->options['rate_limit'] : 'unlimited';
611 171
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'));
172 + // Check if rate limit is not 'unlimited'
173 + if ($rate_limit_option !== 'unlimited') {
174 + $rate_limit = intval($rate_limit_option);
615 175
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 176 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 - ]);
177 + wp_send_json_error('Rate limit exceeded. Please try again later.');
655 178 wp_die();
656 179 }
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);
180 + set_transient($rate_limit_transient_key, $chat_count + 1, DAY_IN_SECONDS);
661 181 }
662 182
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 183 // 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'));
184 + if (!isset($_POST['message'])) {
185 + wp_send_json_error('No message received');
677 186 wp_die();
678 187 }
679 188
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 - ]);
189 + $message = sanitize_text_field($_POST['message']);
190 + if (empty($message)) {
191 + wp_send_json_error('Message is empty or invalid.');
724 192 wp_die();
725 193 }
726 194
727 - $intent_info = '';
195 + // Initialize the variable with the original message
196 + $message_with_order_details = $message;
728 197
729 - // Check chat mode
730 - $chat_mode = get_option("mxchat_mode_{$session_id}", 'ai');
731 - //error_log("Chat Mode: $chat_mode");
198 + // Check if the user asked about orders
199 + if (MxChat_WooCommerce::mxchat_is_order_related_query($message)) {
200 + $order_details = MxChat_WooCommerce::mxchat_fetch_user_orders_details();
732 201
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'));
202 + // If order details are available, append them to the user's message
203 + if (!empty($order_details)) {
204 + $message_with_order_details = $message . "\n\n" . $order_details;
776 205 }
777 - wp_die();
778 206 }
779 - }
780 207
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 208
785 - // Check if this is likely a PDF-related request
786 - $pdf_keywords = ['pdf', 'document', 'read', 'analyze'];
787 - $is_pdf_request = false;
209 + // Save the combined message to the database
210 + $this->mxchat_save_chat_message($session_id, 'user', $message_with_order_details);
788 211
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']);
212 + // Generate and validate the embedding
213 + $user_message_embedding = $this->mxchat_generate_embedding($message_with_order_details, $this->options['api_key']);
887 214 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'));
215 + wp_send_json_error('Error processing your message.');
890 216 wp_die();
891 217 }
892 218
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
219 + // Find relevant content based on embedding
897 220 $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 221
222 + // Fetch conversation history from the database
223 + $conversation_history = $this->mxchat_fetch_conversation_history_for_ajax($session_id);
902 224
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 - }
225 + // Increment the chat count
226 + $this->mxchat_increment_chat_count();
917 227
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 - );
228 + // Generate a response from the AI model
229 + $response = $this->mxchat_generate_response($relevant_content, $this->options['api_key'], $conversation_history);
941 230
231 + // Save the bot response to the database
942 232 $this->mxchat_save_chat_message($session_id, 'bot', $response);
943 233
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
234 + // Send the response back to the client
1106 235 wp_send_json(['message' => $response]);
1107 - wp_die();
1108 -}
1109 236
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 237 wp_die();
1149 238 }
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 239
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 240
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 - }
241 +private function mxchat_get_user_identifier() {
242 + return MxChat_User::mxchat_get_user_identifier();
1184 243 }
1185 244
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 245
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 246
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;
247 + private function mxchat_generate_embedding($text, $api_key) {
248 + $endpoint = 'https://api.openai.com/v1/embeddings';
1213 249
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 - }
250 + $body = wp_json_encode([
251 + 'input' => $text,
252 + 'model' => 'text-embedding-ada-002'
253 + ]);
1220 254
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 255 $args = [
256 + 'body' => $body,
1450 257 'headers' => [
1451 - 'Accept' => 'application/json',
1452 - 'Accept-Encoding' => 'gzip',
1453 - 'X-Subscription-Token' => $api_key,
258 + 'Content-Type' => 'application/json',
259 + 'Authorization' => 'Bearer ' . $api_key,
1454 260 ],
1455 - 'timeout' => 10,
261 + 'timeout' => 60,
262 + 'redirection' => 5,
263 + 'blocking' => true,
264 + 'httpversion' => '1.0',
265 + 'sslverify' => true,
1456 266 ];
1457 267
1458 - $response = wp_remote_get($api_url, $args);
268 + $response = wp_remote_post($endpoint, $args);
1459 269
1460 270 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;
271 + return null;
1472 272 }
1473 273
1474 - $body = json_decode(wp_remote_retrieve_body($response), true);
1475 - set_transient($transient_key, $body, HOUR_IN_SECONDS);
1476 - }
274 + $response_body = json_decode(wp_remote_retrieve_body($response), true);
1477 275
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)
276 + if (isset($response_body['data'][0]['embedding']) && is_array($response_body['data'][0]['embedding'])) {
277 + return $response_body['data'][0]['embedding'];
1787 278 } else {
1788 - $this->fallbackResponse['text'] = $trigger_text;
279 + return null;
1789 280 }
1790 - return;
1791 281 }
1792 282
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 - // Get options and selected model
2434 - $options = get_option('mxchat_options');
2435 - $selected_model = $options['embedding_model'] ?? 'text-embedding-ada-002';
2436 -
2437 - // Determine endpoint and API key based on model
2438 - if (strpos($selected_model, 'voyage') === 0) {
2439 - $endpoint = 'https://api.voyageai.com/v1/embeddings';
2440 - $api_key = $options['voyage_api_key'] ?? '';
2441 - } else {
2442 - $endpoint = 'https://api.openai.com/v1/embeddings';
2443 - // Use the passed API key for OpenAI
2444 - }
2445 -
2446 - // Prepare request body with conditional output_dimension
2447 - $request_body = [
2448 - 'input' => $text,
2449 - 'model' => $selected_model
2450 - ];
2451 -
2452 - // Add output_dimension for voyage-3-large
2453 - if ($selected_model === 'voyage-3-large') {
2454 - $request_body['output_dimension'] = 2048;
2455 - }
2456 -
2457 - // Prepare request arguments
2458 - $args = [
2459 - 'body' => wp_json_encode($request_body),
2460 - 'headers' => [
2461 - 'Content-Type' => 'application/json',
2462 - 'Authorization' => 'Bearer ' . $api_key,
2463 - ],
2464 - 'timeout' => 60,
2465 - 'redirection' => 5,
2466 - 'blocking' => true,
2467 - 'httpversion' => '1.0',
2468 - 'sslverify' => true,
2469 - ];
2470 -
2471 - // Make the request
2472 - $response = wp_remote_post($endpoint, $args);
2473 -
2474 - // Rest of your existing code...
2475 - if (is_wp_error($response)) {
2476 - //error_log('Embedding Generation Error: ' . $response->get_error_message());
2477 - return null;
2478 - }
2479 -
2480 - $response_body = json_decode(wp_remote_retrieve_body($response), true);
2481 -
2482 - if (isset($response_body['data'][0]['embedding']) && is_array($response_body['data'][0]['embedding'])) {
2483 - return $response_body['data'][0]['embedding'];
2484 - } else {
2485 - //error_log('Invalid embedding response: ' . wp_json_encode($response_body));
2486 - return null;
2487 - }
2488 -}
2489 -
2490 -
2491 283 private function mxchat_find_relevant_content($user_embedding) {
2492 - //error_log('MXChat Vector Search: Starting content search...');
2493 -
2494 - // Retrieve the add-on settings from the database.
2495 - $addon_options = get_option('mxchat_pinecone_addon_options', array());
2496 -
2497 - // Determine whether Pinecone is enabled.
2498 - // We expect the sanitized setting to be a string '1' if enabled, otherwise '0'.
2499 - $use_pinecone = (isset($addon_options['mxchat_use_pinecone']) && $addon_options['mxchat_use_pinecone'] === '1') ? 1 : 0;
2500 -
2501 - //error_log('Pinecone enabled flag: ' . $use_pinecone);
2502 -
2503 - if ($use_pinecone === 1) {
2504 - //error_log('MXChat Vector Search: Using Pinecone database');
2505 - return $this->find_relevant_content_pinecone($user_embedding);
2506 - } else {
2507 - //error_log('MXChat Vector Search: Using WordPress database');
2508 - return $this->find_relevant_content_wordpress($user_embedding);
2509 - }
2510 -}
2511 -
2512 -private function find_relevant_content_wordpress($user_embedding) {
2513 284 global $wpdb;
2514 285 $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
286 +
287 + // Define a cache key for embeddings
2515 288 $cache_key = 'mxchat_system_prompt_embeddings';
2516 - $batch_size = 500;
2517 289
2518 - // Retrieve embeddings from cache or database
290 + // Attempt to get the embeddings from the cache
2519 291 $embeddings = wp_cache_get($cache_key, 'mxchat_system_prompts');
292 +
2520 293 if ($embeddings === false) {
2521 - $embeddings = [];
2522 - $offset = 0;
294 + // Cache miss, query the database and cache the results
295 + $query = "SELECT id, embedding_vector FROM {$system_prompt_table}";
296 + $embeddings = $wpdb->get_results($query);
2523 297
2524 - // Load in batches and build cache
2525 - do {
2526 - $query = $wpdb->prepare(
2527 - "SELECT id, embedding_vector
2528 - FROM {$system_prompt_table}
2529 - LIMIT %d OFFSET %d",
2530 - $batch_size,
2531 - $offset
2532 - );
298 + if ($embeddings === null || empty($embeddings)) {
299 + error_log("No embeddings found in the database.");
300 + return null; // Return null to handle no embeddings gracefully
301 + }
2533 302
2534 - $batch = $wpdb->get_results($query);
2535 - if (empty($batch)) {
2536 - break;
2537 - }
303 + // Cache the results if successful
304 + wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600); // Cache for 1 hour
305 + }
2538 306
2539 - $embeddings = array_merge($embeddings, $batch);
2540 - $offset += $batch_size;
307 + $most_relevant_id = null;
308 + $highest_similarity = -INF;
2541 309
2542 - // Free memory
2543 - unset($batch);
310 + foreach ($embeddings as $embedding) {
311 + $database_embedding = maybe_unserialize($embedding->embedding_vector);
2544 312
2545 - } while (true);
313 + // Debugging: Log the embeddings
314 + // if (!is_array($database_embedding)) {
315 + // error_log("Invalid database embedding format for ID {$embedding->id}: " . print_r($database_embedding, true));
316 + // continue;
317 + // }
2546 318
2547 - if (empty($embeddings)) {
2548 - return ''; // Return an empty string if no embeddings found
2549 - }
2550 - wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600);
2551 - }
2552 -
2553 - // Initialize array to store relevant results with similarity scores
2554 - $relevant_results = [];
2555 - // Iterate through embeddings to calculate similarity
2556 - foreach ($embeddings as $embedding) {
2557 - $database_embedding = $embedding->embedding_vector
2558 - ? unserialize($embedding->embedding_vector, ['allowed_classes' => false])
2559 - : null;
2560 - if (is_array($database_embedding) && is_array($user_embedding)) {
319 + if (is_array($user_embedding)) {
2561 320 $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $database_embedding);
2562 - $relevant_results[] = [
2563 - 'id' => $embedding->id,
2564 - 'similarity' => $similarity
2565 - ];
2566 - }
2567 - // Free memory
2568 - unset($database_embedding);
2569 - }
2570 321
2571 - // Retrieve the similarity threshold
2572 - $similarity_threshold = ((int) get_option('mxchat_similarity_threshold', 80)) / 100;
322 + // Debugging: Log the similarity score
323 + // error_log("Calculated similarity for ID {$embedding->id}: {$similarity}");
2573 324
2574 - // Filter and sort relevant results by similarity
2575 - $relevant_results = array_filter($relevant_results, function ($result) use ($similarity_threshold) {
2576 - return $result['similarity'] >= $similarity_threshold;
2577 - });
2578 - usort($relevant_results, function ($a, $b) {
2579 - return $b['similarity'] <=> $a['similarity'];
2580 - });
2581 -
2582 - // Limit to the top 5 results
2583 - $top_results = array_slice($relevant_results, 0, 5);
2584 -
2585 - // Initialize the final content
2586 - $content = '';
2587 -
2588 - // Fetch and combine content for the top results
2589 - foreach ($top_results as $result) {
2590 - $chunk_content = $this->fetch_content_with_product_links($result['id']);
2591 - // Check if the content is PDF-related and add surrounding pages
2592 - if (strpos($chunk_content, '{"document_type":"pdf"') !== false) {
2593 - $surrounding_content = $wpdb->get_results($wpdb->prepare(
2594 - "SELECT article_content FROM {$system_prompt_table}
2595 - WHERE id IN (
2596 - (SELECT id FROM {$system_prompt_table} WHERE id < %d ORDER BY id DESC LIMIT 1),
2597 - (SELECT id FROM {$system_prompt_table} WHERE id > %d ORDER BY id ASC LIMIT 1)
2598 - )",
2599 - $result['id'],
2600 - $result['id']
2601 - ));
2602 - // Add previous content if it exists
2603 - if (!empty($surrounding_content[0])) {
2604 - $content .= $surrounding_content[0]->article_content . "\n\n";
325 + if ($similarity > $highest_similarity) {
326 + $highest_similarity = $similarity;
327 + $most_relevant_id = $embedding->id;
2605 328 }
2606 - // Add the main chunk content
2607 - $content .= $chunk_content . "\n\n";
2608 - // Add next content if it exists
2609 - if (!empty($surrounding_content[1])) {
2610 - $content .= $surrounding_content[1]->article_content . "\n\n";
2611 - }
2612 329 } else {
2613 - // For non-PDF content, add directly
2614 - $content .= $chunk_content . "\n\n";
330 + // error_log("User embedding is not an array. Embedding data: " . print_r($user_embedding, true));
2615 331 }
2616 332 }
2617 333
2618 - return trim($content);
2619 -}
2620 -/**
2621 - * Find relevant content in Pinecone vector database
2622 - */
2623 -private function find_relevant_content_pinecone($user_embedding) {
2624 - $options = get_option('mxchat_pinecone_addon_options', array());
2625 - $api_key = $options['mxchat_pinecone_api_key'] ?? '';
2626 - $host = $options['mxchat_pinecone_host'] ?? '';
2627 -
2628 - if (empty($host) || empty($api_key)) {
2629 - //error_log('Pinecone credentials not properly configured');
2630 - return '';
334 + if ($most_relevant_id !== null) {
335 + // Fetch content with product links
336 + return $this->fetch_content_with_product_links($most_relevant_id);
2631 337 }
2632 338
2633 - // Get similarity threshold from WordPress settings
2634 - $similarity_threshold = ((int) get_option('mxchat_similarity_threshold', 80)) / 100;
2635 -
2636 - // Prepare the query request for Pinecone
2637 - $api_endpoint = "https://{$host}/query";
2638 -
2639 - $request_body = array(
2640 - 'vector' => $user_embedding,
2641 - 'topK' => 5,
2642 - 'includeMetadata' => true,
2643 - 'includeValues' => true
2644 - );
2645 -
2646 - $response = wp_remote_post($api_endpoint, array(
2647 - 'headers' => array(
2648 - 'Api-Key' => $api_key,
2649 - 'accept' => 'application/json',
2650 - 'content-type' => 'application/json'
2651 - ),
2652 - 'body' => wp_json_encode($request_body),
2653 - 'timeout' => 30
2654 - ));
2655 -
2656 - if (is_wp_error($response)) {
2657 - //error_log('Pinecone query error: ' . $response->get_error_message());
2658 - return '';
2659 - }
2660 -
2661 - $response_code = wp_remote_retrieve_response_code($response);
2662 - if ($response_code !== 200) {
2663 - //error_log('Pinecone API error: ' . wp_remote_retrieve_body($response));
2664 - return '';
2665 - }
2666 -
2667 - $results = json_decode(wp_remote_retrieve_body($response), true);
2668 - if (empty($results['matches'])) {
2669 - return '';
2670 - }
2671 -
2672 - // Initialize the final content
2673 - $content = '';
2674 -
2675 - // Process each match
2676 - foreach ($results['matches'] as $match) {
2677 - // Skip if similarity is below threshold
2678 - if ($match['score'] < $similarity_threshold) {
2679 - continue;
2680 - }
2681 -
2682 - if (!empty($match['metadata']['text']) && !empty($match['metadata']['source_url'])) {
2683 - // Add content with citation
2684 - $content .= $match['metadata']['text'] . "\n";
2685 - $content .= "Source: " . $match['metadata']['source_url'] . "\n\n";
2686 - }
2687 - }
2688 -
2689 - return trim($content);
339 + error_log("No relevant content found. Most relevant ID was null.");
340 + return null; // Return null if no relevant content is found
2690 341 }
2691 342
2692 343
2693 -private function mxchat_find_relevant_products($user_embedding) {
2694 - //error_log('MXChat Vector Search: Starting product search...');
2695 -
2696 - // Retrieve the add-on settings from the database
2697 - $addon_options = get_option('mxchat_pinecone_addon_options', array());
2698 -
2699 - // Determine whether Pinecone is enabled
2700 - $use_pinecone = (isset($addon_options['mxchat_use_pinecone']) && $addon_options['mxchat_use_pinecone'] === '1') ? 1 : 0;
2701 -
2702 - //error_log('Pinecone enabled flag: ' . $use_pinecone);
2703 -
2704 - if ($use_pinecone === 1) {
2705 - //error_log('MXChat Vector Search: Using Pinecone database for products');
2706 - return $this->find_relevant_products_pinecone($user_embedding);
2707 - } else {
2708 - //error_log('MXChat Vector Search: Using WordPress database for products');
2709 - return $this->find_relevant_products_wordpress($user_embedding);
2710 - }
2711 -}
2712 -
2713 -private function find_relevant_products_wordpress($user_embedding) {
2714 - global $wpdb;
2715 - $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
2716 - $cache_key = 'mxchat_system_prompt_embeddings';
2717 - $batch_size = 500;
2718 -
2719 - // Original WordPress database search logic
2720 - // [Previous implementation remains the same]
2721 - $embeddings = wp_cache_get($cache_key, 'mxchat_system_prompts');
2722 - if ($embeddings === false) {
2723 - $embeddings = [];
2724 - $offset = 0;
2725 -
2726 - do {
2727 - $query = $wpdb->prepare(
2728 - "SELECT id, embedding_vector
2729 - FROM {$system_prompt_table}
2730 - LIMIT %d OFFSET %d",
2731 - $batch_size,
2732 - $offset
2733 - );
2734 -
2735 - $batch = $wpdb->get_results($query);
2736 - if (empty($batch)) {
2737 - break;
2738 - }
2739 -
2740 - $embeddings = array_merge($embeddings, $batch);
2741 - $offset += $batch_size;
2742 -
2743 - unset($batch);
2744 -
2745 - } while (true);
2746 -
2747 - if (empty($embeddings)) {
2748 - return '';
2749 - }
2750 - wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600);
2751 - }
2752 -
2753 - $relevant_results = [];
2754 - foreach ($embeddings as $embedding) {
2755 - $database_embedding = $embedding->embedding_vector
2756 - ? unserialize($embedding->embedding_vector, ['allowed_classes' => false])
2757 - : null;
2758 - if (is_array($database_embedding) && is_array($user_embedding)) {
2759 - $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $database_embedding);
2760 - $relevant_results[] = [
2761 - 'id' => $embedding->id,
2762 - 'similarity' => $similarity
2763 - ];
2764 - }
2765 - unset($database_embedding);
2766 - }
2767 -
2768 - // Use fixed threshold for products
2769 - $similarity_threshold = 0.85;
2770 -
2771 - $relevant_results = array_filter($relevant_results, function ($result) use ($similarity_threshold) {
2772 - return $result['similarity'] >= $similarity_threshold;
2773 - });
2774 - usort($relevant_results, function ($a, $b) {
2775 - return $b['similarity'] <=> $a['similarity'];
2776 - });
2777 -
2778 - $top_results = array_slice($relevant_results, 0, 5);
2779 - $content = '';
2780 -
2781 - foreach ($top_results as $result) {
2782 - $chunk_content = $this->fetch_content_with_product_links($result['id']);
2783 - $content .= $chunk_content . "\n\n";
2784 - }
2785 -
2786 - return trim($content);
2787 -}
2788 -
2789 -// Modified search function with correct filter syntax
2790 -private function find_relevant_products_pinecone($user_embedding) {
2791 - //error_log('Starting Pinecone product search...');
2792 -
2793 - $options = get_option('mxchat_pinecone_addon_options', array());
2794 - $api_key = $options['mxchat_pinecone_api_key'] ?? '';
2795 - $host = $options['mxchat_pinecone_host'] ?? '';
2796 -
2797 - if (empty($host) || empty($api_key)) {
2798 - //error_log('Pinecone credentials not properly configured for product search');
2799 - return '';
2800 - }
2801 -
2802 - $similarity_threshold = 0.85;
2803 - $api_endpoint = "https://{$host}/query";
2804 -
2805 - $request_body = array(
2806 - 'vector' => $user_embedding,
2807 - 'topK' => 5,
2808 - 'includeMetadata' => true,
2809 - 'includeValues' => true,
2810 - 'filter' => array(
2811 - 'type' => 'product'
2812 - )
2813 - );
2814 -
2815 - //error_log('Sending request to Pinecone with body: ' . wp_json_encode($request_body));
2816 -
2817 - $response = wp_remote_post($api_endpoint, array(
2818 - 'headers' => array(
2819 - 'Api-Key' => $api_key,
2820 - 'accept' => 'application/json',
2821 - 'content-type' => 'application/json'
2822 - ),
2823 - 'body' => wp_json_encode($request_body),
2824 - 'timeout' => 30
2825 - ));
2826 -
2827 - if (is_wp_error($response)) {
2828 - //error_log('Pinecone product query error: ' . $response->get_error_message());
2829 - return '';
2830 - }
2831 -
2832 - $response_code = wp_remote_retrieve_response_code($response);
2833 - //error_log('Pinecone response code: ' . $response_code);
2834 -
2835 - if ($response_code !== 200) {
2836 - //error_log('Pinecone API error during product search: ' . wp_remote_retrieve_body($response));
2837 - return '';
2838 - }
2839 -
2840 - $results = json_decode(wp_remote_retrieve_body($response), true);
2841 - //error_log('Pinecone raw response: ' . wp_remote_retrieve_body($response));
2842 -
2843 - if (empty($results['matches'])) {
2844 - //error_log('No matches found in Pinecone response');
2845 - return '';
2846 - }
2847 -
2848 - $content = '';
2849 - foreach ($results['matches'] as $match) {
2850 - if ($match['score'] < $similarity_threshold) {
2851 - //error_log("Match below threshold: " . $match['score']);
2852 - continue;
2853 - }
2854 -
2855 - if (!empty($match['metadata']['text'])) {
2856 - $content .= $match['metadata']['text'];
2857 - if (!empty($match['metadata']['source_url'])) {
2858 - $content .= "\n\nFor more details, check out this product: " . esc_url($match['metadata']['source_url']);
2859 - }
2860 - $content .= "\n\n";
2861 - }
2862 - }
2863 -
2864 - return trim($content);
2865 -}
2866 -
2867 -
2868 344 private function fetch_content_with_product_links($most_relevant_id) {
2869 345 global $wpdb;
2870 346 $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
2871 347
@@ -2884,291 +360,41 @@
2884 360
2885 361 return null;
2886 362 }
2887 363
2888 -// Function definition
2889 -private function mxchat_generate_response($relevant_content, $api_key, $xai_api_key, $claude_api_key, $deepseek_api_key, $conversation_history) {
2890 - try {
2891 - if (!$relevant_content) {
2892 - return esc_html__("I'm sorry, I couldn't find relevant information on that topic.", 'mxchat');
2893 - }
2894 364
2895 - // Ensure conversation_history is an array
2896 - if (!is_array($conversation_history)) {
2897 - $conversation_history = array();
2898 - }
2899 -
2900 - // Get selected model with default fallback
2901 - $selected_model = isset($this->options['model']) ? $this->options['model'] : 'gpt-4o';
2902 -
2903 - // Extract model prefix to determine the provider
2904 - $model_parts = explode('-', $selected_model);
2905 - $provider = strtolower($model_parts[0]);
2906 -
2907 - // Handle model selection based on provider prefix
2908 - switch ($provider) {
2909 - case 'claude':
2910 - if (empty($claude_api_key)) {
2911 - throw new Exception(esc_html__('Claude API key is not configured', 'mxchat'));
2912 - }
2913 - return $this->mxchat_generate_response_claude(
2914 - $selected_model,
2915 - $claude_api_key,
2916 - $conversation_history,
2917 - $relevant_content
2918 - );
2919 -
2920 - case 'grok':
2921 - if (empty($xai_api_key)) {
2922 - throw new Exception(esc_html__('X.AI API key is not configured', 'mxchat'));
2923 - }
2924 - return $this->mxchat_generate_response_xai(
2925 - $selected_model,
2926 - $xai_api_key,
2927 - $conversation_history,
2928 - $relevant_content
2929 - );
2930 -
2931 - case 'deepseek':
2932 - if (empty($deepseek_api_key)) {
2933 - throw new Exception(esc_html__('DeepSeek API key is not configured', 'mxchat'));
2934 - }
2935 - return $this->mxchat_generate_response_deepseek(
2936 - $selected_model,
2937 - $deepseek_api_key,
2938 - $conversation_history,
2939 - $relevant_content
2940 - );
2941 -
2942 - case 'gpt':
2943 - if (empty($api_key)) {
2944 - throw new Exception(esc_html__('OpenAI API key is not configured', 'mxchat'));
2945 - }
2946 - return $this->mxchat_generate_response_openai(
2947 - $selected_model,
2948 - $api_key,
2949 - $conversation_history,
2950 - $relevant_content
2951 - );
2952 -
2953 - default:
2954 - // Default to OpenAI for custom models or unrecognized prefixes
2955 - if (empty($api_key)) {
2956 - throw new Exception(esc_html__('OpenAI API key is not configured', 'mxchat'));
2957 - }
2958 - return $this->mxchat_generate_response_openai(
2959 - $selected_model,
2960 - $api_key,
2961 - $conversation_history,
2962 - $relevant_content
2963 - );
2964 - }
2965 - } catch (Exception $e) {
2966 - //error_log('MXChat Error: ' . $e->getMessage());
2967 - return sprintf(
2968 - esc_html__('An error occurred: %s', 'mxchat'),
2969 - esc_html($e->getMessage())
2970 - );
365 + private function mxchat_generate_response($relevant_content, $api_key, $conversation_history) {
366 + if (!$relevant_content) {
367 + return "I'm sorry, I couldn't find relevant information on that topic.";
2971 368 }
2972 -}
2973 369
2974 -
2975 -private function mxchat_generate_response_deepseek($selected_model, $deepseek_api_key, $conversation_history, $relevant_content) {
2976 - // Ensure conversation_history is an array
2977 - if (!is_array($conversation_history)) {
2978 - $conversation_history = array();
2979 - }
2980 -
2981 - // Get system prompt instructions from options
2982 370 $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
2983 371
2984 - // Create a new array for the formatted conversation
2985 - $formatted_conversation = array();
2986 -
2987 - // Add system message first
2988 - $formatted_conversation[] = array(
2989 - 'role' => 'system',
2990 - 'content' => $system_prompt_instructions . " " . $relevant_content
2991 - );
2992 -
2993 - // Add the rest of the conversation history
2994 - foreach ($conversation_history as $message) {
2995 - if (is_array($message) && isset($message['role']) && isset($message['content'])) {
2996 - $role = $message['role'];
2997 -
2998 - // Convert roles to supported format
2999 - if ($role === 'bot' || $role === 'agent') {
3000 - $role = 'assistant';
3001 - }
3002 - if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
3003 - $role = 'user';
3004 - }
3005 -
3006 - $formatted_conversation[] = array(
3007 - 'role' => $role,
3008 - 'content' => $message['content']
3009 - );
3010 - }
3011 - }
3012 -
3013 - $body = json_encode([
3014 - 'model' => $selected_model,
3015 - 'messages' => $formatted_conversation,
3016 - 'temperature' => 0.8,
3017 - 'stream' => false
3018 - ]);
3019 -
3020 - $args = [
3021 - 'body' => $body,
3022 - 'headers' => [
3023 - 'Content-Type' => 'application/json',
3024 - 'Authorization' => 'Bearer ' . $deepseek_api_key,
3025 - ],
3026 - 'timeout' => 60,
3027 - 'redirection' => 5,
3028 - 'blocking' => true,
3029 - 'httpversion' => '1.0',
3030 - 'sslverify' => true,
3031 - ];
3032 -
3033 - $response = wp_remote_post('https://api.deepseek.com/v1/chat/completions', $args);
3034 -
3035 - if (is_wp_error($response)) {
3036 - //error_log('DeepSeek API Error: ' . $response->get_error_message());
3037 - return "Sorry, there was an error processing your request.";
3038 - }
3039 -
3040 - $response_body = wp_remote_retrieve_body($response);
3041 - $decoded_response = json_decode($response_body, true);
3042 -
3043 - if (isset($decoded_response['choices'][0]['message']['content'])) {
3044 - return trim($decoded_response['choices'][0]['message']['content']);
3045 - } else {
3046 - //error_log('DeepSeek API Response Format Error: ' . print_r($decoded_response, true));
3047 - return "Sorry, I couldn't process that request.";
3048 - }
3049 -}
3050 -private function mxchat_generate_response_openai($selected_model, $api_key, $conversation_history, $relevant_content) {
3051 - // Ensure conversation_history is an array
3052 - if (!is_array($conversation_history)) {
3053 - $conversation_history = array();
3054 - }
3055 -
3056 - // Get system prompt instructions from options
3057 - $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3058 -
3059 - // Create a new array for the formatted conversation
3060 - $formatted_conversation = array();
3061 -
3062 - // Add system message first
3063 - $formatted_conversation[] = array(
3064 - 'role' => 'system',
3065 - 'content' => $system_prompt_instructions . " " . $relevant_content
3066 - );
3067 -
3068 - // Add the rest of the conversation history
3069 - foreach ($conversation_history as $message) {
3070 - if (is_array($message) && isset($message['role']) && isset($message['content'])) {
3071 - $role = $message['role'];
3072 -
3073 - // Convert roles to supported format
3074 - if ($role === 'bot' || $role === 'agent') {
3075 - $role = 'assistant';
3076 - }
3077 - if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
3078 - $role = 'user';
3079 - }
3080 -
3081 - $formatted_conversation[] = array(
3082 - 'role' => $role,
3083 - 'content' => $message['content']
3084 - );
3085 - }
3086 - }
3087 -
3088 - $body = json_encode([
3089 - 'model' => $selected_model,
3090 - 'messages' => $formatted_conversation,
3091 - 'temperature' => 0.8,
3092 - 'stream' => false
3093 - ]);
3094 -
3095 - $args = [
3096 - 'body' => $body,
3097 - 'headers' => [
3098 - 'Content-Type' => 'application/json',
3099 - 'Authorization' => 'Bearer ' . $api_key,
3100 - ],
3101 - 'timeout' => 60,
3102 - 'redirection' => 5,
3103 - 'blocking' => true,
3104 - 'httpversion' => '1.0',
3105 - 'sslverify' => true,
3106 - ];
3107 -
3108 - $response = wp_remote_post('https://api.openai.com/v1/chat/completions', $args);
3109 -
3110 - if (is_wp_error($response)) {
3111 - //error_log('OpenAI API Error: ' . $response->get_error_message());
3112 - return "Sorry, there was an error processing your request.";
3113 - }
3114 -
3115 - $response_body = wp_remote_retrieve_body($response);
3116 - $decoded_response = json_decode($response_body, true);
3117 -
3118 - if (isset($decoded_response['choices'][0]['message']['content'])) {
3119 - return trim($decoded_response['choices'][0]['message']['content']);
3120 - } else {
3121 - //error_log('OpenAI API Response Format Error: ' . print_r($decoded_response, true));
3122 - return "Sorry, I couldn't process that request.";
3123 - }
3124 -}
3125 -private function mxchat_generate_response_xai($selected_model, $xai_api_key, $conversation_history, $relevant_content) {
3126 - // Get system prompt instructions from options
3127 - $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3128 -
3129 - // Add system prompt to relevant content
3130 372 $content_with_instructions = $system_prompt_instructions . " " . $relevant_content;
3131 373
3132 - // Prepend system instructions to the conversation history
3133 374 array_unshift($conversation_history, [
3134 375 'role' => 'system',
3135 376 'content' => "Here are your instructions: " . $content_with_instructions
3136 377 ]);
3137 378
3138 - // Ensure consistency: Replace 'bot' and 'agent' roles with supported values
3139 379 foreach ($conversation_history as &$message) {
3140 380 if ($message['role'] === 'bot') {
3141 381 $message['role'] = 'assistant';
3142 - } elseif ($message['role'] === 'agent') {
3143 - // Tag the message as coming from a live agent
3144 - $message['role'] = 'assistant';
3145 - if (!isset($message['metadata'])) {
3146 - $message['metadata'] = ['source' => 'live_agent'];
3147 - }
3148 382 }
3149 -
3150 - // Ensure all roles are valid
3151 - if (!in_array($message['role'], ['system', 'assistant', 'user', 'function', 'tool'])) {
3152 - $message['role'] = 'user'; // Default to 'user'
3153 - }
3154 383 }
3155 384
385 + $api_url = 'https://api.openai.com/v1/chat/completions';
3156 386
3157 - // Build the request body
3158 387 $body = json_encode([
3159 - 'model' => $selected_model,
388 + 'model' => isset($this->options['model']) ? $this->options['model'] : 'gpt-3.5',
3160 389 'messages' => $conversation_history,
3161 - 'temperature' => 0.8,
3162 - 'stream' => false
3163 390 ]);
3164 391
3165 - // Set up the API request
3166 392 $args = [
3167 393 'body' => $body,
3168 394 'headers' => [
3169 395 'Content-Type' => 'application/json',
3170 - 'Authorization' => 'Bearer ' . $xai_api_key,
396 + 'Authorization' => 'Bearer ' . $api_key,
3171 397 ],
3172 398 'timeout' => 60,
3173 399 'redirection' => 5,
3174 400 'blocking' => true,
@@ -3175,12 +401,10 @@
3175 401 'httpversion' => '1.0',
3176 402 'sslverify' => true,
3177 403 ];
3178 404
3179 - // Make the API request
3180 - $response = wp_remote_post('https://api.x.ai/v1/chat/completions', $args);
405 + $response = wp_remote_post($api_url, $args);
3181 406
3182 - // Process the response
3183 407 if (is_wp_error($response)) {
3184 408 return "Sorry, there was an error processing your request.";
3185 409 }
3186 410
@@ -3186,116 +410,19 @@
3186 410
3187 411 $response_body = json_decode(wp_remote_retrieve_body($response), true);
3188 412
3189 413 if (isset($response_body['choices'][0]['message']['content'])) {
414 + if (isset($response_body['usage'])) {
415 + $prompt_tokens = $response_body['usage']['prompt_tokens'];
416 + $total_tokens = $response_body['usage']['total_tokens'];
417 + }
3190 418 return trim($response_body['choices'][0]['message']['content']);
3191 419 } else {
3192 420 return "Sorry, I couldn't process that request.";
3193 421 }
3194 422 }
3195 -private function mxchat_generate_response_claude($selected_model, $claude_api_key, $conversation_history, $relevant_content) {
3196 - // Get system prompt instructions from options
3197 - $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3198 423
3199 - // Clean and validate conversation history
3200 - foreach ($conversation_history as &$message) {
3201 - // Convert bot and agent roles to assistant
3202 - if ($message['role'] === 'bot' || $message['role'] === 'agent') {
3203 - $message['role'] = 'assistant';
3204 - }
3205 -
3206 - // Remove unsupported roles - Claude only supports 'assistant' and 'user'
3207 - if (!in_array($message['role'], ['assistant', 'user'])) {
3208 - $message['role'] = 'user';
3209 - }
3210 424
3211 - // Ensure content field exists
3212 - if (!isset($message['content']) || empty($message['content'])) {
3213 - $message['content'] = '';
3214 - }
3215 -
3216 - // Remove any unsupported fields
3217 - $message = array_intersect_key($message, array_flip(['role', 'content']));
3218 - }
3219 -
3220 - // Add relevant content as the latest user message
3221 - $conversation_history[] = [
3222 - 'role' => 'user',
3223 - 'content' => $relevant_content
3224 - ];
3225 -
3226 - // Build request body
3227 - $body = json_encode([
3228 - 'model' => $selected_model,
3229 - 'max_tokens' => 1000,
3230 - 'temperature' => 0.8,
3231 - 'messages' => $conversation_history,
3232 - 'system' => $system_prompt_instructions
3233 - ]);
3234 -
3235 - // Set up API request
3236 - $args = [
3237 - 'body' => $body,
3238 - 'headers' => [
3239 - 'Content-Type' => 'application/json',
3240 - 'x-api-key' => $claude_api_key,
3241 - 'anthropic-version' => '2023-06-01'
3242 - ],
3243 - 'timeout' => 60,
3244 - 'redirection' => 5,
3245 - 'blocking' => true,
3246 - 'httpversion' => '1.0',
3247 - 'sslverify' => true,
3248 - ];
3249 -
3250 - // Make API request
3251 - $response = wp_remote_post('https://api.anthropic.com/v1/messages', $args);
3252 -
3253 - // Check for WordPress errors
3254 - if (is_wp_error($response)) {
3255 - //error_log("Claude API request error: " . $response->get_error_message());
3256 - return "Sorry, there was an error connecting to the API.";
3257 - }
3258 -
3259 - // Check HTTP response code
3260 - $http_code = wp_remote_retrieve_response_code($response);
3261 - if ($http_code !== 200) {
3262 - $error_body = wp_remote_retrieve_body($response);
3263 - //error_log("Claude API HTTP error: " . $http_code . " - " . $error_body);
3264 -
3265 - // Try to extract error message from response
3266 - $error_data = json_decode($error_body, true);
3267 - $error_message = isset($error_data['error']['message']) ?
3268 - $error_data['error']['message'] :
3269 - "HTTP error " . $http_code;
3270 -
3271 - return "Sorry, the API returned an error: " . $error_message;
3272 - }
3273 -
3274 - // Parse response
3275 - $response_body = json_decode(wp_remote_retrieve_body($response), true);
3276 -
3277 - // Check for JSON decode errors
3278 - if (json_last_error() !== JSON_ERROR_NONE) {
3279 - //error_log("Claude API JSON decode error: " . json_last_error_msg());
3280 - return "Sorry, there was an error processing the API response.";
3281 - }
3282 -
3283 - // Extract and validate response content
3284 - if (isset($response_body['content']) &&
3285 - is_array($response_body['content']) &&
3286 - !empty($response_body['content']) &&
3287 - isset($response_body['content'][0]['text'])) {
3288 - return trim($response_body['content'][0]['text']);
3289 - }
3290 -
3291 - // Log unexpected response format
3292 - //error_log("Claude API unexpected response format: " . print_r($response_body, true));
3293 - return "Sorry, I received an unexpected response format from the API.";
3294 -}
3295 -
3296 -
3297 -
3298 425 public function mxchat_dismiss_pre_chat_message() {
3299 426 // Get and sanitize the user identifier
3300 427 $user_id = $this->mxchat_get_user_identifier();
3301 428 $user_id = sanitize_key($user_id);
@@ -3306,30 +433,11 @@
3306 433
3307 434 wp_send_json_success();
3308 435 }
3309 436
3310 -public function mxchat_check_pre_chat_message_status() {
3311 - // Get and sanitize the user identifier
3312 - $user_id = $this->mxchat_get_user_identifier();
3313 - $user_id = sanitize_key($user_id);
3314 437
3315 - // Check if the transient exists (i.e., if the message was dismissed)
3316 - $transient_key = 'mxchat_pre_chat_message_dismissed_' . $user_id;
3317 - $dismissed = get_transient($transient_key);
3318 438
3319 - // Log the result to see if it's being set correctly
3320 - //error_log("Check pre-chat message dismissed for $user_id: " . ($dismissed ? 'Yes' : 'No'));
3321 -
3322 - if ($dismissed) {
3323 - wp_send_json_success(['dismissed' => true]);
3324 - } else {
3325 - wp_send_json_success(['dismissed' => false]);
3326 - }
3327 -
3328 - wp_die();
3329 -}
3330 -
3331 -private function mxchat_calculate_cosine_similarity($vectorA, $vectorB) {
439 + private function mxchat_calculate_cosine_similarity($vectorA, $vectorB) {
3332 440 if (!is_array($vectorA) || !is_array($vectorB) || empty($vectorA) || empty($vectorB)) {
3333 441 return 0;
3334 442 }
3335 443
@@ -3349,72 +457,48 @@
3349 457
3350 458 return $dotProduct / ($normA * $normB);
3351 459 }
3352 460
3353 -public function mxchat_enqueue_scripts_styles() {
3354 - // Define version numbers for the styles and scripts
3355 - $chat_style_version = '2.0.6'; // Replace with your actual version
3356 - $chat_script_version = '2.0.6'; // Replace with your actual version
461 + public function mxchat_enqueue_scripts_styles() {
462 + // Define version numbers for the styles and scripts
463 + $chat_style_version = '1.0.8'; // Replace with your actual version
464 + $chat_script_version = '1.0.8'; // Replace with your actual version
3357 465
3358 - // Enqueue the script
3359 - wp_enqueue_script(
3360 - 'mxchat-chat-js',
3361 - plugin_dir_url(__FILE__) . '../js/chat-script.js',
3362 - array('jquery'),
3363 - $chat_script_version,
3364 - true
3365 - );
466 + // Correct path to the script file
467 + wp_enqueue_script(
468 + 'mxchat-chat-js', // Handle for the script
469 + plugin_dir_url(__FILE__) . '../js/chat-script.js', // Correct path using __FILE__
470 + array('jquery'), // Dependencies
471 + $chat_script_version, // Version for cache busting
472 + true // Load script in footer
473 + );
3366 474
3367 - // Enqueue the CSS
3368 - wp_enqueue_style(
3369 - 'mxchat-chat-css',
3370 - plugin_dir_url(__FILE__) . '../css/chat-style.css',
3371 - array(),
3372 - $chat_style_version
3373 - );
475 + // Enqueue the CSS file similarly
476 + wp_enqueue_style(
477 + 'mxchat-chat-css', // Handle for the style
478 + plugin_dir_url(__FILE__) . '../css/chat-style.css', // Correct path using __FILE__
479 + array(), // No dependencies
480 + $chat_style_version // Version for cache busting
481 + );
3374 482
3375 - // Fetch options from the database
3376 - $this->options = get_option('mxchat_options');
3377 - $prompts_options = get_option('mxchat_prompts_options', array());
483 + // Fetch options from the database
484 + $this->options = get_option('mxchat_options');
3378 485
3379 - // Prepare settings for JavaScript
3380 - $style_settings = array(
3381 - 'ajax_url' => admin_url('admin-ajax.php'),
3382 - 'nonce' => wp_create_nonce('mxchat_chat_nonce'),
3383 - 'link_target_toggle' => $this->options['link_target_toggle'] ?? 'off',
3384 - 'rate_limit_message' => $this->options['rate_limit_message'] ?? 'Rate limit exceeded. Please try again later.',
3385 - 'complianz_toggle' => isset($this->options['complianz_toggle']) && $this->options['complianz_toggle'] === 'on',
3386 - 'user_message_bg_color' => $this->options['user_message_bg_color'] ?? '#fff',
3387 - 'user_message_font_color' => $this->options['user_message_font_color'] ?? '#212121',
3388 - 'bot_message_bg_color' => $this->options['bot_message_bg_color'] ?? '#212121',
3389 - 'bot_message_font_color' => $this->options['bot_message_font_color'] ?? '#fff',
3390 - 'top_bar_bg_color' => $this->options['top_bar_bg_color'] ?? '#212121',
3391 - 'send_button_font_color' => $this->options['send_button_font_color'] ?? '#212121',
3392 - 'close_button_color' => $this->options['close_button_color'] ?? '#fff',
3393 - 'chatbot_background_color' => $this->options['chatbot_background_color'] ?? '#212121',
3394 - 'chatbot_bg_color' => $this->options['chatbot_bg_color'] ?? '#fff',
3395 - 'icon_color' => $this->options['icon_color'] ?? '#fff',
3396 - 'chat_input_font_color' => $this->options['chat_input_font_color'] ?? '#212121',
3397 - 'chat_persistence_toggle' => $this->options['chat_persistence_toggle'] ?? 'off',
3398 - 'appendWidgetToBody' => $this->options['append_to_body'] ?? 'off', // Example for consistency
486 + // Prepare settings to pass to JavaScript
487 + $style_settings = array(
488 + 'ajax_url' => admin_url('admin-ajax.php'),
489 + 'nonce' => wp_create_nonce('mxchat_chat_nonce'), // Nonce for security
490 + 'rate_limit_message' => 'Rate limit exceeded. Please try again later.',
491 + 'appendWidgetToBody' => $this->options['append_to_body'] ?? 'off'
492 + );
3399 493
3400 - 'live_agent_message_bg_color' => $this->options['live_agent_message_bg_color'] ?? '#ffffff',
3401 - 'live_agent_message_font_color' => $this->options['live_agent_message_font_color'] ?? '#333333',
3402 - 'chat_toolbar_toggle' => $this->options['chat_toolbar_toggle'] ?? 'off',
3403 - 'mode_indicator_bg_color' => $this->options['mode_indicator_bg_color'] ?? '#767676',
3404 - 'mode_indicator_font_color' => $this->options['mode_indicator_font_color'] ?? '#ffffff',
3405 - 'toolbar_icon_color' => $this->options['toolbar_icon_color'] ?? '#212121',
494 + // Localize the script with necessary data
495 + wp_localize_script('mxchat-chat-js', 'mxchatChat', $style_settings);
496 + }
3406 497
3407 - 'use_pinecone' => $prompts_options['mxchat_use_pinecone'] ?? '0',
3408 - 'pinecone_enabled' => isset($prompts_options['mxchat_use_pinecone']) && $prompts_options['mxchat_use_pinecone'] === '1'
3409 - );
3410 498
3411 - // Pass the settings to the script
3412 - wp_localize_script('mxchat-chat-js', 'mxchatChat', $style_settings);
3413 -}
3414 499
3415 -
3416 -public function mxchat_reset_rate_limits() {
500 + public function mxchat_reset_rate_limits() {
3417 501 global $wpdb;
3418 502
3419 503 // Define a cache key pattern for rate limits
3420 504 $cache_key_pattern = 'mxchat_chat_limit_%';
@@ -3435,8 +519,9 @@
3435 519 // Optionally, clear a general cache if you have one
3436 520 wp_cache_delete('mxchat_all_chat_limits', 'options');
3437 521 }
3438 522
523 +
3439 524 private function mxchat_fetch_woocommerce_products() {
3440 525 // Ensure WooCommerce is active
3441 526 if (!class_exists('WooCommerce')) {
3442 527 return [];
@@ -3471,7 +556,13 @@
3471 556 }
3472 557
3473 558 return $product_data;
3474 559 }
560 +
561 +
562 +
563 +
564 +
565 +
3475 566
3476 567 }
3477 568 ?>