Changeset 3311750

Timestamp:

06/15/2025 03:15:07 AM (8 months ago)

Author:

mxchat

Message:

2.2.5 various updates including streaming for openai & claude, pinecone UI fix and slack dup message fix.

Location:

mxchat-basic

Files:

• tags/2.2.5 (added)
• tags/2.2.5/admin (added)
• tags/2.2.5/admin/class-ajax-handler.php (added)
• tags/2.2.5/admin/class-knowledge-manager.php (added)
• tags/2.2.5/admin/class-pinecone-manager.php (added)
• tags/2.2.5/css (added)
• tags/2.2.5/css/admin-add-ons.css (added)
• tags/2.2.5/css/admin-style.css (added)
• tags/2.2.5/css/chat-style.css (added)
• tags/2.2.5/css/chat-transcripts.css (added)
• tags/2.2.5/css/content-selector.css (added)
• tags/2.2.5/css/intent-style.css (added)
• tags/2.2.5/css/knowledge-style.css (added)
• tags/2.2.5/images (added)
• tags/2.2.5/images/Icon-01.svg (added)
• tags/2.2.5/images/Icon-02.svg (added)
• tags/2.2.5/images/Icon-03.svg (added)
• tags/2.2.5/images/Icon-04.svg (added)
• tags/2.2.5/images/pro-only-dark.png (added)
• tags/2.2.5/includes (added)
• tags/2.2.5/includes/class-mxchat-addons.php (added)
• tags/2.2.5/includes/class-mxchat-admin.php (added)
• tags/2.2.5/includes/class-mxchat-integrator.php (added)
• tags/2.2.5/includes/class-mxchat-public.php (added)
• tags/2.2.5/includes/class-mxchat-user.php (added)
• tags/2.2.5/includes/class-mxchat-utils.php (added)
• tags/2.2.5/includes/class-mxchat-word-handler.php (added)
• tags/2.2.5/includes/pdf-parser (added)
• tags/2.2.5/includes/pdf-parser/alt_autoload.php (added)
• tags/2.2.5/includes/pdf-parser/src (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Config.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Document.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementArray.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementBoolean.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementDate.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementHexa.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementMissing.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementName.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementNull.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementNumeric.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementString.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementStruct.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Element/ElementXRef.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/AbstractEncoding.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/EncodingLocator.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/ISOLatin1Encoding.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/ISOLatin9Encoding.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/MacRomanEncoding.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/PDFDocEncoding.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/PostScriptGlyphs.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/StandardEncoding.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Encoding/WinAnsiEncoding.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Exception (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Exception/EmptyPdfException.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Exception/EncodingNotFoundException.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Exception/MissingPdfHeaderException.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Exception/NotImplementedException.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Font (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Font.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Font/FontCIDFontType0.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Font/FontCIDFontType2.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Font/FontTrueType.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Font/FontType0.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Font/FontType1.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Font/FontType3.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Header.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/PDFObject.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Page.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Pages.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/Parser.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/RawData (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/RawData/FilterHelper.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/RawData/RawDataParser.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/XObject (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/XObject/Form.php (added)
• tags/2.2.5/includes/pdf-parser/src/Smalot/PdfParser/XObject/Image.php (added)
• tags/2.2.5/js (added)
• tags/2.2.5/js/activation-script.js (added)
• tags/2.2.5/js/chat-script.js (added)
• tags/2.2.5/js/content-selector.js (added)
• tags/2.2.5/js/knowledge-processing.js (added)
• tags/2.2.5/js/mxchat-admin.js (added)
• tags/2.2.5/js/mxchat_transcripts.js (added)
• tags/2.2.5/languages (added)
• tags/2.2.5/languages/mxchat.pot (added)
• tags/2.2.5/mxchat-basic.php (added)
• tags/2.2.5/readme.txt (added)
• trunk/admin/class-ajax-handler.php (modified) (2 diffs)
• trunk/admin/class-knowledge-manager.php (modified) (1 diff)
• trunk/admin/class-pinecone-manager.php (modified) (3 diffs)
• trunk/css/chat-style.css (modified) (5 diffs)
• trunk/includes/class-mxchat-addons.php (modified) (1 diff)
• trunk/includes/class-mxchat-admin.php (modified) (18 diffs)
• trunk/includes/class-mxchat-integrator.php (modified) (31 diffs)
• trunk/js/chat-script.js (modified) (6 diffs)
• trunk/js/mxchat-admin.js (modified) (1 diff)
• trunk/mxchat-basic.php (modified) (2 diffs)
• trunk/readme.txt (modified) (6 diffs)

mxchat-basic/trunk/admin/class-ajax-handler.php

@@ -182 +182 @@
                  }
                  // Handle toggles
-                 else if (strpos($name, 'toggle') !== false || in_array($name, [
-                     'chat_persistence_toggle',
-                     'privacy_toggle',
-                     'complianz_toggle',
-                     'chat_toolbar_toggle',
-                     'show_pdf_upload_button',
-                     'show_word_upload_button'
-                 ])) {
-                     //error_log('MXChat Save: Processing toggle: ' . $name);
-                     $options[$name] = ($value === 'on') ? 'on' : 'off';
-                 } else {
+                else if (strpos($name, 'toggle') !== false || in_array($name, [
+                    'chat_persistence_toggle',
+                    'privacy_toggle',
+                    'complianz_toggle',
+                    'chat_toolbar_toggle',
+                    'show_pdf_upload_button',
+                    'show_word_upload_button',
+                    'enable_streaming_toggle' // Add this line
+                ])) {
+                    //error_log('MXChat Save: Processing toggle: ' . $name);
+                    $options[$name] = ($value === 'on') ? 'on' : 'off';
+                } else {
                      //error_log('MXChat Save: Processing standard field: ' . $name);
                      // Store all other values directly
@@ -662 +663 @@
      }
 
-    /**
-     * Checks if a value has changed from old to new
-     */
-     private function mxchat_has_value_changed($old_value, $new_value) {
-         // Handle null values
-         if ($old_value === null && $new_value === '') {
-             return false;
-         }
-
-         // Handle array values (like additional_popular_questions)
-         if (is_array($old_value) && is_array($new_value)) {
-             // Convert both to JSON for comparison to handle ordering differences
-             return json_encode($old_value) !== json_encode($new_value);
-         }
-
-         // Handle toggle/checkbox values consistently
-         if (in_array($old_value, ['on', '1', 1, true]) && in_array($new_value, ['on', '1', 1, true])) {
-             return false;
-         }
-         if (in_array($old_value, ['off', '0', 0, false, '']) && in_array($new_value, ['off', '0', 0, false, ''])) {
-             return false;
-         }
-
-         // Default direct comparison
-         return $old_value !== $new_value;
-     }
-
 }
 

mxchat-basic/trunk/admin/class-knowledge-manager.php

@@ -1853 +1853 @@
     $pinecone_options = get_option('mxchat_pinecone_addon_options', array());
     $pinecone_manager->mxchat_refresh_after_new_content($pinecone_options);
-        
+    $use_pinecone = ($pinecone_options['mxchat_use_pinecone'] ?? '0') === '1';
+
     if ($use_pinecone && !empty($pinecone_options['mxchat_pinecone_api_key'])) {
         // ONLY check Pinecone if it's enabled

mxchat-basic/trunk/admin/class-pinecone-manager.php

@@ -76 +76 @@
 
 /**
+     * Get embedding dimensions based on the selected model
+     * ADD THIS NEW FUNCTION
+     */
+    private function mxchat_get_embedding_dimensions() {
+        $options = get_option('mxchat_options', array());
+        $selected_model = $options['embedding_model'] ?? 'text-embedding-ada-002';
+        
+        // Define dimensions for different models
+        $model_dimensions = array(
+            'text-embedding-ada-002' => 1536,
+            'text-embedding-3-small' => 1536,
+            'text-embedding-3-large' => 3072,
+            'voyage-2' => 1024,
+            'voyage-large-2' => 1536,
+            'voyage-3-large' => 2048,
+            'gemini-embedding-001' => 1536,
+        );
+        
+        // Check if it's a voyage model with custom dimensions
+        if (strpos($selected_model, 'voyage-3-large') === 0) {
+            $custom_dimensions = $options['voyage_output_dimension'] ?? 2048;
+            return intval($custom_dimensions);
+        }
+        
+        // Check if it's a gemini model with custom dimensions
+        if (strpos($selected_model, 'gemini-embedding') === 0) {
+            $custom_dimensions = $options['gemini_output_dimension'] ?? 1536;
+            return intval($custom_dimensions);
+        }
+        
+        // Return known dimensions or default to 1536
+        return $model_dimensions[$selected_model] ?? 1536;
+    }
+
+    /**
+     * Generate random unit vector with correct dimensions
+     * ADD THIS NEW FUNCTION
+     */
+    private function mxchat_generate_random_vector() {
+        $dimensions = $this->mxchat_get_embedding_dimensions();
+        
+        $random_vector = array();
+        for ($i = 0; $i < $dimensions; $i++) {
+            $random_vector[] = (rand(-1000, 1000) / 1000.0);
+        }
+        
+        // Normalize the vector to unit length
+        $magnitude = sqrt(array_sum(array_map(function($x) { return $x * $x; }, $random_vector)));
+        if ($magnitude > 0) {
+            $random_vector = array_map(function($x) use ($magnitude) { return $x / $magnitude; }, $random_vector);
+        }
+        
+        return $random_vector;
+    }
+
+/**
  * Get 1,000 most recent entries from Pinecone (SIMPLE VERSION)
  */
@@ -98 +154 @@
             //error_log('DEBUG: Fetching batch ' . ($pass + 1) . '/5');
             
-            // Generate random vector for similarity search
-            $random_vector = array();
-            for ($i = 0; $i < 1536; $i++) {
-                $random_vector[] = (rand(-1000, 1000) / 1000.0);
-            }
-            
-            // Normalize vector
-            $magnitude = sqrt(array_sum(array_map(function($x) { return $x * $x; }, $random_vector)));
-            if ($magnitude > 0) {
-                $random_vector = array_map(function($x) use ($magnitude) { return $x / $magnitude; }, $random_vector);
-            }
+            // Generate random vector with CORRECT dimensions
+            $random_vector = $this->mxchat_generate_random_vector();
 
             $query_data = array(
@@ -175 +222 @@
     }
 }
+
+/**
+     * Scan Pinecone for processed content (MISSING FUNCTION - ADD THIS)
+     */
+    public function mxchat_scan_pinecone_for_processed_content($pinecone_options) {
+        //error_log('=== DEBUG: Starting mxchat_scan_pinecone_for_processed_content ===');
+        
+        $api_key = $pinecone_options['mxchat_pinecone_api_key'] ?? '';
+        $host = $pinecone_options['mxchat_pinecone_host'] ?? '';
+
+        if (empty($api_key) || empty($host)) {
+            //error_log('DEBUG: Missing API credentials for scanning');
+            return array();
+        }
+
+        try {
+            // Use multiple random vectors to get better coverage
+            $all_matches = array();
+            $seen_ids = array();
+
+            // Try 3 different random vectors to get better coverage
+            for ($i = 0; $i < 3; $i++) {
+                //error_log('DEBUG: Scanning attempt ' . ($i + 1) . '/3');
+                
+                $query_url = "https://{$host}/query";
+
+                // Generate random vector with CORRECT dimensions
+                $random_vector = $this->mxchat_generate_random_vector();
+
+                $query_data = array(
+                    'includeMetadata' => true,
+                    'includeValues' => false,
+                    'topK' => 10000,
+                    'vector' => $random_vector
+                );
+
+                $response = wp_remote_post($query_url, array(
+                    'headers' => array(
+                        'Api-Key' => $api_key,
+                        'Content-Type' => 'application/json'
+                    ),
+                    'body' => json_encode($query_data),
+                    'timeout' => 30
+                ));
+
+                if (is_wp_error($response)) {
+                    //error_log('DEBUG: Query attempt ' . ($i + 1) . ' WP error: ' . $response->get_error_message());
+                    continue;
+                }
+
+                $response_code = wp_remote_retrieve_response_code($response);
+                //error_log('DEBUG: Query attempt ' . ($i + 1) . ' response code: ' . $response_code);
+                
+                if ($response_code !== 200) {
+                    $error_body = wp_remote_retrieve_body($response);
+                    //error_log('DEBUG: Query attempt ' . ($i + 1) . ' failed with body: ' . substr($error_body, 0, 500));
+                    continue;
+                }
+
+                $body = wp_remote_retrieve_body($response);
+                $data = json_decode($body, true);
+
+                if (isset($data['matches'])) {
+                    //error_log('DEBUG: Query attempt ' . ($i + 1) . ' returned ' . count($data['matches']) . ' matches');
+                    foreach ($data['matches'] as $match) {
+                        $match_id = $match['id'] ?? '';
+                        if (!empty($match_id) && !isset($seen_ids[$match_id])) {
+                            $all_matches[] = $match;
+                            $seen_ids[$match_id] = true;
+                        }
+                    }
+                } else {
+                    //error_log('DEBUG: Query attempt ' . ($i + 1) . ' - no matches key in response');
+                }
+            }
+
+            //error_log('DEBUG: Total unique matches found: ' . count($all_matches));
+
+            // Convert matches to processed data format
+            $processed_data = array();
+            $vector_ids_for_cache = array();
+
+            foreach ($all_matches as $match) {
+                $metadata = $match['metadata'] ?? array();
+                $source_url = $metadata['source_url'] ?? '';
+                $match_id = $match['id'] ?? '';
+
+                if (!empty($source_url) && !empty($match_id)) {
+                    $post_id = url_to_postid($source_url);
+                    if ($post_id) {
+                        $created_at = $metadata['created_at'] ?? '';
+                        $processed_date = 'Recently';
+
+                        if (!empty($created_at)) {
+                            $timestamp = is_numeric($created_at) ? $created_at : strtotime($created_at);
+                            if ($timestamp) {
+                                $processed_date = human_time_diff($timestamp, current_time('timestamp')) . ' ago';
+                            }
+                        }
+
+                        $processed_data[$post_id] = array(
+                            'db_id' => $match_id,
+                            'processed_date' => $processed_date,
+                            'url' => $source_url,
+                            'source' => 'pinecone',
+                            'timestamp' => $timestamp ?? current_time('timestamp')
+                        );
+
+                        $vector_ids_for_cache[] = $match_id;
+                    }
+                }
+            }
+
+            // Update the vector IDs cache for future use
+            if (!empty($vector_ids_for_cache)) {
+                update_option('mxchat_pinecone_vector_ids_cache', $vector_ids_for_cache);
+                //error_log('DEBUG: Updated vector IDs cache with ' . count($vector_ids_for_cache) . ' IDs');
+            }
+
+            //error_log('DEBUG: Returning ' . count($processed_data) . ' processed items from scanning');
+            return $processed_data;
+
+        } catch (Exception $e) {
+            //error_log('DEBUG: Exception in scan_pinecone_for_processed_content: ' . $e->getMessage());
+            return array();
+        }
+    }
 
 /**

mxchat-basic/trunk/css/chat-style.css

@@ -317 +317 @@
     gap: 10px;
     padding: 8px;
-    border-top: 1px solid #e5e5e5;
     background: none;
     align-items: end;
@@ -604 +603 @@
     padding: 10px;
 }
-
+.user-message p {
+    margin: 0;
+}
 .mxchat-popular-questions-title {
     font-size: 14px;
@@ -619 +620 @@
     max-height: 200px;
     overflow-y: auto;
+    padding-top: 20px;
     padding-right: 10px;
     padding-bottom: 10px;
@@ -790 +792 @@
   clear: both;
   border-radius: 18px 0 18px 18px;
-  border: 1px solid #e2e8ff;
-    word-wrap: break-word;
+  word-wrap: break-word;
+  border: 1px solid rgba(226, 232, 255, .2);
 }
 
@@ -840 +842 @@
     padding: 0.4em 0.5em;
     outline: none;
+    border-radius: 10px;
 }
 

mxchat-basic/trunk/includes/class-mxchat-addons.php

@@ -153 +153 @@
      */
     public function enqueue_styles() {
-        $plugin_version = '2.2.4';
+        $plugin_version = '2.2.5';
 
         wp_enqueue_style(

mxchat-basic/trunk/includes/class-mxchat-admin.php

@@ -64 +64 @@
         'voyage_api_key' => '',
         'gemini_api_key' => '',
+        'enable_streaming_toggle' => 'on',
         'embedding_model' => 'text-embedding-ada-002',
         'system_prompt_instructions' => 'You are an AI Chatbot assistant for this website. Your main goal is to assist visitors with questions and provide helpful information. Here are your key guidelines:
@@ -326 +327 @@
                     <div class="mxchat-pro-content">
                         <h3>🚀 Limited Lifetime Offer: Save 30% on MxChat Pro, Agency, or Agency Plus!</h3>
-                    <p>Unlock <strong>unlimited access</strong> to our growing collection of powerful add-ons including Admin AI Assistant (ChatGPT-like experience in your admin panel), Forms Builder, Theme Customizer, WooCommerce, Perplexity, and more – all included with your <strong>lifetime license!</strong></p>                    </div>
+                    <p>Unlock <strong>unlimited access</strong> to our growing collection of powerful add-ons including Admin AI Assistant (ChatGPT-like experience in your admin panel), Forms Builder, AI Theme Generator, WooCommerce, Perplexity, and more – all included with your <strong>lifetime license!</strong></p>                    </div>
                     <div class="mxchat-pro-cta">
                         <a href="https://mxchat.ai/" target="_blank" class="mxchat-button"><?php echo esc_html__('Upgrade Today', 'mxchat'); ?></a>
@@ -425 +426 @@
 
     <div class="tutorial-grid">
+        
+        <div class="tutorial-item">
+    <h3><?php echo esc_html__('AI Theme Generator Tutorial', 'mxchat'); ?></h3>
+    <div class="video-description">
+        <p><?php echo esc_html__('Learn how to instantly restyle your chatbot using plain English prompts. The AI Theme Generator lets you generate and apply beautiful designs with real-time previews—no CSS skills needed.', 'mxchat'); ?></p>
+        <a href="https://www.youtube.com/watch?v=rSQDW2qbtRU&t" target="_blank" rel="noopener" class="video-link">
+            <span class="video-icon"><svg xmlns="http://www.w3.org/2000/svg" width="24" height="24" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><path d="M12 19c-2.3 0-6.4-.2-8.1-.6-.7-.2-1.2-.7-1.4-1.4-.3-1.1-.5-3.4-.5-5s.2-3.9.5-5c.2-.7.7-1.2 1.4-1.4C5.6 5.2 9.7 5 12 5s6.4.2 8.1.6c.7.2 1.2.7 1.4 1.4.3 1.1.5 3.4.5 5s-.2 3.9-.5 5c-.2.7-.7 1.2-1.4 1.4-1.7.4-5.8.6-8.1.6z"></path><polygon points="10 15 15 12 10 9 10 15"></polygon></svg></span>
+            <?php echo esc_html__('Watch AI Theme Generator Tutorial', 'mxchat'); ?>
+        </a>
+    </div>
+</div>
+
+        
         <div class="tutorial-item">
             <h3><?php echo esc_html__('MxChat Forms Tutorial', 'mxchat'); ?></h3>
@@ -1141 +1155 @@
 
 public function mxchat_create_prompts_page() {
-    error_log('=== DEBUG: mxchat_create_prompts_page started ===');
+    //error_log('=== DEBUG: mxchat_create_prompts_page started ===');
     
     global $wpdb;
@@ -1160 +1174 @@
     $per_page = 10;
 
-    error_log('DEBUG: Search query: ' . $search_query);
-    error_log('DEBUG: Current page: ' . $current_page);
-    error_log('DEBUG: Per page: ' . $per_page);
+    //error_log('DEBUG: Search query: ' . $search_query);
+    //error_log('DEBUG: Current page: ' . $current_page);
+    //error_log('DEBUG: Per page: ' . $per_page);
 
     // ================================
@@ -1170 +1184 @@
     // Get Pinecone settings to determine data source
     $pinecone_options = get_option('mxchat_pinecone_addon_options', array());
-    error_log('DEBUG: Pinecone options retrieved: ' . print_r($pinecone_options, true));
+    //error_log('DEBUG: Pinecone options retrieved: ' . print_r($pinecone_options, true));
     
     $use_pinecone = ($pinecone_options['mxchat_use_pinecone'] ?? '0') === '1';
-    error_log('DEBUG: use_pinecone decision: ' . ($use_pinecone ? 'TRUE' : 'FALSE'));
+    //error_log('DEBUG: use_pinecone decision: ' . ($use_pinecone ? 'TRUE' : 'FALSE'));
     
     $pinecone_api_key = $pinecone_options['mxchat_pinecone_api_key'] ?? '';
-    error_log('DEBUG: Pinecone API key present: ' . (!empty($pinecone_api_key) ? 'YES' : 'NO'));
+    //error_log('DEBUG: Pinecone API key present: ' . (!empty($pinecone_api_key) ? 'YES' : 'NO'));
 
    if ($use_pinecone && !empty($pinecone_options['mxchat_pinecone_api_key'])) {
-    error_log('DEBUG: Using PINECONE data source');
+    //error_log('DEBUG: Using PINECONE data source');
     // PINECONE DATA SOURCE
     $data_source = 'pinecone';
     $pinecone_manager = MxChat_Pinecone_Manager::get_instance();
-    error_log('DEBUG: About to call mxchat_fetch_pinecone_records');
+    //error_log('DEBUG: About to call mxchat_fetch_pinecone_records');
     
     $records = $pinecone_manager->mxchat_fetch_pinecone_records($pinecone_options, $search_query, $current_page, $per_page);
@@ -1193 +1207 @@
     $total_pages = ceil($total_records / $per_page);
     
-    error_log('DEBUG: Pinecone - total_records: ' . $total_records);
-    error_log('DEBUG: Pinecone - prompts count: ' . count($prompts));
-    error_log('DEBUG: Pinecone - total_pages: ' . $total_pages);
-    error_log('DEBUG: Pinecone - showing_recent_only: ' . ($showing_recent_only ? 'TRUE' : 'FALSE'));
-    error_log('DEBUG: Pinecone - total_in_database: ' . $total_in_database);
+    //error_log('DEBUG: Pinecone - total_records: ' . $total_records);
+    //error_log('DEBUG: Pinecone - prompts count: ' . count($prompts));
+    //error_log('DEBUG: Pinecone - total_pages: ' . $total_pages);
+    //error_log('DEBUG: Pinecone - showing_recent_only: ' . ($showing_recent_only ? 'TRUE' : 'FALSE'));
+    //error_log('DEBUG: Pinecone - total_in_database: ' . $total_in_database);
 } else {
-    error_log('DEBUG: Using WORDPRESS DB data source');
+    //error_log('DEBUG: Using WORDPRESS DB data source');
     // WORDPRESS DB DATA SOURCE (your existing logic)
     $data_source = 'wordpress';
@@ -1217 +1231 @@
     // Retrieve total number of prompts, considering search filter
     $count_query = "SELECT COUNT(*) FROM {$table_name} {$sql_search}";
-    error_log('DEBUG: WordPress count query: ' . $count_query);
+    //error_log('DEBUG: WordPress count query: ' . $count_query);
     
     $total_records = $wpdb->get_var($count_query);
-    error_log('DEBUG: WordPress total_records: ' . $total_records);
+    //error_log('DEBUG: WordPress total_records: ' . $total_records);
     
     $total_pages = ceil($total_records / $per_page);
@@ -1230 +1244 @@
         $offset
     );
-    error_log('DEBUG: WordPress prompts query: ' . $prompts_query);
+    //error_log('DEBUG: WordPress prompts query: ' . $prompts_query);
     
     $prompts = $wpdb->get_results($prompts_query);
-    error_log('DEBUG: WordPress prompts count: ' . count($prompts));
-}
-
-error_log('DEBUG: Final data_source: ' . $data_source);
-error_log('DEBUG: Final total_records: ' . $total_records);
-error_log('DEBUG: Final prompts count: ' . count($prompts));
-error_log('DEBUG: Final showing_recent_only: ' . ($showing_recent_only ? 'TRUE' : 'FALSE'));
-error_log('DEBUG: Final total_in_database: ' . $total_in_database);
+    //error_log('DEBUG: WordPress prompts count: ' . count($prompts));
+}
+
+//error_log('DEBUG: Final data_source: ' . $data_source);
+//error_log('DEBUG: Final total_records: ' . $total_records);
+//error_log('DEBUG: Final prompts count: ' . count($prompts));
+//error_log('DEBUG: Final showing_recent_only: ' . ($showing_recent_only ? 'TRUE' : 'FALSE'));
+//error_log('DEBUG: Final total_in_database: ' . $total_in_database);
 
     // Add the pagination links generation here
@@ -1273 +1287 @@
                    || ($sitemap_status && ($sitemap_status['status'] === 'processing' || $sitemap_status['status'] === 'error'));
 
-    error_log('=== DEBUG: mxchat_create_prompts_page data preparation completed ===');
+    //error_log('=== DEBUG: mxchat_create_prompts_page data preparation completed ===');
     
     ?>
@@ -1369 +1383 @@
            </button>
 
-           <!-- PDF Import Option -->
-           <button type="button" class="mxchat-import-box" data-option="pdf" data-placeholder="<?php esc_attr_e('Enter PDF URL here', 'mxchat'); ?>" data-type="pdf">
-               <div class="mxchat-import-icon">
-                   <span class="dashicons dashicons-media-document"></span>
-               </div>
-               <div class="mxchat-import-content">
-                   <h4><?php esc_html_e('PDF Import', 'mxchat'); ?></h4>
-                   <p><?php esc_html_e('Import knowledge from PDF documents.', 'mxchat'); ?></p>
-               </div>
-           </button>
-
            <!-- Sitemap Import Option -->
            <button type="button" class="mxchat-import-box" data-option="sitemap" data-placeholder="<?php esc_attr_e('Enter sitemap URL here', 'mxchat'); ?>" data-type="sitemap">
@@ -1410 +1413 @@
                    <h4><?php esc_html_e('Direct Content', 'mxchat'); ?></h4>
                    <p><?php esc_html_e('Submit content to be vectorized.', 'mxchat'); ?></p>
+               </div>
+           </button>
+           
+                      <!-- PDF Import Option -->
+           <button type="button" class="mxchat-import-box" data-option="pdf" data-placeholder="<?php esc_attr_e('Enter PDF URL here', 'mxchat'); ?>" data-type="pdf">
+               <div class="mxchat-import-icon">
+                   <span class="dashicons dashicons-media-document"></span>
+               </div>
+               <div class="mxchat-import-content">
+                   <h4><?php esc_html_e('PDF Import', 'mxchat'); ?></h4>
+                   <p><?php esc_html_e('Import knowledge from PDF documents.', 'mxchat'); ?></p>
                </div>
            </button>
@@ -1694 +1708 @@
         <div class="mxchat-info-banner pinecone" style="display: flex; align-items: center; gap: 8px; padding: 12px 16px; margin-bottom: 20px; border-radius: 6px; font-size: 14px; background: #e8f5e8; border-left: 4px solid #4caf50; color: #2e7d2e;">
             <span class="dashicons dashicons-cloud"></span>
-            <span><?php esc_html_e('Data is stored in Pinecone vector database for enhanced AI performance. Refresh page after adding content to database.', 'mxchat'); ?></span>
-        </div>
+            <span><?php esc_html_e('Refresh page to see new content, but wait 5-10 seconds first! Refreshing too early means content won\'t show and you\'ll need to refresh again.', 'mxchat'); ?></span>
+            </div>
     <?php else : ?>
         <div class="mxchat-info-banner wordpress" style="display: flex; align-items: center; gap: 8px; padding: 12px 16px; margin-bottom: 20px; border-radius: 6px; font-size: 14px; background: #fff3e0; border-left: 4px solid #ff9800; color: #e65100;">
             <span class="dashicons dashicons-database-view"></span>
-            <span><?php esc_html_e('Data is stored in WordPress database. Refresh page after adding content to database.', 'mxchat'); ?></span>
+            <span><?php esc_html_e('Refresh page to see new content, but wait 5-10 seconds first! Refreshing too early means content won\'t show and you\'ll need to refresh again.', 'mxchat'); ?></span>
         </div>
     <?php endif; ?>
@@ -3329 +3343 @@
             )
         );
+        
+    add_settings_field(
+        'enable_streaming_toggle',
+        esc_html__('Enable Streaming', 'mxchat'),
+        array($this, 'enable_streaming_toggle_callback'),
+        'mxchat-chatbot',
+        'mxchat_chatbot_section', // Same section as your working toggle
+        array(
+            'class' => 'mxchat-setting-row streaming-setting',
+            'style' => 'display: none;' // Hidden by default, shown when OpenAI/Claude selected
+        )
+    );
+
 
     add_settings_field(
@@ -3337 +3364 @@
         'mxchat_chatbot_section'
     );
-
-    // Add the settings field
+    
     add_settings_field(
         'embedding_model',
@@ -4316 +4342 @@
 }
 
+public function enable_streaming_toggle_callback() {
+    // Get value from options array, default to 'on'
+    $enabled = isset($this->options['enable_streaming_toggle']) ? $this->options['enable_streaming_toggle'] : 'on';
+    $checked = ($enabled === 'on') ? 'checked' : '';
+    
+    echo '<label class="toggle-switch">';
+    echo sprintf(
+        '<input type="checkbox" id="enable_streaming_toggle" name="enable_streaming_toggle" value="on" %s />',
+        esc_attr($checked)
+    );
+    echo '<span class="slider"></span>'; // Remove 'round' class to match working toggle
+    echo '</label>';
+    echo '<p class="description">' . 
+        esc_html__('Enable real-time streaming responses for supported models (OpenAI and Claude). When disabled, responses will load all at once.', 'mxchat') . 
+    '</p>';
+}
 // Callback function for embedding model selection
 public function embedding_model_callback() {
@@ -5447 +5489 @@
 public function mxchat_enqueue_admin_assets() {
     // Get plugin version (define this in your main plugin file)
-    $version = defined('MXCHAT_VERSION') ? MXCHAT_VERSION : '2.2.4';
+    $version = defined('MXCHAT_VERSION') ? MXCHAT_VERSION : '2.2.5';
     
     // Use file modification time for development (remove in production)
@@ -5633 +5675 @@
         $new_input['claude_api_key'] = sanitize_text_field($input['claude_api_key']);
     }
+    
+    if (isset($input['enable_streaming_toggle'])) {
+        $new_input['enable_streaming_toggle'] = ($input['enable_streaming_toggle'] === 'on') ? 'on' : 'off';
+    } else {
+        // If checkbox not checked, it won't be in $input, so set to 'off'
+        $new_input['enable_streaming_toggle'] = 'off';
+    }
+    
 
     if (isset($input['deepseek_api_key'])) {

mxchat-basic/trunk/includes/class-mxchat-integrator.php

@@ -88 +88 @@
     add_action('wp_ajax_nopriv_mxchat_check_email_provided', [$this, 'mxchat_check_email_provided']);
     add_action('wp_ajax_mxchat_check_email_provided', [$this, 'mxchat_check_email_provided']);
+    
+    add_action('wp_ajax_mxchat_stream_chat', array($this, 'mxchat_handle_chat_request'));
+    add_action('wp_ajax_nopriv_mxchat_stream_chat', array($this, 'mxchat_handle_chat_request'));
 }
 
@@ -122 +125 @@
     wp_die();
 }
-private function mxchat_fetch_conversation_history_for_ajax($session_id) {
-    $history = get_option("mxchat_history_{$session_id}", []); // Retrieve stored history based on session ID
-    $formatted_history = [];
-
-    // Format the history to align with the expected structure for OpenAI
-    foreach ($history as $entry) {
-        $formatted_history[] = [
-            'role' => $entry['role'],  // Ensure this matches 'user' or 'assistant'
-            'content' => $entry['content']
-        ];
-    }
-
-    return $formatted_history;
-}
-
 
 private function mxchat_fetch_conversation_history_for_ai($session_id) {
@@ -553 +541 @@
 }
 
-// Add this to your plugin's main PHP file
-public function mxchat_check_new_messages() {
-    if (!isset($_POST['session_id']) || !isset($_POST['last_seen_id'])) {
-        wp_send_json_error(['message' => 'Missing required parameters']);
-        wp_die();
-    }
-
-    $session_id = sanitize_text_field($_POST['session_id']);
-    $last_seen_id = sanitize_text_field($_POST['last_seen_id']);
-
-    // Get chat history
-    $history = get_option("mxchat_history_{$session_id}", []);
-
-    if (empty($history)) {
-        wp_send_json_success([
-            'hasNewMessages' => false,
-            'new_messages' => []
-        ]);
-        wp_die();
-    }
-
-    // Filter new messages
-    $new_messages = array_filter($history, function($message) use ($last_seen_id) {
-        return isset($message['id']) && $message['id'] > $last_seen_id;
-    });
-
-    // Sort by ID to ensure proper order
-    usort($new_messages, function($a, $b) {
-        return $a['id'] <=> $b['id'];
-    });
-
-    wp_send_json_success([
-        'hasNewMessages' => !empty($new_messages),
-        'new_messages' => array_values($new_messages),
-        'latestMessageId' => end($new_messages)['id'] ?? $last_seen_id
-    ]);
-    wp_die();
-}
-
 public function mxchat_handle_chat_request() {
     global $wpdb;
+
+    // NEW: Check if this is a streaming request
+    $is_streaming = isset($_POST['action']) && $_POST['action'] === 'mxchat_stream_chat';
+    
+    // NEW: Set streaming headers if needed
+    if ($is_streaming) {
+        // Disable output buffering
+        while (ob_get_level()) {
+            ob_end_clean();
+        }
+        
+        // Set headers for SSE
+        header('Content-Type: text/event-stream');
+        header('Cache-Control: no-cache');
+        header('Connection: keep-alive');
+        header('X-Accel-Buffering: no');
+    }
 
 
@@ -723 +689 @@
     }
     
-    // Return the response
+    // ALWAYS send as regular JSON response for add-on results
+    // This ensures image galleries, product cards, etc. display properly
     wp_send_json([
         'text' => $pre_processed_result['text'],
@@ -739 +706 @@
         // Add the email to Loops
         $this->add_email_to_loops($message);
-
+    
         // Send success response
         $response_message = $this->options['email_capture_response'] ??
                            esc_html__('Thank you! Your coupon is on the way!', 'mxchat');
-
+    
+        // Clear streaming headers if they were set
+        if ($is_streaming) {
+            header_remove('Content-Type');
+            header_remove('Cache-Control');
+            header_remove('Connection');
+            header_remove('X-Accel-Buffering');
+            header('Content-Type: application/json');
+        }
+    
         wp_send_json([
             'success' => true,
@@ -927 +903 @@
 // Step 3: Handle the intent result appropriately
 if ($intent_result !== false) {
-    // The intent was matched and handled
-    //error_log("Intent was matched and handled.");
+    // Intent was matched - ALWAYS send as JSON response, never streaming
+    // This ensures image galleries, product cards, and other intent responses work properly
     
     if (is_array($intent_result) && (isset($intent_result['text']) || isset($intent_result['html']))) {
         // Intent returned a direct response array
-        //error_log("Intent returned a direct response.");
         $response_data = [
             'text' => $intent_result['text'] ?? '',
@@ -939 +914 @@
         ];
         
+        // Clear streaming headers if they were set
+        if ($is_streaming) {
+            header_remove('Content-Type');
+            header_remove('Cache-Control');
+            header_remove('Connection');
+            header_remove('X-Accel-Buffering');
+            header('Content-Type: application/json');
+        }
+        
         wp_send_json($response_data);
         wp_die();
@@ -944 +928 @@
     else if ($intent_result === true && (!empty($this->fallbackResponse['text']) || !empty($this->fallbackResponse['html']))) {
         // Intent returned true and set fallbackResponse
-        //error_log("Intent returned true with fallbackResponse set.");
         $response_data = [
             'text' => $this->fallbackResponse['text'] ?? '',
@@ -951 +934 @@
         ];
         
+        // Clear streaming headers if they were set
+        if ($is_streaming) {
+            header_remove('Content-Type');
+            header_remove('Cache-Control');
+            header_remove('Connection');
+            header_remove('X-Accel-Buffering');
+            header('Content-Type: application/json');
+        }
+        
         wp_send_json($response_data);
         wp_die();
     }
-    
-    // Intent was matched but no usable response was provided
-    // This shouldn't happen with proper intent implementation
-    //error_log("Warning: Intent matched but no response provided.");
 }
 
@@ -1039 +1027 @@
         $context_content = apply_filters('mxchat_prepare_context', $context_content, $session_id);
 
-        // Generate the response using the full context
         $response = $this->mxchat_generate_response(
             $context_content,
@@ -1047 +1034 @@
             $this->options['deepseek_api_key'],
             $this->options['gemini_api_key'],
-            $conversation_history
+            $conversation_history,
+            $is_streaming,
+            $session_id 
         );
+        
+        // Handle streaming vs non-streaming responses
+        if ($is_streaming) {
+            // For streaming, the response is already sent and saved by the streaming functions
+            wp_die();
+        }
         
         // Check if the response is an error array
@@ -1487 +1482 @@
     }
 }
-/**
- * Format search results into a natural text summary.
- *
- * @since 1.0.0
- * @param array  $results The search results from the API.
- * @param string $query   The original search query.
- * @return string The text summary of the top results.
- */
-private function format_search_results( $results, $query ) {
-    $summary = sprintf(
-        esc_html__( 'Here are the most relevant results for "%s":', 'mxchat' ),
-        esc_html( $query )
-    ) . "\n\n";
-
-    $max_results = min( count( $results ), 3 );
-    for ( $i = 0; $i < $max_results; $i++ ) {
-        $result      = $results[ $i ];
-        $title       = isset( $result['title'] ) ? wp_strip_all_tags( $result['title'] ) : '';
-        $description = isset( $result['description'] ) ? wp_strip_all_tags( $result['description'] ) : '';
-
-        // Append title and description to the summary
-        $summary .= sprintf(
-            "%s\n%s\n\n",
-            esc_html( $title ),
-            esc_html( $description )
-        );
-    }
-
-    return $summary;
-}
-
-/**
- * Generate HTML markup for search results.
- *
- * @since 1.0.0
- * @param array  $results The search results from the API.
- * @param string $query   The user-refined query.
- * @return string The HTML markup for displaying the results.
- */
-private function generate_search_results_html( $results, $query ) {
-    ob_start();
-    ?>
-    <div class="mxchat-search-results">
-        <?php foreach ( $results as $result ) :
-            $title       = isset( $result['title'] ) ? wp_strip_all_tags( $result['title'] ) : '';
-            $url         = isset( $result['url'] ) ? esc_url( $result['url'] ) : '#';
-            $description = isset( $result['description'] ) ? wp_strip_all_tags( $result['description'] ) : '';
-            $favicon     = isset( $result['meta_url']['favicon'] ) ? esc_url( $result['meta_url']['favicon'] ) : '';
-            $thumbnail   = isset( $result['thumbnail']['src'] ) ? esc_url( $result['thumbnail']['src'] ) : '';
-            $domain      = parse_url( $url, PHP_URL_HOST );
-            ?>
-            <div class="mxchat-search-item">
-                <div class="mxchat-search-header">
-                    <?php if ( $favicon ) : ?>
-                        <img
-                            src="<?php echo esc_url( $favicon ); ?>"
-                            class="mxchat-site-icon"
-                            alt="<?php echo esc_attr__( 'Site icon', 'mxchat' ); ?>"
-                            width="16"
-                            height="16"
-                        />
-                    <?php endif; ?>
-                    <div class="mxchat-site-url"><?php echo esc_html( $domain ); ?></div>
-                </div>
-
-                <div class="mxchat-search-content">
-                    <h3 class="mxchat-search-title">
-                        <a href="<?php echo esc_url( $url ); ?>"
-                           target="_blank"
-                           rel="noopener noreferrer"
-                        >
-                            <?php echo esc_html( $title ); ?>
-                        </a>
-                    </h3>
-
-                    <?php if ( $thumbnail ) : ?>
-                        <div class="mxchat-search-thumbnail">
-                            <img
-                                src="<?php echo esc_url( $thumbnail ); ?>"
-                                alt="<?php echo esc_attr__( 'Thumbnail image', 'mxchat' ); ?>"
-                                loading="lazy"
-                            />
-                        </div>
-                    <?php endif; ?>
-
-                    <div class="mxchat-search-description">
-                        <?php echo esc_html( $description ); ?>
-                    </div>
-                </div>
-            </div>
-        <?php endforeach; ?>
-    </div>
-    <?php
-    return ob_get_clean();
-}
-
 
 //very good
@@ -1954 +1853 @@
     return sanitize_text_field($user_query);
 }
-
-
-
-private function find_product_in_message($message) {
-    global $wpdb;
-
-    // Get embedding for the search query
-    $query_embedding = $this->mxchat_generate_embedding($message, $this->options['api_key']);
-    
-    // Check if embedding generation returned an error
-    if (is_array($query_embedding) && isset($query_embedding['error'])) {
-        $error_message = $query_embedding['error'];
-        $error_code = $query_embedding['error_code'] ?? 'embedding_error';
-        
-        //error_log("Product search embedding error: $error_message (Code: $error_code)");
-        
-        // Set a user-friendly fallback response
-        $this->fallbackResponse['text'] = esc_html__("I'm having trouble processing your product search. Please try again later or contact support if this persists.", 'mxchat');
-        
-        // Also store the technical error for admin users
-        $this->fallbackResponse['admin_error'] = $error_message;
-        $this->fallbackResponse['error_code'] = $error_code;
-        
-        return null;
-    }
-    
-    // Check if embedding is valid
-    if (!is_array($query_embedding) || empty($query_embedding)) {
-        //error_log("Failed to generate embedding for product search");
-        $this->fallbackResponse['text'] = esc_html__("I couldn't process your product search. Please try again with different wording.", 'mxchat');
-        return null;
-    }
-    
-    // Get relevant content as string
-    $relevant_content = $this->mxchat_find_relevant_products($query_embedding);
-    if (empty($relevant_content)) {
-        // Return null to indicate no results and set fallback response
-        $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');
-        return null;
-    }
-
-
-    // Extract product URLs from the content
-    preg_match_all('/https?:\/\/[^\s<>"\']+?\/product\/[^\s<>"\']+/', $relevant_content, $matches);
-
-    if (!empty($matches[0])) {
-        // Try each URL found
-        foreach ($matches[0] as $url) {
-            // Clean the URL
-            $url = rtrim($url, '/."\']');
-
-            // Get the product slug
-            $path = parse_url($url, PHP_URL_PATH);
-            $slug = basename(rtrim($path, '/'));
-
-            // Find product by slug
-            $args = array(
-                'post_type' => 'product',
-                'post_status' => 'publish',
-                'name' => $slug,
-                'posts_per_page' => 1
-            );
-
-            $products = get_posts($args);
-
-            if (!empty($products)) {
-                $product_id = $products[0]->ID;
-                $product = wc_get_product($product_id);
-
-                if ($product && $product->is_purchasable()) {
-                    return $product_id;
-                }
-            }
-        }
-    }
-
-    // Fallback: Look for product names in the content
-    $products = wc_get_products([
-        'status' => 'publish',
-        'limit' => -1,
-        'return' => 'all'
-    ]);
-
-    foreach ($products as $product) {
-        $name = $product->get_name();
-        if (stripos($relevant_content, $name) !== false) {
-            if ($product->is_purchasable()) {
-                return $product->get_id();
-            }
-        }
-    }
-
-    // If no product is found after all checks, set the fallback response
-    $this->fallbackResponse['text'] = esc_html__("I couldn't find any relevant products based on your query. Try to be more specific", 'mxchat');
-    return null;
-}
-
-// New method to handle intent responses
-private function generate_intent_response($context_content, $session_id) {
-    // Convert the context array to a structured string for the AI
-    $context_string = $this->format_intent_context($context_content);
-    // Generate AI response using the context
-    $response = $this->mxchat_generate_response(
-        $context_string,
-        $this->options['api_key'],
-        $this->options['xai_api_key'],
-        $this->options['claude_api_key'],
-        $this->options['deepseek_api_key'],
-        $this->options['gemini_api_key'], // Added Gemini API key
-        $this->mxchat_fetch_conversation_history_for_ai($session_id)
-    );
-    $this->fallbackResponse['text'] = $response;
-    return true;
-}
-
-// Helper method to format intent context
-private function format_intent_context($context) {
-    $context_string = esc_html__("INTENT CONTEXT:\n", 'mxchat');
-
-    switch ($context['intent']) {
-        case 'add_to_cart':
-            if ($context['status'] === 'success') {
-                $context_string .= esc_html__("Action: Successfully added product to cart\n", 'mxchat');
-                $context_string .= sprintf(esc_html__("Product: %s\n", 'mxchat'), $context['product']['name']);
-                $context_string .= esc_html__("Available actions: ", 'mxchat') . implode(', ', $context['available_actions']) . "\n";
-                $context_string .= sprintf(esc_html__("Cart URL: %s\n", 'mxchat'), $context['cart_url']);
-                $context_string .= esc_html__("\nPlease inform the user of the successful addition and their available options.", 'mxchat');
-            } else {
-                $context_string .= esc_html__("Action: Failed to add product to cart\n", 'mxchat');
-                $context_string .= sprintf(esc_html__("Reason: %s\n", 'mxchat'), $context['reason']);
-                switch ($context['reason']) {
-                    case 'woocommerce_not_available':
-                        $context_string .= esc_html__("\nPlease inform the user that shopping features are not available.", 'mxchat');
-                        break;
-                    case 'no_product_context':
-                        $context_string .= esc_html__("\nPlease ask the user to specify which product they want to add.", 'mxchat');
-                        break;
-                    case 'product_not_found':
-                        $context_string .= esc_html__("\nPlease inform the user that the product couldn't be found and ask them to try again.", 'mxchat');
-                        break;
-                    case 'add_to_cart_failed':
-                        $context_string .= esc_html__("\nPlease apologize to the user and suggest they try again or ask for assistance.", 'mxchat');
-                        break;
-                }
-            }
-            break;
-    }
-
-    return $context_string;
-}
-
 
 //very good
@@ -2791 +2539 @@
     if (isset($data['type']) && $data['type'] === 'url_verification') {
         //error_log('Slack URL verification challenge: ' . $data['challenge']);
-        // Return just the challenge string, not wrapped in an array
         return new WP_REST_Response($data['challenge'], 200, ['Content-Type' => 'text/plain']);
+    }
+    
+    // IMPORTANT: Handle Slack's event deduplication
+    if (isset($data['event_id'])) {
+        $event_id = $data['event_id'];
+        $processed_events = get_transient('mxchat_slack_events') ?: [];
+        
+        // Check if we've already processed this event
+        if (in_array($event_id, $processed_events)) {
+            //error_log("Duplicate event detected: $event_id");
+            return new WP_REST_Response(['ok' => true]);
+        }
+        
+        // Add this event to processed list
+        $processed_events[] = $event_id;
+        // Keep only last 100 events to prevent memory issues
+        if (count($processed_events) > 100) {
+            $processed_events = array_slice($processed_events, -100);
+        }
+        // Store for 1 hour
+        set_transient('mxchat_slack_events', $processed_events, HOUR_IN_SECONDS);
     }
     
@@ -2799 +2567 @@
         $event = $data['event'];
         
-        // Skip bot messages and messages with subtypes
+        // Skip bot messages and messages with subtypes (like bot_message)
         if (isset($event['bot_id']) || isset($event['subtype'])) {
             return new WP_REST_Response(['ok' => true]);
         }
         
+        // Additional check: Skip if this is a threaded reply to our confirmation
+        if (isset($event['thread_ts']) && $event['thread_ts'] !== $event['ts']) {
+            return new WP_REST_Response(['ok' => true]);
+        }
+        
         $channel_id = $event['channel'];
         $message_text = $event['text'] ?? '';
+        $message_ts = $event['ts'] ?? '';
         
         // Find session ID by looking for matching channel
@@ -2821 +2595 @@
             $session_id = str_replace('mxchat_channel_', '', $session_option);
             
+            // Create a unique key for this specific message
+            $message_key = md5($session_id . $message_ts . $message_text);
+            $processed_messages = get_transient('mxchat_processed_messages_' . $session_id) ?: [];
+            
+            // Check if we've already processed this exact message
+            if (in_array($message_key, $processed_messages)) {
+                //error_log("Duplicate message detected for session $session_id");
+                return new WP_REST_Response(['ok' => true]);
+            }
+            
+            // Add to processed messages
+            $processed_messages[] = $message_key;
+            // Keep only last 50 messages per session
+            if (count($processed_messages) > 50) {
+                $processed_messages = array_slice($processed_messages, -50);
+            }
+            set_transient('mxchat_processed_messages_' . $session_id, $processed_messages, HOUR_IN_SECONDS);
+            
             // Save the agent message
             $this->mxchat_save_chat_message($session_id, 'agent', $message_text);
             
-            // Send confirmation back to Slack
+            // Send confirmation back to Slack (only once)
             $slack_bot_token = $this->options['live_agent_bot_token'] ?? '';
             if (!empty($slack_bot_token)) {
-                wp_remote_post('https://slack.com/api/chat.postMessage', [
-                    'headers' => [
-                        'Content-Type' => 'application/json',
-                        'Authorization' => 'Bearer ' . $slack_bot_token
-                    ],
-                    'body' => json_encode([
-                        'channel' => $channel_id,
-                        'text' => "✅ _Message sent to user_",
-                        'thread_ts' => $event['ts'] // Reply in thread
-                    ])
-                ]);
+                // Use a transient to prevent duplicate confirmations
+                $confirm_key = 'mxchat_confirm_' . $message_key;
+                if (!get_transient($confirm_key)) {
+                    wp_remote_post('https://slack.com/api/chat.postMessage', [
+                        'headers' => [
+                            'Content-Type' => 'application/json',
+                            'Authorization' => 'Bearer ' . $slack_bot_token
+                        ],
+                        'body' => json_encode([
+                            'channel' => $channel_id,
+                            'text' => "✅ _Message sent to user_",
+                            'thread_ts' => $event['ts'] // Reply in thread
+                        ])
+                    ]);
+                    // Set transient to prevent duplicate confirmations
+                    set_transient($confirm_key, true, 300); // 5 minutes
+                }
             }
         }
@@ -2844 +2642 @@
     return new WP_REST_Response(['ok' => true]);
 }
-
 
 // For the word upload handler
@@ -3521 +3318 @@
 }
 
-private function mxchat_generate_response($relevant_content, $api_key, $xai_api_key, $claude_api_key, $deepseek_api_key, $gemini_api_key, $conversation_history) {
+private function mxchat_generate_response($relevant_content, $api_key, $xai_api_key, $claude_api_key, $deepseek_api_key, $gemini_api_key, $conversation_history, $streaming = false, $session_id = '') {
     try {
         if (!$relevant_content) {
@@ -3566 +3363 @@
                     ];
                 }
-                $response = $this->mxchat_generate_response_claude(
-                    $selected_model,
-                    $claude_api_key,
-                    $conversation_history,
-                    $relevant_content
-                );
+                if ($streaming) {
+                    return $this->mxchat_generate_response_claude_stream(
+                        $selected_model,
+                        $claude_api_key,
+                        $conversation_history,
+                        $relevant_content,
+                        $session_id
+                    );
+                } else {
+                    $response = $this->mxchat_generate_response_claude(
+                        $selected_model,
+                        $claude_api_key,
+                        $conversation_history,
+                        $relevant_content
+                    );
+                }
                 break;
                 
@@ -3605 +3412 @@
                 
             case 'gpt':
+            case 'o1':
                 if (empty($api_key)) {
                     return [
@@ -3611 +3419 @@
                     ];
                 }
-                $response = $this->mxchat_generate_response_openai(
-                    $selected_model,
-                    $api_key,
-                    $conversation_history,
-                    $relevant_content
-                );
+                if ($streaming) {
+                    return $this->mxchat_generate_response_openai_stream(
+                        $selected_model,
+                        $api_key,
+                        $conversation_history,
+                        $relevant_content,
+                        $session_id
+                    );
+                } else {
+                    $response = $this->mxchat_generate_response_openai(
+                        $selected_model,
+                        $api_key,
+                        $conversation_history,
+                        $relevant_content
+                    );
+                }
                 break;
                 
@@ -3627 +3445 @@
                     ];
                 }
-                $response = $this->mxchat_generate_response_openai(
-                    $selected_model,
-                    $api_key,
-                    $conversation_history,
-                    $relevant_content
-                );
+                if ($streaming) {
+                    return $this->mxchat_generate_response_openai_stream(
+                        $selected_model,
+                        $api_key,
+                        $conversation_history,
+                        $relevant_content,
+                        $session_id
+                    );
+                } else {
+                    $response = $this->mxchat_generate_response_openai(
+                        $selected_model,
+                        $api_key,
+                        $conversation_history,
+                        $relevant_content
+                    );
+                }
                 break;
         }
@@ -3649 +3477 @@
             'error_code' => 'system_exception',
             'exception_details' => $e->getMessage()
+        ];
+    }
+}
+private function mxchat_generate_response_claude($selected_model, $claude_api_key, $conversation_history, $relevant_content) {
+    // Get system prompt instructions from options
+    $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
+
+    // Clean and validate conversation history
+    foreach ($conversation_history as &$message) {
+        // Convert bot and agent roles to assistant
+        if ($message['role'] === 'bot' || $message['role'] === 'agent') {
+            $message['role'] = 'assistant';
+        }
+        
+        // Remove unsupported roles - Claude only supports 'assistant' and 'user'
+        if (!in_array($message['role'], ['assistant', 'user'])) {
+            $message['role'] = 'user';
+        }
+
+        // Ensure content field exists
+        if (!isset($message['content']) || empty($message['content'])) {
+            $message['content'] = '';
+        }
+
+        // Remove any unsupported fields
+        $message = array_intersect_key($message, array_flip(['role', 'content']));
+    }
+
+    // Add relevant content as the latest user message
+    $conversation_history[] = [
+        'role' => 'user',
+        'content' => $relevant_content
+    ];
+
+    // Build request body
+    $body = json_encode([
+        'model' => $selected_model,
+        'max_tokens' => 1000,
+        'temperature' => 0.8,
+        'messages' => $conversation_history,
+        'system' => $system_prompt_instructions
+    ]);
+
+    // Set up API request
+    $args = [
+        'body' => $body,
+            'headers' => [
+                'Content-Type' => 'application/json',
+                'x-api-key' => $claude_api_key,
+                'anthropic-version' => '2023-06-01'
+            ],
+        'timeout' => 60,
+        'redirection' => 5,
+        'blocking' => true,
+        'httpversion' => '1.0',
+        'sslverify' => true,
+    ];
+
+    // Make API request
+    $response = wp_remote_post('https://api.anthropic.com/v1/messages', $args);
+
+    // Check for WordPress errors
+    if (is_wp_error($response)) {
+        //error_log("Claude API request error: " . $response->get_error_message());
+        return "Sorry, there was an error connecting to the API.";
+    }
+
+    // Check HTTP response code
+    $http_code = wp_remote_retrieve_response_code($response);
+    if ($http_code !== 200) {
+        $error_body = wp_remote_retrieve_body($response);
+        //error_log("Claude API HTTP error: " . $http_code . " - " . $error_body);
+        
+        // Try to extract error message from response
+        $error_data = json_decode($error_body, true);
+        $error_message = isset($error_data['error']['message']) ? 
+            $error_data['error']['message'] : 
+            "HTTP error " . $http_code;
+            
+        return "Sorry, the API returned an error: " . $error_message;
+    }
+
+    // Parse response
+    $response_body = json_decode(wp_remote_retrieve_body($response), true);
+    
+    // Check for JSON decode errors
+    if (json_last_error() !== JSON_ERROR_NONE) {
+        //error_log("Claude API JSON decode error: " . json_last_error_msg());
+        return "Sorry, there was an error processing the API response.";
+    }
+
+    // Extract and validate response content
+    if (isset($response_body['content']) && 
+        is_array($response_body['content']) && 
+        !empty($response_body['content']) && 
+        isset($response_body['content'][0]['text'])) {
+        return trim($response_body['content'][0]['text']);
+    }
+
+    // Log unexpected response format
+    //error_log("Claude API unexpected response format: " . print_r($response_body, true));
+    return "Sorry, I received an unexpected response format from the API.";
+}
+private function mxchat_generate_response_claude_stream($selected_model, $claude_api_key, $conversation_history, $relevant_content, $session_id) {
+    try {
+        // Get system prompt instructions from options
+        $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
+
+        // Ensure conversation_history is an array
+        if (!is_array($conversation_history)) {
+            $conversation_history = array();
+        }
+
+        // Clean and validate conversation history
+        foreach ($conversation_history as &$message) {
+            // Convert bot and agent roles to assistant
+            if ($message['role'] === 'bot' || $message['role'] === 'agent') {
+                $message['role'] = 'assistant';
+            }
+            
+            // Remove unsupported roles - Claude only supports 'assistant' and 'user'
+            if (!in_array($message['role'], ['assistant', 'user'])) {
+                $message['role'] = 'user';
+            }
+
+            // Ensure content field exists
+            if (!isset($message['content']) || empty($message['content'])) {
+                $message['content'] = '';
+            }
+
+            // Remove any unsupported fields
+            $message = array_intersect_key($message, array_flip(['role', 'content']));
+        }
+
+        // Add relevant content as the latest user message
+        $conversation_history[] = [
+            'role' => 'user',
+            'content' => $relevant_content
+        ];
+
+        // Prepare the request body with stream: true
+        $body = json_encode([
+            'model' => $selected_model,
+            'messages' => $conversation_history,
+            'max_tokens' => 1000,
+            'temperature' => 0.8,
+            'system' => $system_prompt_instructions,
+            'stream' => true
+        ]);
+
+        // Use cURL for streaming support
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, 'https://api.anthropic.com/v1/messages');
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, false);
+        curl_setopt($ch, CURLOPT_POST, true);
+        curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
+        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
+            'Content-Type: application/json',
+            'x-api-key: ' . $claude_api_key,
+            'anthropic-version: 2023-06-01'
+        ));
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
+        curl_setopt($ch, CURLOPT_TIMEOUT, 60);
+
+        $full_response = ''; // Accumulate full response for saving
+
+        // Buffer control for real-time streaming
+        curl_setopt($ch, CURLOPT_WRITEFUNCTION, function($ch, $data) use (&$full_response) {
+            // Process each chunk of data
+            $lines = explode("\n", $data);
+
+            foreach ($lines as $line) {
+                if (trim($line) === '') {
+                    continue;
+                }
+
+                // Claude uses event: and data: format
+                if (strpos($line, 'event: ') === 0) {
+                    // Store the event type for the next data line
+                    continue;
+                }
+
+                if (strpos($line, 'data: ') === 0) {
+                    $json_str = substr($line, 6); // Remove 'data: ' prefix
+
+                    $json = json_decode($json_str, true);
+                    if (json_last_error() !== JSON_ERROR_NONE) {
+                        continue;
+                    }
+
+                    // Handle different event types
+                    if (isset($json['type'])) {
+                        switch ($json['type']) {
+                            case 'content_block_delta':
+                                if (isset($json['delta']['text'])) {
+                                    $content = $json['delta']['text'];
+                                    $full_response .= $content; // Accumulate
+                                    // Send as SSE format compatible with your frontend
+                                    echo "data: " . json_encode(['content' => $content]) . "\n\n";
+                                    flush();
+                                }
+                                break;
+
+                            case 'message_stop':
+                                echo "data: [DONE]\n\n";
+                                flush();
+                                break;
+
+                            case 'error':
+                                echo "data: " . json_encode(['error' => $json['error']['message'] ?? 'Unknown error']) . "\n\n";
+                                flush();
+                                break;
+                        }
+                    }
+                }
+            }
+
+            return strlen($data);
+        });
+
+        $response = curl_exec($ch);
+        $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+
+        if (curl_errno($ch)) {
+            throw new Exception('cURL Error: ' . curl_error($ch));
+        }
+
+        curl_close($ch);
+
+        if ($http_code !== 200) {
+            throw new Exception('HTTP Error: ' . $http_code);
+        }
+
+        // Save the complete response to maintain chat persistence
+        if (!empty($full_response) && !empty($session_id)) {
+            $this->mxchat_save_chat_message($session_id, 'bot', $full_response);
+        }
+
+        return true; // Indicate streaming completed successfully
+
+    } catch (Exception $e) {
+        echo "data: " . json_encode(['error' => $e->getMessage()]) . "\n\n";
+        flush();
+        return false;
+    }
+}
+private function mxchat_generate_response_openai_stream($selected_model, $api_key, $conversation_history, $relevant_content, $session_id) {
+    try {
+        // Get system prompt instructions from options
+        $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
+        
+        // Ensure conversation_history is an array
+        if (!is_array($conversation_history)) {
+            $conversation_history = array();
+        }
+
+        // Format conversation history for OpenAI
+        $formatted_conversation = array();
+
+        $formatted_conversation[] = array(
+            'role' => 'system',
+            'content' => $system_prompt_instructions . " " . $relevant_content
+        );
+
+        foreach ($conversation_history as $message) {
+            if (is_array($message) && isset($message['role']) && isset($message['content'])) {
+                $role = $message['role'];
+                if ($role === 'bot' || $role === 'agent') {
+                    $role = 'assistant';
+                }
+                if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
+                    $role = 'user';
+                }
+                $formatted_conversation[] = array(
+                    'role' => $role,
+                    'content' => $message['content']
+                );
+            }
+        }
+
+        // Prepare the request body with stream: true
+        $body = json_encode([
+            'model' => $selected_model,
+            'messages' => $formatted_conversation,
+            'temperature' => 0.8,
+            'stream' => true
+        ]);
+
+        // Use cURL for streaming support
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, 'https://api.openai.com/v1/chat/completions');
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, false);
+        curl_setopt($ch, CURLOPT_POST, true);
+        curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
+        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
+            'Content-Type: application/json',
+            'Authorization: Bearer ' . $api_key
+        ));
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
+        curl_setopt($ch, CURLOPT_TIMEOUT, 60);
+        
+        $full_response = ''; // Accumulate full response for saving
+        
+        // Buffer control for real-time streaming
+        curl_setopt($ch, CURLOPT_WRITEFUNCTION, function($ch, $data) use (&$full_response) {
+            // Process each chunk of data
+            $lines = explode("\n", $data);
+            
+            foreach ($lines as $line) {
+                if (trim($line) === '' || strpos($line, 'data: ') !== 0) {
+                    continue;
+                }
+                
+                $json_str = substr($line, 6); // Remove 'data: ' prefix
+                
+                if ($json_str === '[DONE]') {
+                    echo "data: [DONE]\n\n";
+                    flush();
+                    continue;
+                }
+                
+                $json = json_decode($json_str, true);
+                if (isset($json['choices'][0]['delta']['content'])) {
+                    $content = $json['choices'][0]['delta']['content'];
+                    $full_response .= $content; // Accumulate
+                    // Send as SSE format
+                    echo "data: " . json_encode(['content' => $content]) . "\n\n";
+                    flush();
+                }
+            }
+            
+            return strlen($data);
+        });
+        
+        $response = curl_exec($ch);
+        $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        
+        if (curl_errno($ch)) {
+            throw new Exception('cURL Error: ' . curl_error($ch));
+        }
+        
+        curl_close($ch);
+        
+        if ($http_code !== 200) {
+            throw new Exception('HTTP Error: ' . $http_code);
+        }
+        
+        // Save the complete response to maintain chat persistence
+        if (!empty($full_response) && !empty($session_id)) {
+            $this->mxchat_save_chat_message($session_id, 'bot', $full_response);
+        }
+        
+        return true; // Indicate streaming completed successfully
+        
+    } catch (Exception $e) {
+        echo "data: " . json_encode(['error' => $e->getMessage()]) . "\n\n";
+        flush();
+        return false;
+    }
+}
+private function mxchat_generate_response_openai($selected_model, $api_key, $conversation_history, $relevant_content) {
+    try {
+        // Ensure conversation_history is an array
+        if (!is_array($conversation_history)) {
+            $conversation_history = array();
+        }
+
+        // Get system prompt instructions from options
+        $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
+
+        // Create a new array for the formatted conversation
+        $formatted_conversation = array();
+
+        // Add system message first
+        $formatted_conversation[] = array(
+            'role' => 'system',
+            'content' => $system_prompt_instructions . " " . $relevant_content
+        );
+
+        // Add the rest of the conversation history
+        foreach ($conversation_history as $message) {
+            if (is_array($message) && isset($message['role']) && isset($message['content'])) {
+                $role = $message['role'];
+
+                // Convert roles to supported format
+                if ($role === 'bot' || $role === 'agent') {
+                    $role = 'assistant';
+                }
+                if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
+                    $role = 'user';
+                }
+
+                $formatted_conversation[] = array(
+                    'role' => $role,
+                    'content' => $message['content']
+                );
+            }
+        }
+
+        $body = json_encode([
+            'model' => $selected_model,
+            'messages' => $formatted_conversation,
+            'temperature' => 0.8,
+            'stream' => false
+        ]);
+
+        $args = [
+            'body'        => $body,
+            'headers'     => [
+                'Content-Type' => 'application/json',
+                'Authorization' => 'Bearer ' . $api_key,
+            ],
+            'timeout'     => 60,
+            'redirection' => 5,
+            'blocking'    => true,
+            'httpversion' => '1.0',
+            'sslverify'   => true,
+        ];
+
+        $response = wp_remote_post('https://api.openai.com/v1/chat/completions', $args);
+
+        if (is_wp_error($response)) {
+            $error_message = $response->get_error_message();
+            //error_log('OpenAI API Error: ' . $error_message);
+            return [
+                'error' => esc_html__('Connection error when contacting OpenAI: ', 'mxchat') . esc_html($error_message),
+                'error_code' => 'openai_connection_error',
+                'provider' => 'openai'
+            ];
+        }
+
+        $status_code = wp_remote_retrieve_response_code($response);
+        if ($status_code !== 200) {
+            $response_body = wp_remote_retrieve_body($response);
+            $decoded_response = json_decode($response_body, true);
+            
+            $error_message = isset($decoded_response['error']['message']) 
+                ? $decoded_response['error']['message'] 
+                : 'HTTP Error ' . $status_code;
+            
+            $error_type = isset($decoded_response['error']['type']) 
+                ? $decoded_response['error']['type'] 
+                : 'unknown';
+            
+            //error_log('OpenAI API HTTP Error: ' . $status_code . ' - ' . $error_message);
+            
+            // Handle specific error types
+            switch ($error_type) {
+                case 'invalid_request_error':
+                    if (strpos($error_message, 'API key') !== false) {
+                        return [
+                            'error' => esc_html__('Invalid OpenAI API key. Please check your API key configuration.', 'mxchat'),
+                            'error_code' => 'openai_invalid_api_key',
+                            'provider' => 'openai'
+                        ];
+                    }
+                    break;
+                    
+                case 'authentication_error':
+                    return [
+                        'error' => esc_html__('Authentication failed with OpenAI. Please check your API key.', 'mxchat'),
+                        'error_code' => 'openai_auth_error',
+                        'provider' => 'openai'
+                    ];
+                
+                case 'rate_limit_exceeded':
+                    return [
+                        'error' => esc_html__('OpenAI rate limit exceeded. Please try again later.', 'mxchat'),
+                        'error_code' => 'openai_rate_limit',
+                        'provider' => 'openai'
+                    ];
+                    
+                case 'quota_exceeded':
+                    return [
+                        'error' => esc_html__('OpenAI API quota exceeded. Please check your billing details.', 'mxchat'),
+                        'error_code' => 'openai_quota_exceeded',
+                        'provider' => 'openai'
+                    ];
+            }
+            
+            // Generic error fallback
+            return [
+                'error' => esc_html__('OpenAI API error: ', 'mxchat') . esc_html($error_message),
+                'error_code' => 'openai_api_error',
+                'provider' => 'openai',
+                'status_code' => $status_code
+            ];
+        }
+
+        $response_body = wp_remote_retrieve_body($response);
+        $decoded_response = json_decode($response_body, true);
+
+        if (isset($decoded_response['choices'][0]['message']['content'])) {
+            return trim($decoded_response['choices'][0]['message']['content']);
+        } else {
+            //error_log('OpenAI API Response Format Error: ' . print_r($decoded_response, true));
+            return [
+                'error' => esc_html__('Unexpected response format from OpenAI.', 'mxchat'),
+                'error_code' => 'openai_response_format_error',
+                'provider' => 'openai'
+            ];
+        }
+    } catch (Exception $e) {
+        //error_log('OpenAI Exception: ' . $e->getMessage());
+        return [
+            'error' => esc_html__('System error when processing OpenAI request: ', 'mxchat') . esc_html($e->getMessage()),
+            'error_code' => 'openai_exception',
+            'provider' => 'openai'
         ];
     }
@@ -3815 +4151 @@
     }
 }
-
-private function mxchat_generate_response_openai($selected_model, $api_key, $conversation_history, $relevant_content) {
-    try {
-        // Ensure conversation_history is an array
-        if (!is_array($conversation_history)) {
-            $conversation_history = array();
-        }
-
-        // Get system prompt instructions from options
-        $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
-
-        // Create a new array for the formatted conversation
-        $formatted_conversation = array();
-
-        // Add system message first
-        $formatted_conversation[] = array(
-            'role' => 'system',
-            'content' => $system_prompt_instructions . " " . $relevant_content
-        );
-
-        // Add the rest of the conversation history
-        foreach ($conversation_history as $message) {
-            if (is_array($message) && isset($message['role']) && isset($message['content'])) {
-                $role = $message['role'];
-
-                // Convert roles to supported format
-                if ($role === 'bot' || $role === 'agent') {
-                    $role = 'assistant';
-                }
-                if (!in_array($role, ['system', 'assistant', 'user', 'function', 'tool'])) {
-                    $role = 'user';
-                }
-
-                $formatted_conversation[] = array(
-                    'role' => $role,
-                    'content' => $message['content']
-                );
-            }
-        }
-
-        $body = json_encode([
-            'model' => $selected_model,
-            'messages' => $formatted_conversation,
-            'temperature' => 0.8,
-            'stream' => false
-        ]);
-
-        $args = [
-            'body'        => $body,
-            'headers'     => [
-                'Content-Type' => 'application/json',
-                'Authorization' => 'Bearer ' . $api_key,
-            ],
-            'timeout'     => 60,
-            'redirection' => 5,
-            'blocking'    => true,
-            'httpversion' => '1.0',
-            'sslverify'   => true,
-        ];
-
-        $response = wp_remote_post('https://api.openai.com/v1/chat/completions', $args);
-
-        if (is_wp_error($response)) {
-            $error_message = $response->get_error_message();
-            //error_log('OpenAI API Error: ' . $error_message);
-            return [
-                'error' => esc_html__('Connection error when contacting OpenAI: ', 'mxchat') . esc_html($error_message),
-                'error_code' => 'openai_connection_error',
-                'provider' => 'openai'
-            ];
-        }
-
-        $status_code = wp_remote_retrieve_response_code($response);
-        if ($status_code !== 200) {
-            $response_body = wp_remote_retrieve_body($response);
-            $decoded_response = json_decode($response_body, true);
-            
-            $error_message = isset($decoded_response['error']['message']) 
-                ? $decoded_response['error']['message'] 
-                : 'HTTP Error ' . $status_code;
-            
-            $error_type = isset($decoded_response['error']['type']) 
-                ? $decoded_response['error']['type'] 
-                : 'unknown';
-            
-            //error_log('OpenAI API HTTP Error: ' . $status_code . ' - ' . $error_message);
-            
-            // Handle specific error types
-            switch ($error_type) {
-                case 'invalid_request_error':
-                    if (strpos($error_message, 'API key') !== false) {
-                        return [
-                            'error' => esc_html__('Invalid OpenAI API key. Please check your API key configuration.', 'mxchat'),
-                            'error_code' => 'openai_invalid_api_key',
-                            'provider' => 'openai'
-                        ];
-                    }
-                    break;
-                    
-                case 'authentication_error':
-                    return [
-                        'error' => esc_html__('Authentication failed with OpenAI. Please check your API key.', 'mxchat'),
-                        'error_code' => 'openai_auth_error',
-                        'provider' => 'openai'
-                    ];
-                
-                case 'rate_limit_exceeded':
-                    return [
-                        'error' => esc_html__('OpenAI rate limit exceeded. Please try again later.', 'mxchat'),
-                        'error_code' => 'openai_rate_limit',
-                        'provider' => 'openai'
-                    ];
-                    
-                case 'quota_exceeded':
-                    return [
-                        'error' => esc_html__('OpenAI API quota exceeded. Please check your billing details.', 'mxchat'),
-                        'error_code' => 'openai_quota_exceeded',
-                        'provider' => 'openai'
-                    ];
-            }
-            
-            // Generic error fallback
-            return [
-                'error' => esc_html__('OpenAI API error: ', 'mxchat') . esc_html($error_message),
-                'error_code' => 'openai_api_error',
-                'provider' => 'openai',
-                'status_code' => $status_code
-            ];
-        }
-
-        $response_body = wp_remote_retrieve_body($response);
-        $decoded_response = json_decode($response_body, true);
-
-        if (isset($decoded_response['choices'][0]['message']['content'])) {
-            return trim($decoded_response['choices'][0]['message']['content']);
-        } else {
-            //error_log('OpenAI API Response Format Error: ' . print_r($decoded_response, true));
-            return [
-                'error' => esc_html__('Unexpected response format from OpenAI.', 'mxchat'),
-                'error_code' => 'openai_response_format_error',
-                'provider' => 'openai'
-            ];
-        }
-    } catch (Exception $e) {
-        //error_log('OpenAI Exception: ' . $e->getMessage());
-        return [
-            'error' => esc_html__('System error when processing OpenAI request: ', 'mxchat') . esc_html($e->getMessage()),
-            'error_code' => 'openai_exception',
-            'provider' => 'openai'
-        ];
-    }
-}
 private function mxchat_generate_response_xai($selected_model, $xai_api_key, $conversation_history, $relevant_content) {
     try {
@@ -4155 +4339 @@
     ];
 }
-}
-private function mxchat_generate_response_claude($selected_model, $claude_api_key, $conversation_history, $relevant_content) {
-    // Get system prompt instructions from options
-    $system_prompt_instructions = isset($this->options['system_prompt_instructions']) ? $this->options['system_prompt_instructions'] : '';
-
-    // Clean and validate conversation history
-    foreach ($conversation_history as &$message) {
-        // Convert bot and agent roles to assistant
-        if ($message['role'] === 'bot' || $message['role'] === 'agent') {
-            $message['role'] = 'assistant';
-        }
-        
-        // Remove unsupported roles - Claude only supports 'assistant' and 'user'
-        if (!in_array($message['role'], ['assistant', 'user'])) {
-            $message['role'] = 'user';
-        }
-
-        // Ensure content field exists
-        if (!isset($message['content']) || empty($message['content'])) {
-            $message['content'] = '';
-        }
-
-        // Remove any unsupported fields
-        $message = array_intersect_key($message, array_flip(['role', 'content']));
-    }
-
-    // Add relevant content as the latest user message
-    $conversation_history[] = [
-        'role' => 'user',
-        'content' => $relevant_content
-    ];
-
-    // Build request body
-    $body = json_encode([
-        'model' => $selected_model,
-        'max_tokens' => 1000,
-        'temperature' => 0.8,
-        'messages' => $conversation_history,
-        'system' => $system_prompt_instructions
-    ]);
-
-    // Set up API request
-    $args = [
-        'body' => $body,
-            'headers' => [
-                'Content-Type' => 'application/json',
-                'x-api-key' => $claude_api_key,
-                'anthropic-version' => '2023-06-01'
-            ],
-        'timeout' => 60,
-        'redirection' => 5,
-        'blocking' => true,
-        'httpversion' => '1.0',
-        'sslverify' => true,
-    ];
-
-    // Make API request
-    $response = wp_remote_post('https://api.anthropic.com/v1/messages', $args);
-
-    // Check for WordPress errors
-    if (is_wp_error($response)) {
-        //error_log("Claude API request error: " . $response->get_error_message());
-        return "Sorry, there was an error connecting to the API.";
-    }
-
-    // Check HTTP response code
-    $http_code = wp_remote_retrieve_response_code($response);
-    if ($http_code !== 200) {
-        $error_body = wp_remote_retrieve_body($response);
-        //error_log("Claude API HTTP error: " . $http_code . " - " . $error_body);
-        
-        // Try to extract error message from response
-        $error_data = json_decode($error_body, true);
-        $error_message = isset($error_data['error']['message']) ? 
-            $error_data['error']['message'] : 
-            "HTTP error " . $http_code;
-            
-        return "Sorry, the API returned an error: " . $error_message;
-    }
-
-    // Parse response
-    $response_body = json_decode(wp_remote_retrieve_body($response), true);
-    
-    // Check for JSON decode errors
-    if (json_last_error() !== JSON_ERROR_NONE) {
-        //error_log("Claude API JSON decode error: " . json_last_error_msg());
-        return "Sorry, there was an error processing the API response.";
-    }
-
-    // Extract and validate response content
-    if (isset($response_body['content']) && 
-        is_array($response_body['content']) && 
-        !empty($response_body['content']) && 
-        isset($response_body['content'][0]['text'])) {
-        return trim($response_body['content'][0]['text']);
-    }
-
-    // Log unexpected response format
-    //error_log("Claude API unexpected response format: " . print_r($response_body, true));
-    return "Sorry, I received an unexpected response format from the API.";
 }
 private function mxchat_generate_response_gemini($selected_model, $gemini_api_key, $conversation_history, $relevant_content) {
@@ -4456 +4540 @@
 public function mxchat_enqueue_scripts_styles() {
     // Define version numbers for the styles and scripts
-    $chat_style_version = '2.2.4';
-    $chat_script_version = '2.2.4';
-
+    $chat_style_version = '2.2.5';
+    $chat_script_version = '2.2.5';
     // Enqueue the script
     wp_enqueue_script(
@@ -4467 +4550 @@
         true
     );
-
     // Enqueue the CSS
     wp_enqueue_style(
@@ -4475 +4557 @@
         $chat_style_version
     );
-
     // Fetch options from the database
     $this->options = get_option('mxchat_options');
     $prompts_options = get_option('mxchat_prompts_options', array());
-
+    
     // Prepare settings for JavaScript
     $style_settings = array(
         'ajax_url' => admin_url('admin-ajax.php'),
         'nonce' => wp_create_nonce('mxchat_chat_nonce'),
+        'model' => isset($this->options['model']) ? $this->options['model'] : 'gpt-4o',
+        'enable_streaming_toggle' => isset($this->options['enable_streaming_toggle']) ? $this->options['enable_streaming_toggle'] : 'on', // ADD THIS LINE
         'link_target_toggle' => $this->options['link_target_toggle'] ?? 'off',
         'rate_limit_message' => $this->options['rate_limit_message'] ?? 'Rate limit exceeded. Please try again later.',
@@ -4499 +4582 @@
         'chat_input_font_color' => $this->options['chat_input_font_color'] ?? '#212121',
         'chat_persistence_toggle' => $this->options['chat_persistence_toggle'] ?? 'off',
-        'appendWidgetToBody' => $this->options['append_to_body'] ?? 'off', // Example for consistency
-
+        'appendWidgetToBody' => $this->options['append_to_body'] ?? 'off',
         'live_agent_message_bg_color' => $this->options['live_agent_message_bg_color'] ?? '#ffffff',
         'live_agent_message_font_color' => $this->options['live_agent_message_font_color'] ?? '#333333',
@@ -4507 +4589 @@
         'mode_indicator_font_color' => $this->options['mode_indicator_font_color'] ?? '#ffffff',
         'toolbar_icon_color' => $this->options['toolbar_icon_color'] ?? '#212121',
-
         'use_pinecone' => $prompts_options['mxchat_use_pinecone'] ?? '0',
         'pinecone_enabled' => isset($prompts_options['mxchat_use_pinecone']) && $prompts_options['mxchat_use_pinecone'] === '1'
     );
-
     // Pass the settings to the script
     wp_localize_script('mxchat-chat-js', 'mxchatChat', $style_settings);
 }
 
-
-// Modify the mxchat_reset_rate_limits function to handle different timeframes
 // Modify the mxchat_reset_rate_limits function to handle different timeframes
 public function mxchat_reset_rate_limits() {
@@ -4599 +4677 @@
 public function cleanup_cron_events() {
     wp_clear_scheduled_hook('mxchat_reset_rate_limits');
-}
-
-private function mxchat_fetch_woocommerce_products() {
-    // Ensure WooCommerce is active
-    if (!class_exists('WooCommerce')) {
-        return [];
-    }
-
-    $args = array(
-        'post_type' => 'product',
-        'post_status' => 'publish',
-        'posts_per_page' => -1,
-    );
-
-    $products = get_posts($args);
-    $product_data = [];
-
-    foreach ($products as $product) {
-        $product_id = $product->ID;
-        $product_obj = wc_get_product($product_id);
-
-        $product_data[] = array(
-            'id' => $product_id,
-            'name' => $product_obj->get_name(),
-            'description' => $product_obj->get_description(),
-            'short_description' => $product_obj->get_short_description(),
-            'url' => get_permalink($product_id),
-            'price' => $product_obj->get_regular_price(),
-            'sale_price' => $product_obj->get_sale_price(),
-            'stock_status' => $product_obj->get_stock_status(),
-            'sku' => $product_obj->get_sku(),
-            'in_stock' => $product_obj->is_in_stock(),
-            'total_sales' => $product_obj->get_total_sales(),
-        );
-    }
-
-    return $product_data;
 }
 

mxchat-basic/trunk/js/chat-script.js

@@ -59 +59 @@
 
 
-    // ====================================
-    // CORE CHAT FUNCTIONALITY
-    // ====================================
-    
-    function sendMessage() {
-        var message = $('#chat-input').val(); // Get value from textarea
-        if (message) {
-            appendMessage("user", message); // Append user's message
-            $('#chat-input').val(''); // Clear the textarea
-            $('#chat-input').css('height', 'auto'); // Reset height after clearing content
-    
-            // Hide the popular questions section
-            $('#mxchat-popular-questions').hide();
-    
-            // Show typing indicator
-            appendThinkingMessage();
-            scrollToBottom();
-    
+// ====================================
+// CORE CHAT FUNCTIONALITY
+// ====================================
+
+// Update your existing sendMessage function
+function sendMessage() {
+    var message = $('#chat-input').val();
+    if (message) {
+        appendMessage("user", message);
+        $('#chat-input').val('');
+        $('#chat-input').css('height', 'auto');
+
+        $('#mxchat-popular-questions').hide();
+        appendThinkingMessage();
+        scrollToBottom();
+
+        const currentModel = mxchatChat.model || 'gpt-4o';
+
+        // Check if streaming is enabled AND supported for this model
+        if (shouldUseStreaming(currentModel)) {
+            callMxChatStream(message, function(response) {
+                $('.bot-message.temporary-message').removeClass('temporary-message');
+            });
+        } else {
             callMxChat(message, function(response) {
-                // Replace typing indicator with actual response
                 replaceLastMessage("bot", response);
             });
         }
     }
-    
-    function sendMessageToChatbot(message) {
-        var sessionId = getChatSession(); // Reuse the session ID logic
-    
-        // Hide the popular questions section
-        $('#mxchat-popular-questions').hide();
-    
-        // Show thinking indicator (no need to append the user's message again)
-        appendThinkingMessage();
-        scrollToBottom();
-    
-        //console.log("Sending message to chatbot:", message); // Log the message
-        //console.log("Session ID:", sessionId); // Log the session ID
-    
-        // Call the chatbot using the same call logic as sendMessage
+}
+
+// Update your existing sendMessageToChatbot function
+function sendMessageToChatbot(message) {
+    var sessionId = getChatSession();
+
+    $('#mxchat-popular-questions').hide();
+    appendThinkingMessage();
+    scrollToBottom();
+
+    const currentModel = mxchatChat.model || 'gpt-4o';
+
+    // Check if streaming is enabled AND supported for this model
+    if (shouldUseStreaming(currentModel)) {
+        callMxChatStream(message, function(response) {
+            $('.bot-message.temporary-message').removeClass('temporary-message');
+        });
+    } else {
         callMxChat(message, function(response) {
-            // ** Ensure temporary thinking message is removed before adding new response **
             $('.temporary-message').remove();
-    
-            // Replace thinking indicator with actual response
             replaceLastMessage("bot", response);
         });
     }
-    
-    function callMxChat(message, callback) {
-        $.ajax({
-            url: mxchatChat.ajax_url,
-            type: 'POST',
-            dataType: 'json',
-            data: {
-                action: 'mxchat_handle_chat_request',
-                message: message,
-                session_id: getChatSession(),
-                nonce: mxchatChat.nonce
-            },
-            success: function(response) {
-                // Log the full response for debugging
-                //console.log("API Response:", response);
+}
+
+
+// Updated shouldUseStreaming function with debugging
+function shouldUseStreaming(model) {
+    // Check if streaming is enabled in settings (using your toggle naming pattern)
+    const streamingEnabled = mxchatChat.enable_streaming_toggle === 'on';
+    
+    // Check if model supports streaming
+    const streamingSupported = isStreamingSupported(model);
+    
+    
+    // Only use streaming if both enabled and supported
+    return streamingEnabled && streamingSupported;
+}
+
+function callMxChat(message, callback) {
+    $.ajax({
+        url: mxchatChat.ajax_url,
+        type: 'POST',
+        dataType: 'json',
+        data: {
+            action: 'mxchat_handle_chat_request',
+            message: message,
+            session_id: getChatSession(),
+            nonce: mxchatChat.nonce
+        },
+        success: function(response) {
+            // Log the full response for debugging
+            //console.log("API Response:", response);
+
+            // First check if this is a successful response by looking for text, html, or message fields
+            // This preserves compatibility with your server response format
+            if (response.text !== undefined || response.html !== undefined || response.message !== undefined || 
+                (response.success === true && response.data && response.data.status === 'waiting_for_agent')) {
+
+                // Handle successful response - this is your original success handling code
+
+                // Existing chat mode check
+                if (response.chat_mode) {
+                    updateChatModeIndicator(response.chat_mode);
+                }
+                else if (response.fallbackResponse && response.fallbackResponse.chat_mode) {
+                    updateChatModeIndicator(response.fallbackResponse.chat_mode);
+                }
+
+                // Add PDF filename handling
+                if (response.data && response.data.filename) {
+                    showActivePdf(response.data.filename);
+                    activePdfFile = response.data.filename;
+                }
+
+                // Add redirect check here
+                if (response.redirect_url) {
+                    let responseText = response.text || '';
+                    if (responseText) {
+                        replaceLastMessage("bot", responseText);
+                    }
+                    setTimeout(() => {
+                        window.location.href = response.redirect_url;
+                    }, 1500);
+                    return;
+                }
+
+                // Check for live agent response
+                if (response.success && response.data && response.data.status === 'waiting_for_agent') {
+                    updateChatModeIndicator('agent');
+                    return;
+                }
+
+                // Handle other responses
+                let responseText = response.text || '';
+                let responseHtml = response.html || '';
+                let responseMessage = response.message || '';
+
+                if (responseText === 'You are now chatting with the AI chatbot.') {
+                    updateChatModeIndicator('ai');
+                }
+
+                // Handle the message and show notification if chat is hidden
+                if (responseText || responseHtml || responseMessage) {
+                    // Update the messages as before
+                    if (responseText && responseHtml) {
+                        replaceLastMessage("bot", responseText, responseHtml);
+                    } else if (responseText) {
+                        replaceLastMessage("bot", responseText);
+                    } else if (responseHtml) {
+                        replaceLastMessage("bot", "", responseHtml);
+                    } else if (responseMessage) {
+                        replaceLastMessage("bot", responseMessage);
+                    }
+
+                    // Check if chat is hidden and show notification
+                    if ($('#floating-chatbot').hasClass('hidden')) {
+                        const badge = $('#chat-notification-badge');
+                        if (badge.length) {
+                            badge.show();
+                        }
+                    }
+                } else {
+                    //console.error("Unexpected response format:", response);
+                    replaceLastMessage("bot", "I received an empty response. Please try again or contact support if this persists.");
+                }
+
+                if (response.message_id) {
+                    lastSeenMessageId = response.message_id;
+                }
+
+                return;
+            }
+
+            // If we got here, it's likely an error response
+            // Now we can check for error conditions with our robust error handling
+
+            let errorMessage = "";
+            let errorCode = "";
+
+            // Check various possible error locations in the response
+            if (response.data && response.data.error_message) {
+                errorMessage = response.data.error_message;
+                errorCode = response.data.error_code || "";
+            } else if (response.error_message) {
+                errorMessage = response.error_message;
+                errorCode = response.error_code || "";
+            } else if (response.message) {
+                errorMessage = response.message;
+            } else if (typeof response.data === 'string') {
+                errorMessage = response.data;
+            } else if (!response.success) {
+                // Explicit check for success: false without other error info
+                errorMessage = "An error occurred. Please try again or contact support.";
+            } else {
+                // Fallback for any other unexpected response format
+                errorMessage = "Unexpected response received. Please try again or contact support.";
+            }
+
+            // Log the error with code for debugging
+            //console.log("Response data:", response.data);
+            //console.error("API Error:", errorMessage, "Code:", errorCode);
+
+            // Format user-friendly error message
+            let displayMessage = errorMessage;
+
+            // Customize message for admin users
+            if (mxchatChat.is_admin) {
+                // For admin users, show more technical details including error code
+                displayMessage = errorMessage + (errorCode ? " (Error code: " + errorCode + ")" : "");
+            }
+
+            replaceLastMessage("bot", displayMessage);
+        },
+        error: function(xhr, status, error) {
+            console.error("AJAX Error:", status, error);
+            //console.log("Response Text:", xhr.responseText);
+
+            let errorMessage = "An unexpected error occurred.";
+
+            // Try to parse the response if it's JSON
+            try {
+                const responseJson = JSON.parse(xhr.responseText);
+                //console.log("Parsed error response:", responseJson);
+
+                if (responseJson.data && responseJson.data.error_message) {
+                    errorMessage = responseJson.data.error_message;
+                } else if (responseJson.message) {
+                    errorMessage = responseJson.message;
+                }
+            } catch (e) {
+                // Not JSON or parsing failed, use HTTP status based messages
+                if (xhr.status === 0) {
+                    errorMessage = "Network error: Please check your internet connection.";
+                } else if (xhr.status === 403) {
+                    errorMessage = "Access denied: Your session may have expired. Please refresh the page.";
+                } else if (xhr.status === 404) {
+                    errorMessage = "API endpoint not found. Please contact support.";
+                } else if (xhr.status === 429) {
+                    errorMessage = "Too many requests. Please try again in a moment.";
+                } else if (xhr.status >= 500) {
+                    errorMessage = "Server error: The server encountered an issue. Please try again later.";
+                }
+            }
+
+            replaceLastMessage("bot", errorMessage);
+        }
+    });
+}
+
+function callMxChatStream(message, callback) {
+    //console.log("Using streaming for message:", message);
+    
+    const currentModel = mxchatChat.model || 'gpt-4o';
+    if (!isStreamingSupported(currentModel)) {
+        //console.log("Streaming not supported, falling back to regular call");
+        callMxChat(message, callback);
+        return;
+    }
+
+    const formData = new FormData();
+    formData.append('action', 'mxchat_stream_chat');
+    formData.append('message', message);
+    formData.append('session_id', getChatSession());
+    formData.append('nonce', mxchatChat.nonce);
+
+    let accumulatedContent = '';
+
+    fetch(mxchatChat.ajax_url, {
+        method: 'POST',
+        body: formData,
+        credentials: 'same-origin'
+    })
+    .then(response => {
+        //console.log("Streaming response received:", response);
+        
+        if (!response.ok) {
+            throw new Error('Network response was not ok');
+        }
+
+        // Check if response is JSON instead of streaming
+        const contentType = response.headers.get('content-type');
+        if (contentType && contentType.includes('application/json')) {
+            //console.log("Received JSON response instead of stream, handling as regular response");
+            return response.json().then(data => {
+                // Handle as regular JSON response - this is the key fix!
+                // Remove thinking dots first
+                $('.bot-message.temporary-message').remove();
                 
-                // First check if this is a successful response by looking for text, html, or message fields
-                // This preserves compatibility with your server response format
-                if (response.text !== undefined || response.html !== undefined || response.message !== undefined || 
-                    (response.success === true && response.data && response.data.status === 'waiting_for_agent')) {
-                    
-                    // Handle successful response - this is your original success handling code
-                    
-                    // Existing chat mode check
-                    if (response.chat_mode) {
-                        updateChatModeIndicator(response.chat_mode);
+                // Handle different response formats (including intent responses)
+                if (data.text || data.html || data.message) {
+                    if (data.text && data.html) {
+                        replaceLastMessage("bot", data.text, data.html);
+                    } else if (data.text) {
+                        replaceLastMessage("bot", data.text);
+                    } else if (data.html) {
+                        replaceLastMessage("bot", "", data.html);
+                    } else if (data.message) {
+                        // This handles intent responses that use 'message' field
+                        replaceLastMessage("bot", data.message);
                     }
-                    else if (response.fallbackResponse && response.fallbackResponse.chat_mode) {
-                        updateChatModeIndicator(response.fallbackResponse.chat_mode);
+                }
+                
+                // Handle other response properties
+                if (data.chat_mode) {
+                    updateChatModeIndicator(data.chat_mode);
+                }
+                
+                if (data.data && data.data.filename) {
+                    showActivePdf(data.data.filename);
+                    activePdfFile = data.data.filename;
+                }
+                
+                if (callback) {
+                    callback(data.text || data.message || '');
+                }
+            });
+        }
+
+        // Continue with streaming processing
+        const reader = response.body.getReader();
+        const decoder = new TextDecoder();
+        let buffer = '';
+
+        function processStream() {
+            reader.read().then(({ done, value }) => {
+                if (done) {
+                    //console.log("Streaming completed, final content:", accumulatedContent);
+                    if (callback) {
+                        callback(accumulatedContent);
                     }
-                    
-                    // Add PDF filename handling
-                    if (response.data && response.data.filename) {
-                        showActivePdf(response.data.filename);
-                        activePdfFile = response.data.filename;
+                    return;
+                }
+
+                buffer += decoder.decode(value, { stream: true });
+                const lines = buffer.split('\n');
+                buffer = lines.pop() || '';
+
+                for (const line of lines) {
+                    if (line.startsWith('data: ')) {
+                        const data = line.substring(6);
+
+                        if (data === '[DONE]') {
+                            //console.log("Received [DONE] signal");
+                            if (callback) {
+                                callback(accumulatedContent);
+                            }
+                            return;
+                        }
+
+                        try {
+                            const json = JSON.parse(data);
+                            if (json.content) {
+                                accumulatedContent += json.content;
+                                updateStreamingMessage(accumulatedContent);
+                            } else if (json.error) {
+                                console.error("Streaming error:", json.error);
+                                replaceLastMessage("bot", "Error: " + json.error);
+                                return;
+                            }
+                        } catch (e) {
+                            console.error('Error parsing SSE data:', e);
+                        }
                     }
-                    
-                    // Add redirect check here
-                    if (response.redirect_url) {
-                        let responseText = response.text || '';
-                        if (responseText) {
-                            replaceLastMessage("bot", responseText);
-                        }
-                        setTimeout(() => {
-                            window.location.href = response.redirect_url;
-                        }, 1500);
-                        return;
-                    }
-                    
-                    // Check for live agent response
-                    if (response.success && response.data && response.data.status === 'waiting_for_agent') {
-                        updateChatModeIndicator('agent');
-                        return;
-                    }
-                    
-                    // Handle other responses
-                    let responseText = response.text || '';
-                    let responseHtml = response.html || '';
-                    let responseMessage = response.message || '';
-                    
-                    if (responseText === 'You are now chatting with the AI chatbot.') {
-                        updateChatModeIndicator('ai');
-                    }
-                    
-                    // Handle the message and show notification if chat is hidden
-                    if (responseText || responseHtml || responseMessage) {
-                        // Update the messages as before
-                        if (responseText && responseHtml) {
-                            replaceLastMessage("bot", responseText, responseHtml);
-                        } else if (responseText) {
-                            replaceLastMessage("bot", responseText);
-                        } else if (responseHtml) {
-                            replaceLastMessage("bot", "", responseHtml);
-                        } else if (responseMessage) {
-                            replaceLastMessage("bot", responseMessage);
-                        }
-                        
-                        // Check if chat is hidden and show notification
-                        if ($('#floating-chatbot').hasClass('hidden')) {
-                            const badge = $('#chat-notification-badge');
-                            if (badge.length) {
-                                badge.show();
-                            }
-                        }
-                    } else {
-                        //console.error("Unexpected response format:", response);
-                        replaceLastMessage("bot", "I received an empty response. Please try again or contact support if this persists.");
-                    }
-                    
-                    if (response.message_id) {
-                        lastSeenMessageId = response.message_id;
-                    }
-                    
-                    return;
-                }
-                
-                // If we got here, it's likely an error response
-                // Now we can check for error conditions with our robust error handling
-                
-                let errorMessage = "";
-                let errorCode = "";
-                
-                // Check various possible error locations in the response
-                if (response.data && response.data.error_message) {
-                    errorMessage = response.data.error_message;
-                    errorCode = response.data.error_code || "";
-                } else if (response.error_message) {
-                    errorMessage = response.error_message;
-                    errorCode = response.error_code || "";
-                } else if (response.message) {
-                    errorMessage = response.message;
-                } else if (typeof response.data === 'string') {
-                    errorMessage = response.data;
-                } else if (!response.success) {
-                    // Explicit check for success: false without other error info
-                    errorMessage = "An error occurred. Please try again or contact support.";
-                } else {
-                    // Fallback for any other unexpected response format
-                    errorMessage = "Unexpected response received. Please try again or contact support.";
-                }
-                
-                // Log the error with code for debugging
-                //console.log("Response data:", response.data);
-                //console.error("API Error:", errorMessage, "Code:", errorCode);
-                
-                // Format user-friendly error message
-                let displayMessage = errorMessage;
-                
-                // Customize message for admin users
-                if (mxchatChat.is_admin) {
-                    // For admin users, show more technical details including error code
-                    displayMessage = errorMessage + (errorCode ? " (Error code: " + errorCode + ")" : "");
-                }
-                
-                replaceLastMessage("bot", displayMessage);
-            },
-            error: function(xhr, status, error) {
-                console.error("AJAX Error:", status, error);
-                //console.log("Response Text:", xhr.responseText);
-                
-                let errorMessage = "An unexpected error occurred.";
-                
-                // Try to parse the response if it's JSON
-                try {
-                    const responseJson = JSON.parse(xhr.responseText);
-                    //console.log("Parsed error response:", responseJson);
-                    
-                    if (responseJson.data && responseJson.data.error_message) {
-                        errorMessage = responseJson.data.error_message;
-                    } else if (responseJson.message) {
-                        errorMessage = responseJson.message;
-                    }
-                } catch (e) {
-                    // Not JSON or parsing failed, use HTTP status based messages
-                    if (xhr.status === 0) {
-                        errorMessage = "Network error: Please check your internet connection.";
-                    } else if (xhr.status === 403) {
-                        errorMessage = "Access denied: Your session may have expired. Please refresh the page.";
-                    } else if (xhr.status === 404) {
-                        errorMessage = "API endpoint not found. Please contact support.";
-                    } else if (xhr.status === 429) {
-                        errorMessage = "Too many requests. Please try again in a moment.";
-                    } else if (xhr.status >= 500) {
-                        errorMessage = "Server error: The server encountered an issue. Please try again later.";
-                    }
-                }
-                
-                replaceLastMessage("bot", errorMessage);
-            }
-        });
-    }
+                }
+
+                processStream();
+            });
+        }
+
+        processStream();
+    })
+    .catch(error => {
+        console.error('Streaming error:', error);
+        callMxChat(message, callback);
+    });
+}
+
+// Function to update message during streaming
+function updateStreamingMessage(content) {
+    const formattedContent = linkify(formatBoldText(convertNewlinesToBreaks(formatCodeBlocks(content))));
+
+    // Find the temporary message
+    const tempMessage = $('.bot-message.temporary-message').last();
+
+    if (tempMessage.length) {
+        // Update existing message
+        tempMessage.html(formattedContent);
+    } else {
+        // Create new temporary message if it doesn't exist
+        appendMessage("bot", content, '', [], true);
+    }
+
+}
+
+// Function to check if streaming is supported for the current model
+function isStreamingSupported(model) {
+    if (!model) return false;
+
+    //console.log("Checking streaming support for model:", model); // Debug log
+
+    // Get the model prefix
+    const modelPrefix = model.split('-')[0].toLowerCase();
+    
+    //console.log("Model prefix:", modelPrefix); // Debug log
+
+    // Support streaming for OpenAI and Claude models
+    const isSupported = modelPrefix === 'gpt' || modelPrefix === 'o1' || modelPrefix === 'claude';
+    
+    //console.log("Streaming supported:", isSupported); // Debug log
+    
+    return isSupported;
+}
+
+// Update the event handlers to use the correct function names
+$('#send-button').off('click').on('click', function() {
+    sendMessage(); // Use the updated sendMessage function
+});
+
+// Override enter key handler
+$('#chat-input').off('keypress').on('keypress', function(e) {
+    if (e.which == 13 && !e.shiftKey) {
+        e.preventDefault();
+        sendMessage(); // Use the updated sendMessage function
+    }
+});
+
     
     function appendMessage(sender, messageText = '', messageHtml = '', images = [], isTemporary = false) {
@@ -777 +975 @@
     }
     
-    function checkForAgentMessages() {
-        const sessionId = getChatSession();
-        $.ajax({
-            url: mxchatChat.ajax_url,
-            type: 'POST',
-            dataType: 'json',
-            data: {
-                action: 'mxchat_fetch_new_messages',
-                session_id: sessionId,
-                last_seen_id: lastSeenMessageId,
-                nonce: mxchatChat.nonce
-            },
-            success: function (response) {
-                if (response.success && response.data?.new_messages) {
-                    let hasNewMessage = false;
-                    
-                    response.data.new_messages.forEach(function (message) {
-                        if (message.role === "agent" && !processedMessageIds.has(message.id)) {
-                            hasNewMessage = true;
-                            replaceLastMessage("agent", message.content);
-                            lastSeenMessageId = message.id;
-                            processedMessageIds.add(message.id);
-                        }
-                    });
-    
-                    if (hasNewMessage && $('#floating-chatbot').hasClass('hidden')) {
-                        showNotification();
+function checkForAgentMessages() {
+    const sessionId = getChatSession();
+    $.ajax({
+        url: mxchatChat.ajax_url,
+        type: 'POST',
+        dataType: 'json',
+        data: {
+            action: 'mxchat_fetch_new_messages',
+            session_id: sessionId,
+            last_seen_id: lastSeenMessageId,
+            persistence_enabled: 'true', // Add this too
+            nonce: mxchatChat.nonce
+        },
+        success: function (response) {
+            if (response.success && response.data?.new_messages) {
+                let hasNewMessage = false;
+                
+                response.data.new_messages.forEach(function (message) {
+                    if (message.role === "agent" && !processedMessageIds.has(message.id)) {
+                        hasNewMessage = true;
+                        // CHANGE THIS LINE:
+                        appendMessage("agent", message.content); // Instead of replaceLastMessage
+                        lastSeenMessageId = message.id;
+                        processedMessageIds.add(message.id);
                     }
-                    
-                    scrollToBottom(true);
-                }
-            },
-            error: function (xhr, status, error) {
-                console.error("Polling error:", xhr, status, error);
-            }
-        });
-    }
-
+                });
+
+                if (hasNewMessage && $('#floating-chatbot').hasClass('hidden')) {
+                    showNotification();
+                }
+                
+                scrollToBottom(true);
+            }
+        },
+        error: function (xhr, status, error) {
+            console.error("Polling error:", xhr, status, error);
+        }
+    });
+}
 
     // ====================================
@@ -1032 +1231 @@
     }
     
-    function checkInitialDocumentStatus() {
-        if (!sessionId) return;
-    
-        // Check PDF status
-        fetch(mxchatChat.ajax_url, {
-            method: 'POST',
-            headers: {
-                'Content-Type': 'application/x-www-form-urlencoded',
-            },
-            body: new URLSearchParams({
-                'action': 'mxchat_check_pdf_status',
-                'session_id': sessionId,
-                'nonce': mxchatChat.nonce
-            })
-        })
-        .then(response => response.json())
-        .then(data => {
-            if (data.success && data.data.filename) {
-                showActivePdf(data.data.filename);
-                activePdfFile = data.data.filename;
-            }
-        })
-        .catch(error => {
-            console.error('Error checking PDF status:', error);
-        });
-    
-        // Check Word document status
-        fetch(mxchatChat.ajax_url, {
-            method: 'POST',
-            headers: {
-                'Content-Type': 'application/x-www-form-urlencoded',
-            },
-            body: new URLSearchParams({
-                'action': 'mxchat_check_word_status',
-                'session_id': sessionId,
-                'nonce': mxchatChat.nonce
-            })
-        })
-        .then(response => response.json())
-        .then(data => {
-            if (data.success && data.data.filename) {
-                showActiveWord(data.data.filename);
-                activeWordFile = data.data.filename;
-            }
-        })
-        .catch(error => {
-            console.error('Error checking Word document status:', error);
-        });
-    }
-
-
     // ====================================
     // CONSENT & COMPLIANCE (GDPR)
@@ -1219 +1367 @@
     // ====================================
 
-    // Enter key handler for chat input
-    $('#chat-input').keypress(function(e) {
-        if (e.which == 13 && !e.shiftKey) { // Check if "Enter" is pressed without Shift
-            e.preventDefault(); // Prevent default "Enter" behavior
-            $('#send-button').click(); // Trigger send button click
-        }
-    });
-    
-    // Send button click handler
-    $('#send-button').click(function() {
-        sendMessage();
-    });
-    
     // Popular questions click handler
     $('.mxchat-popular-question').on('click', function () {
@@ -1282 +1417 @@
     $(document).on('click', '.mxchat-add-to-cart-button', function() {
         var productId = $(this).data('product-id');
+        
+        // Get the button text instead of hardcoded "add to cart"
+        var buttonText = $(this).text() || "add to cart";
+        
         // Add a special prefix to indicate this is from button
-        appendMessage("user", "add to cart");
+        appendMessage("user", buttonText);
         sendMessageToChatbot("!addtocart");  // Special command to indicate button click
     });
-    
+
     // PDF upload button handlers
     if (document.getElementById('pdf-upload-btn')) {
@@ -1674 +1813 @@
     }
 });
-
-// Initialize on page load
-document.addEventListener('DOMContentLoaded', function() {
-    checkInitialDocumentStatus();
-});

mxchat-basic/trunk/js/mxchat-admin.js

@@ -390 +390 @@
 
         // Handle all input changes (including range slider)
- $autosaveSections.find('input, textarea, select').on('change', function() {
-            const $field = $(this);
-            const name = $field.attr('name');
-            
-            // Skip saving for API key fields that haven't been interacted with and are empty
-            const isApiKeyField = name && (
-                name === 'loops_api_key' || 
-                name === 'api_key' || 
-                name === 'xai_api_key' || 
-                name === 'claude_api_key' ||
-                name === 'voyage_api_key' ||
-                name === 'gemini_api_key' ||
-                name === 'deepseek_api_key' ||
-                name.indexOf('_api_key') !== -1
-            );
-            
-            // Skip processing if:
-            // 1. It's an API key field
-            // 2. The user hasn't interacted with it
-            // 3. The field is empty
-            if (isApiKeyField && !userModifiedFields.has(name) && (!$field.val() || $field.val().trim() === '')) {
-                //console.log('Skipping auto-save for untouched API key field:', name);
-                return;
-            }
-            
-            let value;
-
-            // Handle different input types
-            if ($field.attr('type') === 'checkbox') {
-                // *** UPDATED: Handle Pinecone checkboxes differently ***
+         $autosaveSections.find('input, textarea, select').on('change', function() {
+                    const $field = $(this);
+                    const name = $field.attr('name');
+                    
+                    // Skip saving for API key fields that haven't been interacted with and are empty
+                    const isApiKeyField = name && (
+                        name === 'loops_api_key' || 
+                        name === 'api_key' || 
+                        name === 'xai_api_key' || 
+                        name === 'claude_api_key' ||
+                        name === 'voyage_api_key' ||
+                        name === 'gemini_api_key' ||
+                        name === 'deepseek_api_key' ||
+                        name.indexOf('_api_key') !== -1
+                    );
+                    
+                    // Skip processing if:
+                    // 1. It's an API key field
+                    // 2. The user hasn't interacted with it
+                    // 3. The field is empty
+                    if (isApiKeyField && !userModifiedFields.has(name) && (!$field.val() || $field.val().trim() === '')) {
+                        //console.log('Skipping auto-save for untouched API key field:', name);
+                        return;
+                    }
+                    
+                    let value;
+        
+                    // Handle different input types
+                    if ($field.attr('type') === 'checkbox') {
+                        // *** UPDATED: Handle Pinecone checkboxes differently ***
+                        if (name && name.indexOf('mxchat_pinecone_addon_options') !== -1) {
+                            value = $field.is(':checked') ? '1' : '0';
+                        } else {
+                            value = $field.is(':checked') ? 'on' : 'off';
+                        }
+                    } else {
+                        value = $field.val();
+                    }
+        
+                    // Create feedback container
+                    const feedbackContainer = $('<div class="feedback-container"></div>');
+                    const spinner = $('<div class="saving-spinner"></div>');
+                    const successIcon = $('<div class="success-icon">✔</div>');
+        
+                    // Position feedback container based on input type
+                    if ($field.closest('.toggle-switch').length) {
+                        $field.closest('td').append(feedbackContainer);
+                    } else if ($field.closest('.mxchat-toggle-switch').length) {
+                        $field.closest('.mxchat-toggle-container').append(feedbackContainer);
+                    } else if ($field.closest('.slider-container').length) {
+                        $field.closest('.slider-container').after(feedbackContainer);
+                    } else {
+                        $field.after(feedbackContainer);
+                    }
+                    feedbackContainer.append(spinner);
+        
+                    // Determine which AJAX action and nonce to use:
+                    var ajaxAction, nonce;
+                    // *** UPDATED: Add Pinecone fields to prompts action ***
+                    if (name.indexOf('mxchat_prompts_options') !== -1 ||
+                        name === 'mxchat_auto_sync_posts' || 
+                        name === 'mxchat_auto_sync_pages' ||
+                        name.indexOf('mxchat_auto_sync_') === 0 ||
+                        name.indexOf('mxchat_pinecone_addon_options') !== -1) { // *** ADD THIS LINE ***
+                        ajaxAction = 'mxchat_save_prompts_setting';
+                        nonce = mxchatPromptsAdmin.prompts_setting_nonce;
+                    } else {
+                        // Otherwise, use the existing AJAX action.
+                        ajaxAction = 'mxchat_save_setting';
+                        nonce = mxchatAdmin.setting_nonce;
+                    }
+        
+                    // *** ADD THIS: Debug logging for Pinecone fields ***
+                    if (name && name.indexOf('mxchat_pinecone_addon_options') !== -1) {
+                        //console.log('Saving Pinecone field:', name, '=', value);
+                    }
+        
+                    // AJAX save request
+                    $.ajax({
+                        url: (ajaxAction === 'mxchat_save_prompts_setting') ? mxchatPromptsAdmin.ajax_url : mxchatAdmin.ajax_url,
+                        type: 'POST',
+                        data: {
+                            action: ajaxAction,
+                            name: name,
+                            value: value,
+                            _ajax_nonce: nonce
+                        },
+                        success: function(response) {
+            if (response.success) {
+                spinner.fadeOut(200, function() {
+                    feedbackContainer.append(successIcon);
+                    successIcon.fadeIn(200).delay(1000).fadeOut(200, function() {
+                        feedbackContainer.remove();
+                    });
+                });
+                
+                // *** ADD THIS: Update Pinecone checkbox state after successful save ***
+                if (name && name.indexOf('mxchat_pinecone_addon_options[mxchat_use_pinecone]') !== -1) {
+                    //console.log('Pinecone toggle saved successfully, value:', value);
+                    
+                    // The checkbox state is already updated by the user interaction
+                    // But let's make sure the UI state matches the saved value
+                    var $checkbox = $('input[name="mxchat_pinecone_addon_options[mxchat_use_pinecone]"]');
+                    var settingsDiv = $('.mxchat-pinecone-settings');
+                    
+                    // Double-check the UI state matches what was saved
+                    if (value === '1' && !$checkbox.is(':checked')) {
+                        $checkbox.prop('checked', true);
+                        settingsDiv.slideDown(300);
+                    } else if (value === '0' && $checkbox.is(':checked')) {
+                        $checkbox.prop('checked', false);
+                        settingsDiv.slideUp(300);
+                    }
+                    
+                    //console.log('Pinecone UI state synchronized');
+                    
+                    // Check if Knowledge Import tab is currently active
+                    if ($('.mxchat-kb-tab-button[data-tab="import"]').hasClass('active')) {
+                        // Show a notice that we need to refresh
+                        var $knowledgeCard = $('#mxchat-kb-tab-import .mxchat-card').eq(1);
+                        if ($knowledgeCard.length > 0) {
+                            // Add a refresh notice at the top of the knowledge base card
+                            var refreshNotice = $('<div class="notice notice-warning" style="margin: 15px 0; padding: 10px 15px;">' +
+                                '<p style="margin: 0;">' +
+                                '<span class="dashicons dashicons-info" style="color: #f0ad4e; margin-right: 5px;"></span>' +
+                                'Database settings have changed. ' +
+                                '<a href="#" onclick="location.reload(); return false;" style="font-weight: bold;">Click here to refresh</a> to see the updated knowledge base.' +
+                                '</p></div>');
+                            
+                            $knowledgeCard.prepend(refreshNotice);
+                        }
+                    } else {
+                        // If not on import tab, set a flag to refresh when they go there
+                        sessionStorage.setItem('mxchat_pinecone_changed', 'true');
+                    }
+                }
+                
+                // *** ADD THIS: Debug logging for successful saves ***
                 if (name && name.indexOf('mxchat_pinecone_addon_options') !== -1) {
-                    value = $field.is(':checked') ? '1' : '0';
+                    //console.log('Pinecone field saved successfully:', name, '=', value);
+                }
+                
+                // Check if the response contains a "no changes" message and log it
+                if (response.data && response.data.message === 'No changes detected') {
+                    //console.log('No changes detected for field:', name);
+                }
+            } else {
+                // Only show alert for actual errors, not for "no changes"
+                let errorMessage = response.data?.message || 'Unknown error';
+                
+                // Don't display an alert for "no changes" message
+                if (errorMessage !== 'No changes detected' && errorMessage !== 'Update failed or no changes') {
+                    alert('Error saving: ' + errorMessage);
                 } else {
-                    value = $field.is(':checked') ? 'on' : 'off';
-                }
-            } else {
-                value = $field.val();
-            }
-
-            // Create feedback container
-            const feedbackContainer = $('<div class="feedback-container"></div>');
-            const spinner = $('<div class="saving-spinner"></div>');
-            const successIcon = $('<div class="success-icon">✔</div>');
-
-            // Position feedback container based on input type
-            if ($field.closest('.toggle-switch').length) {
-                $field.closest('td').append(feedbackContainer);
-            } else if ($field.closest('.mxchat-toggle-switch').length) {
-                $field.closest('.mxchat-toggle-container').append(feedbackContainer);
-            } else if ($field.closest('.slider-container').length) {
-                $field.closest('.slider-container').after(feedbackContainer);
-            } else {
-                $field.after(feedbackContainer);
-            }
-            feedbackContainer.append(spinner);
-
-            // Determine which AJAX action and nonce to use:
-            var ajaxAction, nonce;
-            // *** UPDATED: Add Pinecone fields to prompts action ***
-            if (name.indexOf('mxchat_prompts_options') !== -1 ||
-                name === 'mxchat_auto_sync_posts' || 
-                name === 'mxchat_auto_sync_pages' ||
-                name.indexOf('mxchat_auto_sync_') === 0 ||
-                name.indexOf('mxchat_pinecone_addon_options') !== -1) { // *** ADD THIS LINE ***
-                ajaxAction = 'mxchat_save_prompts_setting';
-                nonce = mxchatPromptsAdmin.prompts_setting_nonce;
-            } else {
-                // Otherwise, use the existing AJAX action.
-                ajaxAction = 'mxchat_save_setting';
-                nonce = mxchatAdmin.setting_nonce;
-            }
-
-            // *** ADD THIS: Debug logging for Pinecone fields ***
-            if (name && name.indexOf('mxchat_pinecone_addon_options') !== -1) {
-                //console.log('Saving Pinecone field:', name, '=', value);
-            }
-
-            // AJAX save request
-            $.ajax({
-                url: (ajaxAction === 'mxchat_save_prompts_setting') ? mxchatPromptsAdmin.ajax_url : mxchatAdmin.ajax_url,
-                type: 'POST',
-                data: {
-                    action: ajaxAction,
-                    name: name,
-                    value: value,
-                    _ajax_nonce: nonce
-                },
-                success: function(response) {
-    if (response.success) {
-        spinner.fadeOut(200, function() {
-            feedbackContainer.append(successIcon);
-            successIcon.fadeIn(200).delay(1000).fadeOut(200, function() {
-                feedbackContainer.remove();
-            });
-        });
-        
-        // *** ADD THIS: Update Pinecone checkbox state after successful save ***
-        if (name && name.indexOf('mxchat_pinecone_addon_options[mxchat_use_pinecone]') !== -1) {
-            //console.log('Pinecone toggle saved successfully, value:', value);
-            
-            // The checkbox state is already updated by the user interaction
-            // But let's make sure the UI state matches the saved value
-            var $checkbox = $('input[name="mxchat_pinecone_addon_options[mxchat_use_pinecone]"]');
-            var settingsDiv = $('.mxchat-pinecone-settings');
-            
-            // Double-check the UI state matches what was saved
-            if (value === '1' && !$checkbox.is(':checked')) {
-                $checkbox.prop('checked', true);
-                settingsDiv.slideDown(300);
-            } else if (value === '0' && $checkbox.is(':checked')) {
-                $checkbox.prop('checked', false);
-                settingsDiv.slideUp(300);
-            }
-            
-            //console.log('Pinecone UI state synchronized');
-            
-            // Check if Knowledge Import tab is currently active
-            if ($('.mxchat-kb-tab-button[data-tab="import"]').hasClass('active')) {
-                // Show a notice that we need to refresh
-                var $knowledgeCard = $('#mxchat-kb-tab-import .mxchat-card').eq(1);
-                if ($knowledgeCard.length > 0) {
-                    // Add a refresh notice at the top of the knowledge base card
-                    var refreshNotice = $('<div class="notice notice-warning" style="margin: 15px 0; padding: 10px 15px;">' +
-                        '<p style="margin: 0;">' +
-                        '<span class="dashicons dashicons-info" style="color: #f0ad4e; margin-right: 5px;"></span>' +
-                        'Database settings have changed. ' +
-                        '<a href="#" onclick="location.reload(); return false;" style="font-weight: bold;">Click here to refresh</a> to see the updated knowledge base.' +
-                        '</p></div>');
-                    
-                    $knowledgeCard.prepend(refreshNotice);
-                }
-            } else {
-                // If not on import tab, set a flag to refresh when they go there
-                sessionStorage.setItem('mxchat_pinecone_changed', 'true');
-            }
-        }
-        
-        // *** ADD THIS: Debug logging for successful saves ***
-        if (name && name.indexOf('mxchat_pinecone_addon_options') !== -1) {
-            //console.log('Pinecone field saved successfully:', name, '=', value);
-        }
-        
-        // Check if the response contains a "no changes" message and log it
-        if (response.data && response.data.message === 'No changes detected') {
-            //console.log('No changes detected for field:', name);
-        }
-    } else {
-        // Only show alert for actual errors, not for "no changes"
-        let errorMessage = response.data?.message || 'Unknown error';
-        
-        // Don't display an alert for "no changes" message
-        if (errorMessage !== 'No changes detected' && errorMessage !== 'Update failed or no changes') {
-            alert('Error saving: ' + errorMessage);
-        } else {
-            // Still provide visual feedback that no changes were needed
-            spinner.fadeOut(200, function() {
-                feedbackContainer.append(successIcon);
-                successIcon.fadeIn(200).delay(1000).fadeOut(200, function() {
-                    feedbackContainer.remove();
-                });
-            });
-            //console.log('No changes detected for field:', name);
-            return;
-        }
-        
-        // Only revert checkbox state if it was an actual error
-        if (errorMessage !== 'No changes detected' && errorMessage !== 'Update failed or no changes') {
-            if ($field.attr('type') === 'checkbox') {
-                $field.prop('checked', !$field.is(':checked'));
-            }
-        }
-        
-        // Always clean up the feedback container
-        feedbackContainer.remove();
-    }
-},
-                error: function(xhr, textStatus, error) {
-                    //console.error('AJAX Error:', textStatus, error);
-                    alert('An error occurred while saving. Please try again.');
-                    
-                    // Revert checkbox state on error
+                    // Still provide visual feedback that no changes were needed
+                    spinner.fadeOut(200, function() {
+                        feedbackContainer.append(successIcon);
+                        successIcon.fadeIn(200).delay(1000).fadeOut(200, function() {
+                            feedbackContainer.remove();
+                        });
+                    });
+                    //console.log('No changes detected for field:', name);
+                    return;
+                }
+                
+                // Only revert checkbox state if it was an actual error
+                if (errorMessage !== 'No changes detected' && errorMessage !== 'Update failed or no changes') {
                     if ($field.attr('type') === 'checkbox') {
                         $field.prop('checked', !$field.is(':checked'));
                     }
-                    
-                    feedbackContainer.remove();
-                }
-            });
-        });
+                }
+                
+                // Always clean up the feedback container
+                feedbackContainer.remove();
+            }
+        },
+                        error: function(xhr, textStatus, error) {
+                            //console.error('AJAX Error:', textStatus, error);
+                            alert('An error occurred while saving. Please try again.');
+                            
+                            // Revert checkbox state on error
+                            if ($field.attr('type') === 'checkbox') {
+                                $field.prop('checked', !$field.is(':checked'));
+                            }
+                            
+                            feedbackContainer.remove();
+                        }
+                    });
+                });
 
         // Initialize color pickers with debouncing

mxchat-basic/trunk/mxchat-basic.php

@@ -3 +3 @@
  * Plugin Name: MxChat
  * Description: AI chatbot for WordPress with OpenAI, Claude, xAI, DeepSeek, live agent, PDF uploads, WooCommerce, and training on website data.
- * Version: 2.2.4
+ * Version: 2.2.5
  * Author: MxChat
  * Author URI: https://mxchat.ai
@@ -17 +17 @@
 
 // Define plugin version constant for asset versioning
-define('MXCHAT_VERSION', '2.2.4');
+define('MXCHAT_VERSION', '2.2.5');
 
 function mxchat_load_textdomain() {

mxchat-basic/trunk/readme.txt

@@ -6 +6 @@
 Tested up to: 6.8
 Requires PHP: 7.2
-Stable tag: 2.2.4
+Stable tag: 2.2.5
 License: GPLv2 or later
 License URI: https://www.gnu.org/licenses/gpl-2.0.html
@@ -18 +18 @@
 ### Product Demo Videos:
 - [Admin Assistant Add-On](https://www.youtube.com/watch?v=AdEA1k-UCFM) - Discover how to use the MxChat Admin Assistant to bring a ChatGPT-like experience directly inside your WordPress dashboard. Learn to access multiple AI models, save conversations, generate images, and use web search - all without leaving your admin panel.
+- [AI Theme Generator (Part of Theme Customizer Add-On)](https://www.youtube.com/watch?v=rSQDW2qbtRU&t) - Transform your chatbot's appearance in seconds with our revolutionary AI-powered theme generator! Just describe your ideal design and watch as AI creates and applies custom CSS styling in real-time. No coding required. Supports GPT-4, Claude, Gemini, and more.
+- [Theme Customizer Add-On](https://www.youtube.com/watch?v=MfbB9mZi6ag) - Learn how to customize your chatbot appearance with the Theme Customizer add-on. Easily modify colors, fonts, and styles with real-time previews to match your brand perfectly.
 - [MxChat Forms Add-On](https://www.youtube.com/watch?v=3MrWy5dRalA) - Effortlessly create forms to capture leads, support tickets, and more with MxChat Forms!
-- [Theme Customizer Add-On](https://www.youtube.com/watch?v=MfbB9mZi6ag) - Learn how to customize your chatbot appearance with the Theme Customizer add-on. Easily modify colors, fonts, and styles with real-time previews to match your brand perfectly.
 - [MxChat Similarity Tester Add-On](https://www.youtube.com/watch?v=uTr14tn59Hc) - Visualize how your chatbot’s actions perform and which data would be pulled from the database for improved accuracy.
 - [WooCommerce Add-On](https://www.youtube.com/watch?v=WsqAppHRGdA) - Display product cards, recommend items, guide users to checkout, and supercharge your store.
@@ -46 +47 @@
 
 - **Pro Features:**  
-  Upgrade to the Pro tier to unlock advanced tools and functionality built directly into MxChat, plus access to all available add-ons: 
+  Upgrade to the Pro tier to unlock advanced tools and functionality built directly into MxChat, plus access to all available add-ons:  
   - **Full Access to the MxChat Add-on Ecosystem**: Unlock our complete library of specialized extensions to create a truly customized chatbot experience tailored to your business needs—with new integrations added regularly.  
   - **Live Agent Transfer via Slack**: Seamlessly connect users to live agents for real-time support.  
   - **PDF Content Processing**: Enable in-chat processing of PDF content for richer interactions.  
   - **Robust Action Recognition System**: Power precise and context-aware chatbot responses.  
+  - **AI Theme Generator**: Instantly transform your chatbot’s design using natural language. Describe your ideal look—like “modern dark theme with gold accents”—and AI will generate custom CSS with real-time preview and one-click apply. No coding needed.  
   - **Exclusive Access to MxChat AI Agents**: Test and deploy your chatbot with [MxChat AI Agents](https://mxchat.ai/agents/), a revolutionary tool to simulate real-world scenarios and refine performance.
 
@@ -57 +59 @@
 
 - **MxChat Similarity Tester (Free for All Users)** – Optimize action recognition with query testing, similarity scores, and database insights—perfect for admins enhancing chatbot precision.  
-- **MxChat Admin Assistant (Pro Only)** - Experience a ChatGPT-like interface directly in your WordPress admin panel, with chat thread management, image generation capabilities, and Perplexity search integration—all using your existing MxChat API keys.
+- **MxChat Admin Assistant (Pro Only)** - Experience a ChatGPT-like interface directly in your WordPress admin panel, with chat thread management, image generation capabilities, and Perplexity search integration—all using your existing MxChat API keys.  
 - **MxChat Forms (Pro Only)** – Enable chatbot-triggered form collection with seamless creation, management, and real-time display in chat—exclusive to Pro users.  
-- **Theme Customization with Live Preview (Pro Only)** – Unlock full theme customization with real-time previews to adjust colors, layouts, and styles dynamically—exclusive to Pro users.  
+- **Theme Customizer with AI Generator & Live Preview (Pro Only)** – Instantly redesign your chatbot using natural language prompts like "dark mode with gold accents." The AI generates and applies CSS themes with real-time preview, supporting GPT-4, Claude, Gemini, and more. Easily fine-tune styles like color, layout, and font—no coding needed.  
 - **Chat Moderation (Pro Only)** – Maintain a secure chat environment with advanced moderation tools, including email and IP banning—available only for Pro users.  
 - **MxChat WooCommerce (Pro Only)** – Supercharge your WooCommerce store with AI-powered chat interactions, including product recommendations, order history, cart management, and checkout assistance.  
-- **MxChat Perplexity Integration (Pro Only)** – Add real-time web search capabilities powered by Perplexity AI, delivering up-to-date, well-sourced responses—exclusive to Pro users.
+- **MxChat Perplexity Integration (Pro Only)** – Add real-time web search capabilities powered by Perplexity AI, delivering up-to-date, well-sourced responses—exclusive to Pro users.  
 - **MxChat Smart Recommender (Pro Only)** – Create intelligent recommendation flows that collect user preferences and provide personalized product or service recommendations from your custom collections. Features customizable similarity thresholds, trigger phrases, and AI prompt templates for tailored recommendation experiences with no coding required.
 
 The MxChat Add-On Ecosystem offers flexibility to customize and scale your chatbot experience. Stay tuned for more add-ons coming soon!
 
-## New in 2.2.2
-- **Enhanced Slack Integration** – Live agent handoff via Slack now creates new channels for each incoming conversation. Live agents can reply directly within the Slack channel to chat with users on your website in real-time.
-- **Major Codebase Refactoring** – Significant refactoring for improved code organization, performance, and maintainability.
-- **Improved Sitemap & PDF Processing** – Enhanced robustness with a new retry mechanism. Failed pages or URLs are now displayed for review. Added manual batch processing button for situations where scheduled (cron) jobs do not run.
-- **Pinecone Setting Fix** – Resolved an issue where Pinecone integration was not automatically enabled for users who previously did not have the Pinecone add-on.
+## New in 2.2.5
+- **Streaming Response Support** – You can now enable streaming responses for OpenAI and Claude models. This delivers a faster, smoother chat experience for users by displaying replies in real-time as they’re generated.
+- **Slack Live Agent Fix** – Resolved a minor bug that occasionally caused duplicate messages in Slack during live agent conversations.
+- **Pinecone UI Update** – Fixed a UI display issue in the Pinecone database panel when using the TE3 model.
 
 ### Advanced Action Recognition
@@ -175 +176 @@
 == Changelog ==
 
+= 2.2.5 =
+- Streaming Response Support – You can now enable streaming responses for OpenAI and Claude models. This delivers a faster, smoother chat experience for users by displaying replies in real-time as they’re generated.
+- Slack Live Agent Fix – Resolved a minor bug that occasionally caused duplicate messages in Slack during live agent conversations.
+- Pinecone UI Update – Fixed a UI display issue in the Pinecone database panel when using the TE3 model.
+
 = 2.2.4 =
 - Critical update to error when working with large databases in Pinecone.
@@ -510 +516 @@
 == Upgrade Notice ==
 
-= 2.2.4 =
-Critical update to error when working with large databases in Pinecone.
+= 2.2.5 =
+New streaming response support for OpenAI and Claude, plus important fixes for Slack live agent messaging and Pinecone UI display.
 
 == License & Warranty ==