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 +213 -3099 2.0.5 → 1.0.8 View file →
@@ -4,2433 +4,248 @@
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;
1213 -
1214 - if ( empty( $api_key ) ) {
1215 - $this->fallbackResponse = array(
1216 - 'text' => esc_html__( 'Search functionality is temporarily unavailable. Please try again later.', 'mxchat' ),
1217 - );
1218 - return;
1219 - }
1220 -
1221 - // Build the API request URL
1222 - $api_url = add_query_arg(
1223 - array(
1224 - 'q' => rawurlencode( $refined_search_query ),
1225 - 'count' => $results_count,
1226 - 'text_decorations' => 'true',
1227 - 'rich_data' => 'true',
1228 - ),
1229 - 'https://api.search.brave.com/res/v1/web/search'
1230 - );
1231 -
1232 - // Attempt to retrieve cached results first
1233 - $transient_key = 'mxchat_search_' . md5( $refined_search_query );
1234 - $results = get_transient( $transient_key );
1235 -
1236 - if ( false === $results ) {
1237 - // Fetch new results from the Brave Search API
1238 - $response = wp_remote_get(
1239 - $api_url,
1240 - array(
1241 - 'headers' => array(
1242 - 'Accept' => 'application/json',
1243 - 'Accept-Encoding' => 'gzip',
1244 - 'X-Subscription-Token'=> $api_key,
1245 - ),
1246 - 'timeout' => 10,
1247 - )
1248 - );
1249 -
1250 - if ( is_wp_error( $response ) ) {
1251 - $this->fallbackResponse = array(
1252 - 'text' => esc_html__( 'I encountered an error while searching. Please try again.', 'mxchat' ),
1253 - );
1254 - return;
1255 - }
1256 -
1257 - $results = json_decode( wp_remote_retrieve_body( $response ), true );
1258 -
1259 - if ( json_last_error() !== JSON_ERROR_NONE ) {
1260 - $this->fallbackResponse = array(
1261 - 'text' => esc_html__( 'I received an invalid response from the search service.', 'mxchat' ),
1262 - );
1263 - return;
1264 - }
1265 -
1266 - // Cache results for one hour
1267 - set_transient( $transient_key, $results, HOUR_IN_SECONDS );
1268 - }
1269 -
1270 - // Process and display results
1271 - if ( ! empty( $results['web']['results'] ) && is_array( $results['web']['results'] ) ) {
1272 - $html = $this->generate_search_results_html( $results['web']['results'], $refined_search_query );
1273 -
1274 - // Only return HTML (no large text summary)
1275 - $this->fallbackResponse = array(
1276 - 'html' => $html,
1277 - );
1278 -
1279 - // Save to chat history
1280 - $this->mxchat_save_chat_message( $session_id, 'bot', $html );
1281 - } else {
1282 - $this->fallbackResponse = array(
1283 - 'text' => sprintf(
1284 - esc_html__( 'I couldn\'t find any relevant results for "%s". Would you like to try different search terms?', 'mxchat' ),
1285 - esc_html( $refined_search_query )
1286 - ),
1287 - );
1288 - }
1289 -}
1290 -
1291 -
1292 -/**
1293 - * Format search results into a natural text summary.
1294 - *
1295 - * @since 1.0.0
1296 - * @param array $results The search results from the API.
1297 - * @param string $query The original search query.
1298 - * @return string The text summary of the top results.
1299 - */
1300 -private function format_search_results( $results, $query ) {
1301 - $summary = sprintf(
1302 - esc_html__( 'Here are the most relevant results for "%s":', 'mxchat' ),
1303 - esc_html( $query )
1304 - ) . "\n\n";
1305 -
1306 - $max_results = min( count( $results ), 3 );
1307 - for ( $i = 0; $i < $max_results; $i++ ) {
1308 - $result = $results[ $i ];
1309 - $title = isset( $result['title'] ) ? wp_strip_all_tags( $result['title'] ) : '';
1310 - $description = isset( $result['description'] ) ? wp_strip_all_tags( $result['description'] ) : '';
1311 -
1312 - // Append title and description to the summary
1313 - $summary .= sprintf(
1314 - "%s\n%s\n\n",
1315 - esc_html( $title ),
1316 - esc_html( $description )
1317 - );
1318 - }
1319 -
1320 - return $summary;
1321 -}
1322 -
1323 -/**
1324 - * Generate HTML markup for search results.
1325 - *
1326 - * @since 1.0.0
1327 - * @param array $results The search results from the API.
1328 - * @param string $query The user-refined query.
1329 - * @return string The HTML markup for displaying the results.
1330 - */
1331 -private function generate_search_results_html( $results, $query ) {
1332 - ob_start();
1333 - ?>
1334 - <div class="mxchat-search-results">
1335 - <?php foreach ( $results as $result ) :
1336 - $title = isset( $result['title'] ) ? wp_strip_all_tags( $result['title'] ) : '';
1337 - $url = isset( $result['url'] ) ? esc_url( $result['url'] ) : '#';
1338 - $description = isset( $result['description'] ) ? wp_strip_all_tags( $result['description'] ) : '';
1339 - $favicon = isset( $result['meta_url']['favicon'] ) ? esc_url( $result['meta_url']['favicon'] ) : '';
1340 - $thumbnail = isset( $result['thumbnail']['src'] ) ? esc_url( $result['thumbnail']['src'] ) : '';
1341 - $domain = parse_url( $url, PHP_URL_HOST );
1342 - ?>
1343 - <div class="mxchat-search-item">
1344 - <div class="mxchat-search-header">
1345 - <?php if ( $favicon ) : ?>
1346 - <img
1347 - src="<?php echo esc_url( $favicon ); ?>"
1348 - class="mxchat-site-icon"
1349 - alt="<?php echo esc_attr__( 'Site icon', 'mxchat' ); ?>"
1350 - width="16"
1351 - height="16"
1352 - />
1353 - <?php endif; ?>
1354 - <div class="mxchat-site-url"><?php echo esc_html( $domain ); ?></div>
1355 - </div>
1356 -
1357 - <div class="mxchat-search-content">
1358 - <h3 class="mxchat-search-title">
1359 - <a href="<?php echo esc_url( $url ); ?>"
1360 - target="_blank"
1361 - rel="noopener noreferrer"
1362 - >
1363 - <?php echo esc_html( $title ); ?>
1364 - </a>
1365 - </h3>
1366 -
1367 - <?php if ( $thumbnail ) : ?>
1368 - <div class="mxchat-search-thumbnail">
1369 - <img
1370 - src="<?php echo esc_url( $thumbnail ); ?>"
1371 - alt="<?php echo esc_attr__( 'Thumbnail image', 'mxchat' ); ?>"
1372 - loading="lazy"
1373 - />
1374 - </div>
1375 - <?php endif; ?>
1376 -
1377 - <div class="mxchat-search-description">
1378 - <?php echo esc_html( $description ); ?>
1379 - </div>
1380 - </div>
1381 - </div>
1382 - <?php endforeach; ?>
1383 - </div>
1384 - <?php
1385 - return ob_get_clean();
1386 -}
1387 -
1388 -
1389 -//very good
1390 -public function mxchat_handle_image_search_request($message, $user_id, $session_id) {
1391 -
1392 - // Step 1: Interpret the search query for better results
1393 - $refined_search_query = $this->mxchat_interpret_search_query($message);
1394 -
1395 -
1396 - // If no query was interpreted, return a fallback message
1397 - if (empty($refined_search_query)) {
1398 - $this->fallbackResponse = [
1399 - 'text' => __("I'm sorry, I couldn't interpret your search query. Please specify what you'd like to see images of.", 'mxchat'),
1400 - 'html' => "",
1401 - ];
1402 - return;
1403 - }
1404 -
1405 - // Brave API URL
1406 - $api_url = 'https://api.search.brave.com/res/v1/images/search';
1407 -
1408 - // Retrieve Brave API settings
1409 - $options = get_option('mxchat_options');
1410 - $api_key = isset($options['brave_api_key']) ? sanitize_text_field($options['brave_api_key']) : '';
1411 -
1412 - if (empty($api_key)) {
1413 -/*
1414 - if (defined('WP_DEBUG') && WP_DEBUG) {
1415 - error_log("Brave API key is missing.");
1416 - }
1417 -*/
1418 -
1419 - $this->fallbackResponse = [
1420 - 'text' => __("API key is not configured. Please set it in the Brave Search Settings.", 'mxchat'),
1421 - 'html' => "",
1422 - ];
1423 - return;
1424 - }
1425 -
1426 - $image_count = isset($options['brave_image_count']) ? intval($options['brave_image_count']) : 4;
1427 - $safe_search = isset($options['brave_safe_search']) ? sanitize_text_field($options['brave_safe_search']) : 'strict';
1428 -
1429 - // Append query parameters based on settings
1430 - $api_url = add_query_arg([
1431 - 'q' => rawurlencode($refined_search_query),
1432 - 'count' => $image_count,
1433 - 'safesearch' => $safe_search,
1434 - ], $api_url);
1435 -
1436 -/*
1437 - // Log the final API URL for the search
1438 - if (defined('WP_DEBUG') && WP_DEBUG) {
1439 - error_log("Final API URL for Brave Image Search: " . esc_url_raw($api_url));
1440 - }
1441 -*/
1442 -
1443 -
1444 - // Implement caching
1445 - $transient_key = 'mxchat_image_search_' . md5($refined_search_query);
1446 - $body = get_transient($transient_key);
1447 -
1448 - if (false === $body) {
1449 - $args = [
1450 - 'headers' => [
1451 - 'Accept' => 'application/json',
1452 - 'Accept-Encoding' => 'gzip',
1453 - 'X-Subscription-Token' => $api_key,
1454 - ],
1455 - 'timeout' => 10,
1456 - ];
1457 -
1458 - $response = wp_remote_get($api_url, $args);
1459 -
1460 - if (is_wp_error($response)) {
1461 -/*
1462 - if (defined('WP_DEBUG') && WP_DEBUG) {
1463 - error_log("Brave Image API request failed: " . $response->get_error_message());
1464 - }
1465 -*/
1466 -
1467 - $this->fallbackResponse = [
1468 - 'text' => __("I'm sorry, I couldn't retrieve any images based on your request.", 'mxchat'),
1469 - 'html' => "",
1470 - ];
1471 - return;
1472 - }
1473 -
1474 - $body = json_decode(wp_remote_retrieve_body($response), true);
1475 - set_transient($transient_key, $body, HOUR_IN_SECONDS);
1476 - }
1477 -
1478 - // Process the API response
1479 - if (isset($body['results']) && is_array($body['results']) && count($body['results']) > 0) {
1480 - $html_output = '<div class="mxchat-image-gallery">';
1481 -
1482 - foreach ($body['results'] as $image) {
1483 - $image_url = isset($image['url']) ? esc_url($image['url']) : '';
1484 - $thumbnail_url = isset($image['thumbnail']['src']) ? esc_url($image['thumbnail']['src']) : '';
1485 - $title = isset($image['title']) ? esc_html($image['title']) : esc_html__('Image', 'mxchat');
1486 -
1487 - if ($image_url && $thumbnail_url) {
1488 - $html_output .= '<div class="mxchat-image-item">';
1489 - $html_output .= '<strong class="mxchat-image-title">' . $title . '</strong>';
1490 - $html_output .= '<a href="' . $image_url . '" target="_blank" rel="noopener noreferrer" class="mxchat-image-link">';
1491 - $html_output .= '<img src="' . $thumbnail_url . '" alt="' . $title . '" class="mxchat-image-thumbnail">';
1492 - $html_output .= '</a></div>';
1493 - }
1494 - }
1495 -
1496 - $html_output .= '</div>';
1497 -
1498 - $this->fallbackResponse = [
1499 - 'text' => "",
1500 - 'html' => $html_output,
1501 - ];
1502 -
1503 - // Save response in chat history
1504 - $this->mxchat_save_chat_message($session_id, 'bot', $html_output);
1505 -
1506 - } else {
1507 -/*
1508 - if (defined('WP_DEBUG') && WP_DEBUG) {
1509 - error_log("Brave Image API response did not contain expected data structure or was empty: " . print_r($body, true));
1510 - }
1511 -*/
1512 -
1513 - $this->fallbackResponse = [
1514 - 'text' => __("I'm sorry, I couldn't retrieve any images based on your request.", 'mxchat'),
1515 - 'html' => "",
1516 - ];
1517 - }
1518 -}
1519 -public function mxchat_interpret_search_query($user_query) {
1520 - $system_prompt = esc_html__("Interpret the user's request to provide only the essential keywords or phrases for image searching. Remove conversational language, politeness, or extra context. Return a concise search query that doesn't lose any of the original meaning.", 'mxchat');
1521 -
1522 - // Retrieve OpenAI API key using 'api_key' as the option key
1523 - $api_key = isset($this->options['api_key']) ? sanitize_text_field($this->options['api_key']) : sanitize_text_field(get_option('mxchat_options')['api_key']);
1524 -
1525 - /*
1526 - // Log the API key check, without exposing the key
1527 - if (defined('WP_DEBUG') && WP_DEBUG) {
1528 - error_log("Retrieved OpenAI API Key: " . ($api_key ? "Present" : "Missing"));
1529 - }
1530 - */
1531 -
1532 - if (empty($api_key)) {
1533 - //error_log("OpenAI API key is missing.");
1534 - return sanitize_text_field($user_query); // Default to the original query if API key is missing
1535 - }
1536 -
1537 - $url = 'https://api.openai.com/v1/chat/completions';
1538 - $args = [
1539 - 'headers' => [
1540 - 'Authorization' => 'Bearer ' . $api_key,
1541 - 'Content-Type' => 'application/json',
1542 - ],
1543 - 'body' => wp_json_encode([
1544 - 'model' => 'gpt-3.5-turbo',
1545 - 'messages' => [
1546 - ['role' => 'system', 'content' => $system_prompt],
1547 - ['role' => 'user', 'content' => sanitize_text_field($user_query)],
1548 - ],
1549 - 'temperature' => 0.2,
1550 - 'max_tokens' => 20,
1551 - ]),
1552 - 'method' => 'POST',
1553 - ];
1554 -
1555 - $response = wp_remote_post($url, $args);
1556 -
1557 - if (is_wp_error($response)) {
1558 - //error_log("OpenAI request failed: " . $response->get_error_message());
1559 - return sanitize_text_field($user_query); // Fallback to the original query if there's an error
1560 - }
1561 -
1562 - $body = json_decode(wp_remote_retrieve_body($response), true);
1563 -
1564 - // Check for a valid response and sanitize output
1565 - if (isset($body['choices'][0]['message']['content'])) {
1566 - $interpreted_query = sanitize_text_field(trim($body['choices'][0]['message']['content']));
1567 -
1568 - /*
1569 - // Log the interpreted query for debugging
1570 - if (defined('WP_DEBUG') && WP_DEBUG) {
1571 - error_log("Interpreted search query: " . $interpreted_query);
1572 - }
1573 - */
1574 -
1575 - return $interpreted_query;
1576 - } else {
1577 - //error_log("Unexpected API response format: " . print_r($body, true));
1578 - return sanitize_text_field($user_query);
1579 - }
1580 -}
1581 -
1582 -
1583 -
1584 -private function find_product_in_message($message) {
1585 - global $wpdb;
1586 -
1587 - // Get embedding for the search query
1588 - $query_embedding = $this->mxchat_generate_embedding($message, $this->options['api_key']);
1589 - if (!is_array($query_embedding)) {
1590 - return null;
1591 - }
1592 -
1593 - // Get relevant content as string
1594 - $relevant_content = $this->mxchat_find_relevant_products($query_embedding);
1595 - if (empty($relevant_content)) {
1596 - // Return null to indicate no results and set fallback response
1597 - $this->fallbackResponse['text'] = esc_html__("I couldn't find any relevant products based on your query. Could you please be more specific about the product you're looking for?", 'mxchat');
1598 - return null;
1599 - }
1600 -
1601 - // Extract product URLs from the content
1602 - preg_match_all('/https?:\/\/[^\s<>"\']+?\/product\/[^\s<>"\']+/', $relevant_content, $matches);
1603 -
1604 - if (!empty($matches[0])) {
1605 - // Try each URL found
1606 - foreach ($matches[0] as $url) {
1607 - // Clean the URL
1608 - $url = rtrim($url, '/."\']');
1609 -
1610 - // Get the product slug
1611 - $path = parse_url($url, PHP_URL_PATH);
1612 - $slug = basename(rtrim($path, '/'));
1613 -
1614 - // Find product by slug
1615 - $args = array(
1616 - 'post_type' => 'product',
1617 - 'post_status' => 'publish',
1618 - 'name' => $slug,
1619 - 'posts_per_page' => 1
1620 - );
1621 -
1622 - $products = get_posts($args);
1623 -
1624 - if (!empty($products)) {
1625 - $product_id = $products[0]->ID;
1626 - $product = wc_get_product($product_id);
1627 -
1628 - if ($product && $product->is_purchasable()) {
1629 - return $product_id;
1630 - }
1631 - }
1632 - }
1633 - }
1634 -
1635 - // Fallback: Look for product names in the content
1636 - $products = wc_get_products([
1637 - 'status' => 'publish',
1638 - 'limit' => -1,
1639 - 'return' => 'all'
1640 - ]);
1641 -
1642 - foreach ($products as $product) {
1643 - $name = $product->get_name();
1644 - if (stripos($relevant_content, $name) !== false) {
1645 - if ($product->is_purchasable()) {
1646 - return $product->get_id();
1647 - }
1648 - }
1649 - }
1650 -
1651 - // If no product is found after all checks, set the fallback response
1652 - $this->fallbackResponse['text'] = esc_html__("I couldn't find any relevant products based on your query. Try to be more specific", 'mxchat');
1653 - return null;
1654 -}
1655 -
1656 -// New method to handle intent responses
1657 -private function generate_intent_response($context_content, $session_id) {
1658 - // Convert the context array to a structured string for the AI
1659 - $context_string = $this->format_intent_context($context_content);
1660 -
1661 - // Generate AI response using the context
1662 - $response = $this->mxchat_generate_response(
1663 - $context_string,
1664 - $this->options['api_key'],
1665 - $this->options['xai_api_key'],
1666 - $this->options['claude_api_key'],
1667 - $this->options['deepseek_api_key'],
1668 - $this->mxchat_fetch_conversation_history_for_ai($session_id)
1669 - );
1670 -
1671 - $this->fallbackResponse['text'] = $response;
1672 - return true;
1673 -}
1674 -// Helper method to format intent context
1675 -private function format_intent_context($context) {
1676 - $context_string = esc_html__("INTENT CONTEXT:\n", 'mxchat');
1677 -
1678 - switch ($context['intent']) {
1679 - case 'add_to_cart':
1680 - if ($context['status'] === 'success') {
1681 - $context_string .= esc_html__("Action: Successfully added product to cart\n", 'mxchat');
1682 - $context_string .= sprintf(esc_html__("Product: %s\n", 'mxchat'), $context['product']['name']);
1683 - $context_string .= esc_html__("Available actions: ", 'mxchat') . implode(', ', $context['available_actions']) . "\n";
1684 - $context_string .= sprintf(esc_html__("Cart URL: %s\n", 'mxchat'), $context['cart_url']);
1685 - $context_string .= esc_html__("\nPlease inform the user of the successful addition and their available options.", 'mxchat');
1686 - } else {
1687 - $context_string .= esc_html__("Action: Failed to add product to cart\n", 'mxchat');
1688 - $context_string .= sprintf(esc_html__("Reason: %s\n", 'mxchat'), $context['reason']);
1689 - switch ($context['reason']) {
1690 - case 'woocommerce_not_available':
1691 - $context_string .= esc_html__("\nPlease inform the user that shopping features are not available.", 'mxchat');
1692 - break;
1693 - case 'no_product_context':
1694 - $context_string .= esc_html__("\nPlease ask the user to specify which product they want to add.", 'mxchat');
1695 - break;
1696 - case 'product_not_found':
1697 - $context_string .= esc_html__("\nPlease inform the user that the product couldn't be found and ask them to try again.", 'mxchat');
1698 - break;
1699 - case 'add_to_cart_failed':
1700 - $context_string .= esc_html__("\nPlease apologize to the user and suggest they try again or ask for assistance.", 'mxchat');
1701 - break;
1702 - }
1703 - }
1704 - break;
1705 - }
1706 -
1707 - return $context_string;
1708 -}
1709 -
1710 -
1711 -//very good
1712 -private function add_email_to_loops($email) {
1713 - // Sanitize the email
1714 - $email = sanitize_email($email);
1715 -
1716 - // Retrieve and sanitize options
1717 - $api_key = isset($this->options['loops_api_key']) ? sanitize_text_field($this->options['loops_api_key']) : '';
1718 - $mailing_list_id = isset($this->options['loops_mailing_list']) ? sanitize_text_field($this->options['loops_mailing_list']) : '';
1719 -
1720 - // Check for missing API key or mailing list ID
1721 - if (empty($api_key) || empty($mailing_list_id)) {
1722 - //error_log(esc_html__('Loops API key or mailing list ID is missing.', 'mxchat'));
1723 - return;
1724 - }
1725 -
1726 - $data = array(
1727 - 'email' => $email,
1728 - 'subscribed' => true,
1729 - 'source' => __('MxChat AI Chatbot', 'mxchat'),
1730 - 'mailingLists' => array($mailing_list_id => true),
1731 - );
1732 -
1733 - $url = 'https://app.loops.so/api/v1/contacts/create';
1734 - $args = array(
1735 - 'body' => wp_json_encode($data),
1736 - 'headers' => array(
1737 - 'Authorization' => 'Bearer ' . $api_key,
1738 - 'Content-Type' => 'application/json',
1739 - ),
1740 - 'method' => 'POST',
1741 - 'timeout' => 45,
1742 - );
1743 -
1744 - $response = wp_remote_post($url, $args);
1745 -
1746 - // Handle errors in the API request
1747 - if (is_wp_error($response)) {
1748 - //error_log(esc_html__('Error adding email to Loops: ', 'mxchat') . $response->get_error_message());
1749 - return;
1750 - }
1751 -
1752 - // Check for non-200 HTTP responses
1753 - $response_code = wp_remote_retrieve_response_code($response);
1754 - if ($response_code != 200) {
1755 - $response_body = wp_remote_retrieve_body($response);
1756 - //error_log(esc_html__('Loops API responded with code ', 'mxchat') . $response_code . ': ' . $response_body);
1757 - }
1758 -}
1759 -
1760 -public function mxchat_handle_pdf_discussion($message, $user_id, $session_id) {
1761 - // Get the maximum number of pages allowed from admin settings
1762 - $max_pages = isset($this->options['pdf_max_pages']) ? intval($this->options['pdf_max_pages']) : 69;
1763 -
1764 - // Retrieve options for dynamic texts
1765 - $trigger_text = $this->options['pdf_intent_trigger_text'] ?? __("Please provide the URL to the PDF you'd like to discuss.", 'mxchat');
1766 - $success_text = $this->options['pdf_intent_success_text'] ?? __("I've processed the PDF. What questions do you have about it?", 'mxchat');
1767 - $error_text = $this->options['pdf_intent_error_text'] ?? __("Sorry, I couldn't process the PDF. Please ensure it's a valid file.", 'mxchat');
1768 -
1769 - // Check for explicit request for new PDF
1770 - $new_pdf_requested = stripos($message, 'new') !== false ||
1771 - stripos($message, 'another') !== false ||
1772 - stripos($message, 'different') !== false;
1773 -
1774 - // If user mentions adding/reading a PDF, set waiting flag
1775 - if (stripos($message, 'pdf') !== false ||
1776 - stripos($message, 'document') !== false ||
1777 - stripos($message, 'read') !== false) {
1778 - set_transient('mxchat_waiting_for_pdf_url_' . $session_id, true, HOUR_IN_SECONDS);
1779 - $this->fallbackResponse['text'] = $trigger_text;
1780 - return;
1781 - }
1782 -
1783 - // If we're waiting for a URL or user requested new PDF
1784 - if ($new_pdf_requested || get_transient('mxchat_waiting_for_pdf_url_' . $session_id)) {
1785 - if (preg_match('/https?:\/\/[^\s"]+/i', $message, $matches)) {
1786 - // Process URL... (rest of your existing URL processing code)
1787 - } else {
1788 - $this->fallbackResponse['text'] = $trigger_text;
1789 - }
1790 - return;
1791 - }
1792 -
1793 - // Default to proceeding with conversation if no specific PDF action is needed
1794 - $this->fallbackResponse['text'] = '';
1795 -}
1796 -private function fetch_and_split_pdf_pages($pdf_source, $max_pages) {
1797 - $upload_dir = wp_upload_dir();
1798 - $temp_file = null;
1799 -
1800 - try {
1801 - // Handle URL vs local file
1802 - if (filter_var($pdf_source, FILTER_VALIDATE_URL)) {
1803 - // Validate and download the file from URL
1804 - $temp_file = wp_tempnam($pdf_source); // Safe temporary file name
1805 - $response = wp_remote_get($pdf_source, ['timeout' => 60]);
1806 -
1807 - if (is_wp_error($response) || wp_remote_retrieve_response_code($response) !== 200) {
1808 - //error_log(esc_html__("Failed to download PDF. Error: ", 'mxchat') . print_r($response, true));
1809 - return false;
1810 - }
1811 -
1812 - file_put_contents($temp_file, wp_remote_retrieve_body($response));
1813 -
1814 - // Validate that the downloaded file is a PDF
1815 - $mime_type = mime_content_type($temp_file);
1816 - if ($mime_type !== 'application/pdf') {
1817 - //error_log(esc_html__("Invalid MIME type detected for PDF: ", 'mxchat') . $mime_type);
1818 - unlink($temp_file);
1819 - return false;
1820 - }
1821 - } else {
1822 - // For local files, use the provided path directly
1823 - $temp_file = $pdf_source;
1824 - }
1825 -
1826 - // Parse and process the PDF
1827 - $parser = new \Smalot\PdfParser\Parser();
1828 - $pdf = $parser->parseFile($temp_file);
1829 - $pages = $pdf->getPages();
1830 -
1831 - if (count($pages) > $max_pages) {
1832 - //error_log(esc_html__("PDF exceeds the maximum allowed pages: ", 'mxchat') . count($pages));
1833 - if (filter_var($pdf_source, FILTER_VALIDATE_URL)) {
1834 - unlink($temp_file);
1835 - }
1836 - return esc_html__('too_many_pages', 'mxchat');
1837 - }
1838 -
1839 - $embeddings = [];
1840 - foreach ($pages as $page_number => $page) {
1841 - $text = $page->getText();
1842 -
1843 - // Ensure text is non-empty before generating embeddings
1844 - if (empty(trim($text))) {
1845 - //error_log(esc_html__("Skipping empty page: ", 'mxchat') . ($page_number + 1));
1846 - continue;
1847 - }
1848 -
1849 - $embedding = $this->mxchat_generate_embedding(
1850 - esc_html__("Page ", 'mxchat') . ($page_number + 1) . ": " . $text,
1851 - $this->options['api_key']
1852 - );
1853 -
1854 - if ($embedding) {
1855 - $embeddings[] = [
1856 - 'page_number' => $page_number + 1,
1857 - 'embedding' => $embedding,
1858 - 'text' => $text,
1859 - ];
1860 - } else {
1861 - //error_log(esc_html__("Failed to generate embedding for page ", 'mxchat') . ($page_number + 1));
1862 - }
1863 - }
1864 -
1865 - // Clean up downloaded file if it was from URL
1866 - if (filter_var($pdf_source, FILTER_VALIDATE_URL) && $temp_file) {
1867 - unlink($temp_file);
1868 - }
1869 -
1870 - return $embeddings;
1871 -
1872 - } catch (\Exception $e) {
1873 - // error_log(esc_html__("Error parsing or processing PDF: ", 'mxchat') . $e->getMessage());
1874 -
1875 - // Cleanup in case of exception
1876 - if (filter_var($pdf_source, FILTER_VALIDATE_URL) && $temp_file && file_exists($temp_file)) {
1877 - unlink($temp_file);
1878 - }
1879 -
1880 - return false;
1881 - }
1882 -}
1883 -private function find_relevant_pdf_pages($query_embedding, $embeddings) {
1884 - //error_log(esc_html__("find_relevant_pdf_pages called.", 'mxchat'));
1885 -
1886 - $most_relevant = null;
1887 - $highest_similarity = -INF;
1888 -
1889 - foreach ($embeddings as $page_data) {
1890 - $similarity = $this->mxchat_calculate_cosine_similarity($query_embedding, $page_data['embedding']);
1891 -
1892 - if ($similarity > $highest_similarity) {
1893 - $highest_similarity = $similarity;
1894 - $most_relevant = $page_data['page_number'];
1895 - }
1896 - }
1897 -
1898 - if (!is_null($most_relevant)) {
1899 - $page_numbers = range(max(1, $most_relevant - 1), min(count($embeddings), $most_relevant + 1));
1900 - return array_filter($embeddings, function ($page) use ($page_numbers) {
1901 - return in_array($page['page_number'], $page_numbers);
1902 - });
1903 - }
1904 -
1905 - return [];
1906 -}
1907 -// Add this to your class
1908 -public function handle_pdf_upload() {
1909 - check_ajax_referer('mxchat_chat_nonce', 'nonce');
1910 -
1911 - if (!isset($_FILES['pdf_file']) || !isset($_POST['session_id'])) {
1912 - wp_send_json_error(esc_html__('Missing required parameters.', 'mxchat'));
1913 - return;
1914 - }
1915 -
1916 - $file = $_FILES['pdf_file'];
1917 - $session_id = sanitize_text_field($_POST['session_id']);
1918 - $original_filename = sanitize_text_field($file['name']);
1919 -
1920 - $file_type = wp_check_filetype($file['name'], ['pdf' => 'application/pdf']);
1921 - if ($file_type['type'] !== 'application/pdf') {
1922 - wp_send_json_error(esc_html__('Invalid file type. Only PDF files are allowed.', 'mxchat'));
1923 - return;
1924 - }
1925 -
1926 - $upload_dir = wp_upload_dir();
1927 - $pdf_filename = 'mxchat_' . $session_id . '_' . time() . '.pdf';
1928 - $pdf_path = $upload_dir['path'] . '/' . $pdf_filename;
1929 -
1930 - if (!move_uploaded_file($file['tmp_name'], $pdf_path)) {
1931 - wp_send_json_error(esc_html__('Failed to upload file.', 'mxchat'));
1932 - return;
1933 - }
1934 -
1935 - $this->clear_pdf_transients($session_id);
1936 -
1937 - $max_pages = isset($this->options['pdf_max_pages']) ? intval($this->options['pdf_max_pages']) : 69;
1938 - $embeddings = $this->fetch_and_split_pdf_pages($pdf_path, $max_pages);
1939 -
1940 - if ($embeddings === 'too_many_pages') {
1941 - unlink($pdf_path);
1942 - $error_message = sprintf(
1943 - $this->options['pdf_intent_error_text'] ??
1944 - esc_html__("The provided PDF exceeds the maximum allowed limit of %d pages. Please provide a smaller document.", 'mxchat'),
1945 - $max_pages
1946 - );
1947 - wp_send_json_error($error_message);
1948 - return;
1949 - }
1950 -
1951 - if ($embeddings === false || empty($embeddings)) {
1952 - unlink($pdf_path);
1953 - $error_message = $this->options['pdf_intent_error_text'] ??
1954 - esc_html__('The uploaded PDF appears to be empty or contains unsupported content.', 'mxchat');
1955 - wp_send_json_error($error_message);
1956 - return;
1957 - }
1958 -
1959 - if (!empty($embeddings)) {
1960 - set_transient('mxchat_pdf_url_' . $session_id, $pdf_path, HOUR_IN_SECONDS);
1961 - set_transient('mxchat_pdf_filename_' . $session_id, $original_filename, HOUR_IN_SECONDS);
1962 - set_transient('mxchat_pdf_embeddings_' . $session_id, $embeddings, HOUR_IN_SECONDS);
1963 - set_transient('mxchat_include_pdf_in_context_' . $session_id, true, HOUR_IN_SECONDS);
1964 -
1965 - $success_message = $this->options['pdf_intent_success_text'] ??
1966 - esc_html__("I've processed the PDF. What questions do you have about it?", 'mxchat');
1967 -
1968 - wp_send_json_success([
1969 - 'message' => $success_message,
1970 - 'filename' => $original_filename
1971 - ]);
1972 - return;
1973 - }
1974 -
1975 - unlink($pdf_path);
1976 - $error_message = $this->options['pdf_intent_error_text'] ??
1977 - esc_html__('Sorry, I couldn\'t process the PDF. Please ensure it\'s a valid file.', 'mxchat');
1978 - wp_send_json_error($error_message);
1979 - return;
1980 -}
1981 -public function handle_pdf_remove() {
1982 - check_ajax_referer('mxchat_chat_nonce', 'nonce');
1983 -
1984 - if (empty($_POST['session_id'])) {
1985 - wp_send_json_error(esc_html__('Session ID missing.', 'mxchat'));
1986 - wp_die();
1987 - }
1988 -
1989 - $session_id = sanitize_text_field($_POST['session_id']);
1990 - $pdf_path = get_transient('mxchat_pdf_url_' . $session_id);
1991 -
1992 - if ($pdf_path && file_exists($pdf_path)) {
1993 - unlink($pdf_path);
1994 - }
1995 -
1996 - $this->clear_pdf_transients($session_id);
1997 -
1998 - wp_send_json_success([
1999 - 'message' => esc_html__('PDF removed successfully.', 'mxchat')
2000 - ]);
2001 - wp_die();
2002 -}
2003 -
2004 -
2005 -
2006 -
2007 -function mxchat_fetch_new_messages() {
2008 - $session_id = sanitize_text_field($_POST['session_id']);
2009 - $last_seen_id = sanitize_text_field($_POST['last_seen_id']);
2010 - $persistence_enabled = $_POST['persistence_enabled'] === 'true';
2011 - $initial_timestamp = isset($_POST['initial_timestamp']) ? intval($_POST['initial_timestamp']) : 0;
2012 -
2013 - if (empty($session_id)) {
2014 - //error_log(esc_html__('Fetch new messages error: Session ID missing.', 'mxchat'));
2015 - wp_send_json_error(['message' => esc_html__('Session ID missing.', 'mxchat')]);
2016 - wp_die();
2017 - }
2018 -
2019 - $history = get_option("mxchat_history_{$session_id}", []);
2020 -
2021 - $new_messages = array_filter($history, function ($message) use ($last_seen_id, $persistence_enabled, $initial_timestamp) {
2022 - // If persistence is enabled, show all new messages
2023 - if ($persistence_enabled) {
2024 - return !empty($message['id']) &&
2025 - strcmp($message['id'], $last_seen_id) > 0 &&
2026 - $message['role'] === 'agent';
2027 - }
2028 -
2029 - // If persistence is disabled, only show messages after initial timestamp
2030 - return !empty($message['id']) &&
2031 - $message['role'] === 'agent' &&
2032 - $message['timestamp'] > $initial_timestamp;
2033 - });
2034 -
2035 - //error_log(esc_html__("New agent messages fetched for session $session_id. Last seen ID: $last_seen_id", 'mxchat'));
2036 -
2037 - wp_send_json_success([
2038 - 'new_messages' => array_values($new_messages)
2039 - ]);
2040 - wp_die();
2041 -}
2042 -
2043 -
2044 -public function mxchat_live_agent_handover($message, $user_id, $session_id) {
2045 - // First check if live agents are available
2046 - $live_agent_available = $this->options['live_agent_status'] ?? 'off';
2047 - if ($live_agent_available !== 'on') {
2048 - $away_message = $this->options['live_agent_away_message'] ?? 'Sorry, live agents are currently unavailable. I can continue helping you as an AI assistant.';
2049 - $this->fallbackResponse = [
2050 - 'text' => $away_message,
2051 - 'html' => '',
2052 - 'images' => [],
2053 - 'chat_mode' => 'ai'
2054 - ];
2055 - wp_send_json([
2056 - 'text' => $away_message,
2057 - 'html' => '',
2058 - 'chat_mode' => 'ai',
2059 - 'session_id' => $session_id
2060 - ]);
2061 - wp_die();
2062 - }
2063 -
2064 - $slack_webhook_url = $this->options['live_agent_webhook_url'] ?? '';
2065 - if (empty($slack_webhook_url)) {
2066 - return false;
2067 - }
2068 -
2069 - // Get recent chat history (last 5 messages)
2070 - $history = get_option("mxchat_history_{$session_id}", []);
2071 - $recent_history = array_slice($history, -5); // Get last 5 messages
2072 -
2073 - // Format conversation history
2074 - $conversation_context = "";
2075 - if (!empty($recent_history)) {
2076 - $conversation_context = "*Recent Conversation:*\n";
2077 - foreach ($recent_history as $hist_message) {
2078 - $role_display = $hist_message['role'] === 'user' ? 'User' : 'AI';
2079 - $conversation_context .= ">{$role_display}: {$hist_message['content']}\n";
2080 - }
2081 - $conversation_context .= "\n";
2082 - }
2083 -
2084 - update_option("mxchat_mode_{$session_id}", 'agent');
2085 -
2086 - $webhook_data = [
2087 - 'blocks' => [
2088 - [
2089 - 'type' => 'header',
2090 - 'text' => [
2091 - 'type' => 'plain_text',
2092 - 'text' => '🔔 New Live Agent Request',
2093 - 'emoji' => true
2094 - ]
2095 - ],
2096 - [
2097 - 'type' => 'section',
2098 - 'fields' => [
2099 - [
2100 - 'type' => 'mrkdwn',
2101 - 'text' => sprintf('*User ID:*\n`%s`', $user_id)
2102 - ],
2103 - [
2104 - 'type' => 'mrkdwn',
2105 - 'text' => sprintf('*Session ID:*\n`%s`', $session_id)
2106 - ]
2107 - ]
2108 - ]
2109 - ]
2110 - ];
2111 -
2112 - // Add conversation history if exists
2113 - if (!empty($conversation_context)) {
2114 - $webhook_data['blocks'][] = [
2115 - 'type' => 'section',
2116 - 'text' => [
2117 - 'type' => 'mrkdwn',
2118 - 'text' => $conversation_context
2119 - ]
2120 - ];
2121 - }
2122 -
2123 - // Add the current message
2124 - $webhook_data['blocks'][] = [
2125 - 'type' => 'section',
2126 - 'text' => [
2127 - 'type' => 'mrkdwn',
2128 - 'text' => sprintf('*Current Message:*\n%s', $message)
2129 - ]
2130 - ];
2131 -
2132 - // Add the reply button
2133 - $webhook_data['blocks'][] = [
2134 - 'type' => 'actions',
2135 - 'elements' => [
2136 - [
2137 - 'type' => 'button',
2138 - 'text' => [
2139 - 'type' => 'plain_text',
2140 - 'text' => '✍️ Reply',
2141 - 'emoji' => true
2142 - ],
2143 - 'value' => $session_id,
2144 - 'action_id' => 'reply_to_user',
2145 - 'style' => 'primary'
2146 - ]
2147 - ]
2148 - ];
2149 -
2150 - $response = wp_remote_post($slack_webhook_url, [
2151 - 'body' => json_encode($webhook_data),
2152 - 'headers' => [
2153 - 'Content-Type' => 'application/json',
2154 - ],
2155 - ]);
2156 -
2157 - if (is_wp_error($response)) {
2158 - return false;
2159 - }
2160 -
2161 - $success_message = $this->options['live_agent_notification_message'] ?? 'Live agent has been notified.';
2162 - $this->mxchat_save_chat_message($session_id, 'bot', $success_message);
2163 -
2164 - $this->fallbackResponse = [
2165 - 'text' => $success_message,
2166 - 'html' => '',
2167 - 'images' => [],
2168 - 'chat_mode' => 'agent'
2169 - ];
2170 -
2171 - wp_send_json([
2172 - 'success' => true,
2173 - 'text' => $success_message,
2174 - 'html' => '',
2175 - 'chat_mode' => 'agent',
2176 - 'session_id' => $session_id,
2177 - 'fallbackResponse' => $this->fallbackResponse
2178 - ]);
2179 - wp_die();
2180 -}
2181 -public function mxchat_send_user_message_to_agent($message, $user_id, $session_id) {
2182 - $slack_webhook_url = $this->options['live_agent_webhook_url'] ?? '';
2183 -
2184 - if (empty($slack_webhook_url)) {
2185 - //error_log(esc_html__('Slack Webhook URL is not configured.', 'mxchat'));
2186 - return false;
2187 - }
2188 -
2189 - $webhook_data = [
2190 - 'blocks' => [
2191 - [
2192 - 'type' => 'header',
2193 - 'text' => [
2194 - 'type' => 'plain_text',
2195 - 'text' => esc_html__('📩 New Chat Message', 'mxchat'),
2196 - 'emoji' => true
2197 - ]
2198 - ],
2199 - [
2200 - 'type' => 'section',
2201 - 'fields' => [
2202 - [
2203 - 'type' => 'mrkdwn',
2204 - 'text' => sprintf(esc_html__('*User ID:*\n`%s`', 'mxchat'), $user_id)
2205 - ],
2206 - [
2207 - 'type' => 'mrkdwn',
2208 - 'text' => sprintf(esc_html__('*Session ID:*\n`%s`', 'mxchat'), $session_id)
2209 - ]
2210 - ]
2211 - ],
2212 - [
2213 - 'type' => 'section',
2214 - 'text' => [
2215 - 'type' => 'mrkdwn',
2216 - 'text' => sprintf(esc_html__('*Message:*\n%s', 'mxchat'), $message)
2217 - ]
2218 - ],
2219 - [
2220 - 'type' => 'actions',
2221 - 'elements' => [
2222 - [
2223 - 'type' => 'button',
2224 - 'text' => [
2225 - 'type' => 'plain_text',
2226 - 'text' => esc_html__('✍️ Reply', 'mxchat'),
2227 - 'emoji' => true
2228 - ],
2229 - 'value' => $session_id,
2230 - 'action_id' => 'reply_to_user',
2231 - 'style' => 'primary'
2232 - ]
2233 - ]
2234 - ]
2235 - ]
2236 - ];
2237 -
2238 - $response = wp_remote_post($slack_webhook_url, [
2239 - 'body' => json_encode($webhook_data),
2240 - 'headers' => [
2241 - 'Content-Type' => 'application/json',
2242 - ],
2243 - ]);
2244 -
2245 - if (is_wp_error($response)) {
2246 - //error_log(esc_html__('Error sending message to Slack: ', 'mxchat') . $response->get_error_message());
2247 - return false;
2248 - }
2249 -
2250 - //error_log(esc_html__('Message sent to Slack successfully.', 'mxchat'));
2251 - return true;
2252 -}
2253 -public function handle_slack_interaction(WP_REST_Request $request) {
2254 - //error_log('Received Slack interaction');
2255 -
2256 - $payload = json_decode($request->get_param('payload'), true);
2257 - //error_log('Payload: ' . print_r($payload, true));
2258 -
2259 - // Handle button click
2260 - if ($payload['type'] === 'block_actions' && $payload['actions'][0]['action_id'] === 'reply_to_user') {
2261 - $session_id = $payload['actions'][0]['value'];
2262 - $trigger_id = $payload['trigger_id'];
2263 -
2264 - // Get Bot Token from settings
2265 - $slack_token = $this->options['live_agent_bot_token'] ?? '';
2266 -
2267 - if (empty($slack_token)) {
2268 - //error_log('Slack Bot Token not configured');
2269 - return new WP_REST_Response(['error' => esc_html__('Bot token not configured', 'mxchat')], 400);
2270 - }
2271 - $response = wp_remote_post('https://slack.com/api/views.open', [
2272 - 'headers' => [
2273 - 'Content-Type' => 'application/json',
2274 - 'Authorization' => 'Bearer ' . $slack_token
2275 - ],
2276 - 'body' => json_encode([
2277 - 'trigger_id' => $trigger_id,
2278 - 'view' => [
2279 - 'type' => 'modal',
2280 - 'callback_id' => 'reply_modal',
2281 - 'title' => [
2282 - 'type' => 'plain_text',
2283 - 'text' => __('Reply to User', 'mxchat')
2284 - ],
2285 - 'submit' => [
2286 - 'type' => 'plain_text',
2287 - 'text' => __('Send', 'mxchat')
2288 - ],
2289 - 'close' => [
2290 - 'type' => 'plain_text',
2291 - 'text' => __('Cancel', 'mxchat')
2292 - ],
2293 - 'blocks' => [
2294 - [
2295 - 'type' => 'input',
2296 - 'block_id' => 'reply_block',
2297 - 'label' => [
2298 - 'type' => 'plain_text',
2299 - 'text' => sprintf(__('Reply to session: %s', 'mxchat'), $session_id)
2300 - ],
2301 - 'element' => [
2302 - 'type' => 'plain_text_input',
2303 - 'action_id' => 'message',
2304 - 'multiline' => true,
2305 - 'placeholder' => [
2306 - 'type' => 'plain_text',
2307 - 'text' => __('Type your message here...', 'mxchat')
2308 - ]
2309 - ]
2310 - ]
2311 - ],
2312 - 'private_metadata' => $session_id
2313 - ]
2314 - ])
2315 - ]);
2316 -
2317 - //error_log('Views.open response: ' . print_r($response, true));
2318 -
2319 - // Return immediate acknowledgment
2320 - return new WP_REST_Response(['ok' => true]);
2321 - }
2322 -
2323 - // Handle modal submission
2324 -// Handle modal submission
2325 -if ($payload['type'] === 'view_submission') {
2326 - $session_id = $payload['view']['private_metadata'];
2327 - $message = $payload['view']['state']['values']['reply_block']['message']['value'];
2328 -
2329 - // Save the message (keep the message_id but don't include in response)
2330 - $this->mxchat_save_chat_message($session_id, 'agent', $message);
2331 -
2332 - // Keep the original response format for Slack
2333 - return new WP_REST_Response([
2334 - 'response_action' => 'clear'
2335 - ]);
2336 -}
2337 -
2338 - // Default acknowledgment
2339 - return new WP_REST_Response(['ok' => true]);
2340 -}
2341 -
2342 -public function mxchat_handle_agent_response(WP_REST_Request $request) {
2343 - //error_log('Received agent response request');
2344 - //error_log('Request data: ' . print_r($request->get_params(), true));
2345 - // error_log('Raw body: ' . file_get_contents('php://input'));
2346 -
2347 - // Get the data from Slack's slash command format
2348 - $command_text = $request->get_param('text');
2349 - // error_log('Command text: ' . $command_text);
2350 -
2351 - if (empty($command_text)) {
2352 - //error_log(esc_html__('Agent response error: No command text received', 'mxchat'));
2353 - return new WP_REST_Response([
2354 - 'error' => esc_html__('Command text is required. Format: /reply session_id message', 'mxchat')
2355 - ], 400);
2356 - }
2357 -
2358 - // Split the command text into session_id and message
2359 - $parts = explode(' ', $command_text, 2);
2360 - if (count($parts) !== 2) {
2361 - //error_log('Agent response error: Invalid command format');
2362 - return new WP_REST_Response([
2363 - 'error' => esc_html__('Invalid format. Use: /reply session_id message', 'mxchat')
2364 - ], 400);
2365 - }
2366 -
2367 - $session_id = sanitize_text_field($parts[0]);
2368 - $message = sanitize_text_field($parts[1]);
2369 -
2370 - //error_log("Processing agent response - Session ID: $session_id, Message: $message");
2371 -
2372 - // Save the message
2373 - $message_id = $this->mxchat_save_chat_message($session_id, 'agent', $message);
2374 -
2375 - if (!$message_id) {
2376 - // error_log('Failed to save agent message');
2377 - return new WP_REST_Response([
2378 - 'error' => esc_html__('Failed to save message', 'mxchat')
2379 - ], 500);
2380 - }
2381 -
2382 - // Return success response in Slack's expected format
2383 - return new WP_REST_Response([
2384 - 'response_type' => 'in_channel',
2385 - 'text' => esc_html__("Message sent successfully to session $session_id", 'mxchat')
2386 - ], 200);
2387 -}
2388 -
2389 -
2390 -public function mxchat_handle_switch_to_chatbot_intent($message, $user_id, $session_id) {
2391 - //error_log(esc_html__("Switching back to chatbot mode via intent.", 'mxchat'));
2392 -
2393 - // Just update mode to AI
2394 - update_option("mxchat_mode_{$session_id}", 'ai');
2395 -
2396 - // Initialize states
2397 - $this->fallbackResponse = ['text' => '', 'html' => '', 'images' => []];
2398 - $this->productCardHtml = '';
2399 -
2400 - // Set the response message
2401 - $this->fallbackResponse['text'] = esc_html__('You are now chatting with the AI chatbot.', 'mxchat');
2402 -
2403 - return true; // Intent was handled
2404 -}
2405 -
2406 -
2407 -
2408 -
2409 -// For the word upload handler
2410 -public function mxchat_handle_word_upload() {
2411 - // Delegate to word handler
2412 - $this->word_handler->mxchat_handle_word_upload();
2413 -}
2414 -
2415 -// For the word removal handler
2416 -public function mxchat_handle_word_remove() {
2417 - // Delegate to word handler
2418 - $this->word_handler->mxchat_handle_word_remove();
2419 -}
2420 -
2421 -// For the word status check
2422 -public function mxchat_check_word_status() {
2423 - // Delegate to word handler
2424 - $this->word_handler->mxchat_check_word_status();
2425 -}
2426 -
2427 -
2428 -private function mxchat_get_user_identifier() {
2429 - return MxChat_User::mxchat_get_user_identifier();
2430 -}
2431 -
2432 -private function mxchat_generate_embedding($text, $api_key) {
247 + private function mxchat_generate_embedding($text, $api_key) {
2433 248 $endpoint = 'https://api.openai.com/v1/embeddings';
2434 249
2435 250 $body = wp_json_encode([
2436 251 'input' => $text,
@@ -2464,386 +279,69 @@
2464 279 return null;
2465 280 }
2466 281 }
2467 282
2468 -
2469 283 private function mxchat_find_relevant_content($user_embedding) {
2470 - //error_log('MXChat Vector Search: Starting content search...');
2471 -
2472 - // Retrieve the add-on settings from the database.
2473 - $addon_options = get_option('mxchat_pinecone_addon_options', array());
2474 -
2475 - // Determine whether Pinecone is enabled.
2476 - // We expect the sanitized setting to be a string '1' if enabled, otherwise '0'.
2477 - $use_pinecone = (isset($addon_options['mxchat_use_pinecone']) && $addon_options['mxchat_use_pinecone'] === '1') ? 1 : 0;
2478 -
2479 - //error_log('Pinecone enabled flag: ' . $use_pinecone);
2480 -
2481 - if ($use_pinecone === 1) {
2482 - //error_log('MXChat Vector Search: Using Pinecone database');
2483 - return $this->find_relevant_content_pinecone($user_embedding);
2484 - } else {
2485 - //error_log('MXChat Vector Search: Using WordPress database');
2486 - return $this->find_relevant_content_wordpress($user_embedding);
2487 - }
2488 -}
2489 -
2490 -private function find_relevant_content_wordpress($user_embedding) {
2491 284 global $wpdb;
2492 285 $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
286 +
287 + // Define a cache key for embeddings
2493 288 $cache_key = 'mxchat_system_prompt_embeddings';
2494 - $batch_size = 500;
2495 289
2496 - // Retrieve embeddings from cache or database
290 + // Attempt to get the embeddings from the cache
2497 291 $embeddings = wp_cache_get($cache_key, 'mxchat_system_prompts');
292 +
2498 293 if ($embeddings === false) {
2499 - $embeddings = [];
2500 - $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);
2501 297
2502 - // Load in batches and build cache
2503 - do {
2504 - $query = $wpdb->prepare(
2505 - "SELECT id, embedding_vector
2506 - FROM {$system_prompt_table}
2507 - LIMIT %d OFFSET %d",
2508 - $batch_size,
2509 - $offset
2510 - );
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 + }
2511 302
2512 - $batch = $wpdb->get_results($query);
2513 - if (empty($batch)) {
2514 - break;
2515 - }
303 + // Cache the results if successful
304 + wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600); // Cache for 1 hour
305 + }
2516 306
2517 - $embeddings = array_merge($embeddings, $batch);
2518 - $offset += $batch_size;
307 + $most_relevant_id = null;
308 + $highest_similarity = -INF;
2519 309
2520 - // Free memory
2521 - unset($batch);
310 + foreach ($embeddings as $embedding) {
311 + $database_embedding = maybe_unserialize($embedding->embedding_vector);
2522 312
2523 - } 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 + // }
2524 318
2525 - if (empty($embeddings)) {
2526 - return ''; // Return an empty string if no embeddings found
2527 - }
2528 - wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600);
2529 - }
2530 -
2531 - // Initialize array to store relevant results with similarity scores
2532 - $relevant_results = [];
2533 - // Iterate through embeddings to calculate similarity
2534 - foreach ($embeddings as $embedding) {
2535 - $database_embedding = $embedding->embedding_vector
2536 - ? unserialize($embedding->embedding_vector, ['allowed_classes' => false])
2537 - : null;
2538 - if (is_array($database_embedding) && is_array($user_embedding)) {
319 + if (is_array($user_embedding)) {
2539 320 $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $database_embedding);
2540 - $relevant_results[] = [
2541 - 'id' => $embedding->id,
2542 - 'similarity' => $similarity
2543 - ];
2544 - }
2545 - // Free memory
2546 - unset($database_embedding);
2547 - }
2548 321
2549 - // Retrieve the similarity threshold
2550 - $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}");
2551 324
2552 - // Filter and sort relevant results by similarity
2553 - $relevant_results = array_filter($relevant_results, function ($result) use ($similarity_threshold) {
2554 - return $result['similarity'] >= $similarity_threshold;
2555 - });
2556 - usort($relevant_results, function ($a, $b) {
2557 - return $b['similarity'] <=> $a['similarity'];
2558 - });
2559 -
2560 - // Limit to the top 5 results
2561 - $top_results = array_slice($relevant_results, 0, 5);
2562 -
2563 - // Initialize the final content
2564 - $content = '';
2565 -
2566 - // Fetch and combine content for the top results
2567 - foreach ($top_results as $result) {
2568 - $chunk_content = $this->fetch_content_with_product_links($result['id']);
2569 - // Check if the content is PDF-related and add surrounding pages
2570 - if (strpos($chunk_content, '{"document_type":"pdf"') !== false) {
2571 - $surrounding_content = $wpdb->get_results($wpdb->prepare(
2572 - "SELECT article_content FROM {$system_prompt_table}
2573 - WHERE id IN (
2574 - (SELECT id FROM {$system_prompt_table} WHERE id < %d ORDER BY id DESC LIMIT 1),
2575 - (SELECT id FROM {$system_prompt_table} WHERE id > %d ORDER BY id ASC LIMIT 1)
2576 - )",
2577 - $result['id'],
2578 - $result['id']
2579 - ));
2580 - // Add previous content if it exists
2581 - if (!empty($surrounding_content[0])) {
2582 - $content .= $surrounding_content[0]->article_content . "\n\n";
325 + if ($similarity > $highest_similarity) {
326 + $highest_similarity = $similarity;
327 + $most_relevant_id = $embedding->id;
2583 328 }
2584 - // Add the main chunk content
2585 - $content .= $chunk_content . "\n\n";
2586 - // Add next content if it exists
2587 - if (!empty($surrounding_content[1])) {
2588 - $content .= $surrounding_content[1]->article_content . "\n\n";
2589 - }
2590 329 } else {
2591 - // For non-PDF content, add directly
2592 - $content .= $chunk_content . "\n\n";
330 + // error_log("User embedding is not an array. Embedding data: " . print_r($user_embedding, true));
2593 331 }
2594 332 }
2595 333
2596 - return trim($content);
2597 -}
2598 -/**
2599 - * Find relevant content in Pinecone vector database
2600 - */
2601 -private function find_relevant_content_pinecone($user_embedding) {
2602 - $options = get_option('mxchat_pinecone_addon_options', array());
2603 - $api_key = $options['mxchat_pinecone_api_key'] ?? '';
2604 - $host = $options['mxchat_pinecone_host'] ?? '';
2605 -
2606 - if (empty($host) || empty($api_key)) {
2607 - //error_log('Pinecone credentials not properly configured');
2608 - return '';
334 + if ($most_relevant_id !== null) {
335 + // Fetch content with product links
336 + return $this->fetch_content_with_product_links($most_relevant_id);
2609 337 }
2610 338
2611 - // Get similarity threshold from WordPress settings
2612 - $similarity_threshold = ((int) get_option('mxchat_similarity_threshold', 80)) / 100;
2613 -
2614 - // Prepare the query request for Pinecone
2615 - $api_endpoint = "https://{$host}/query";
2616 -
2617 - $request_body = array(
2618 - 'vector' => $user_embedding,
2619 - 'topK' => 5,
2620 - 'includeMetadata' => true,
2621 - 'includeValues' => true
2622 - );
2623 -
2624 - $response = wp_remote_post($api_endpoint, array(
2625 - 'headers' => array(
2626 - 'Api-Key' => $api_key,
2627 - 'accept' => 'application/json',
2628 - 'content-type' => 'application/json'
2629 - ),
2630 - 'body' => wp_json_encode($request_body),
2631 - 'timeout' => 30
2632 - ));
2633 -
2634 - if (is_wp_error($response)) {
2635 - //error_log('Pinecone query error: ' . $response->get_error_message());
2636 - return '';
2637 - }
2638 -
2639 - $response_code = wp_remote_retrieve_response_code($response);
2640 - if ($response_code !== 200) {
2641 - //error_log('Pinecone API error: ' . wp_remote_retrieve_body($response));
2642 - return '';
2643 - }
2644 -
2645 - $results = json_decode(wp_remote_retrieve_body($response), true);
2646 - if (empty($results['matches'])) {
2647 - return '';
2648 - }
2649 -
2650 - // Initialize the final content
2651 - $content = '';
2652 -
2653 - // Process each match
2654 - foreach ($results['matches'] as $match) {
2655 - // Skip if similarity is below threshold
2656 - if ($match['score'] < $similarity_threshold) {
2657 - continue;
2658 - }
2659 -
2660 - if (!empty($match['metadata']['text']) && !empty($match['metadata']['source_url'])) {
2661 - // Add content with citation
2662 - $content .= $match['metadata']['text'] . "\n";
2663 - $content .= "Source: " . $match['metadata']['source_url'] . "\n\n";
2664 - }
2665 - }
2666 -
2667 - return trim($content);
339 + error_log("No relevant content found. Most relevant ID was null.");
340 + return null; // Return null if no relevant content is found
2668 341 }
2669 342
2670 343
2671 -private function mxchat_find_relevant_products($user_embedding) {
2672 - //error_log('MXChat Vector Search: Starting product search...');
2673 -
2674 - // Retrieve the add-on settings from the database
2675 - $addon_options = get_option('mxchat_pinecone_addon_options', array());
2676 -
2677 - // Determine whether Pinecone is enabled
2678 - $use_pinecone = (isset($addon_options['mxchat_use_pinecone']) && $addon_options['mxchat_use_pinecone'] === '1') ? 1 : 0;
2679 -
2680 - //error_log('Pinecone enabled flag: ' . $use_pinecone);
2681 -
2682 - if ($use_pinecone === 1) {
2683 - //error_log('MXChat Vector Search: Using Pinecone database for products');
2684 - return $this->find_relevant_products_pinecone($user_embedding);
2685 - } else {
2686 - //error_log('MXChat Vector Search: Using WordPress database for products');
2687 - return $this->find_relevant_products_wordpress($user_embedding);
2688 - }
2689 -}
2690 -
2691 -private function find_relevant_products_wordpress($user_embedding) {
2692 - global $wpdb;
2693 - $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
2694 - $cache_key = 'mxchat_system_prompt_embeddings';
2695 - $batch_size = 500;
2696 -
2697 - // Original WordPress database search logic
2698 - // [Previous implementation remains the same]
2699 - $embeddings = wp_cache_get($cache_key, 'mxchat_system_prompts');
2700 - if ($embeddings === false) {
2701 - $embeddings = [];
2702 - $offset = 0;
2703 -
2704 - do {
2705 - $query = $wpdb->prepare(
2706 - "SELECT id, embedding_vector
2707 - FROM {$system_prompt_table}
2708 - LIMIT %d OFFSET %d",
2709 - $batch_size,
2710 - $offset
2711 - );
2712 -
2713 - $batch = $wpdb->get_results($query);
2714 - if (empty($batch)) {
2715 - break;
2716 - }
2717 -
2718 - $embeddings = array_merge($embeddings, $batch);
2719 - $offset += $batch_size;
2720 -
2721 - unset($batch);
2722 -
2723 - } while (true);
2724 -
2725 - if (empty($embeddings)) {
2726 - return '';
2727 - }
2728 - wp_cache_set($cache_key, $embeddings, 'mxchat_system_prompts', 3600);
2729 - }
2730 -
2731 - $relevant_results = [];
2732 - foreach ($embeddings as $embedding) {
2733 - $database_embedding = $embedding->embedding_vector
2734 - ? unserialize($embedding->embedding_vector, ['allowed_classes' => false])
2735 - : null;
2736 - if (is_array($database_embedding) && is_array($user_embedding)) {
2737 - $similarity = $this->mxchat_calculate_cosine_similarity($user_embedding, $database_embedding);
2738 - $relevant_results[] = [
2739 - 'id' => $embedding->id,
2740 - 'similarity' => $similarity
2741 - ];
2742 - }
2743 - unset($database_embedding);
2744 - }
2745 -
2746 - // Use fixed threshold for products
2747 - $similarity_threshold = 0.85;
2748 -
2749 - $relevant_results = array_filter($relevant_results, function ($result) use ($similarity_threshold) {
2750 - return $result['similarity'] >= $similarity_threshold;
2751 - });
2752 - usort($relevant_results, function ($a, $b) {
2753 - return $b['similarity'] <=> $a['similarity'];
2754 - });
2755 -
2756 - $top_results = array_slice($relevant_results, 0, 5);
2757 - $content = '';
2758 -
2759 - foreach ($top_results as $result) {
2760 - $chunk_content = $this->fetch_content_with_product_links($result['id']);
2761 - $content .= $chunk_content . "\n\n";
2762 - }
2763 -
2764 - return trim($content);
2765 -}
2766 -
2767 -// Modified search function with correct filter syntax
2768 -private function find_relevant_products_pinecone($user_embedding) {
2769 - //error_log('Starting Pinecone product search...');
2770 -
2771 - $options = get_option('mxchat_pinecone_addon_options', array());
2772 - $api_key = $options['mxchat_pinecone_api_key'] ?? '';
2773 - $host = $options['mxchat_pinecone_host'] ?? '';
2774 -
2775 - if (empty($host) || empty($api_key)) {
2776 - //error_log('Pinecone credentials not properly configured for product search');
2777 - return '';
2778 - }
2779 -
2780 - $similarity_threshold = 0.85;
2781 - $api_endpoint = "https://{$host}/query";
2782 -
2783 - $request_body = array(
2784 - 'vector' => $user_embedding,
2785 - 'topK' => 5,
2786 - 'includeMetadata' => true,
2787 - 'includeValues' => true,
2788 - 'filter' => array(
2789 - 'type' => 'product'
2790 - )
2791 - );
2792 -
2793 - //error_log('Sending request to Pinecone with body: ' . wp_json_encode($request_body));
2794 -
2795 - $response = wp_remote_post($api_endpoint, array(
2796 - 'headers' => array(
2797 - 'Api-Key' => $api_key,
2798 - 'accept' => 'application/json',
2799 - 'content-type' => 'application/json'
2800 - ),
2801 - 'body' => wp_json_encode($request_body),
2802 - 'timeout' => 30
2803 - ));
2804 -
2805 - if (is_wp_error($response)) {
2806 - //error_log('Pinecone product query error: ' . $response->get_error_message());
2807 - return '';
2808 - }
2809 -
2810 - $response_code = wp_remote_retrieve_response_code($response);
2811 - //error_log('Pinecone response code: ' . $response_code);
2812 -
2813 - if ($response_code !== 200) {
2814 - //error_log('Pinecone API error during product search: ' . wp_remote_retrieve_body($response));
2815 - return '';
2816 - }
2817 -
2818 - $results = json_decode(wp_remote_retrieve_body($response), true);
2819 - //error_log('Pinecone raw response: ' . wp_remote_retrieve_body($response));
2820 -
2821 - if (empty($results['matches'])) {
2822 - //error_log('No matches found in Pinecone response');
2823 - return '';
2824 - }
2825 -
2826 - $content = '';
2827 - foreach ($results['matches'] as $match) {
2828 - if ($match['score'] < $similarity_threshold) {
2829 - //error_log("Match below threshold: " . $match['score']);
2830 - continue;
2831 - }
2832 -
2833 - if (!empty($match['metadata']['text'])) {
2834 - $content .= $match['metadata']['text'];
2835 - if (!empty($match['metadata']['source_url'])) {
2836 - $content .= "\n\nFor more details, check out this product: " . esc_url($match['metadata']['source_url']);
2837 - }
2838 - $content .= "\n\n";
2839 - }
2840 - }
2841 -
2842 - return trim($content);
2843 -}
2844 -
2845 -
2846 344 private function fetch_content_with_product_links($most_relevant_id) {
2847 345 global $wpdb;
2848 346 $system_prompt_table = $wpdb->prefix . 'mxchat_system_prompt_content';
2849 347
@@ -2862,292 +360,41 @@
2862 360
2863 361 return null;
2864 362 }
2865 363
2866 -// Function definition
2867 -private function mxchat_generate_response($relevant_content, $api_key, $xai_api_key, $claude_api_key, $deepseek_api_key, $conversation_history) {
2868 - try {
2869 - if (!$relevant_content) {
2870 - return esc_html__("I'm sorry, I couldn't find relevant information on that topic.", 'mxchat');
2871 - }
2872 364
2873 - // Ensure conversation_history is an array
2874 - if (!is_array($conversation_history)) {
2875 - $conversation_history = array();
2876 - }
2877 -
2878 - // Get selected model with default fallback
2879 - $selected_model = isset($this->options['model']) ? $this->options['model'] : 'gpt-4o';
2880 -
2881 - // Extract model prefix to determine the provider
2882 - $model_parts = explode('-', $selected_model);
2883 - $provider = strtolower($model_parts[0]);
2884 -
2885 - // Handle model selection based on provider prefix
2886 - switch ($provider) {
2887 - case 'claude':
2888 - if (empty($claude_api_key)) {
2889 - throw new Exception(esc_html__('Claude API key is not configured', 'mxchat'));
2890 - }
2891 - return $this->mxchat_generate_response_claude(
2892 - $selected_model,
2893 - $claude_api_key,
2894 - $conversation_history,
2895 - $relevant_content
2896 - );
2897 -
2898 - case 'grok':
2899 - if (empty($xai_api_key)) {
2900 - throw new Exception(esc_html__('X.AI API key is not configured', 'mxchat'));
2901 - }
2902 - return $this->mxchat_generate_response_xai(
2903 - $selected_model,
2904 - $xai_api_key,
2905 - $conversation_history,
2906 - $relevant_content
2907 - );
2908 -
2909 - case 'deepseek':
2910 - if (empty($deepseek_api_key)) {
2911 - throw new Exception(esc_html__('DeepSeek API key is not configured', 'mxchat'));
2912 - }
2913 - return $this->mxchat_generate_response_deepseek(
2914 - $selected_model,
2915 - $deepseek_api_key,
2916 - $conversation_history,
2917 - $relevant_content
2918 - );
2919 -
2920 - case 'gpt':
2921 - if (empty($api_key)) {
2922 - throw new Exception(esc_html__('OpenAI API key is not configured', 'mxchat'));
2923 - }
2924 - return $this->mxchat_generate_response_openai(
2925 - $selected_model,
2926 - $api_key,
2927 - $conversation_history,
2928 - $relevant_content
2929 - );
2930 -
2931 - default:
2932 - // Default to OpenAI for custom models or unrecognized prefixes
2933 - if (empty($api_key)) {
2934 - throw new Exception(esc_html__('OpenAI API key is not configured', 'mxchat'));
2935 - }
2936 - return $this->mxchat_generate_response_openai(
2937 - $selected_model,
2938 - $api_key,
2939 - $conversation_history,
2940 - $relevant_content
2941 - );
2942 - }
2943 - } catch (Exception $e) {
2944 - //error_log('MXChat Error: ' . $e->getMessage());
2945 - return sprintf(
2946 - esc_html__('An error occurred: %s', 'mxchat'),
2947 - esc_html($e->getMessage())
2948 - );
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.";
2949 368 }
2950 -}
2951 369
2952 -
2953 -private function mxchat_generate_response_deepseek($selected_model, $deepseek_api_key, $conversation_history, $relevant_content) {
2954 - // Ensure conversation_history is an array
2955 - if (!is_array($conversation_history)) {
2956 - $conversation_history = array();
2957 - }
2958 -
2959 - // Get system prompt instructions from options
2960 370 $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
2961 371
2962 - // Create a new array for the formatted conversation
2963 - $formatted_conversation = array();
2964 -
2965 - // Add system message first
2966 - $formatted_conversation[] = array(
2967 - 'role' => 'system',
2968 - 'content' => $system_prompt_instructions . " " . $relevant_content
2969 - );
2970 -
2971 - // Add the rest of the conversation history
2972 - foreach ($conversation_history as $message) {
2973 - if (is_array($message) && isset($message['role']) && isset($message['content'])) {
2974 - $role = $message['role'];
2975 -
2976 - // Convert roles to supported format
2977 - if ($role === 'bot' || $role === 'agent') {
2978 - $role = 'assistant';
2979 - }
2980 - if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
2981 - $role = 'user';
2982 - }
2983 -
2984 - $formatted_conversation[] = array(
2985 - 'role' => $role,
2986 - 'content' => $message['content']
2987 - );
2988 - }
2989 - }
2990 -
2991 - $body = json_encode([
2992 - 'model' => $selected_model,
2993 - 'messages' => $formatted_conversation,
2994 - 'temperature' => 0.8,
2995 - 'stream' => false
2996 - ]);
2997 -
2998 - $args = [
2999 - 'body' => $body,
3000 - 'headers' => [
3001 - 'Content-Type' => 'application/json',
3002 - 'Authorization' => 'Bearer ' . $deepseek_api_key,
3003 - ],
3004 - 'timeout' => 60,
3005 - 'redirection' => 5,
3006 - 'blocking' => true,
3007 - 'httpversion' => '1.0',
3008 - 'sslverify' => true,
3009 - ];
3010 -
3011 - $response = wp_remote_post('https://api.deepseek.com/v1/chat/completions', $args);
3012 -
3013 - if (is_wp_error($response)) {
3014 - //error_log('DeepSeek API Error: ' . $response->get_error_message());
3015 - return "Sorry, there was an error processing your request.";
3016 - }
3017 -
3018 - $response_body = wp_remote_retrieve_body($response);
3019 - $decoded_response = json_decode($response_body, true);
3020 -
3021 - if (isset($decoded_response['choices'][0]['message']['content'])) {
3022 - return trim($decoded_response['choices'][0]['message']['content']);
3023 - } else {
3024 - //error_log('DeepSeek API Response Format Error: ' . print_r($decoded_response, true));
3025 - return "Sorry, I couldn't process that request.";
3026 - }
3027 -}
3028 -
3029 -private function mxchat_generate_response_openai($selected_model, $api_key, $conversation_history, $relevant_content) {
3030 - // Ensure conversation_history is an array
3031 - if (!is_array($conversation_history)) {
3032 - $conversation_history = array();
3033 - }
3034 -
3035 - // Get system prompt instructions from options
3036 - $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3037 -
3038 - // Create a new array for the formatted conversation
3039 - $formatted_conversation = array();
3040 -
3041 - // Add system message first
3042 - $formatted_conversation[] = array(
3043 - 'role' => 'system',
3044 - 'content' => $system_prompt_instructions . " " . $relevant_content
3045 - );
3046 -
3047 - // Add the rest of the conversation history
3048 - foreach ($conversation_history as $message) {
3049 - if (is_array($message) && isset($message['role']) && isset($message['content'])) {
3050 - $role = $message['role'];
3051 -
3052 - // Convert roles to supported format
3053 - if ($role === 'bot' || $role === 'agent') {
3054 - $role = 'assistant';
3055 - }
3056 - if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
3057 - $role = 'user';
3058 - }
3059 -
3060 - $formatted_conversation[] = array(
3061 - 'role' => $role,
3062 - 'content' => $message['content']
3063 - );
3064 - }
3065 - }
3066 -
3067 - $body = json_encode([
3068 - 'model' => $selected_model,
3069 - 'messages' => $formatted_conversation,
3070 - 'temperature' => 0.8,
3071 - 'stream' => false
3072 - ]);
3073 -
3074 - $args = [
3075 - 'body' => $body,
3076 - 'headers' => [
3077 - 'Content-Type' => 'application/json',
3078 - 'Authorization' => 'Bearer ' . $api_key,
3079 - ],
3080 - 'timeout' => 60,
3081 - 'redirection' => 5,
3082 - 'blocking' => true,
3083 - 'httpversion' => '1.0',
3084 - 'sslverify' => true,
3085 - ];
3086 -
3087 - $response = wp_remote_post('https://api.openai.com/v1/chat/completions', $args);
3088 -
3089 - if (is_wp_error($response)) {
3090 - //error_log('OpenAI API Error: ' . $response->get_error_message());
3091 - return "Sorry, there was an error processing your request.";
3092 - }
3093 -
3094 - $response_body = wp_remote_retrieve_body($response);
3095 - $decoded_response = json_decode($response_body, true);
3096 -
3097 - if (isset($decoded_response['choices'][0]['message']['content'])) {
3098 - return trim($decoded_response['choices'][0]['message']['content']);
3099 - } else {
3100 - //error_log('OpenAI API Response Format Error: ' . print_r($decoded_response, true));
3101 - return "Sorry, I couldn't process that request.";
3102 - }
3103 -}
3104 -private function mxchat_generate_response_xai($selected_model, $xai_api_key, $conversation_history, $relevant_content) {
3105 - // Get system prompt instructions from options
3106 - $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3107 -
3108 - // Add system prompt to relevant content
3109 372 $content_with_instructions = $system_prompt_instructions . " " . $relevant_content;
3110 373
3111 - // Prepend system instructions to the conversation history
3112 374 array_unshift($conversation_history, [
3113 375 'role' => 'system',
3114 376 'content' => "Here are your instructions: " . $content_with_instructions
3115 377 ]);
3116 378
3117 - // Ensure consistency: Replace 'bot' and 'agent' roles with supported values
3118 379 foreach ($conversation_history as &$message) {
3119 380 if ($message['role'] === 'bot') {
3120 381 $message['role'] = 'assistant';
3121 - } elseif ($message['role'] === 'agent') {
3122 - // Tag the message as coming from a live agent
3123 - $message['role'] = 'assistant';
3124 - if (!isset($message['metadata'])) {
3125 - $message['metadata'] = ['source' => 'live_agent'];
3126 - }
3127 382 }
3128 -
3129 - // Ensure all roles are valid
3130 - if (!in_array($message['role'], ['system', 'assistant', 'user', 'function', 'tool'])) {
3131 - $message['role'] = 'user'; // Default to 'user'
3132 - }
3133 383 }
3134 384
385 + $api_url = 'https://api.openai.com/v1/chat/completions';
3135 386
3136 - // Build the request body
3137 387 $body = json_encode([
3138 - 'model' => $selected_model,
388 + 'model' => isset($this->options['model']) ? $this->options['model'] : 'gpt-3.5',
3139 389 'messages' => $conversation_history,
3140 - 'temperature' => 0.8,
3141 - 'stream' => false
3142 390 ]);
3143 391
3144 - // Set up the API request
3145 392 $args = [
3146 393 'body' => $body,
3147 394 'headers' => [
3148 395 'Content-Type' => 'application/json',
3149 - 'Authorization' => 'Bearer ' . $xai_api_key,
396 + 'Authorization' => 'Bearer ' . $api_key,
3150 397 ],
3151 398 'timeout' => 60,
3152 399 'redirection' => 5,
3153 400 'blocking' => true,
@@ -3154,12 +401,10 @@
3154 401 'httpversion' => '1.0',
3155 402 'sslverify' => true,
3156 403 ];
3157 404
3158 - // Make the API request
3159 - $response = wp_remote_post('https://api.x.ai/v1/chat/completions', $args);
405 + $response = wp_remote_post($api_url, $args);
3160 406
3161 - // Process the response
3162 407 if (is_wp_error($response)) {
3163 408 return "Sorry, there was an error processing your request.";
3164 409 }
3165 410
@@ -3165,8 +410,12 @@
3165 410
3166 411 $response_body = json_decode(wp_remote_retrieve_body($response), true);
3167 412
3168 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 + }
3169 418 return trim($response_body['choices'][0]['message']['content']);
3170 419 } else {
3171 420 return "Sorry, I couldn't process that request.";
3172 421 }
@@ -3171,108 +420,9 @@
3171 420 return "Sorry, I couldn't process that request.";
3172 421 }
3173 422 }
3174 423
3175 -private function mxchat_generate_response_claude($selected_model, $claude_api_key, $conversation_history, $relevant_content) {
3176 - // Get system prompt instructions from options
3177 - $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
3178 424
3179 - // Clean and validate conversation history
3180 - foreach ($conversation_history as &$message) {
3181 - // Convert bot and agent roles to assistant
3182 - if ($message['role'] === 'bot' || $message['role'] === 'agent') {
3183 - $message['role'] = 'assistant';
3184 - }
3185 -
3186 - // Remove unsupported roles - Claude only supports 'assistant' and 'user'
3187 - if (!in_array($message['role'], ['assistant', 'user'])) {
3188 - $message['role'] = 'user';
3189 - }
3190 -
3191 - // Ensure content field exists
3192 - if (!isset($message['content']) || empty($message['content'])) {
3193 - $message['content'] = '';
3194 - }
3195 -
3196 - // Remove any unsupported fields
3197 - $message = array_intersect_key($message, array_flip(['role', 'content']));
3198 - }
3199 -
3200 - // Add relevant content as the latest user message
3201 - $conversation_history[] = [
3202 - 'role' => 'user',
3203 - 'content' => $relevant_content
3204 - ];
3205 -
3206 - // Build request body
3207 - $body = json_encode([
3208 - 'model' => $selected_model,
3209 - 'max_tokens' => 1000,
3210 - 'temperature' => 0.8,
3211 - 'messages' => $conversation_history,
3212 - 'system' => $system_prompt_instructions
3213 - ]);
3214 -
3215 - // Set up API request
3216 - $args = [
3217 - 'body' => $body,
3218 - 'headers' => [
3219 - 'Content-Type' => 'application/json',
3220 - 'x-api-key' => $claude_api_key,
3221 - 'anthropic-version' => '2023-06-01'
3222 - ],
3223 - 'timeout' => 60,
3224 - 'redirection' => 5,
3225 - 'blocking' => true,
3226 - 'httpversion' => '1.0',
3227 - 'sslverify' => true,
3228 - ];
3229 -
3230 - // Make API request
3231 - $response = wp_remote_post('https://api.anthropic.com/v1/messages', $args);
3232 -
3233 - // Check for WordPress errors
3234 - if (is_wp_error($response)) {
3235 - //error_log("Claude API request error: " . $response->get_error_message());
3236 - return "Sorry, there was an error connecting to the API.";
3237 - }
3238 -
3239 - // Check HTTP response code
3240 - $http_code = wp_remote_retrieve_response_code($response);
3241 - if ($http_code !== 200) {
3242 - $error_body = wp_remote_retrieve_body($response);
3243 - //error_log("Claude API HTTP error: " . $http_code . " - " . $error_body);
3244 -
3245 - // Try to extract error message from response
3246 - $error_data = json_decode($error_body, true);
3247 - $error_message = isset($error_data['error']['message']) ?
3248 - $error_data['error']['message'] :
3249 - "HTTP error " . $http_code;
3250 -
3251 - return "Sorry, the API returned an error: " . $error_message;
3252 - }
3253 -
3254 - // Parse response
3255 - $response_body = json_decode(wp_remote_retrieve_body($response), true);
3256 -
3257 - // Check for JSON decode errors
3258 - if (json_last_error() !== JSON_ERROR_NONE) {
3259 - //error_log("Claude API JSON decode error: " . json_last_error_msg());
3260 - return "Sorry, there was an error processing the API response.";
3261 - }
3262 -
3263 - // Extract and validate response content
3264 - if (isset($response_body['content']) &&
3265 - is_array($response_body['content']) &&
3266 - !empty($response_body['content']) &&
3267 - isset($response_body['content'][0]['text'])) {
3268 - return trim($response_body['content'][0]['text']);
3269 - }
3270 -
3271 - // Log unexpected response format
3272 - //error_log("Claude API unexpected response format: " . print_r($response_body, true));
3273 - return "Sorry, I received an unexpected response format from the API.";
3274 -}
3275 425 public function mxchat_dismiss_pre_chat_message() {
3276 426 // Get and sanitize the user identifier
3277 427 $user_id = $this->mxchat_get_user_identifier();
3278 428 $user_id = sanitize_key($user_id);
@@ -3283,30 +433,11 @@
3283 433
3284 434 wp_send_json_success();
3285 435 }
3286 436
3287 -public function mxchat_check_pre_chat_message_status() {
3288 - // Get and sanitize the user identifier
3289 - $user_id = $this->mxchat_get_user_identifier();
3290 - $user_id = sanitize_key($user_id);
3291 437
3292 - // Check if the transient exists (i.e., if the message was dismissed)
3293 - $transient_key = 'mxchat_pre_chat_message_dismissed_' . $user_id;
3294 - $dismissed = get_transient($transient_key);
3295 438
3296 - // Log the result to see if it's being set correctly
3297 - //error_log("Check pre-chat message dismissed for $user_id: " . ($dismissed ? 'Yes' : 'No'));
3298 -
3299 - if ($dismissed) {
3300 - wp_send_json_success(['dismissed' => true]);
3301 - } else {
3302 - wp_send_json_success(['dismissed' => false]);
3303 - }
3304 -
3305 - wp_die();
3306 -}
3307 -
3308 -private function mxchat_calculate_cosine_similarity($vectorA, $vectorB) {
439 + private function mxchat_calculate_cosine_similarity($vectorA, $vectorB) {
3309 440 if (!is_array($vectorA) || !is_array($vectorB) || empty($vectorA) || empty($vectorB)) {
3310 441 return 0;
3311 442 }
3312 443
@@ -3326,72 +457,48 @@
3326 457
3327 458 return $dotProduct / ($normA * $normB);
3328 459 }
3329 460
3330 -public function mxchat_enqueue_scripts_styles() {
3331 - // Define version numbers for the styles and scripts
3332 - $chat_style_version = '2.0.5'; // Replace with your actual version
3333 - $chat_script_version = '2.0.5'; // Replace with your actual version
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
3334 465
3335 - // Enqueue the script
3336 - wp_enqueue_script(
3337 - 'mxchat-chat-js',
3338 - plugin_dir_url(__FILE__) . '../js/chat-script.js',
3339 - array('jquery'),
3340 - $chat_script_version,
3341 - true
3342 - );
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 + );
3343 474
3344 - // Enqueue the CSS
3345 - wp_enqueue_style(
3346 - 'mxchat-chat-css',
3347 - plugin_dir_url(__FILE__) . '../css/chat-style.css',
3348 - array(),
3349 - $chat_style_version
3350 - );
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 + );
3351 482
3352 - // Fetch options from the database
3353 - $this->options = get_option('mxchat_options');
3354 - $prompts_options = get_option('mxchat_prompts_options', array());
483 + // Fetch options from the database
484 + $this->options = get_option('mxchat_options');
3355 485
3356 - // Prepare settings for JavaScript
3357 - $style_settings = array(
3358 - 'ajax_url' => admin_url('admin-ajax.php'),
3359 - 'nonce' => wp_create_nonce('mxchat_chat_nonce'),
3360 - 'link_target_toggle' => $this->options['link_target_toggle'] ?? 'off',
3361 - 'rate_limit_message' => $this->options['rate_limit_message'] ?? 'Rate limit exceeded. Please try again later.',
3362 - 'complianz_toggle' => isset($this->options['complianz_toggle']) && $this->options['complianz_toggle'] === 'on',
3363 - 'user_message_bg_color' => $this->options['user_message_bg_color'] ?? '#fff',
3364 - 'user_message_font_color' => $this->options['user_message_font_color'] ?? '#212121',
3365 - 'bot_message_bg_color' => $this->options['bot_message_bg_color'] ?? '#212121',
3366 - 'bot_message_font_color' => $this->options['bot_message_font_color'] ?? '#fff',
3367 - 'top_bar_bg_color' => $this->options['top_bar_bg_color'] ?? '#212121',
3368 - 'send_button_font_color' => $this->options['send_button_font_color'] ?? '#212121',
3369 - 'close_button_color' => $this->options['close_button_color'] ?? '#fff',
3370 - 'chatbot_background_color' => $this->options['chatbot_background_color'] ?? '#212121',
3371 - 'chatbot_bg_color' => $this->options['chatbot_bg_color'] ?? '#fff',
3372 - 'icon_color' => $this->options['icon_color'] ?? '#fff',
3373 - 'chat_input_font_color' => $this->options['chat_input_font_color'] ?? '#212121',
3374 - 'chat_persistence_toggle' => $this->options['chat_persistence_toggle'] ?? 'off',
3375 - 'appendWidgetToBody' => $this->options['append_to_body'] ?? 'off', // Example for consistency
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 + );
3376 493
3377 - 'live_agent_message_bg_color' => $this->options['live_agent_message_bg_color'] ?? '#ffffff',
3378 - 'live_agent_message_font_color' => $this->options['live_agent_message_font_color'] ?? '#333333',
3379 - 'chat_toolbar_toggle' => $this->options['chat_toolbar_toggle'] ?? 'off',
3380 - 'mode_indicator_bg_color' => $this->options['mode_indicator_bg_color'] ?? '#767676',
3381 - 'mode_indicator_font_color' => $this->options['mode_indicator_font_color'] ?? '#ffffff',
3382 - 'toolbar_icon_color' => $this->options['toolbar_icon_color'] ?? '#212121',
494 + // Localize the script with necessary data
495 + wp_localize_script('mxchat-chat-js', 'mxchatChat', $style_settings);
496 + }
3383 497
3384 - 'use_pinecone' => $prompts_options['mxchat_use_pinecone'] ?? '0',
3385 - 'pinecone_enabled' => isset($prompts_options['mxchat_use_pinecone']) && $prompts_options['mxchat_use_pinecone'] === '1'
3386 - );
3387 498
3388 - // Pass the settings to the script
3389 - wp_localize_script('mxchat-chat-js', 'mxchatChat', $style_settings);
3390 -}
3391 499
3392 -
3393 -public function mxchat_reset_rate_limits() {
500 + public function mxchat_reset_rate_limits() {
3394 501 global $wpdb;
3395 502
3396 503 // Define a cache key pattern for rate limits
3397 504 $cache_key_pattern = 'mxchat_chat_limit_%';
@@ -3412,8 +519,9 @@
3412 519 // Optionally, clear a general cache if you have one
3413 520 wp_cache_delete('mxchat_all_chat_limits', 'options');
3414 521 }
3415 522
523 +
3416 524 private function mxchat_fetch_woocommerce_products() {
3417 525 // Ensure WooCommerce is active
3418 526 if (!class_exists('WooCommerce')) {
3419 527 return [];
@@ -3448,7 +556,13 @@
3448 556 }
3449 557
3450 558 return $product_data;
3451 559 }
560 +
561 +
562 +
563 +
564 +
565 +
3452 566
3453 567 }
3454 568 ?>