Merge branch 'feat/CW-6153' into feature/cw-6144

Co-authored-by: Shivam Mishra <scm.mymail@gmail.com>
Co-authored-by: Aakash Bakhle <48802744+aakashb95@users.noreply.github.com>
Fixes https://linear.app/chatwoot/issue/CW-5648/reply-editor-ai-changes

AGENTS.md

@@ -48,7 +48,6 @@
 - Remove dead/unreachable/unused code
 - Don’t write multiple versions or backups for the same logic — pick the best approach and implement it
 - Don't reference Claude in commit messages
-- Prefer `with_modified_env` (from spec helpers) over stubbing `ENV` directly in specs
 
 ## Project-Specific
 
@@ -79,4 +78,3 @@ Practical checklist for any change impacting core logic or public APIs
 - Keep request/response contracts stable across OSS and Enterprise; update both sets of routes/controllers when introducing new APIs.
 - When renaming/moving shared code, mirror the change in `enterprise/` to prevent drift.
 - Tests: Add Enterprise-specific specs under `spec/enterprise`, mirroring OSS spec layout where applicable.
-- When modifying existing OSS features for Enterprise-only behavior, add an Enterprise module (via `prepend_mod_with`/`include_mod_with`) instead of editing OSS files directly—especially for policies, controllers, and services. For Enterprise-exclusive features, place code directly under `enterprise/`.

app/builders/year_in_review_builder.rb

@@ -1,74 +0,0 @@
-class YearInReviewBuilder
-  attr_reader :account, :user_id, :year
-
-  def initialize(account:, user_id:, year:)
-    @account = account
-    @user_id = user_id
-    @year = year
-  end
-
-  def build
-    {
-      year: year,
-      total_conversations: total_conversations_count,
-      busiest_day: busiest_day_data,
-      support_personality: support_personality_data
-    }
-  end
-
-  private
-
-  def year_range
-    @year_range ||= begin
-      start_time = Time.zone.local(year, 1, 1).beginning_of_day
-      end_time = Time.zone.local(year, 12, 31).end_of_day
-      start_time..end_time
-    end
-  end
-
-  def total_conversations_count
-    account.conversations
-           .where(assignee_id: user_id, created_at: year_range)
-           .count
-  end
-
-  def busiest_day_data
-    daily_counts = account.conversations
-                          .where(assignee_id: user_id, created_at: year_range)
-                          .group_by_day(:created_at, range: year_range, time_zone: Time.zone)
-                          .count
-
-    return nil if daily_counts.empty?
-
-    busiest_date, count = daily_counts.max_by { |_date, cnt| cnt }
-
-    return nil if count.zero?
-
-    {
-      date: busiest_date.strftime('%b %d'),
-      count: count
-    }
-  end
-
-  def support_personality_data
-    response_time = average_response_time
-
-    return { avg_response_time_seconds: 0 } if response_time.nil?
-
-    {
-      avg_response_time_seconds: response_time.to_i
-    }
-  end
-
-  def average_response_time
-    avg_time = account.reporting_events
-                      .where(
-                        name: 'first_response',
-                        user_id: user_id,
-                        created_at: year_range
-                      )
-                      .average(:value)
-
-    avg_time&.to_f
-  end
-end

app/controllers/api/v2/accounts/year_in_reviews_controller.rb

@@ -1,26 +0,0 @@
-class Api::V2::Accounts::YearInReviewsController < Api::V1::Accounts::BaseController
-  def show
-    year = params[:year] || 2025
-    cache_key = "year_in_review_#{Current.account.id}_#{year}"
-
-    cached_data = Current.user.ui_settings&.dig(cache_key)
-
-    if cached_data.present?
-      render json: cached_data
-    else
-      builder = YearInReviewBuilder.new(
-        account: Current.account,
-        user_id: Current.user.id,
-        year: year
-      )
-
-      data = builder.build
-
-      ui_settings = Current.user.ui_settings || {}
-      ui_settings[cache_key] = data
-      Current.user.update(ui_settings: ui_settings)
-
-      render json: data
-    end
-  end
-end

app/javascript/dashboard/api/captain/editor.js

@@ -0,0 +1,113 @@
+/* global axios */
+import ApiClient from '../ApiClient';
+
+/**
+ * A client for the Captain Editor API.
+ * @extends ApiClient
+ */
+class EditorAPI extends ApiClient {
+  /**
+   * Creates a new EditorAPI instance.
+   */
+  constructor() {
+    super('captain/editor', { accountScoped: true });
+  }
+
+  /**
+   * Processes an event using the Captain Editor API.
+   * @param {Object} options - The options for the event.
+   * @param {string} [options.type='improve'] - The type of event to process.
+   * @param {string} [options.content] - The content of the event.
+   * @param {string} [options.conversationId] - The ID of the conversation to process the event for.
+   * @param {AbortSignal} [signal] - AbortSignal to cancel the request.
+   * @returns {Promise} A promise that resolves with the result of the event processing.
+   */
+  processEvent({ type = 'improve', content, conversationId }, signal) {
+    // Route to appropriate endpoint based on type
+    if (type === 'summarize') {
+      return this.summarize(conversationId, signal);
+    }
+
+    if (type === 'reply_suggestion') {
+      return this.replySuggestion(conversationId, signal);
+    }
+
+    if (type === 'label_suggestion') {
+      return this.labelSuggestion(conversationId, signal);
+    }
+
+    // All other types are rewrite operations
+    return this.rewrite({ content, operation: type, conversationId }, signal);
+  }
+
+  /**
+   * Rewrites content with a specific operation.
+   * @param {Object} options - The rewrite options.
+   * @param {string} options.content - The content to rewrite.
+   * @param {string} options.operation - The rewrite operation (fix_spelling_grammar, casual, professional, etc).
+   * @param {string} [options.conversationId] - The conversation ID for context (required for 'improve').
+   * @param {AbortSignal} [signal] - AbortSignal to cancel the request.
+   * @returns {Promise} A promise that resolves with the rewritten content.
+   */
+  rewrite({ content, operation, conversationId }, signal) {
+    return axios.post(
+      `${this.url}/rewrite`,
+      {
+        content,
+        operation,
+        conversation_display_id: conversationId,
+      },
+      { signal }
+    );
+  }
+
+  /**
+   * Summarizes a conversation.
+   * @param {string} conversationId - The conversation ID to summarize.
+   * @param {AbortSignal} [signal] - AbortSignal to cancel the request.
+   * @returns {Promise} A promise that resolves with the summary.
+   */
+  summarize(conversationId, signal) {
+    return axios.post(
+      `${this.url}/summarize`,
+      {
+        conversation_display_id: conversationId,
+      },
+      { signal }
+    );
+  }
+
+  /**
+   * Gets a reply suggestion for a conversation.
+   * @param {string} conversationId - The conversation ID.
+   * @param {AbortSignal} [signal] - AbortSignal to cancel the request.
+   * @returns {Promise} A promise that resolves with the reply suggestion.
+   */
+  replySuggestion(conversationId, signal) {
+    return axios.post(
+      `${this.url}/reply_suggestion`,
+      {
+        conversation_display_id: conversationId,
+      },
+      { signal }
+    );
+  }
+
+  /**
+   * Gets label suggestions for a conversation.
+   * @param {string} conversationId - The conversation ID.
+   * @param {AbortSignal} [signal] - AbortSignal to cancel the request.
+   * @returns {Promise} A promise that resolves with label suggestions.
+   */
+  labelSuggestion(conversationId, signal) {
+    return axios.post(
+      `${this.url}/label_suggestion`,
+      {
+        conversation_display_id: conversationId,
+      },
+      { signal }
+    );
+  }
+}
+
+export default new EditorAPI();

app/javascript/dashboard/api/integrations/openapi.js

@@ -1,81 +0,0 @@
-/* global axios */
-
-import ApiClient from '../ApiClient';
-
-/**
- * Represents the data object for a OpenAI hook.
- * @typedef {Object} ConversationMessageData
- * @property {string} [tone] - The tone of the message.
- * @property {string} [content] - The content of the message.
- * @property {string} [conversation_display_id] - The display ID of the conversation (optional).
- */
-
-/**
- * A client for the OpenAI API.
- * @extends ApiClient
- */
-class OpenAIAPI extends ApiClient {
-  /**
-   * Creates a new OpenAIAPI instance.
-   */
-  constructor() {
-    super('integrations', { accountScoped: true });
-
-    /**
-     * The conversation events supported by the API.
-     * @type {string[]}
-     */
-    this.conversation_events = [
-      'summarize',
-      'reply_suggestion',
-      'label_suggestion',
-    ];
-
-    /**
-     * The message events supported by the API.
-     * @type {string[]}
-     */
-    this.message_events = ['rephrase'];
-  }
-
-  /**
-   * Processes an event using the OpenAI API.
-   * @param {Object} options - The options for the event.
-   * @param {string} [options.type='rephrase'] - The type of event to process.
-   * @param {string} [options.content] - The content of the event.
-   * @param {string} [options.tone] - The tone of the event.
-   * @param {string} [options.conversationId] - The ID of the conversation to process the event for.
-   * @param {string} options.hookId - The ID of the hook to use for processing the event.
-   * @returns {Promise} A promise that resolves with the result of the event processing.
-   */
-  processEvent({ type = 'rephrase', content, tone, conversationId, hookId }) {
-    /**
-     * @type {ConversationMessageData}
-     */
-    let data = {
-      tone,
-      content,
-    };
-
-    // Always include conversation_display_id when available for session tracking
-    if (conversationId) {
-      data.conversation_display_id = conversationId;
-    }
-
-    // For conversation-level events, only send conversation_display_id
-    if (this.conversation_events.includes(type)) {
-      data = {
-        conversation_display_id: conversationId,
-      };
-    }
-
-    return axios.post(`${this.url}/hooks/${hookId}/process_event`, {
-      event: {
-        name: type,
-        data,
-      },
-    });
-  }
-}
-
-export default new OpenAIAPI();

app/javascript/dashboard/api/yearInReview.js

@@ -1,16 +0,0 @@
-/* global axios */
-import ApiClient from './ApiClient';
-
-class YearInReviewAPI extends ApiClient {
-  constructor() {
-    super('year_in_review', { accountScoped: true, apiVersion: 'v2' });
-  }
-
-  get(year) {
-    return axios.get(`${this.url}`, {
-      params: { year },
-    });
-  }
-}
-
-export default new YearInReviewAPI();

app/javascript/dashboard/assets/scss/_next-colors.scss

@@ -94,6 +94,19 @@
     --gray-11: 100 100 100;
     --gray-12: 32 32 32;
 
+    --violet-1: 253 252 254;
+    --violet-2: 250 248 255;
+    --violet-3: 244 240 254;
+    --violet-4: 235 228 255;
+    --violet-5: 225 217 255;
+    --violet-6: 212 202 254;
+    --violet-7: 194 178 248;
+    --violet-8: 169 153 236;
+    --violet-9: 110 86 207;
+    --violet-10: 100 84 196;
+    --violet-11: 101 85 183;
+    --violet-12: 47 38 95;
+
     --background-color: 253 253 253;
     --text-blue: 8 109 224;
     --border-container: 236 236 236;
@@ -209,6 +222,19 @@
     --gray-11: 180 180 180;
     --gray-12: 238 238 238;
 
+    --violet-1: 20 17 31;
+    --violet-2: 27 21 37;
+    --violet-3: 41 31 67;
+    --violet-4: 50 37 85;
+    --violet-5: 60 46 105;
+    --violet-6: 71 56 135;
+    --violet-7: 86 70 151;
+    --violet-8: 110 86 171;
+    --violet-9: 110 86 207;
+    --violet-10: 125 109 217;
+    --violet-11: 169 153 236;
+    --violet-12: 226 221 254;
+
     --background-color: 18 18 19;
     --border-strong: 52 52 52;
     --border-weak: 38 38 42;

app/javascript/dashboard/components-next/sidebar/Sidebar.vue

@@ -14,7 +14,6 @@ import Button from 'dashboard/components-next/button/Button.vue';
 import SidebarGroup from './SidebarGroup.vue';
 import SidebarProfileMenu from './SidebarProfileMenu.vue';
 import SidebarChangelogCard from './SidebarChangelogCard.vue';
-import YearInReviewBanner from '../year-in-review/YearInReviewBanner.vue';
 import ChannelLeaf from './ChannelLeaf.vue';
 import SidebarAccountSwitcher from './SidebarAccountSwitcher.vue';
 import Logo from 'next/icon/Logo.vue';
@@ -652,7 +651,6 @@ const menuItems = computed(() => {
       <div
         class="pointer-events-none absolute inset-x-0 -top-[31px] h-8 bg-gradient-to-t from-n-solid-2 to-transparent"
       />
-      <YearInReviewBanner />
       <SidebarChangelogCard
         v-if="isOnChatwootCloud && !isACustomBrandedInstance"
       />

app/javascript/dashboard/components-next/sidebar/SidebarProfileMenu.vue

@@ -1,14 +1,11 @@
 <script setup>
-import { ref, computed } from 'vue';
-import { useRoute } from 'vue-router';
+import { computed } from 'vue';
 import Auth from 'dashboard/api/auth';
 import { useMapGetter } from 'dashboard/composables/store';
 import { useI18n } from 'vue-i18n';
-import { useUISettings } from 'dashboard/composables/useUISettings';
 import Avatar from 'next/avatar/Avatar.vue';
 import SidebarProfileMenuStatus from './SidebarProfileMenuStatus.vue';
 import { FEATURE_FLAGS } from 'dashboard/featureFlags';
-import YearInReviewModal from 'dashboard/components-next/year-in-review/YearInReviewModal.vue';
 
 import {
   DropdownContainer,
@@ -25,8 +22,6 @@ defineOptions({
 });
 
 const { t } = useI18n();
-const route = useRoute();
-const { uiSettings } = useUISettings();
 
 const currentUser = useMapGetter('getCurrentUser');
 const currentUserAvailability = useMapGetter('getCurrentUserAvailability');
@@ -36,29 +31,6 @@ const isFeatureEnabledonAccount = useMapGetter(
   'accounts/isFeatureEnabledonAccount'
 );
 
-const showYearInReviewModal = ref(false);
-
-const bannerClosedKey = computed(() => {
-  return `yir_closed_${accountId.value}_2025`;
-});
-
-const isBannerClosed = computed(() => {
-  return uiSettings.value?.[bannerClosedKey.value] === true;
-});
-
-const showYearInReviewMenuItem = computed(() => {
-  return route.query['year-in-review'] === 'true' && isBannerClosed.value;
-});
-
-const openYearInReviewModal = () => {
-  showYearInReviewModal.value = true;
-  emit('close');
-};
-
-const closeYearInReviewModal = () => {
-  showYearInReviewModal.value = false;
-};
-
 const showChatSupport = computed(() => {
   return (
     isFeatureEnabledonAccount.value(
@@ -70,13 +42,6 @@ const showChatSupport = computed(() => {
 
 const menuItems = computed(() => {
   return [
-    {
-      show: showYearInReviewMenuItem.value,
-      showOnCustomBrandedInstance: false,
-      label: t('SIDEBAR_ITEMS.YEAR_IN_REVIEW'),
-      icon: 'i-lucide-gift',
-      click: openYearInReviewModal,
-    },
     {
       show: showChatSupport.value,
       showOnCustomBrandedInstance: false,
@@ -192,9 +157,4 @@ const allowedMenuItems = computed(() => {
       </template>
     </DropdownBody>
   </DropdownContainer>
-
-  <YearInReviewModal
-    :show="showYearInReviewModal"
-    @close="closeYearInReviewModal"
-  />
 </template>

app/javascript/dashboard/components-next/year-in-review/ShareModal.vue

@@ -1,247 +0,0 @@
-<script setup>
-import { ref } from 'vue';
-import { useI18n } from 'vue-i18n';
-import { toPng } from 'html-to-image';
-
-const props = defineProps({
-  show: {
-    type: Boolean,
-    default: false,
-  },
-  slideElement: {
-    type: Object,
-    default: null,
-  },
-  slideBackground: {
-    type: String,
-    required: true,
-  },
-  year: {
-    type: [Number, String],
-    required: true,
-  },
-});
-
-const emit = defineEmits(['close']);
-
-const { t } = useI18n();
-
-const isGenerating = ref(false);
-const shareImageUrl = ref(null);
-const shareImageBlob = ref(null);
-
-const generateImage = async () => {
-  if (!props.slideElement) return;
-
-  isGenerating.value = true;
-  try {
-    let slideElement = props.slideElement;
-
-    if (slideElement && '$el' in slideElement) {
-      slideElement = slideElement.$el;
-    }
-
-    if (!slideElement) {
-      // eslint-disable-next-line no-console
-      console.error('No slide element found');
-      return;
-    }
-
-    const colorMap = {
-      'bg-[#5BD58A]': '#5BD58A',
-      'bg-[#60a5fa]': '#60a5fa',
-      'bg-[#fb923c]': '#fb923c',
-      'bg-[#f87171]': '#f87171',
-      'bg-[#fbbf24]': '#fbbf24',
-    };
-    const bgColor = colorMap[props.slideBackground] || '#ffffff';
-
-    const dataUrl = await toPng(slideElement, {
-      quality: 2,
-      pixelRatio: 1.2,
-      backgroundColor: bgColor,
-    });
-
-    const img = new Image();
-    img.src = dataUrl;
-    await new Promise(resolve => {
-      img.onload = resolve;
-    });
-
-    const finalCanvas = document.createElement('canvas');
-    const borderSize = 20;
-    const bottomPadding = 50;
-
-    finalCanvas.width = img.width + borderSize * 2;
-    finalCanvas.height = img.height + borderSize * 2 + bottomPadding;
-
-    const ctx = finalCanvas.getContext('2d');
-
-    ctx.fillStyle = 'white';
-    ctx.fillRect(0, 0, finalCanvas.width, finalCanvas.height);
-
-    ctx.drawImage(img, borderSize, borderSize);
-
-    ctx.fillStyle = '#1f2d3d';
-    ctx.font = 'normal 16px system-ui, -apple-system, sans-serif';
-    ctx.textAlign = 'left';
-    ctx.fillText(
-      t('YEAR_IN_REVIEW.SHARE_MODAL.BRANDING'),
-      borderSize,
-      img.height + borderSize + 35
-    );
-
-    const logo = new Image();
-    logo.src = window.location.origin + '/brand-assets/logo.svg';
-    await new Promise(resolve => {
-      logo.onload = resolve;
-    });
-
-    const logoHeight = 30;
-    const logoWidth = (logo.width / logo.height) * logoHeight;
-    const logoX = finalCanvas.width - borderSize - logoWidth;
-    const logoY = img.height + borderSize + 15;
-
-    ctx.drawImage(logo, logoX, logoY, logoWidth, logoHeight);
-
-    shareImageUrl.value = finalCanvas.toDataURL('image/png');
-    shareImageBlob.value = await new Promise(resolve => {
-      finalCanvas.toBlob(resolve, 'image/png');
-    });
-  } catch (err) {
-    // Handle errors silently for now
-    // eslint-disable-next-line no-console
-    console.error('Failed to generate image:', err);
-  } finally {
-    isGenerating.value = false;
-  }
-};
-
-const downloadImage = () => {
-  if (!shareImageUrl.value) return;
-
-  const link = document.createElement('a');
-  link.href = shareImageUrl.value;
-  link.download = `chatwoot-year-in-review-${props.year}.png`;
-  link.click();
-};
-
-const shareImage = async () => {
-  if (!shareImageUrl.value) return;
-
-  try {
-    if (!shareImageBlob.value) {
-      downloadImage();
-      return;
-    }
-
-    const file = new File(
-      [shareImageBlob.value],
-      `chatwoot-year-in-review-${props.year}.png`,
-      {
-        type: 'image/png',
-      }
-    );
-
-    if (
-      navigator.share &&
-      navigator.canShare &&
-      navigator.canShare({ files: [file] })
-    ) {
-      await navigator.share({
-        title: t('YEAR_IN_REVIEW.SHARE_MODAL.SHARE_TITLE', {
-          year: props.year,
-        }),
-        text: t('YEAR_IN_REVIEW.SHARE_MODAL.SHARE_TEXT', { year: props.year }),
-        files: [file],
-      });
-      return;
-    }
-
-    downloadImage();
-  } catch (err) {
-    // Fallback to download if sharing fails
-    downloadImage();
-  }
-};
-
-const close = () => {
-  shareImageUrl.value = null;
-  shareImageBlob.value = null;
-  emit('close');
-};
-
-const handleOpen = async () => {
-  if (props.show && !shareImageUrl.value) {
-    await generateImage();
-  }
-};
-
-defineExpose({ handleOpen });
-</script>
-
-<template>
-  <Teleport to="body">
-    <div
-      v-if="show"
-      class="fixed inset-0 bg-black bg-opacity-90 flex items-center justify-center z-[10001]"
-      @click="close"
-    >
-      <div v-if="isGenerating" class="flex items-center justify-center">
-        <div class="text-center">
-          <div
-            class="inline-block w-12 h-12 border-4 rounded-full border-white border-t-transparent animate-spin"
-          />
-          <p class="mt-4 text-sm text-white">
-            {{ t('YEAR_IN_REVIEW.SHARE_MODAL.PREPARING') }}
-          </p>
-        </div>
-      </div>
-
-      <div
-        v-else-if="shareImageUrl"
-        class="max-w-2xl w-full mx-4 flex flex-col gap-6 bg-slate-800 rounded-2xl p-6"
-        @click.stop
-      >
-        <div class="flex items-center justify-between">
-          <h3 class="text-xl font-medium text-white">
-            {{ t('YEAR_IN_REVIEW.SHARE_MODAL.TITLE') }}
-          </h3>
-          <button
-            class="w-10 h-10 flex items-center justify-center rounded-full text-white hover:bg-white hover:bg-opacity-20 transition-colors"
-            @click="close"
-          >
-            <i class="i-lucide-x w-6 h-6" />
-          </button>
-        </div>
-
-        <div>
-          <img
-            :src="shareImageUrl"
-            alt="Year in Review"
-            class="w-full h-auto"
-          />
-        </div>
-
-        <div class="flex gap-3">
-          <button
-            class="flex-[2] px-4 py-3 flex items-center justify-center gap-2 rounded-full text-white bg-white bg-opacity-20 hover:bg-opacity-30 transition-colors"
-            @click="downloadImage"
-          >
-            <i class="i-lucide-download w-5 h-5" />
-            <span class="text-sm font-medium">{{
-              t('YEAR_IN_REVIEW.SHARE_MODAL.DOWNLOAD')
-            }}</span>
-          </button>
-
-          <button
-            class="w-10 h-10 flex items-center justify-center rounded-full text-white bg-white bg-opacity-20 hover:bg-opacity-30 transition-colors"
-            @click="shareImage"
-          >
-            <i class="i-lucide-share-2 w-5 h-5" />
-          </button>
-        </div>
-      </div>
-    </div>
-  </Teleport>
-</template>

app/javascript/dashboard/components-next/year-in-review/YearInReviewBanner.vue

@@ -1,93 +0,0 @@
-<script setup>
-import { ref, computed } from 'vue';
-import { useRoute } from 'vue-router';
-import { useI18n } from 'vue-i18n';
-import { useUISettings } from 'dashboard/composables/useUISettings';
-import { useStoreGetters } from 'dashboard/composables/store';
-import YearInReviewModal from './YearInReviewModal.vue';
-import Icon from 'dashboard/components-next/icon/Icon.vue';
-
-const yearInReviewBannerImage =
-  '/assets/images/dashboard/year-in-review/year-in-review-sidebar.png';
-const route = useRoute();
-const { t } = useI18n();
-const { uiSettings, updateUISettings } = useUISettings();
-const getters = useStoreGetters();
-const showModal = ref(false);
-const modalRef = ref(null);
-
-const currentYear = 2025;
-
-const isACustomBrandedInstance =
-  getters['globalConfig/isACustomBrandedInstance'];
-
-const bannerClosedKey = computed(() => {
-  const accountId = getters.getCurrentAccountId.value;
-  return `yir_closed_${accountId}_${currentYear}`;
-});
-
-const isBannerClosed = computed(() => {
-  return uiSettings.value?.[bannerClosedKey.value] === true;
-});
-
-const shouldShowBanner = computed(
-  () =>
-    route.query['year-in-review'] === 'true' &&
-    !isBannerClosed.value &&
-    !isACustomBrandedInstance.value
-);
-
-const openModal = () => {
-  showModal.value = true;
-};
-
-const closeModal = () => {
-  showModal.value = false;
-};
-
-const closeBanner = event => {
-  event.stopPropagation();
-  updateUISettings({ [bannerClosedKey.value]: true });
-};
-</script>
-
-<template>
-  <div v-if="shouldShowBanner" class="relative">
-    <div
-      class="mx-2 my-1 p-3 bg-n-iris-9 rounded-lg cursor-pointer hover:shadow-md transition-all"
-      @click="openModal"
-    >
-      <div class="flex items-start justify-between gap-2 mb-3">
-        <span
-          class="text-sm font-semibold text-white leading-tight tracking-tight flex-1"
-        >
-          {{ t('YEAR_IN_REVIEW.BANNER.TITLE', { year: currentYear }) }}
-        </span>
-        <button
-          class="inline-flex items-center justify-center rounded hover:bg-white hover:bg-opacity-20 transition-colors p-0"
-          @click="closeBanner"
-        >
-          <Icon
-            icon="i-lucide-x size-4 mt-0.5 text-n-slate-1 dark:text-n-slate-12"
-          />
-        </button>
-      </div>
-
-      <div class="flex flex-col gap-3">
-        <img
-          :src="yearInReviewBannerImage"
-          alt="Year in Review"
-          class="w-full h-auto rounded"
-        />
-        <button
-          class="w-full px-3 py-2 bg-white text-n-iris-9 text-xs font-medium rounded-mdtracking-tight"
-          @click.stop="openModal"
-        >
-          {{ t('YEAR_IN_REVIEW.BANNER.BUTTON') }}
-        </button>
-      </div>
-    </div>
-
-    <YearInReviewModal ref="modalRef" :show="showModal" @close="closeModal" />
-  </div>
-</template>

app/javascript/dashboard/components-next/year-in-review/YearInReviewModal.vue

@@ -1,384 +0,0 @@
-<script setup>
-import { ref, computed, watch, nextTick } from 'vue';
-import { useI18n } from 'vue-i18n';
-import YearInReviewAPI from 'dashboard/api/yearInReview';
-import { useKeyboardEvents } from 'dashboard/composables/useKeyboardEvents';
-import { useUISettings } from 'dashboard/composables/useUISettings';
-import { useStoreGetters } from 'dashboard/composables/store';
-import IntroSlide from './slides/IntroSlide.vue';
-import ConversationsSlide from './slides/ConversationsSlide.vue';
-import BusiestDaySlide from './slides/BusiestDaySlide.vue';
-import PersonalitySlide from './slides/PersonalitySlide.vue';
-import ThankYouSlide from './slides/ThankYouSlide.vue';
-import ShareModal from './ShareModal.vue';
-
-const props = defineProps({
-  show: {
-    type: Boolean,
-    default: false,
-  },
-});
-
-const emit = defineEmits(['close']);
-
-const { t } = useI18n();
-const { uiSettings } = useUISettings();
-const getters = useStoreGetters();
-const isOpen = ref(false);
-const currentSlide = ref(0);
-const yearData = ref(null);
-const isLoading = ref(false);
-const error = ref(null);
-const slideRefs = ref([]);
-const showShareModal = ref(false);
-const shareModalRef = ref(null);
-const drumrollAudio = ref(null);
-
-const hasConversations = computed(() => {
-  return yearData.value?.total_conversations > 0;
-});
-
-const totalSlides = computed(() => {
-  if (!hasConversations.value) {
-    return 3;
-  }
-  return 5;
-});
-
-const slideIndexMap = computed(() => {
-  if (!hasConversations.value) {
-    return [0, 1, 4];
-  }
-  return [0, 1, 2, 3, 4];
-});
-
-const currentVisualSlide = computed(() => {
-  return slideIndexMap.value.indexOf(currentSlide.value);
-});
-
-const slideBackgrounds = [
-  'bg-[#5BD58A]',
-  'bg-[#60a5fa]',
-  'bg-[#fb923c]',
-  'bg-[#f87171]',
-  'bg-[#fbbf24]',
-];
-
-const playDrumroll = () => {
-  try {
-    if (!drumrollAudio.value) {
-      drumrollAudio.value = new Audio('/audio/dashboard/drumroll.mp3');
-      drumrollAudio.value.volume = 0.5;
-    }
-
-    drumrollAudio.value.currentTime = 0;
-    drumrollAudio.value.play().catch(err => {
-      // eslint-disable-next-line no-console
-      console.log('Could not play drumroll:', err);
-    });
-  } catch (err) {
-    // eslint-disable-next-line no-console
-    console.log('Error playing drumroll:', err);
-  }
-};
-
-const fetchYearInReviewData = async () => {
-  const year = 2025;
-  const accountId = getters.getCurrentAccountId.value;
-  const cacheKey = `year_in_review_${accountId}_${year}`;
-
-  const cachedData = uiSettings.value?.[cacheKey];
-
-  if (cachedData) {
-    yearData.value = cachedData;
-    return;
-  }
-
-  isLoading.value = true;
-  error.value = null;
-  try {
-    const response = await YearInReviewAPI.get(year);
-    yearData.value = response.data;
-  } catch (err) {
-    error.value = err.message;
-  } finally {
-    isLoading.value = false;
-  }
-};
-
-const nextSlide = () => {
-  if (currentSlide.value < 4) {
-    if (!hasConversations.value && currentSlide.value === 1) {
-      currentSlide.value = 4;
-    } else {
-      currentSlide.value += 1;
-    }
-  }
-};
-
-const previousSlide = () => {
-  if (currentSlide.value > 0) {
-    if (!hasConversations.value && currentSlide.value === 4) {
-      currentSlide.value = 1;
-    } else {
-      currentSlide.value -= 1;
-    }
-  }
-};
-
-const goToSlide = visualIndex => {
-  currentSlide.value = slideIndexMap.value[visualIndex];
-};
-
-const close = () => {
-  currentSlide.value = 0;
-  isOpen.value = false;
-  yearData.value = null;
-  isLoading.value = false;
-  error.value = null;
-
-  emit('close');
-};
-
-const open = () => {
-  isOpen.value = true;
-  fetchYearInReviewData();
-  playDrumroll();
-};
-
-const currentSlideBackground = computed(
-  () => slideBackgrounds[currentSlide.value]
-);
-
-const shareCurrentSlide = async () => {
-  showShareModal.value = true;
-  nextTick(() => {
-    if (shareModalRef.value) {
-      shareModalRef.value.handleOpen();
-    }
-  });
-};
-
-const closeShareModal = () => {
-  showShareModal.value = false;
-};
-
-const keyboardEvents = {
-  Escape: { action: close },
-  ArrowLeft: { action: previousSlide },
-  ArrowRight: { action: nextSlide },
-};
-
-useKeyboardEvents(keyboardEvents);
-
-defineExpose({ open, close });
-
-watch(
-  () => props.show,
-  newValue => {
-    if (newValue) {
-      open();
-    }
-  }
-);
-</script>
-
-<template>
-  <Teleport to="body">
-    <div
-      v-if="isOpen"
-      class="fixed inset-0 z-[9999] bg-black font-interDisplay"
-    >
-      <div class="relative w-full h-full overflow-hidden">
-        <div
-          v-if="isLoading"
-          class="flex items-center justify-center w-full h-full bg-n-slate-2"
-        >
-          <div class="text-center">
-            <div
-              class="inline-block w-12 h-12 border-4 rounded-full border-n-slate-6 border-t-n-slate-11 animate-spin"
-            />
-            <p class="mt-4 text-sm text-n-slate-11">
-              {{ t('YEAR_IN_REVIEW.LOADING') }}
-            </p>
-          </div>
-        </div>
-
-        <div
-          v-else-if="error"
-          class="flex items-center justify-center w-full h-full bg-n-slate-2"
-        >
-          <div class="text-center">
-            <p class="text-lg font-semibold text-red-600">
-              {{ t('YEAR_IN_REVIEW.ERROR') }}
-            </p>
-            <p class="mt-2 text-sm text-n-slate-11">{{ error }}</p>
-            <button
-              class="mt-4 px-4 py-2 rounded-full text-n-slate-12 dark:text-n-slate-1 bg-white bg-opacity-20 hover:bg-opacity-30 transition-colors"
-              @click="close"
-            >
-              <span class="text-sm font-medium">{{
-                t('YEAR_IN_REVIEW.CLOSE')
-              }}</span>
-            </button>
-          </div>
-        </div>
-
-        <div
-          v-else-if="yearData"
-          class="relative w-full h-full"
-          :class="currentSlideBackground"
-        >
-          <Transition
-            enter-active-class="transition-all duration-300 ease-out"
-            leave-active-class="transition-all duration-300 ease-out"
-            enter-from-class="opacity-0 translate-x-[30px]"
-            leave-to-class="opacity-0 -translate-x-[30px]"
-          >
-            <IntroSlide
-              v-if="currentSlide === 0"
-              :key="0"
-              :ref="el => (slideRefs[0] = el)"
-              :year="yearData.year"
-            />
-          </Transition>
-
-          <Transition
-            enter-active-class="transition-all duration-300 ease-out"
-            leave-active-class="transition-all duration-300 ease-out"
-            enter-from-class="opacity-0 translate-x-[30px]"
-            leave-to-class="opacity-0 -translate-x-[30px]"
-          >
-            <ConversationsSlide
-              v-if="currentSlide === 1"
-              :key="1"
-              :ref="el => (slideRefs[1] = el)"
-              :total-conversations="yearData.total_conversations"
-            />
-          </Transition>
-
-          <Transition
-            enter-active-class="transition-all duration-300 ease-out"
-            leave-active-class="transition-all duration-300 ease-out"
-            enter-from-class="opacity-0 translate-x-[30px]"
-            leave-to-class="opacity-0 -translate-x-[30px]"
-          >
-            <BusiestDaySlide
-              v-if="
-                currentSlide === 2 && hasConversations && yearData.busiest_day
-              "
-              :key="2"
-              :ref="el => (slideRefs[2] = el)"
-              :busiest-day="yearData.busiest_day"
-            />
-          </Transition>
-
-          <Transition
-            enter-active-class="transition-all duration-300 ease-out"
-            leave-active-class="transition-all duration-300 ease-out"
-            enter-from-class="opacity-0 translate-x-[30px]"
-            leave-to-class="opacity-0 -translate-x-[30px]"
-          >
-            <PersonalitySlide
-              v-if="
-                currentSlide === 3 &&
-                hasConversations &&
-                yearData.support_personality
-              "
-              :key="3"
-              :ref="el => (slideRefs[3] = el)"
-              :support-personality="yearData.support_personality"
-            />
-          </Transition>
-
-          <Transition
-            enter-active-class="transition-all duration-300 ease-out"
-            leave-active-class="transition-all duration-300 ease-out"
-            enter-from-class="opacity-0 translate-x-[30px]"
-            leave-to-class="opacity-0 -translate-x-[30px]"
-          >
-            <ThankYouSlide
-              v-if="currentSlide === 4"
-              :key="4"
-              :ref="el => (slideRefs[4] = el)"
-              :year="yearData.year"
-            />
-          </Transition>
-
-          <div
-            class="absolute bottom-8 left-0 right-0 flex items-center justify-between px-8"
-          >
-            <button
-              v-if="currentSlide > 0"
-              class="px-4 py-2 flex items-center gap-2 rounded-full text-n-slate-12 dark:text-n-slate-1 bg-white bg-opacity-20 hover:bg-opacity-30 transition-colors"
-              @click="previousSlide"
-            >
-              <i class="i-lucide-chevron-left w-5 h-5" />
-              <span class="text-sm font-medium">
-                {{ t('YEAR_IN_REVIEW.NAVIGATION.PREVIOUS') }}
-              </span>
-            </button>
-            <div v-else class="w-20" />
-
-            <div class="flex gap-2">
-              <button
-                v-for="index in totalSlides"
-                :key="index"
-                class="w-2 h-2 rounded-full transition-all"
-                :class="
-                  currentVisualSlide === index - 1
-                    ? 'bg-white w-8'
-                    : 'bg-white bg-opacity-50'
-                "
-                @click="goToSlide(index - 1)"
-              />
-            </div>
-
-            <button
-              class="px-4 py-2 flex items-center gap-2 rounded-full text-n-slate-12 dark:text-n-slate-1 bg-white bg-opacity-20 hover:bg-opacity-30 transition-colors"
-              :class="{ invisible: currentVisualSlide === totalSlides - 1 }"
-              @click="nextSlide"
-            >
-              <span
-                v-if="currentVisualSlide < totalSlides - 1"
-                class="text-sm font-medium"
-              >
-                {{ t('YEAR_IN_REVIEW.NAVIGATION.NEXT') }}
-              </span>
-              <i
-                v-if="currentVisualSlide < totalSlides - 1"
-                class="i-lucide-chevron-right w-5 h-5"
-              />
-            </button>
-          </div>
-
-          <button
-            class="absolute top-4 left-4 px-4 py-2 flex items-center gap-2 rounded-full text-n-slate-12 dark:text-n-slate-1 bg-white bg-opacity-20 hover:bg-opacity-30 transition-colors"
-            @click="shareCurrentSlide"
-          >
-            <i class="i-lucide-share-2 w-5 h-5" />
-            <span class="text-sm font-medium">{{
-              t('YEAR_IN_REVIEW.NAVIGATION.SHARE')
-            }}</span>
-          </button>
-
-          <button
-            class="absolute top-4 right-4 w-10 h-10 flex items-center justify-center rounded-full text-n-slate-12 dark:text-n-slate-1 hover:bg-white hover:bg-opacity-20 transition-colors"
-            @click="close"
-          >
-            <i class="i-lucide-x w-6 h-6" />
-          </button>
-        </div>
-      </div>
-    </div>
-
-    <ShareModal
-      ref="shareModalRef"
-      :show="showShareModal"
-      :slide-element="slideRefs[currentSlide]"
-      :slide-background="currentSlideBackground"
-      :year="yearData?.year"
-      @close="closeShareModal"
-    />
-  </Teleport>
-</template>

app/javascript/dashboard/components-next/year-in-review/slides/BusiestDaySlide.vue

@@ -1,76 +0,0 @@
-<script setup>
-import { computed } from 'vue';
-import { useI18n } from 'vue-i18n';
-
-const props = defineProps({
-  busiestDay: {
-    type: Object,
-    required: true,
-  },
-});
-
-const { t } = useI18n();
-
-const coffeeImage =
-  '/assets/images/dashboard/year-in-review/third-frame-coffee.png';
-const doubleQuotesImage =
-  '/assets/images/dashboard/year-in-review/double-quotes.png';
-
-const performanceHelperText = computed(() => {
-  const count = props.busiestDay.count;
-  if (count <= 5) return t('YEAR_IN_REVIEW.BUSIEST_DAY.COMPARISON.0_5');
-  if (count <= 10) return t('YEAR_IN_REVIEW.BUSIEST_DAY.COMPARISON.5_10');
-  if (count <= 25) return t('YEAR_IN_REVIEW.BUSIEST_DAY.COMPARISON.10_25');
-  if (count <= 50) return t('YEAR_IN_REVIEW.BUSIEST_DAY.COMPARISON.25_50');
-  if (count <= 100) return t('YEAR_IN_REVIEW.BUSIEST_DAY.COMPARISON.50_100');
-  if (count <= 500) return t('YEAR_IN_REVIEW.BUSIEST_DAY.COMPARISON.100_500');
-  return t('YEAR_IN_REVIEW.BUSIEST_DAY.COMPARISON.500_PLUS');
-});
-</script>
-
-<template>
-  <div class="absolute inset-0 flex items-center justify-center px-8 md:px-32">
-    <div class="flex flex-col gap-4 w-full max-w-3xl">
-      <div class="flex items-center justify-center flex-1">
-        <div class="flex items-center justify-between gap-6 flex-1 md:gap-16">
-          <div class="text-white flex gap-2 flex-col">
-            <div class="text-2xl lg:text-3xl xl:text-4xl tracking-tight">
-              {{ t('YEAR_IN_REVIEW.BUSIEST_DAY.TITLE') }}
-            </div>
-            <div class="text-6xl md:text-8xl lg:text-[140px] tracking-tighter">
-              {{ busiestDay.date }}
-            </div>
-          </div>
-
-          <img
-            :src="coffeeImage"
-            alt="Coffee"
-            class="w-auto h-32 md:h-56 lg:h-72"
-          />
-        </div>
-      </div>
-
-      <div class="flex flex-col gap-2 flex-1">
-        <div class="flex items-center justify-center gap-3 md:gap-8">
-          <img
-            :src="doubleQuotesImage"
-            alt="Quote"
-            class="w-8 h-8 md:w-12 md:h-12 lg:w-16 lg:h-16"
-          />
-          <div class="flex-1">
-            <p
-              class="text-xl md:text-3xl lg:text-4xl font-medium tracking-[-0.2px] text-n-slate-12 dark:text-n-slate-1"
-            >
-              {{
-                t('YEAR_IN_REVIEW.BUSIEST_DAY.MESSAGE', {
-                  count: busiestDay.count,
-                })
-              }}
-              {{ performanceHelperText }}
-            </p>
-          </div>
-        </div>
-      </div>
-    </div>
-  </div>
-</template>

app/javascript/dashboard/components-next/year-in-review/slides/ConversationsSlide.vue

@@ -1,94 +0,0 @@
-<script setup>
-import { computed } from 'vue';
-import { useI18n } from 'vue-i18n';
-
-const props = defineProps({
-  totalConversations: {
-    type: Number,
-    required: true,
-  },
-});
-
-const { t } = useI18n();
-
-const cloudImage =
-  '/assets/images/dashboard/year-in-review/second-frame-cloud-icon.png';
-const doubleQuotesImage =
-  '/assets/images/dashboard/year-in-review/double-quotes.png';
-
-const hasData = computed(() => {
-  return props.totalConversations > 0;
-});
-
-const formatNumber = num => {
-  if (num >= 100000) {
-    return '100k+';
-  }
-  return new Intl.NumberFormat().format(num);
-};
-
-const performanceHelperText = computed(() => {
-  if (!hasData.value) {
-    return t('YEAR_IN_REVIEW.CONVERSATIONS.FALLBACK');
-  }
-
-  const count = props.totalConversations;
-  if (count <= 50) return t('YEAR_IN_REVIEW.CONVERSATIONS.COMPARISON.0_50');
-  if (count <= 100) return t('YEAR_IN_REVIEW.CONVERSATIONS.COMPARISON.50_100');
-  if (count <= 500) return t('YEAR_IN_REVIEW.CONVERSATIONS.COMPARISON.100_500');
-  if (count <= 2000)
-    return t('YEAR_IN_REVIEW.CONVERSATIONS.COMPARISON.500_2000');
-  if (count <= 10000)
-    return t('YEAR_IN_REVIEW.CONVERSATIONS.COMPARISON.2000_10000');
-  return t('YEAR_IN_REVIEW.CONVERSATIONS.COMPARISON.10000_PLUS');
-});
-</script>
-
-<template>
-  <div
-    class="absolute inset-0 flex items-center justify-center px-8 md:px-32 py-20"
-  >
-    <div
-      class="flex flex-col gap-16"
-      :class="totalConversations > 100 ? 'max-w-4xl' : 'max-w-3xl'"
-    >
-      <div class="flex items-center justify-center flex-1">
-        <div
-          class="flex items-center justify-between gap-6 flex-1"
-          :class="totalConversations > 100 ? 'md:gap-16' : 'md:gap-8'"
-        >
-          <div class="text-white flex gap-3 flex-col">
-            <div class="text-2xl md:text-3xl lg:text-4xl tracking-tight">
-              {{ t('YEAR_IN_REVIEW.CONVERSATIONS.TITLE') }}
-            </div>
-            <div class="text-6xl md:text-8xl lg:text-[180px] tracking-tighter">
-              {{ formatNumber(totalConversations) }}
-            </div>
-            <div class="text-2xl md:text-3xl lg:text-4xl tracking-tight -mt-2">
-              {{ t('YEAR_IN_REVIEW.CONVERSATIONS.SUBTITLE') }}
-            </div>
-          </div>
-
-          <img
-            :src="cloudImage"
-            alt="Cloud"
-            class="w-auto h-32 md:h-56 lg:h-80 -mr-2"
-          />
-        </div>
-      </div>
-
-      <div class="flex items-center justify-center gap-3 md:gap-6">
-        <img
-          :src="doubleQuotesImage"
-          alt="Quote"
-          class="w-8 h-8 md:w-12 md:h-12 lg:w-16 lg:h-16"
-        />
-        <p
-          class="text-xl md:text-3xl lg:text-4xl font-medium tracking-[-0.2px] text-n-slate-12 dark:text-n-slate-1"
-        >
-          {{ performanceHelperText }}
-        </p>
-      </div>
-    </div>
-  </div>
-</template>

app/javascript/dashboard/components-next/year-in-review/slides/IntroSlide.vue

@@ -1,43 +0,0 @@
-<script setup>
-import { useI18n } from 'vue-i18n';
-
-defineProps({
-  year: {
-    type: Number,
-    required: true,
-  },
-});
-
-const candlesImagePath =
-  '/assets/images/dashboard/year-in-review/first-frame-candles.png';
-
-const { t } = useI18n();
-</script>
-
-<template>
-  <div
-    class="absolute inset-0 flex flex-col items-center justify-center text-black px-8 md:px-16 lg:px-24 py-10 md:py-16 lg:py-20 bg-cover bg-center min-h-[700px]"
-    :style="{
-      backgroundImage: `url('/assets/images/dashboard/year-in-review/first-frame-bg.png')`,
-    }"
-  >
-    <div class="text-center max-w-3xl">
-      <h1
-        class="text-8xl md:text-9xl lg:text-[220px] font-semibold mb-4 md:mb-6 leading-none tracking-tight text-n-slate-12 dark:text-n-slate-1"
-      >
-        {{ year }}
-      </h1>
-      <h2
-        class="text-3xl md:text-4xl lg:text-5xl font-medium mb-12 md:mb-16 lg:mb-20 text-n-slate-12 dark:text-n-slate-1"
-      >
-        {{ t('YEAR_IN_REVIEW.TITLE') }}
-      </h2>
-    </div>
-
-    <img
-      :src="candlesImagePath"
-      alt="Candles"
-      class="absolute bottom-0 left-1/2 transform -translate-x-1/2 w-auto h-32 md:h-48 lg:h-64"
-    />
-  </div>
-</template>

app/javascript/dashboard/components-next/year-in-review/slides/PersonalitySlide.vue

@@ -1,99 +0,0 @@
-<script setup>
-import { computed } from 'vue';
-import { useI18n } from 'vue-i18n';
-
-const props = defineProps({
-  supportPersonality: {
-    type: Object,
-    required: true,
-  },
-});
-
-const { t } = useI18n();
-
-const clockImage =
-  '/assets/images/dashboard/year-in-review/fourth-frame-clock.png';
-const doubleQuotesImage =
-  '/assets/images/dashboard/year-in-review/double-quotes.png';
-
-const formatResponseTime = seconds => {
-  if (seconds < 60) {
-    return 'less than a minute';
-  }
-  if (seconds < 3600) {
-    const minutes = Math.floor(seconds / 60);
-    return minutes === 1 ? '1 minute' : `${minutes} minutes`;
-  }
-  if (seconds < 86400) {
-    const hours = Math.floor(seconds / 3600);
-    return hours === 1 ? '1 hour' : `${hours} hours`;
-  }
-  return 'more than a day';
-};
-
-const personality = computed(() => {
-  const seconds = props.supportPersonality.avg_response_time_seconds;
-  const minutes = seconds / 60;
-
-  if (minutes < 2) {
-    return 'Swift Helper';
-  }
-  if (minutes < 5) {
-    return 'Quick Responder';
-  }
-  if (minutes < 15) {
-    return 'Steady Support';
-  }
-  return 'Thoughtful Advisor';
-});
-
-const personalityMessage = computed(() => {
-  const seconds = props.supportPersonality.avg_response_time_seconds;
-  const time = formatResponseTime(seconds);
-
-  const personalityKeyMap = {
-    'Swift Helper': 'SWIFT_HELPER',
-    'Quick Responder': 'QUICK_RESPONDER',
-    'Steady Support': 'STEADY_SUPPORT',
-    'Thoughtful Advisor': 'THOUGHTFUL_ADVISOR',
-  };
-
-  const key = personalityKeyMap[personality.value];
-  if (!key) return '';
-
-  return t(`YEAR_IN_REVIEW.PERSONALITY.MESSAGES.${key}`, { time });
-});
-</script>
-
-<template>
-  <div class="absolute inset-0 flex items-center justify-center px-8 md:px-32">
-    <div class="flex flex-col gap-9 max-w-3xl">
-      <div class="mb-4 md:mb-6">
-        <img :src="clockImage" alt="Clock" class="w-auto h-28" />
-        <div class="flex items-center justify-start flex-1 mt-9">
-          <div class="text-n-slate-1 dark:text-n-slate-12 flex gap-3 flex-col">
-            <div class="text-2xl md:text-4xl tracking-tight">
-              {{ t('YEAR_IN_REVIEW.PERSONALITY.TITLE') }}
-            </div>
-            <div class="text-6xl md:text-7xl lg:text-8xl tracking-tighter">
-              {{ personality }}
-            </div>
-          </div>
-        </div>
-      </div>
-
-      <div class="flex items-center justify-center gap-3 md:gap-6">
-        <img
-          :src="doubleQuotesImage"
-          alt="Quote"
-          class="w-8 h-8 md:w-12 md:h-12 lg:w-16 lg:h-16"
-        />
-        <p
-          class="text-xl md:text-3xl lg:text-3xl font-medium tracking-[-0.2px] text-n-slate-12 dark:text-n-slate-1"
-        >
-          {{ personalityMessage }}
-        </p>
-      </div>
-    </div>
-  </div>
-</template>

app/javascript/dashboard/components-next/year-in-review/slides/ThankYouSlide.vue

@@ -1,43 +0,0 @@
-<script setup>
-import { useI18n } from 'vue-i18n';
-
-defineProps({
-  year: {
-    type: Number,
-    required: true,
-  },
-});
-
-const { t } = useI18n();
-
-const signatureImage =
-  '/assets/images/dashboard/year-in-review/fifth-frame-signature.png';
-</script>
-
-<template>
-  <div
-    class="absolute inset-0 flex items-center justify-center px-8 md:px-32 py-20"
-  >
-    <div class="flex flex-col items-start max-w-4xl">
-      <div
-        class="text-3xl md:text-5xl lg:text-6xl font-bold tracking-tight !leading-tight text-n-slate-12 dark:text-n-slate-1"
-      >
-        {{ t('YEAR_IN_REVIEW.THANK_YOU.TITLE', { year }) }}
-      </div>
-      <div
-        class="text-xl lg:text-3xl mt-8 font-medium !leading-snug text-n-slate-12 dark:text-n-slate-1"
-      >
-        {{
-          t('YEAR_IN_REVIEW.THANK_YOU.MESSAGE', { nextYear: Number(year) + 1 })
-        }}
-      </div>
-      <div class="mt-12">
-        <img
-          :src="signatureImage"
-          alt="Chatwoot Team Signature"
-          class="w-auto h-8 md:h-10"
-        />
-      </div>
-    </div>
-  </div>
-</template>

app/javascript/dashboard/components/widgets/AIAssistanceModal.vue

@@ -48,7 +48,7 @@ export default {
       this.$emit('close');
     },
 
-    async generateAIContent(type = 'rephrase') {
+    async generateAIContent(type = 'improve') {
       this.isGenerating = true;
       this.generatedContent = await this.processEvent(type);
       this.isGenerating = false;

app/javascript/dashboard/components/widgets/AttachmentsPreview.vue

@@ -46,11 +46,11 @@ const fileName = file => {
 </script>
 
 <template>
-  <div class="flex overflow-auto max-h-[12.5rem]">
+  <div class="flex flex-wrap gap-y-1 gap-x-2 overflow-auto max-h-[12.5rem]">
     <div
       v-for="(attachment, index) in nonRecordedAudioAttachments"
       :key="attachment.id"
-      class="flex items-center p-1 bg-n-slate-3 gap-1 rounded-md w-[15rem] mb-1"
+      class="flex items-center p-1 bg-n-slate-3 gap-1 rounded-md w-[15rem]"
     >
       <div class="max-w-[4rem] flex-shrink-0 w-6 flex items-center">
         <img

app/javascript/dashboard/components/widgets/WootWriter/CopilotEditor.vue

@@ -0,0 +1,246 @@
+<script setup>
+import { ref, computed, watch, onMounted, useTemplateRef } from 'vue';
+
+import {
+  buildMessageSchema,
+  buildEditor,
+  EditorView,
+  MessageMarkdownTransformer,
+  MessageMarkdownSerializer,
+  EditorState,
+  Selection,
+} from '@chatwoot/prosemirror-schema';
+
+import { useMessageFormatter } from 'shared/composables/useMessageFormatter';
+
+import NextButton from 'dashboard/components-next/button/Button.vue';
+
+const props = defineProps({
+  modelValue: { type: String, default: '' },
+  editorId: { type: String, default: '' },
+  placeholder: {
+    type: String,
+    default: 'Give copilot additional prompts, or ask anything else...',
+  },
+  generatedContent: { type: String, default: '' },
+  autofocus: {
+    type: Boolean,
+    default: true,
+  },
+  isPopout: {
+    type: Boolean,
+    default: false,
+  },
+});
+
+const emit = defineEmits([
+  'blur',
+  'input',
+  'update:modelValue',
+  'keyup',
+  'focus',
+  'keydown',
+  'send',
+]);
+
+const { formatMessage } = useMessageFormatter();
+
+// Minimal schema with no marks or nodes for copilot input
+const copilotSchema = buildMessageSchema([], []);
+
+const createState = (
+  content,
+  placeholder,
+  plugins = [],
+  enabledMenuOptions = []
+) => {
+  return EditorState.create({
+    doc: new MessageMarkdownTransformer(copilotSchema).parse(content),
+    plugins: buildEditor({
+      schema: copilotSchema,
+      placeholder,
+      plugins,
+      enabledMenuOptions,
+    }),
+  });
+};
+
+// we don't need them to be reactive
+// It cases weird issues where the objects are proxied
+// and then the editor doesn't work as expected
+let editorView = null;
+let state = null;
+
+// reactive data
+const isTextSelected = ref(false); // Tracks text selection and prevents unnecessary re-renders on mouse selection
+
+// element refs
+const editor = useTemplateRef('editor');
+
+function contentFromEditor() {
+  if (editorView) {
+    return MessageMarkdownSerializer.serialize(editorView.state.doc);
+  }
+  return '';
+}
+
+function focusEditorInputField() {
+  const { tr } = editorView.state;
+  const selection = Selection.atEnd(tr.doc);
+
+  editorView.dispatch(tr.setSelection(selection));
+  editorView.focus();
+}
+
+function emitOnChange() {
+  emit('update:modelValue', contentFromEditor());
+  emit('input', contentFromEditor());
+}
+
+function onKeyup() {
+  emit('keyup');
+}
+
+function onKeydown() {
+  emit('keydown');
+}
+
+function onBlur() {
+  emit('blur');
+}
+
+function onFocus() {
+  emit('focus');
+}
+
+function checkSelection(editorState) {
+  const hasSelection = editorState.selection.from !== editorState.selection.to;
+  if (hasSelection === isTextSelected.value) return;
+  isTextSelected.value = hasSelection;
+}
+
+// computed properties
+const plugins = computed(() => {
+  return [];
+});
+
+const enabledMenuOptions = computed(() => {
+  return [];
+});
+
+function reloadState() {
+  state = createState(
+    props.modelValue,
+    props.placeholder,
+    plugins.value,
+    enabledMenuOptions.value
+  );
+  editorView.updateState(state);
+  focusEditorInputField();
+}
+
+function createEditorView() {
+  editorView = new EditorView(editor.value, {
+    state: state,
+    dispatchTransaction: tx => {
+      state = state.apply(tx);
+      editorView.updateState(state);
+      if (tx.docChanged) {
+        emitOnChange();
+      }
+      checkSelection(state);
+    },
+    handleDOMEvents: {
+      keyup: onKeyup,
+      focus: onFocus,
+      blur: onBlur,
+      keydown: onKeydown,
+    },
+  });
+}
+
+function handleSubmit() {
+  emit('send');
+}
+
+// watchers
+watch(
+  computed(() => props.modelValue),
+  (newValue = '') => {
+    if (newValue !== contentFromEditor()) {
+      reloadState();
+    }
+  }
+);
+
+watch(
+  computed(() => props.editorId),
+  () => {
+    reloadState();
+  }
+);
+
+// lifecycle
+onMounted(() => {
+  state = createState(
+    props.modelValue,
+    props.placeholder,
+    plugins.value,
+    enabledMenuOptions.value
+  );
+
+  createEditorView();
+  editorView.updateState(state);
+
+  if (props.autofocus) {
+    focusEditorInputField();
+  }
+});
+</script>
+
+<template>
+  <div class="space-y-2 mb-4">
+    <div
+      class="overflow-y-auto"
+      :class="{ 'max-h-96': isPopout, 'max-h-56': !isPopout }"
+    >
+      <p
+        v-dompurify-html="formatMessage(generatedContent, false)"
+        class="text-n-iris-12 text-sm prose-sm font-normal !mb-4 underline decoration-n-iris-8 underline-offset-auto decoration-solid decoration-[10%]"
+      />
+    </div>
+    <div class="editor-root relative editor--copilot space-x-2">
+      <div ref="editor" />
+      <div class="flex items-center justify-end absolute right-2 bottom-2">
+        <NextButton
+          class="bg-n-iris-9 text-white !rounded-full"
+          icon="i-lucide-arrow-up"
+          solid
+          sm
+          @click="handleSubmit"
+        />
+      </div>
+    </div>
+  </div>
+</template>
+
+<style lang="scss">
+@import '@chatwoot/prosemirror-schema/src/styles/base.scss';
+
+.editor--copilot {
+  @apply bg-n-iris-5 rounded;
+
+  .ProseMirror-woot-style {
+    min-height: 5rem;
+    max-height: 7.5rem !important;
+    overflow: auto;
+    @apply px-2 !important;
+
+    .empty-node {
+      &::before {
+        @apply text-n-iris-9 dark:text-n-iris-11;
+      }
+    }
+  }
+}
+</style>

app/javascript/dashboard/components/widgets/WootWriter/CopilotMenuBar.vue

@@ -0,0 +1,254 @@
+<script setup>
+import { computed, useTemplateRef } from 'vue';
+import { useI18n } from 'vue-i18n';
+import { useElementSize, useWindowSize } from '@vueuse/core';
+import { useMapGetter } from 'dashboard/composables/store';
+import { REPLY_EDITOR_MODES } from 'dashboard/components/widgets/WootWriter/constants';
+import { useAI } from 'dashboard/composables/useAI';
+import Button from 'dashboard/components-next/button/Button.vue';
+import DropdownBody from 'next/dropdown-menu/base/DropdownBody.vue';
+
+import Icon from 'next/icon/Icon.vue';
+
+const props = defineProps({
+  hasSelection: {
+    type: Boolean,
+    default: false,
+  },
+});
+
+const emit = defineEmits(['executeCopilotAction']);
+
+const { t } = useI18n();
+
+const { draftMessage } = useAI();
+
+const replyMode = useMapGetter('draftMessages/getReplyEditorMode');
+
+// Selection-based menu items (when text is selected)
+const menuItems = computed(() => {
+  const items = [];
+  if (props.hasSelection) {
+    items.push({
+      label: t(
+        'INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.IMPROVE_REPLY_SELECTION'
+      ),
+      key: 'improve_selection',
+      icon: 'i-fluent-pen-sparkle-24-regular',
+    });
+  } else if (
+    replyMode.value === REPLY_EDITOR_MODES.REPLY &&
+    draftMessage.value
+  ) {
+    items.push({
+      label: t('INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.IMPROVE_REPLY'),
+      key: 'improve',
+      icon: 'i-fluent-pen-sparkle-24-regular',
+    });
+  }
+
+  if (draftMessage.value) {
+    items.push(
+      {
+        label: t(
+          'INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.CHANGE_TONE.TITLE'
+        ),
+        key: 'change_tone',
+        icon: 'i-fluent-sound-wave-circle-sparkle-24-regular',
+        subMenuItems: [
+          {
+            label: t(
+              'INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.CHANGE_TONE.OPTIONS.PROFESSIONAL'
+            ),
+            key: 'professional',
+          },
+          {
+            label: t(
+              'INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.CHANGE_TONE.OPTIONS.CASUAL'
+            ),
+            key: 'casual',
+          },
+          {
+            label: t(
+              'INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.CHANGE_TONE.OPTIONS.STRAIGHTFORWARD'
+            ),
+            key: 'straightforward',
+          },
+          {
+            label: t(
+              'INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.CHANGE_TONE.OPTIONS.CONFIDENT'
+            ),
+            key: 'confident',
+          },
+          {
+            label: t(
+              'INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.CHANGE_TONE.OPTIONS.FRIENDLY'
+            ),
+            key: 'friendly',
+          },
+        ],
+      },
+      {
+        label: t('INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.GRAMMAR'),
+        key: 'fix_spelling_grammar',
+        icon: 'i-fluent-flow-sparkle-24-regular',
+      }
+    );
+  }
+  return items;
+});
+
+const generalMenuItems = computed(() => {
+  const items = [];
+  if (replyMode.value === REPLY_EDITOR_MODES.REPLY) {
+    items.push({
+      label: t('INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.SUGGESTION'),
+      key: 'reply_suggestion',
+      icon: 'i-fluent-chat-sparkle-16-regular',
+    });
+  }
+
+  if (replyMode.value === REPLY_EDITOR_MODES.NOTE || true) {
+    items.push({
+      label: t('INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.SUMMARIZE'),
+      key: 'summarize',
+      icon: 'i-fluent-text-bullet-list-square-sparkle-32-regular',
+    });
+  }
+
+  items.push({
+    label: t('INTEGRATION_SETTINGS.OPEN_AI.REPLY_OPTIONS.ASK_COPILOT'),
+    key: 'ask_copilot',
+    icon: 'i-fluent-circle-sparkle-24-regular',
+  });
+
+  return items;
+});
+
+const menuRef = useTemplateRef('menuRef');
+const { height: menuHeight } = useElementSize(menuRef);
+const { width: windowWidth } = useWindowSize();
+
+// Smart submenu positioning based on available space
+const submenuPosition = computed(() => {
+  const el = menuRef.value?.$el;
+  if (!el) return 'ltr:right-full rtl:left-full';
+
+  const { left, right } = el.getBoundingClientRect();
+  const SUBMENU_WIDTH = 200;
+  const spaceRight = (windowWidth.value ?? window.innerWidth) - right;
+  const spaceLeft = left;
+
+  // Prefer right, fallback to side with more space
+  const showRight = spaceRight >= SUBMENU_WIDTH || spaceRight >= spaceLeft;
+
+  return showRight ? 'left-full' : 'right-full';
+});
+
+// Computed style for selection menu positioning (only dynamic top offset)
+const selectionMenuStyle = computed(() => {
+  // Dynamically calculate offset based on actual menu height + 10px gap
+  const dynamicOffset = menuHeight.value > 0 ? menuHeight.value + 10 : 60;
+
+  return {
+    top: `calc(var(--selection-top) - ${dynamicOffset}px)`,
+  };
+});
+
+const handleMenuItemClick = item => {
+  // For items with submenus, do nothing on click (hover will show submenu)
+  if (!item.subMenuItems) {
+    emit('executeCopilotAction', item.key);
+  }
+};
+
+const handleSubMenuItemClick = (parentItem, subItem) => {
+  emit('executeCopilotAction', subItem.key);
+};
+</script>
+
+<template>
+  <DropdownBody
+    ref="menuRef"
+    class="min-w-56 [&>ul]:gap-3 z-50 [&>ul]:px-4 [&>ul]:py-3.5"
+    :class="{ 'selection-menu': hasSelection }"
+    :style="hasSelection ? selectionMenuStyle : {}"
+  >
+    <div v-if="menuItems.length > 0" class="flex flex-col items-start gap-2.5">
+      <div
+        v-for="item in menuItems"
+        :key="item.key"
+        class="w-full relative group/submenu"
+      >
+        <Button
+          :label="item.label"
+          :icon="item.icon"
+          slate
+          link
+          sm
+          class="hover:!no-underline text-n-slate-12 font-normal text-xs w-full !justify-start"
+          @click="handleMenuItemClick(item)"
+        >
+          <template v-if="item.subMenuItems" #default>
+            <div class="flex items-center gap-1 justify-between w-full">
+              <span class="min-w-0 truncate">{{ item.label }}</span>
+              <Icon
+                icon="i-lucide-chevron-right"
+                class="text-n-slate-10 size-3"
+              />
+            </div>
+          </template>
+        </Button>
+
+        <!-- Hover Submenu -->
+        <DropdownBody
+          v-if="item.subMenuItems"
+          class="group-hover/submenu:block hidden [&>ul]:gap-2 [&>ul]:px-3 [&>ul]:py-2.5 [&>ul]:dark:!border-n-strong max-h-[15rem] min-w-32 z-10 top-0"
+          :class="submenuPosition"
+        >
+          <Button
+            v-for="subItem in item.subMenuItems"
+            :key="subItem.key + subItem.label"
+            :label="subItem.label"
+            slate
+            link
+            sm
+            class="hover:!no-underline text-n-slate-12 font-normal text-xs w-full !justify-start mb-1"
+            @click="handleSubMenuItemClick(item, subItem)"
+          />
+        </DropdownBody>
+      </div>
+    </div>
+
+    <div v-if="menuItems.length > 0" class="h-px w-full bg-n-strong" />
+
+    <div class="flex flex-col items-start gap-3">
+      <Button
+        v-for="(item, index) in generalMenuItems"
+        :key="index"
+        :label="item.label"
+        :icon="item.icon"
+        slate
+        link
+        sm
+        class="hover:!no-underline text-n-slate-12 font-normal text-xs w-full !justify-start"
+        @click="handleMenuItemClick(item)"
+      />
+    </div>
+  </DropdownBody>
+</template>
+
+<style scoped lang="scss">
+.selection-menu {
+  position: absolute !important;
+
+  // Default/LTR: position from left
+  left: var(--selection-left);
+
+  // RTL: position from right instead
+  [dir='rtl'] & {
+    left: auto;
+    right: var(--selection-right);
+  }
+}
+</style>

app/javascript/dashboard/components/widgets/WootWriter/CopilotReplyBottomPanel.vue

@@ -0,0 +1,49 @@
+<script setup>
+import NextButton from 'dashboard/components-next/button/Button.vue';
+
+defineProps({
+  isGeneratingContent: {
+    type: Boolean,
+    default: false,
+  },
+  isPrivate: {
+    type: Boolean,
+    default: false,
+  },
+});
+
+const emit = defineEmits(['submit', 'cancel']);
+
+const handleCancel = () => {
+  emit('cancel');
+};
+
+const handleSubmit = () => {
+  emit('submit');
+};
+</script>
+
+<template>
+  <div
+    class="flex justify-between items-center p-3 border-t"
+    :class="{ 'border-n-weak': !isPrivate, 'border-n-amber-12/5': isPrivate }"
+  >
+    <NextButton
+      label="Discard"
+      slate
+      link
+      class="!px-1 hover:!no-underline"
+      sm
+      :disabled="isGeneratingContent"
+      @click="handleCancel"
+    />
+    <NextButton
+      label="Accept"
+      class="bg-n-iris-9 text-white"
+      solid
+      sm
+      :disabled="isGeneratingContent"
+      @click="handleSubmit"
+    />
+  </div>
+</template>

app/javascript/dashboard/components/widgets/WootWriter/Editor.vue

@@ -16,6 +16,7 @@ import KeyboardEmojiSelector from './keyboardEmojiSelector.vue';
 import TagAgents from '../conversation/TagAgents.vue';
 import VariableList from '../conversation/VariableList.vue';
 import TagTools from '../conversation/TagTools.vue';
+import CopilotMenuBar from './CopilotMenuBar.vue';
 
 import { useEmitter } from 'dashboard/composables/emitter';
 import { useI18n } from 'vue-i18n';
@@ -23,6 +24,7 @@ import { useKeyboardEvents } from 'dashboard/composables/useKeyboardEvents';
 import { useTrack } from 'dashboard/composables';
 import { useUISettings } from 'dashboard/composables/useUISettings';
 import { useAlert } from 'dashboard/composables';
+import { vOnClickOutside } from '@vueuse/components';
 
 import { BUS_EVENTS } from 'shared/constants/busEvents';
 import { CONVERSATION_EVENTS } from 'dashboard/helper/AnalyticsHelper/events';
@@ -54,6 +56,7 @@ import {
   getFormattingForEditor,
   getSelectionCoords,
   calculateMenuPosition,
+  stripUnsupportedFormatting,
   getEffectiveChannelType,
 } from 'dashboard/helper/editorHelper';
 import {
@@ -99,6 +102,7 @@ const emit = defineEmits([
   'focus',
   'input',
   'update:modelValue',
+  'executeCopilotAction',
 ]);
 
 const { t } = useI18n();
@@ -106,6 +110,7 @@ const { t } = useI18n();
 const TYPING_INDICATOR_IDLE_TIME = 4000;
 const MAXIMUM_FILE_UPLOAD_SIZE = 4; // in MB
 const DEFAULT_FORMATTING = 'Context::Default';
+const PRIVATE_NOTE_FORMATTING = 'Context::PrivateNote';
 
 const effectiveChannelType = computed(() =>
   getEffectiveChannelType(props.channelType, props.medium)
@@ -115,7 +120,7 @@ const editorSchema = computed(() => {
   if (!props.channelType) return messageSchema;
 
   const formatType = props.isPrivate
-    ? DEFAULT_FORMATTING
+    ? PRIVATE_NOTE_FORMATTING
     : effectiveChannelType.value;
   const formatting = getFormattingForEditor(formatType);
   return buildMessageSchema(formatting.marks, formatting.nodes);
@@ -123,7 +128,7 @@ const editorSchema = computed(() => {
 
 const editorMenuOptions = computed(() => {
   const formatType = props.isPrivate
-    ? DEFAULT_FORMATTING
+    ? PRIVATE_NOTE_FORMATTING
     : effectiveChannelType.value || DEFAULT_FORMATTING;
   const formatting = getFormattingForEditor(formatType);
   return formatting.menu;
@@ -131,8 +136,11 @@ const editorMenuOptions = computed(() => {
 
 const createState = (content, placeholder, plugins = [], methods = {}) => {
   const schema = editorSchema.value;
+  // Strip unsupported formatting before parsing to ensure content is compatible
+  // with the current schema for proper rendering in the editor
+  const sanitizedContent = stripUnsupportedFormatting(content, schema);
   return EditorState.create({
-    doc: new MessageMarkdownTransformer(schema).parse(content),
+    doc: new MessageMarkdownTransformer(schema).parse(sanitizedContent),
     plugins: buildEditor({
       schema,
       placeholder,
@@ -182,6 +190,21 @@ const editorRoot = useTemplateRef('editorRoot');
 const imageUpload = useTemplateRef('imageUpload');
 const editor = useTemplateRef('editor');
 
+const handleCopilotAction = actionKey => {
+  if (actionKey === 'improve_selection' && editorView?.state) {
+    const { from, to } = editorView.state.selection;
+    const selectedText = editorView.state.doc.textBetween(from, to).trim();
+
+    if (from !== to && selectedText) {
+      emit('executeCopilotAction', 'improve', selectedText);
+    }
+  } else {
+    emit('executeCopilotAction', actionKey);
+  }
+
+  showSelectionMenu.value = false;
+};
+
 const contentFromEditor = () => {
   return MessageMarkdownSerializer.serialize(editorView.state.doc);
 };
@@ -364,13 +387,23 @@ function openFileBrowser() {
   imageUpload.value.click();
 }
 
+function handleCopilotClick() {
+  showSelectionMenu.value = !showSelectionMenu.value;
+}
+
+function handleClickOutside(event) {
+  // Check if the clicked element or its parents have the ignored class
+  if (event.target.closest('.ProseMirror-copilot')) return;
+  showSelectionMenu.value = false;
+}
+
 function reloadState(content = props.modelValue) {
   const unrefContent = unref(content);
   state = createState(
     unrefContent,
     props.placeholder,
     plugins.value,
-    { onImageUpload: openFileBrowser },
+    { onImageUpload: openFileBrowser, onCopilotClick: handleCopilotClick },
     editorMenuOptions.value
   );
 
@@ -592,7 +625,12 @@ function insertContentIntoEditor(content, defaultFrom = 0) {
   const from = defaultFrom || editorView.state.selection.from || 0;
   // Use the editor's current schema to ensure compatibility with buildMessageSchema
   const currentSchema = editorView.state.schema;
-  let node = new MessageMarkdownTransformer(currentSchema).parse(content);
+  // Strip unsupported formatting before parsing to ensure content can be inserted
+  // into channels that don't support certain markdown features (e.g., API channels)
+  const sanitizedContent = stripUnsupportedFormatting(content, currentSchema);
+  let node = new MessageMarkdownTransformer(currentSchema).parse(
+    sanitizedContent
+  );
 
   insertNodeIntoEditor(node, from, undefined);
 }
@@ -747,7 +785,7 @@ onMounted(() => {
     props.modelValue,
     props.placeholder,
     plugins.value,
-    { onImageUpload: openFileBrowser },
+    { onImageUpload: openFileBrowser, onCopilotClick: handleCopilotClick },
     editorMenuOptions.value
   );
 
@@ -792,6 +830,14 @@ useEmitter(BUS_EVENTS.INSERT_INTO_RICH_EDITOR, insertContentIntoEditor);
       :search-key="toolSearchKey"
       @select-tool="content => insertSpecialContent('tool', content)"
     />
+    <CopilotMenuBar
+      v-if="showSelectionMenu"
+      v-on-click-outside="handleClickOutside"
+      :has-selection="isTextSelected"
+      :show-selection-menu="showSelectionMenu"
+      :show-general-menu="false"
+      @execute-copilot-action="handleCopilotAction"
+    />
     <input
       ref="imageUpload"
       type="file"
@@ -845,6 +891,10 @@ useEmitter(BUS_EVENTS.INSERT_INTO_RICH_EDITOR, insertContentIntoEditor);
           @apply size-full;
         }
       }
+
+      .ProseMirror-copilot svg {
+        @apply fill-n-violet-9;
+      }
     }
   }
 
@@ -983,6 +1033,10 @@ useEmitter(BUS_EVENTS.INSERT_INTO_RICH_EDITOR, insertContentIntoEditor);
         .ProseMirror-icon {
           @apply p-0.5 flex-shrink-0;
         }
+
+        .ProseMirror-copilot svg {
+          @apply fill-n-violet-9;
+        }
       }
 
       .ProseMirror-menu-active {

app/javascript/dashboard/components/widgets/WootWriter/EditorModeToggle.vue

@@ -12,6 +12,10 @@ const props = defineProps({
     type: Boolean,
     default: false,
   },
+  isReplyRestricted: {
+    type: Boolean,
+    default: false,
+  },
 });
 
 defineEmits(['toggleMode']);
@@ -24,11 +28,17 @@ const privateModeSize = useElementSize(wootEditorPrivateMode);
 
 /**
  * Computed boolean indicating if the editor is in private note mode
- * When disabled, always show NOTE mode regardless of actual mode prop
+ * When isReplyRestricted is true, force switch to private note
+ * Otherwise, respect the current mode prop
  * @type {ComputedRef<boolean>}
  */
 const isPrivate = computed(() => {
-  return props.disabled || props.mode === REPLY_EDITOR_MODES.NOTE;
+  if (props.isReplyRestricted) {
+    // Force switch to private note when replies are restricted
+    return true;
+  }
+  // Otherwise respect the current mode
+  return props.mode === REPLY_EDITOR_MODES.NOTE;
 });
 
 /**
@@ -60,9 +70,9 @@ const translateValue = computed(() => {
 <template>
   <button
     class="flex items-center w-auto h-8 p-1 transition-all border rounded-full bg-n-alpha-2 group relative duration-300 ease-in-out z-0 active:scale-[0.995] active:duration-75"
-    :disabled="disabled"
+    :disabled="disabled || isReplyRestricted"
     :class="{
-      'cursor-not-allowed': disabled,
+      'cursor-not-allowed': disabled || isReplyRestricted,
     }"
     @click="$emit('toggleMode')"
   >
@@ -75,7 +85,7 @@ const translateValue = computed(() => {
     <div
       class="absolute shadow-sm rounded-full h-6 w-[var(--chip-width)] ease-in-out translate-x-[var(--translate-x)] rtl:translate-x-[var(--rtl-translate-x)] bg-n-solid-1"
       :class="{
-        'transition-all duration-300': !disabled,
+        'transition-all duration-300': !disabled && !isReplyRestricted,
       }"
       :style="{
         '--chip-width': width,

app/javascript/dashboard/components/widgets/WootWriter/ReplyBottomPanel.vue

@@ -9,14 +9,13 @@ import { FEATURE_FLAGS } from 'dashboard/featureFlags';
 import { getAllowedFileTypesByChannel } from '@chatwoot/utils';
 import { ALLOWED_FILE_TYPES } from 'shared/constants/messages';
 import VideoCallButton from '../VideoCallButton.vue';
-import AIAssistanceButton from '../AIAssistanceButton.vue';
 import { INBOX_TYPES } from 'dashboard/helper/inbox';
 import { mapGetters } from 'vuex';
 import NextButton from 'dashboard/components-next/button/Button.vue';
 
 export default {
   name: 'ReplyBottomPanel',
-  components: { NextButton, FileUpload, VideoCallButton, AIAssistanceButton },
+  components: { NextButton, FileUpload, VideoCallButton },
   mixins: [inboxMixin],
   props: {
     isNote: {
@@ -98,6 +97,7 @@ export default {
       type: Number,
       required: true,
     },
+    // eslint-disable-next-line vue/no-unused-properties
     message: {
       type: String,
       default: '',
@@ -370,13 +370,6 @@ export default {
         v-if="(isAWebWidgetInbox || isAPIInbox) && !isOnPrivateNote"
         :conversation-id="conversationId"
       />
-      <AIAssistanceButton
-        v-if="!isFetchingAppIntegrations"
-        :conversation-id="conversationId"
-        :is-private-note="isOnPrivateNote"
-        :message="message"
-        @replace-text="replaceText"
-      />
       <transition name="modal-fade">
         <div
           v-show="uploadRef && uploadRef.dropActive"

app/javascript/dashboard/components/widgets/WootWriter/ReplyTopPanel.vue

@@ -1,14 +1,21 @@
 <script>
+import { ref } from 'vue';
 import { useKeyboardEvents } from 'dashboard/composables/useKeyboardEvents';
+import { vOnClickOutside } from '@vueuse/components';
 import { REPLY_EDITOR_MODES, CHAR_LENGTH_WARNING } from './constants';
 import NextButton from 'dashboard/components-next/button/Button.vue';
 import EditorModeToggle from './EditorModeToggle.vue';
+import CopilotMenuBar from './CopilotMenuBar.vue';
 
 export default {
   name: 'ReplyTopPanel',
   components: {
     NextButton,
     EditorModeToggle,
+    CopilotMenuBar,
+  },
+  directives: {
+    OnClickOutside: vOnClickOutside,
   },
   props: {
     mode: {
@@ -19,6 +26,10 @@ export default {
       type: Boolean,
       default: false,
     },
+    disabled: {
+      type: Boolean,
+      default: false,
+    },
     isMessageLengthReachingThreshold: {
       type: Boolean,
       default: () => false,
@@ -28,7 +39,7 @@ export default {
       default: () => 0,
     },
   },
-  emits: ['setReplyMode', 'togglePopout'],
+  emits: ['setReplyMode', 'togglePopout', 'executeCopilotAction'],
   setup(props, { emit }) {
     const setReplyMode = mode => {
       emit('setReplyMode', mode);
@@ -47,6 +58,21 @@ export default {
           : REPLY_EDITOR_MODES.REPLY;
       setReplyMode(newMode);
     };
+    const showCopilotMenu = ref(false);
+
+    const handleCopilotAction = actionKey => {
+      emit('executeCopilotAction', actionKey);
+      showCopilotMenu.value = false;
+    };
+
+    const toggleCopilotMenu = () => {
+      showCopilotMenu.value = !showCopilotMenu.value;
+    };
+
+    const handleClickOutside = () => {
+      showCopilotMenu.value = false;
+    };
+
     const keyboardEvents = {
       'Alt+KeyP': {
         action: () => handleNoteClick(),
@@ -64,6 +90,10 @@ export default {
       handleReplyClick,
       handleNoteClick,
       REPLY_EDITOR_MODES,
+      handleCopilotAction,
+      showCopilotMenu,
+      toggleCopilotMenu,
+      handleClickOutside,
     };
   },
   computed: {
@@ -90,11 +120,13 @@ export default {
 </script>
 
 <template>
-  <div class="flex justify-between h-[3.25rem] gap-2 ltr:pl-3 rtl:pr-3">
+  <div
+    class="flex justify-between gap-2 h-[3.25rem] items-center ltr:pl-3 ltr:pr-2 rtl:pr-3 rtl:pl-2"
+  >
     <EditorModeToggle
       :mode="mode"
-      :disabled="isReplyRestricted"
-      class="mt-3"
+      :disabled="disabled"
+      :is-reply-restricted="isReplyRestricted"
       @toggle-mode="handleModeToggle"
     />
     <div class="flex items-center mx-4 my-0">
@@ -104,11 +136,34 @@ export default {
         </span>
       </div>
     </div>
-    <NextButton
-      ghost
-      class="ltr:rounded-bl-md rtl:rounded-br-md ltr:rounded-br-none rtl:rounded-bl-none ltr:rounded-tl-none rtl:rounded-tr-none text-n-slate-11 ltr:rounded-tr-[11px] rtl:rounded-tl-[11px]"
-      icon="i-lucide-maximize-2"
-      @click="$emit('togglePopout')"
-    />
+    <div class="flex items-center gap-2">
+      <div class="relative">
+        <NextButton
+          ghost
+          :disabled="disabled"
+          :class="{
+            'text-n-violet-9 hover:enabled:!bg-n-violet-3': !showCopilotMenu,
+            'text-n-violet-9 bg-n-violet-3': showCopilotMenu,
+          }"
+          sm
+          icon="i-ph-sparkle-fill"
+          @click="toggleCopilotMenu"
+        />
+        <CopilotMenuBar
+          v-if="showCopilotMenu"
+          v-on-click-outside="handleClickOutside"
+          :has-selection="false"
+          class="ltr:right-0 rtl:left-0 bottom-full mb-2"
+          @execute-copilot-action="handleCopilotAction"
+        />
+      </div>
+      <NextButton
+        ghost
+        class="text-n-slate-11"
+        sm
+        icon="i-lucide-maximize-2"
+        @click="$emit('togglePopout')"
+      />
+    </div>
   </div>
 </template>

app/javascript/dashboard/components/widgets/conversation/CopilotEditorSection.vue

@@ -0,0 +1,87 @@
+<script setup>
+import { ref } from 'vue';
+import CopilotEditor from 'dashboard/components/widgets/WootWriter/CopilotEditor.vue';
+import CaptainLoader from 'dashboard/components/widgets/conversation/copilot/CaptainLoader.vue';
+
+defineProps({
+  showCopilotEditor: {
+    type: Boolean,
+    default: false,
+  },
+  isGeneratingContent: {
+    type: Boolean,
+    default: false,
+  },
+  generatedContent: {
+    type: String,
+    default: '',
+  },
+  isPopout: {
+    type: Boolean,
+    default: false,
+  },
+});
+
+const emit = defineEmits(['focus', 'blur', 'clearSelection', 'contentReady']);
+
+const copilotEditorContent = ref('');
+
+const onFocus = () => {
+  emit('focus');
+};
+
+const onBlur = () => {
+  emit('blur');
+};
+
+const clearEditorSelection = () => {
+  emit('clearSelection');
+};
+</script>
+
+<template>
+  <Transition
+    mode="out-in"
+    enter-active-class="transition-all duration-300 ease-out"
+    enter-from-class="opacity-0 translate-y-2 scale-[0.98]"
+    enter-to-class="opacity-100 translate-y-0 scale-100"
+    leave-active-class="transition-all duration-200 ease-in"
+    leave-from-class="opacity-100 translate-y-0 scale-100"
+    leave-to-class="opacity-0 translate-y-2 scale-[0.98]"
+    @after-enter="emit('contentReady')"
+  >
+    <CopilotEditor
+      v-if="showCopilotEditor && !isGeneratingContent"
+      key="copilot-editor"
+      v-model="copilotEditorContent"
+      class="copilot-editor"
+      :generated-content="generatedContent"
+      :min-height="4"
+      :enabled-menu-options="[]"
+      :is-popout="isPopout"
+      @focus="onFocus"
+      @blur="onBlur"
+      @clear-selection="clearEditorSelection"
+    />
+    <div
+      v-else-if="isGeneratingContent"
+      key="loading-state"
+      class="bg-n-iris-5 rounded min-h-16 w-full mb-4 p-4 flex items-start"
+    >
+      <div class="flex items-center gap-2">
+        <CaptainLoader class="text-n-iris-10 size-4" />
+        <span class="text-sm text-n-iris-10">
+          {{ $t('CONVERSATION.REPLYBOX.COPILOT_THINKING') }}
+        </span>
+      </div>
+    </div>
+  </Transition>
+</template>
+
+<style lang="scss">
+.copilot-editor {
+  .ProseMirror-menubar {
+    display: none;
+  }
+}
+</style>

app/javascript/dashboard/components/widgets/conversation/MessageSignatureMissingAlert.vue

@@ -11,7 +11,7 @@ const openProfileSettings = () => {
 
 <template>
   <div
-    class="my-0 mx-4 px-1 flex max-h-[8vh] items-baseline justify-between hover:bg-n-slate-1 border border-dashed border-n-weak rounded-sm overflow-auto"
+    class="my-0 px-1 flex max-h-[8vh] items-baseline justify-between hover:bg-n-slate-1 border border-dashed border-n-weak rounded-sm overflow-auto"
   >
     <p class="w-fit !m-0">
       {{ $t('CONVERSATION.FOOTER.MESSAGE_SIGNATURE_NOT_CONFIGURED') }}

app/javascript/dashboard/components/widgets/conversation/ReplyBox.vue

@@ -7,14 +7,14 @@ import { useTrack } from 'dashboard/composables';
 import keyboardEventListenerMixins from 'shared/mixins/keyboardEventListenerMixins';
 import { FEATURE_FLAGS } from 'dashboard/featureFlags';
 
-import CannedResponse from './CannedResponse.vue';
 import ReplyToMessage from './ReplyToMessage.vue';
-import ResizableTextArea from 'shared/components/ResizableTextArea.vue';
 import AttachmentPreview from 'dashboard/components/widgets/AttachmentsPreview.vue';
 import ReplyTopPanel from 'dashboard/components/widgets/WootWriter/ReplyTopPanel.vue';
 import ReplyEmailHead from './ReplyEmailHead.vue';
 import ReplyBottomPanel from 'dashboard/components/widgets/WootWriter/ReplyBottomPanel.vue';
+import CopilotReplyBottomPanel from 'dashboard/components/widgets/WootWriter/CopilotReplyBottomPanel.vue';
 import ArticleSearchPopover from 'dashboard/routes/dashboard/helpcenter/components/ArticleSearch/SearchPopover.vue';
+import CopilotEditorSection from './CopilotEditorSection.vue';
 import MessageSignatureMissingAlert from './MessageSignatureMissingAlert.vue';
 import ReplyBoxBanner from './ReplyBoxBanner.vue';
 import QuotedEmailPreview from './QuotedEmailPreview.vue';
@@ -48,6 +48,7 @@ import {
   getEffectiveChannelType,
   extractTextFromMarkdown,
 } from 'dashboard/helper/editorHelper';
+import { useCopilotReply } from 'dashboard/composables/useCopilotReply';
 
 import { LOCAL_STORAGE_KEYS } from 'dashboard/constants/localStorage';
 import { LocalStorage } from 'shared/helpers/localStorage';
@@ -72,8 +73,8 @@ export default {
     WhatsappTemplates,
     WootMessageEditor,
     QuotedEmailPreview,
-    ResizableTextArea,
-    CannedResponse,
+    CopilotEditorSection,
+    CopilotReplyBottomPanel,
   },
   mixins: [inboxMixin, fileUploadMixin, keyboardEventListenerMixins],
   props: {
@@ -93,6 +94,7 @@ export default {
     } = useUISettings();
 
     const replyEditor = useTemplateRef('replyEditor');
+    const copilot = useCopilotReply();
 
     return {
       uiSettings,
@@ -101,6 +103,7 @@ export default {
       setQuotedReplyFlagForInbox,
       fetchQuotedReplyFlagFromUISettings,
       replyEditor,
+      copilot,
     };
   },
   data() {
@@ -406,6 +409,9 @@ export default {
         !!this.quotedEmailText
       );
     },
+    isDefaultEditorMode() {
+      return !this.showAudioRecorderEditor && !this.copilot.isActive.value;
+    },
     showRichContentEditor() {
       if (this.isOnPrivateNote || this.isRichEditorEnabled) {
         return true;
@@ -428,6 +434,8 @@ export default {
         // This prevents overwriting user input (e.g., CC/BCC fields) when performing actions
         // like self-assign or other updates that do not actually change the conversation context
         this.setCCAndToEmailsFromLastChat();
+        // Reset Copilot editor state (includes cancelling ongoing generation)
+        this.copilot.reset();
       }
 
       if (this.isOnPrivateNote) {
@@ -890,6 +898,9 @@ export default {
         this.insertIntoTextEditor(content, selectionStart, selectionEnd);
       }
     },
+    executeCopilotAction(action, data) {
+      this.copilot.execute(action, data);
+    },
     clearMessage() {
       this.message = '';
       if (this.sendWithSignature && !this.isPrivate) {
@@ -1162,6 +1173,9 @@ export default {
     togglePopout() {
       this.$emit('update:popOutReplyBox', !this.popOutReplyBox);
     },
+    onSubmitCopilotReply() {
+      this.message = this.copilot.accept();
+    },
   },
 };
 </script>
@@ -1172,11 +1186,17 @@ export default {
     <ReplyTopPanel
       :mode="replyType"
       :is-reply-restricted="isReplyRestricted"
+      :disabled="
+        (copilot.isActive.value && copilot.isButtonDisabled.value) ||
+        showAudioRecorderEditor
+      "
       :is-message-length-reaching-threshold="isMessageLengthReachingThreshold"
       :characters-remaining="charactersRemaining"
       :popout-reply-box="popOutReplyBox"
       @set-reply-mode="setReplyMode"
       @toggle-popout="togglePopout"
+      @toggle-copilot="copilot.toggleEditor"
+      @execute-copilot-action="executeCopilotAction"
     />
     <ArticleSearchPopover
       v-if="showArticleSearchPopover && connectedPortalSlug"
@@ -1184,135 +1204,167 @@ export default {
       @insert="handleInsert"
       @close="onSearchPopoverClose"
     />
-    <div class="reply-box__top">
-      <ReplyToMessage
-        v-if="shouldShowReplyToMessage"
-        :message="inReplyTo"
-        @dismiss="resetReplyToMessage"
-      />
-      <CannedResponse
-        v-if="showMentions && hasSlashCommand"
-        v-on-clickaway="hideMentions"
-        class="normal-editor__canned-box"
-        :search-key="mentionSearchKey"
-        @replace="replaceText"
-      />
-      <EmojiInput
-        v-if="showEmojiPicker"
-        v-on-clickaway="hideEmojiPicker"
-        :class="{
-          'emoji-dialog--expanded': isOnExpandedLayout || popOutReplyBox,
-        }"
-        :on-click="addIntoEditor"
-      />
-      <ReplyEmailHead
-        v-if="showReplyHead"
-        v-model:cc-emails="ccEmails"
-        v-model:bcc-emails="bccEmails"
-        v-model:to-emails="toEmails"
-      />
-      <AudioRecorder
-        v-if="showAudioRecorderEditor"
-        ref="audioRecorderInput"
-        :audio-record-format="audioRecordFormat"
-        @recorder-progress-changed="onRecordProgressChanged"
-        @finish-record="onFinishRecorder"
-        @play="recordingAudioState = 'playing'"
-        @pause="recordingAudioState = 'paused'"
-      />
-      <ResizableTextArea
-        v-else-if="!showRichContentEditor"
-        ref="messageInput"
-        v-model="message"
-        class="rounded-none input"
-        :placeholder="messagePlaceHolder"
-        :min-height="4"
-        :signature="signatureToApply"
-        allow-signature
-        :send-with-signature="sendWithSignature"
-        @typing-off="onTypingOff"
-        @typing-on="onTypingOn"
-        @focus="onFocus"
-        @blur="onBlur"
-      />
-      <WootMessageEditor
-        v-else
-        v-model="message"
-        :editor-id="editorStateId"
-        class="input popover-prosemirror-menu"
-        :is-private="isOnPrivateNote"
-        :placeholder="messagePlaceHolder"
-        :update-selection-with="updateEditorSelectionWith"
-        :min-height="4"
-        enable-variables
-        :variables="messageVariables"
-        :signature="messageSignature"
-        allow-signature
-        :channel-type="channelType"
-        :medium="inbox.medium"
-        @typing-off="onTypingOff"
-        @typing-on="onTypingOn"
-        @focus="onFocus"
-        @blur="onBlur"
-        @toggle-user-mention="toggleUserMention"
-        @toggle-canned-menu="toggleCannedMenu"
-        @toggle-variables-menu="toggleVariablesMenu"
-        @clear-selection="clearEditorSelection"
-      />
-      <QuotedEmailPreview
-        v-if="shouldShowQuotedPreview"
-        :quoted-email-text="quotedEmailText"
-        :preview-text="quotedEmailPreviewText"
-        @toggle="toggleQuotedReply"
-      />
-    </div>
-    <div
-      v-if="hasAttachments && !showAudioRecorderEditor"
-      class="attachment-preview-box"
-      @paste="onPaste"
+    <Transition
+      mode="out-in"
+      enter-active-class="transition-all duration-300 ease-out"
+      enter-from-class="opacity-0 translate-y-2 scale-[0.98]"
+      enter-to-class="opacity-100 translate-y-0 scale-100"
+      leave-active-class="transition-all duration-200 ease-in"
+      leave-from-class="opacity-100 translate-y-0 scale-100"
+      leave-to-class="opacity-0 translate-y-2 scale-[0.98]"
     >
-      <AttachmentPreview
-        class="flex-col mt-4"
-        :attachments="attachedFiles"
-        @remove-attachment="removeAttachment"
+      <div :key="copilot.editorTransitionKey.value" class="reply-box__top">
+        <ReplyToMessage
+          v-if="shouldShowReplyToMessage"
+          :message="inReplyTo"
+          @dismiss="resetReplyToMessage"
+        />
+        <EmojiInput
+          v-if="showEmojiPicker"
+          v-on-clickaway="hideEmojiPicker"
+          :class="{
+            'emoji-dialog--expanded': isOnExpandedLayout || popOutReplyBox,
+          }"
+          :on-click="addIntoEditor"
+        />
+        <ReplyEmailHead
+          v-if="showReplyHead && isDefaultEditorMode"
+          v-model:cc-emails="ccEmails"
+          v-model:bcc-emails="bccEmails"
+          v-model:to-emails="toEmails"
+        />
+        <AudioRecorder
+          v-if="showAudioRecorderEditor"
+          ref="audioRecorderInput"
+          :audio-record-format="audioRecordFormat"
+          @recorder-progress-changed="onRecordProgressChanged"
+          @finish-record="onFinishRecorder"
+          @play="recordingAudioState = 'playing'"
+          @pause="recordingAudioState = 'paused'"
+        />
+        <CopilotEditorSection
+          v-if="copilot.isActive.value && !showAudioRecorderEditor"
+          :show-copilot-editor="copilot.showEditor.value"
+          :is-generating-content="copilot.isGenerating.value"
+          :generated-content="copilot.generatedContent.value"
+          :is-popout="popOutReplyBox"
+          :placeholder="$t('CONVERSATION.FOOTER.COPILOT_MSG_INPUT')"
+          @focus="onFocus"
+          @blur="onBlur"
+          @clear-selection="clearEditorSelection"
+          @close="copilot.showEditor.value = false"
+          @content-ready="copilot.setContentReady"
+        />
+        <WootMessageEditor
+          v-else-if="!showAudioRecorderEditor"
+          v-model="message"
+          :editor-id="editorStateId"
+          class="input popover-prosemirror-menu"
+          :is-private="isOnPrivateNote"
+          :placeholder="messagePlaceHolder"
+          :update-selection-with="updateEditorSelectionWith"
+          :min-height="4"
+          enable-variables
+          :variables="messageVariables"
+          :signature="messageSignature"
+          allow-signature
+          :channel-type="channelType"
+          @typing-off="onTypingOff"
+          @typing-on="onTypingOn"
+          @focus="onFocus"
+          @blur="onBlur"
+          @toggle-user-mention="toggleUserMention"
+          @toggle-canned-menu="toggleCannedMenu"
+          @toggle-variables-menu="toggleVariablesMenu"
+          @clear-selection="clearEditorSelection"
+          @execute-copilot-action="executeCopilotAction"
+        />
+
+        <QuotedEmailPreview
+          v-if="shouldShowQuotedPreview && isDefaultEditorMode"
+          :quoted-email-text="quotedEmailText"
+          :preview-text="quotedEmailPreviewText"
+          class="mb-2"
+          @toggle="toggleQuotedReply"
+        />
+
+        <div
+          v-if="hasAttachments && isDefaultEditorMode"
+          class="bg-transparent py-0 mb-2"
+          @paste="onPaste"
+        >
+          <AttachmentPreview
+            class="mt-2"
+            :attachments="attachedFiles"
+            @remove-attachment="removeAttachment"
+          />
+        </div>
+        <MessageSignatureMissingAlert
+          v-if="
+            isSignatureEnabledForInbox &&
+            !isSignatureAvailable &&
+            isDefaultEditorMode
+          "
+          class="mb-2"
+        />
+      </div>
+    </Transition>
+
+    <Transition
+      mode="out-in"
+      enter-active-class="transition-all duration-300 ease-out"
+      enter-from-class="opacity-0 translate-y-2 scale-[0.98]"
+      enter-to-class="opacity-100 translate-y-0 scale-100"
+      leave-active-class="transition-all duration-200 ease-in"
+      leave-from-class="opacity-100 translate-y-0 scale-100"
+      leave-to-class="opacity-0 translate-y-2 scale-[0.98]"
+    >
+      <CopilotReplyBottomPanel
+        v-if="copilot.isActive.value"
+        key="copilot-bottom-panel"
+        :is-private="isOnPrivateNote"
+        :is-generating-content="copilot.isButtonDisabled.value"
+        @submit="onSubmitCopilotReply"
+        @cancel="copilot.toggleEditor"
       />
-    </div>
-    <MessageSignatureMissingAlert
-      v-if="isSignatureEnabledForInbox && !isSignatureAvailable"
-    />
-    <ReplyBottomPanel
-      :conversation-id="conversationId"
-      :enable-multiple-file-upload="enableMultipleFileUpload"
-      :enable-whats-app-templates="showWhatsappTemplates"
-      :enable-content-templates="showContentTemplates"
-      :inbox="inbox"
-      :is-on-private-note="isOnPrivateNote"
-      :is-recording-audio="isRecordingAudio"
-      :is-send-disabled="isReplyButtonDisabled"
-      :is-note="isPrivate"
-      :on-file-upload="onFileUpload"
-      :on-send="onSendReply"
-      :conversation-type="conversationType"
-      :recording-audio-duration-text="recordingAudioDurationText"
-      :recording-audio-state="recordingAudioState"
-      :send-button-text="replyButtonLabel"
-      :show-audio-recorder="showAudioRecorder"
-      :show-emoji-picker="showEmojiPicker"
-      :show-file-upload="showFileUpload"
-      :show-quoted-reply-toggle="shouldShowQuotedReplyToggle"
-      :quoted-reply-enabled="quotedReplyPreference"
-      :toggle-audio-recorder-play-pause="toggleAudioRecorderPlayPause"
-      :toggle-audio-recorder="toggleAudioRecorder"
-      :toggle-emoji-picker="toggleEmojiPicker"
-      :message="message"
-      :portal-slug="connectedPortalSlug"
-      :new-conversation-modal-active="newConversationModalActive"
-      @select-whatsapp-template="openWhatsappTemplateModal"
-      @select-content-template="openContentTemplateModal"
-      @replace-text="replaceText"
-      @toggle-insert-article="toggleInsertArticle"
-      @toggle-quoted-reply="toggleQuotedReply"
-    />
+      <ReplyBottomPanel
+        v-else
+        key="reply-bottom-panel"
+        :conversation-id="conversationId"
+        :enable-multiple-file-upload="enableMultipleFileUpload"
+        :enable-whats-app-templates="showWhatsappTemplates"
+        :enable-content-templates="showContentTemplates"
+        :inbox="inbox"
+        :is-on-private-note="isOnPrivateNote"
+        :is-recording-audio="isRecordingAudio"
+        :is-send-disabled="isReplyButtonDisabled"
+        :is-note="isPrivate"
+        :on-file-upload="onFileUpload"
+        :on-send="onSendReply"
+        :conversation-type="conversationType"
+        :recording-audio-duration-text="recordingAudioDurationText"
+        :recording-audio-state="recordingAudioState"
+        :send-button-text="replyButtonLabel"
+        :show-audio-recorder="showAudioRecorder"
+        :show-editor-toggle="isAPIInbox && !isOnPrivateNote"
+        :show-emoji-picker="showEmojiPicker"
+        :show-file-upload="showFileUpload"
+        :show-quoted-reply-toggle="shouldShowQuotedReplyToggle"
+        :quoted-reply-enabled="quotedReplyPreference"
+        :toggle-audio-recorder-play-pause="toggleAudioRecorderPlayPause"
+        :toggle-audio-recorder="toggleAudioRecorder"
+        :toggle-emoji-picker="toggleEmojiPicker"
+        :message="message"
+        :portal-slug="connectedPortalSlug"
+        :new-conversation-modal-active="newConversationModalActive"
+        @select-whatsapp-template="openWhatsappTemplateModal"
+        @select-content-template="openContentTemplateModal"
+        @replace-text="replaceText"
+        @toggle-insert-article="toggleInsertArticle"
+        @toggle-quoted-reply="toggleQuotedReply"
+      />
+    </Transition>
+
     <WhatsappTemplates
       :inbox-id="inbox.id"
       :show="showWhatsAppTemplatesModal"
@@ -1342,13 +1394,7 @@ export default {
   @apply mb-0;
 }
 
-.attachment-preview-box {
-  @apply bg-transparent py-0 px-4;
-}
-
 .reply-box {
-  transition: height 2s cubic-bezier(0.37, 0, 0.63, 1);
-
   @apply relative mb-2 mx-2 border border-n-weak rounded-xl bg-n-solid-1;
 
   &.is-private {

app/javascript/dashboard/components/widgets/conversation/copilot/CaptainLoader.vue

@@ -0,0 +1,33 @@
+<script setup>
+import Icon from 'next/icon/Icon.vue';
+</script>
+
+<template>
+  <Icon v-once icon="i-woot-captain" class="jumping-logo" />
+</template>
+
+<style scoped>
+.jumping-logo {
+  transform-origin: center bottom;
+  animation: jump 1s cubic-bezier(0.28, 0.84, 0.42, 1) infinite;
+  will-change: transform;
+}
+
+@keyframes jump {
+  0% {
+    transform: translateY(0) scale(1, 1);
+  }
+  20% {
+    transform: translateY(0) scale(1.05, 0.95);
+  }
+  50% {
+    transform: translateY(-5px) scale(0.95, 1.05);
+  }
+  80% {
+    transform: translateY(0) scale(1.02, 0.98);
+  }
+  100% {
+    transform: translateY(0) scale(1, 1);
+  }
+}
+</style>

app/javascript/dashboard/composables/commands/useConversationHotKeys.js

@@ -102,8 +102,8 @@ const createNonDraftMessageAIAssistActions = (t, replyMode) => {
 const createDraftMessageAIAssistActions = t => {
   return [
     {
-      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.REPHRASE'),
-      key: 'rephrase',
+      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.CONFIDENT'),
+      key: 'confident',
       icon: ICON_AI_ASSIST,
     },
     {
@@ -112,28 +112,23 @@ const createDraftMessageAIAssistActions = t => {
       icon: ICON_AI_GRAMMAR,
     },
     {
-      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.EXPAND'),
-      key: 'expand',
+      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.PROFESSIONAL'),
+      key: 'professional',
       icon: ICON_AI_EXPAND,
     },
     {
-      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.SHORTEN'),
-      key: 'shorten',
+      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.CASUAL'),
+      key: 'casual',
       icon: ICON_AI_SHORTEN,
     },
     {
       label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.MAKE_FRIENDLY'),
-      key: 'make_friendly',
+      key: 'friendly',
       icon: ICON_AI_ASSIST,
     },
     {
-      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.MAKE_FORMAL'),
-      key: 'make_formal',
-      icon: ICON_AI_ASSIST,
-    },
-    {
-      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.SIMPLIFY'),
-      key: 'simplify',
+      label: t('INTEGRATION_SETTINGS.OPEN_AI.OPTIONS.STRAIGHTFORWARD'),
+      key: 'straightforward',
       icon: ICON_AI_ASSIST,
     },
   ];

app/javascript/dashboard/composables/spec/useAI.spec.js

@@ -5,12 +5,12 @@ import {
   useMapGetter,
 } from 'dashboard/composables/store';
 import { useI18n } from 'vue-i18n';
-import OpenAPI from 'dashboard/api/integrations/openapi';
+import EditorAPI from 'dashboard/api/captain/editor';
 import analyticsHelper from 'dashboard/helper/AnalyticsHelper/index';
 
 vi.mock('dashboard/composables/store');
 vi.mock('vue-i18n');
-vi.mock('dashboard/api/integrations/openapi');
+vi.mock('dashboard/api/captain/editor');
 vi.mock('dashboard/helper/AnalyticsHelper/index', async importOriginal => {
   const actual = await importOriginal();
   actual.default = {
@@ -94,7 +94,7 @@ describe('useAI', () => {
   });
 
   it('fetches label suggestions', async () => {
-    OpenAPI.processEvent.mockResolvedValue({
+    EditorAPI.processEvent.mockResolvedValue({
       data: { message: 'label1, label2' },
     });
 
@@ -111,9 +111,8 @@ describe('useAI', () => {
     const { fetchLabelSuggestions } = useAI();
     const result = await fetchLabelSuggestions();
 
-    expect(OpenAPI.processEvent).toHaveBeenCalledWith({
+    expect(EditorAPI.processEvent).toHaveBeenCalledWith({
       type: 'label_suggestion',
-      hookId: 'hook1',
       conversationId: '123',
     });
 

app/javascript/dashboard/composables/useAI.js

@@ -7,7 +7,7 @@ import {
 import { useAlert, useTrack } from 'dashboard/composables';
 import { useI18n } from 'vue-i18n';
 import { OPEN_AI_EVENTS } from 'dashboard/helper/AnalyticsHelper/events';
-import OpenAPI from 'dashboard/api/integrations/openapi';
+import EditorAPI from 'dashboard/api/captain/editor';
 
 /**
  * Cleans and normalizes a list of labels.
@@ -57,7 +57,7 @@ export function useAI() {
    * Computed property to check if AI integration is enabled.
    * @type {import('vue').ComputedRef<boolean>}
    */
-  const isAIIntegrationEnabled = computed(() => !!aiIntegration.value);
+  const isAIIntegrationEnabled = computed(() => true);
 
   /**
    * Computed property to check if label suggestion feature is enabled.
@@ -77,12 +77,6 @@ export function useAI() {
    */
   const isFetchingAppIntegrations = computed(() => uiFlags.value.isFetching);
 
-  /**
-   * Computed property for the hook ID.
-   * @type {import('vue').ComputedRef<string|undefined>}
-   */
-  const hookId = computed(() => aiIntegration.value?.id);
-
   /**
    * Computed property for the conversation ID.
    * @type {import('vue').ComputedRef<string|undefined>}
@@ -139,9 +133,8 @@ export function useAI() {
     if (!conversationId.value) return [];
 
     try {
-      const result = await OpenAPI.processEvent({
+      const result = await EditorAPI.processEvent({
         type: 'label_suggestion',
-        hookId: hookId.value,
         conversationId: conversationId.value,
       });
 
@@ -156,24 +149,33 @@ export function useAI() {
   };
 
   /**
-   * Processes an AI event, such as rephrasing content.
-   * @param {string} [type='rephrase'] - The type of AI event to process.
+   * Processes an AI event, such as improving content.
+   * @param {string} [type='improve'] - The type of AI event to process.
+   * @param {string} [content=''] - The content to process (for full message) or selected text (for selection-based).
+   * @param {Object} [options={}] - Additional options.
+   * @param {AbortSignal} [options.signal] - AbortSignal to cancel the request.
    * @returns {Promise<string>} The generated message or an empty string if an error occurs.
    */
-  const processEvent = async (type = 'rephrase') => {
+  const processEvent = async (type = 'improve', content = '', options = {}) => {
     try {
-      const result = await OpenAPI.processEvent({
-        hookId: hookId.value,
-        type,
-        content: draftMessage.value,
-        conversationId: conversationId.value,
-      });
+      const result = await EditorAPI.processEvent(
+        {
+          type,
+          content: content || draftMessage.value,
+          conversationId: conversationId.value,
+        },
+        options.signal
+      );
       const {
         data: { message: generatedMessage },
       } = result;
       return generatedMessage;
     } catch (error) {
-      const errorData = error.response.data.error;
+      // Don't show error for aborted requests
+      if (error.name === 'AbortError' || error.name === 'CanceledError') {
+        return '';
+      }
+      const errorData = error.response?.data?.error;
       const errorMessage =
         errorData?.error?.message ||
         t('INTEGRATION_SETTINGS.OPEN_AI.GENERATE_ERROR');

app/javascript/dashboard/composables/useCopilotReply.js

@@ -0,0 +1,122 @@
+import { ref, computed } from 'vue';
+import { useAI } from 'dashboard/composables/useAI';
+import { useUISettings } from 'dashboard/composables/useUISettings';
+
+/**
+ * Composable for managing Copilot reply generation state and actions.
+ * Extracts copilot-related logic from ReplyBox for cleaner code organization.
+ *
+ * @returns {Object} Copilot reply state and methods
+ */
+export function useCopilotReply() {
+  const { processEvent } = useAI();
+  const { updateUISettings } = useUISettings();
+
+  const showEditor = ref(false);
+  const isGenerating = ref(false);
+  const isContentReady = ref(false);
+  const generatedContent = ref('');
+  const abortController = ref(null);
+
+  const isActive = computed(() => showEditor.value || isGenerating.value);
+  const isButtonDisabled = computed(
+    () => isGenerating.value || !isContentReady.value
+  );
+  const editorTransitionKey = computed(() =>
+    isActive.value ? 'copilot' : 'rich'
+  );
+
+  /**
+   * Resets all copilot editor state and cancels any ongoing generation.
+   */
+  function reset() {
+    if (abortController.value) {
+      abortController.value.abort();
+      abortController.value = null;
+    }
+    showEditor.value = false;
+    isGenerating.value = false;
+    isContentReady.value = false;
+    generatedContent.value = '';
+  }
+
+  /**
+   * Toggles the copilot editor visibility.
+   */
+  function toggleEditor() {
+    showEditor.value = !showEditor.value;
+  }
+
+  /**
+   * Marks content as ready (called after transition completes).
+   */
+  function setContentReady() {
+    isContentReady.value = true;
+  }
+
+  /**
+   * Executes a copilot action (e.g., improve, fix grammar).
+   * @param {string} action - The action type
+   * @param {string} data - The content to process
+   */
+  async function execute(action, data) {
+    if (action === 'ask_copilot') {
+      updateUISettings({
+        is_contact_sidebar_open: false,
+        is_copilot_panel_open: true,
+      });
+      return;
+    }
+
+    // Reset and start new generation
+    reset();
+    abortController.value = new AbortController();
+    isGenerating.value = true;
+    isContentReady.value = false;
+
+    try {
+      const content = await processEvent(action, data, {
+        signal: abortController.value.signal,
+      });
+
+      if (!abortController.value?.signal.aborted) {
+        generatedContent.value = content;
+        if (content) showEditor.value = true;
+        isGenerating.value = false;
+      }
+    } catch {
+      if (!abortController.value?.signal.aborted) {
+        isGenerating.value = false;
+      }
+    }
+  }
+
+  /**
+   * Accepts the generated content and returns it.
+   * Note: Formatting is automatically stripped by the Editor component's
+   * createState function based on the channel's schema.
+   * @returns {string} The content ready for the editor
+   */
+  function accept() {
+    const content = generatedContent.value;
+    showEditor.value = false;
+    return content;
+  }
+
+  return {
+    showEditor,
+    isGenerating,
+    isContentReady,
+    generatedContent,
+
+    isActive,
+    isButtonDisabled,
+    editorTransitionKey,
+
+    reset,
+    toggleEditor,
+    setContentReady,
+    execute,
+    accept,
+  };
+}

app/javascript/dashboard/constants/editor.js

@@ -7,6 +7,7 @@ export const FORMATTING = {
     marks: ['strong', 'em', 'code', 'link'],
     nodes: ['bulletList', 'orderedList', 'codeBlock', 'blockquote', 'image'],
     menu: [
+      'copilot',
       'strong',
       'em',
       'code',
@@ -21,6 +22,7 @@ export const FORMATTING = {
     marks: ['strong', 'em', 'code', 'link', 'strike'],
     nodes: ['bulletList', 'orderedList', 'codeBlock', 'blockquote', 'image'],
     menu: [
+      'copilot',
       'strong',
       'em',
       'code',
@@ -35,12 +37,13 @@ export const FORMATTING = {
   'Channel::Api': {
     marks: ['strong', 'em'],
     nodes: [],
-    menu: ['strong', 'em', 'undo', 'redo'],
+    menu: ['copilot', 'strong', 'em', 'undo', 'redo'],
   },
   'Channel::FacebookPage': {
     marks: ['strong', 'em', 'code', 'strike'],
     nodes: ['bulletList', 'orderedList', 'codeBlock'],
     menu: [
+      'copilot',
       'strong',
       'em',
       'code',
@@ -70,6 +73,7 @@ export const FORMATTING = {
     marks: ['strong', 'em', 'code', 'strike'],
     nodes: ['bulletList', 'orderedList', 'codeBlock'],
     menu: [
+      'copilot',
       'strong',
       'em',
       'code',
@@ -83,17 +87,18 @@ export const FORMATTING = {
   'Channel::Line': {
     marks: ['strong', 'em', 'code', 'strike'],
     nodes: ['codeBlock'],
-    menu: ['strong', 'em', 'code', 'strike', 'undo', 'redo'],
+    menu: ['copilot', 'strong', 'em', 'code', 'strike', 'undo', 'redo'],
   },
   'Channel::Telegram': {
     marks: ['strong', 'em', 'link', 'code'],
     nodes: [],
-    menu: ['strong', 'em', 'link', 'code', 'undo', 'redo'],
+    menu: ['copilot', 'strong', 'em', 'link', 'code', 'undo', 'redo'],
   },
   'Channel::Instagram': {
     marks: ['strong', 'em', 'code', 'strike'],
     nodes: ['bulletList', 'orderedList'],
     menu: [
+      'copilot',
       'strong',
       'em',
       'code',
@@ -110,6 +115,22 @@ export const FORMATTING = {
     menu: [],
   },
   // Special contexts (not actual channels)
+  'Context::PrivateNote': {
+    marks: ['strong', 'em', 'code', 'link', 'strike'],
+    nodes: ['bulletList', 'orderedList', 'codeBlock', 'blockquote'],
+    menu: [
+      'copilot',
+      'strong',
+      'em',
+      'code',
+      'link',
+      'strike',
+      'bulletList',
+      'orderedList',
+      'undo',
+      'redo',
+    ],
+  },
   'Context::Default': {
     marks: ['strong', 'em', 'code', 'link', 'strike'],
     nodes: ['bulletList', 'orderedList', 'codeBlock', 'blockquote'],

app/javascript/dashboard/helper/AnalyticsHelper/events.js

@@ -88,6 +88,7 @@ export const OPEN_AI_EVENTS = Object.freeze({
   SUMMARIZE: 'OpenAI: Used summarize',
   REPLY_SUGGESTION: 'OpenAI: Used reply suggestion',
   REPHRASE: 'OpenAI: Used rephrase',
+  IMPROVE: 'OpenAI: Used improve',
   FIX_SPELLING_AND_GRAMMAR: 'OpenAI: Used fix spelling and grammar',
   SHORTEN: 'OpenAI: Used shorten',
   EXPAND: 'OpenAI: Used expand',

app/javascript/dashboard/i18n/locale/en/conversation.json

@@ -185,6 +185,7 @@
       "MSG_INPUT": "Shift + enter for new line. Start with '/' to select a Canned Response.",
       "PRIVATE_MSG_INPUT": "Shift + enter for new line. This will be visible only to Agents",
       "MESSAGE_SIGNATURE_NOT_CONFIGURED": "Message signature is not configured, please configure it in profile settings.",
+      "COPILOT_MSG_INPUT": "Give copilot additional prompts, or ask anything else...",
       "CLICK_HERE": "Click here to update",
       "WHATSAPP_TEMPLATES": "Whatsapp Templates"
     },
@@ -204,7 +205,7 @@
       "DRAG_DROP": "Drag and drop here to attach",
       "START_AUDIO_RECORDING": "Start audio recording",
       "STOP_AUDIO_RECORDING": "Stop audio recording",
-      "": "",
+      "COPILOT_THINKING": "Copilot is thinking",
       "EMAIL_HEAD": {
         "TO": "TO",
         "ADD_BCC": "Add bcc",

app/javascript/dashboard/i18n/locale/en/index.js

@@ -38,7 +38,6 @@ import teamsSettings from './teamsSettings.json';
 import whatsappTemplates from './whatsappTemplates.json';
 import contentTemplates from './contentTemplates.json';
 import mfa from './mfa.json';
-import yearInReview from './yearInReview.json';
 
 export default {
   ...advancedFilters,
@@ -81,5 +80,4 @@ export default {
   ...whatsappTemplates,
   ...contentTemplates,
   ...mfa,
-  ...yearInReview,
 };

app/javascript/dashboard/i18n/locale/en/integrations.json

@@ -145,7 +145,29 @@
         "EXPAND": "Expand",
         "MAKE_FRIENDLY": "Change message tone to friendly",
         "MAKE_FORMAL": "Use formal tone",
-        "SIMPLIFY": "Simplify"
+        "SIMPLIFY": "Simplify",
+        "CONFIDENT": "Use confident tone",
+        "PROFESSIONAL": "Use professional tone",
+        "CASUAL": "Use casual tone",
+        "STRAIGHTFORWARD": "Use straightforward tone"
+      },
+      "REPLY_OPTIONS": {
+        "IMPROVE_REPLY": "Improve reply",
+        "IMPROVE_REPLY_SELECTION": "Improve the selection",
+        "CHANGE_TONE": {
+          "TITLE": "Change tone",
+          "OPTIONS": {
+            "PROFESSIONAL": "Professional",
+            "CASUAL": "Casual",
+            "STRAIGHTFORWARD": "Straightforward",
+            "CONFIDENT": "Confident",
+            "FRIENDLY": "Friendly"
+          }
+        },
+        "GRAMMAR": "Fix grammar & spelling",
+        "SUGGESTION": "Suggest a reply",
+        "SUMMARIZE": "Summarize the conversation",
+        "ASK_COPILOT": "Ask Copilot"
       },
       "ASSISTANCE_MODAL": {
         "DRAFT_TITLE": "Draft content",

app/javascript/dashboard/i18n/locale/en/settings.json

@@ -234,7 +234,6 @@
     "CONTACT_SUPPORT": "Contact support",
     "SELECTOR_SUBTITLE": "Select an account from the following list",
     "PROFILE_SETTINGS": "Profile settings",
-    "YEAR_IN_REVIEW": "Year in Review",
     "KEYBOARD_SHORTCUTS": "Keyboard shortcuts",
     "APPEARANCE": "Change appearance",
     "SUPER_ADMIN_CONSOLE": "SuperAdmin console",

app/javascript/dashboard/i18n/locale/en/yearInReview.json

@@ -1,64 +0,0 @@
-{
-  "YEAR_IN_REVIEW": {
-    "TITLE": "Year in Review",
-    "LOADING": "Loading your year in review...",
-    "ERROR": "Failed to load year in review",
-    "CLOSE": "Close",
-    "CONVERSATIONS": {
-      "TITLE": "You have handled",
-      "SUBTITLE": "conversations",
-      "FALLBACK": "This year wasn't about the numbers. It was about showing up.",
-      "COMPARISON": {
-        "0_50": "You showed up, and that's how every good inbox begins.",
-        "50_100": "You kept the replies flowing and the conversations alive.",
-        "100_500": "You handled serious volume and kept everything on track.",
-        "500_2000": "You kept things moving while the volume kept climbing.",
-        "2000_10000": "You ran high traffic through your inbox without breaking a sweat.",
-        "10000_PLUS": "That's a full city of customers knocking on your door. You made it look effortless."
-      }
-    },
-    "BUSIEST_DAY": {
-      "TITLE": "Your busiest day was",
-      "MESSAGE": "{count} conversations that day.",
-      "COMPARISON": {
-        "0_5": "A warm-up lap that barely woke the inbox.",
-        "5_10": "Enough action to justify a second cup of coffee.",
-        "10_25": "Things got busy and the inbox stayed on its toes.",
-        "25_50": "A proper rush that barely broke a sweat.",
-        "50_100": "Controlled chaos, handled like a normal Tuesday.",
-        "100_500": "Absolute dumpster fire, somehow still shipping replies.",
-        "500_PLUS": "The inbox lost all chill and never slowed down."
-      }
-    },
-    "PERSONALITY": {
-      "TITLE": "Your support personality is",
-      "MESSAGES": {
-        "SWIFT_HELPER": "You replied in {time} on average. Faster than most notifications.",
-        "QUICK_RESPONDER": "You replied in {time} on average. The inbox barely waited.",
-        "STEADY_SUPPORT": "You replied in {time} on average. Calm pace, solid replies.",
-        "THOUGHTFUL_ADVISOR": "You replied in {time} on average. Took the time to get it right."
-      }
-    },
-    "THANK_YOU": {
-      "TITLE": "Congratulations on surviving the inbox of {year}.",
-      "MESSAGE": "Thank you for your incredible dedication to supporting customers throughout this year. Your hard work has made a real difference, and we're grateful to have you on this journey. Here's to making {nextYear} even better together!"
-    },
-    "SHARE_MODAL": {
-      "TITLE": "Share Your Year in Review",
-      "PREPARING": "Preparing your image...",
-      "DOWNLOAD": "Download",
-      "SHARE_TITLE": "My {year} Year in Review",
-      "SHARE_TEXT": "Check out my {year} Year in Review with Chatwoot!",
-      "BRANDING": "Made with Chatwoot"
-    },
-    "BANNER": {
-      "TITLE": "Your {year} Year in Review is here",
-      "BUTTON": "See your impact"
-    },
-    "NAVIGATION": {
-      "PREVIOUS": "Previous",
-      "NEXT": "Next",
-      "SHARE": "Share"
-    }
-  }
-}

app/javascript/shared/constants/openai.js

@@ -1,11 +0,0 @@
-export const OPEN_AI_OPTIONS = {
-  IMPROVE_WRITING: 'improve_writing',
-  FIX_SPELLING_GRAMMAR: 'fix_spelling_grammar',
-  SHORTEN: 'shorten',
-  EXPAND: 'expand',
-  MAKE_FRIENDLY: 'make_friendly',
-  MAKE_FORMAL: 'make_formal',
-  SIMPLIFY: 'simplify',
-  REPLY_SUGGESTION: 'reply_suggestion',
-  SUMMARIZE: 'summarize',
-};

app/models/integrations/hook.rb

@@ -64,13 +64,10 @@ class Integrations::Hook < ApplicationRecord
     update(status: 'disabled')
   end
 
-  def process_event(event)
-    case app_id
-    when 'openai'
-      Integrations::Openai::ProcessorService.new(hook: self, event: event).perform if app_id == 'openai'
-    else
-      { error: 'No processor found' }
-    end
+  def process_event(_event)
+    # OpenAI integration migrated to Captain::EditorService
+    # Other integrations (slack, dialogflow, etc.) handled via HookJob
+    { error: 'No processor found' }
   end
 
   def feature_allowed?

app/policies/captain/editor_policy.rb

@@ -0,0 +1,17 @@
+class Captain::EditorPolicy < ApplicationPolicy
+  def rewrite?
+    true
+  end
+
+  def summarize?
+    true
+  end
+
+  def reply_suggestion?
+    true
+  end
+
+  def label_suggestion?
+    true
+  end
+end

config/llm.yml

@@ -0,0 +1,62 @@
+providers:
+  openai:
+    display_name: "OpenAI"
+    logo: openai.png
+
+models:
+  gpt-4o:
+    provider: openai
+    display_name: "GPT-4o"
+    credit_multiplier: 0.5
+  gpt-4o-mini:
+    provider: openai
+    display_name: "GPT-4o Mini"
+    credit_multiplier: 0.3
+  gpt-4.1:
+    provider: openai
+    display_name: "GPT-4.1"
+    credit_multiplier: 0.5
+  gpt-4.1-mini:
+    provider: openai
+    display_name: "GPT-4.1 Mini"
+    credit_multiplier: 0.3
+  gpt-4.1-nano:
+    provider: openai
+    display_name: "GPT-4.1 Nano"
+    credit_multiplier: 0.1
+  gpt-5:
+    provider: openai
+    display_name: "GPT-5"
+    credit_multiplier: 1
+  gpt-5.1:
+    provider: openai
+    display_name: "GPT-5.1"
+    credit_multiplier: 1
+  gpt-5-mini:
+    provider: openai
+    display_name: "GPT-5 Mini"
+    credit_multiplier: 0.8
+  gpt-5-nano:
+    provider: openai
+    display_name: "GPT-5 Nano"
+    credit_multiplier: 0.3
+  gpt-5.2:
+    provider: openai
+    display_name: "GPT-5.2"
+    credit_multiplier: 1
+
+features:
+  editor:
+    models: [gpt-4o-mini, gpt-4.1-mini, gpt-4.1-nano, gpt-5-mini, gpt-4o, gpt-4.1, gpt-5, gpt-5.1, gpt-5.2]
+    default: gpt-5-mini
+  assistant:
+    models: [gpt-5-mini, gpt-4o, gpt-4.1, gpt-5, gpt-5.1, gpt-5.2]
+    default: gpt-5-mini
+  copilot:
+    models: [gpt-5-mini, gpt-4o, gpt-4.1, gpt-5, gpt-5.1, gpt-5.2]
+    default: gpt-5-mini
+  label_suggestion:
+    models: [gpt-4.1-nano, gpt-4o-mini, gpt-4.1-mini, gpt-5-mini]
+    default: gpt-4.1-nano
+
+# add deprecation_map later

config/routes.rb

@@ -69,6 +69,12 @@ Rails.application.routes.draw do
             end
             resources :custom_tools
             resources :documents, only: [:index, :show, :create, :destroy]
+            resource :editor, only: [], controller: 'editor' do
+              post :rewrite
+              post :summarize
+              post :reply_suggestion
+              post :label_suggestion
+            end
           end
           resource :saml_settings, only: [:show, :create, :update, :destroy]
           resources :agent_bots, only: [:index, :create, :show, :update, :destroy] do
@@ -203,15 +209,9 @@ Rails.application.routes.draw do
             delete :avatar, on: :member
             post :sync_templates, on: :member
             get :health, on: :member
-            if ChatwootApp.enterprise?
-              resource :conference, only: %i[create destroy], controller: 'conference' do
-                get :token, on: :member
-              end
-            end
 
             resource :csat_template, only: [:show, :create], controller: 'inbox_csat_templates'
           end
-
           resources :inbox_members, only: [:create, :show], param: :inbox_id do
             collection do
               delete :destroy
@@ -425,7 +425,6 @@ Rails.application.routes.draw do
               get :bot_metrics
             end
           end
-          resource :year_in_review, only: [:show]
           resources :live_reports, only: [] do
             collection do
               get :conversation_metrics
@@ -557,9 +556,13 @@ Rails.application.routes.draw do
     resources :delivery_status, only: [:create]
 
     if ChatwootApp.enterprise?
-      post 'voice/call/:phone', to: 'voice#call_twiml', as: :voice_call
-      post 'voice/status/:phone', to: 'voice#status', as: :voice_status
-      post 'voice/conference_status/:phone', to: 'voice#conference_status', as: :voice_conference_status
+      resource :voice, only: [], controller: 'voice' do
+        collection do
+          post 'call/:phone', action: :call_twiml
+          post 'status/:phone', action: :status
+          post 'conference_status/:phone', action: :conference_status
+        end
+      end
     end
   end
 

enterprise/app/controllers/api/v1/accounts/captain/editor_controller.rb

@@ -0,0 +1,57 @@
+class Api::V1::Accounts::Captain::EditorController < Api::V1::Accounts::BaseController
+  before_action :check_authorization
+
+  def rewrite
+    result = Captain::RewriteService.new(
+      account: Current.account,
+      content: params[:content],
+      operation: params[:operation],
+      conversation_display_id: params[:conversation_display_id]
+    ).perform
+
+    render_result(result)
+  end
+
+  def summarize
+    result = Captain::SummaryService.new(
+      account: Current.account,
+      conversation_display_id: params[:conversation_display_id]
+    ).perform
+
+    render_result(result)
+  end
+
+  def reply_suggestion
+    result = Captain::ReplySuggestionService.new(
+      account: Current.account,
+      conversation_display_id: params[:conversation_display_id]
+    ).perform
+
+    render_result(result)
+  end
+
+  def label_suggestion
+    result = Captain::LabelSuggestionService.new(
+      account: Current.account,
+      conversation_display_id: params[:conversation_display_id]
+    ).perform
+
+    render_result(result)
+  end
+
+  private
+
+  def render_result(result)
+    if result.nil?
+      render json: { message: nil }
+    elsif result[:error]
+      render json: { error: result[:error] }, status: :unprocessable_entity
+    else
+      render json: { message: result[:message] }
+    end
+  end
+
+  def check_authorization
+    authorize(:'captain/editor')
+  end
+end

enterprise/app/controllers/api/v1/accounts/conference_controller.rb

@@ -1,58 +0,0 @@
-class Api::V1::Accounts::ConferenceController < Api::V1::Accounts::BaseController
-  before_action :set_voice_inbox_for_conference
-
-  def token
-    render json: Voice::Provider::Twilio::TokenService.new(
-      inbox: @voice_inbox,
-      user: Current.user,
-      account: Current.account
-    ).generate
-  end
-
-  def create
-    conversation = fetch_conversation_by_display_id
-    ensure_call_sid!(conversation)
-
-    conference_service = Voice::Provider::Twilio::ConferenceService.new(conversation: conversation)
-    conference_sid = conference_service.ensure_conference_sid
-    conference_service.mark_agent_joined(user: current_user)
-
-    render json: {
-      status: 'success',
-      id: conversation.display_id,
-      conference_sid: conference_sid,
-      using_webrtc: true
-    }
-  end
-
-  def destroy
-    conversation = fetch_conversation_by_display_id
-    Voice::Provider::Twilio::ConferenceService.new(conversation: conversation).end_conference
-    render json: { status: 'success', id: conversation.display_id }
-  end
-
-  private
-
-  def ensure_call_sid!(conversation)
-    return conversation.identifier if conversation.identifier.present?
-
-    incoming_sid = params.require(:call_sid)
-
-    conversation.update!(identifier: incoming_sid)
-    incoming_sid
-  end
-
-  def set_voice_inbox_for_conference
-    @voice_inbox = Current.account.inboxes.find(params[:inbox_id])
-    authorize @voice_inbox, :show?
-  end
-
-  def fetch_conversation_by_display_id
-    cid = params[:conversation_id]
-    raise ActiveRecord::RecordNotFound, 'conversation_id required' if cid.blank?
-
-    conversation = @voice_inbox.conversations.find_by!(display_id: cid)
-    authorize conversation, :show?
-    conversation
-  end
-end

enterprise/app/controllers/twilio/voice_controller.rb

@@ -151,8 +151,9 @@ class Twilio::VoiceController < ApplicationController
   end
 
   def conference_status_callback_url
+    host = ENV.fetch('FRONTEND_URL', '')
     phone_digits = inbox_channel.phone_number.delete_prefix('+')
-    Rails.application.routes.url_helpers.twilio_voice_conference_status_url(phone: phone_digits)
+    "#{host}/twilio/voice/conference_status/#{phone_digits}"
   end
 
   def find_conversation_for_conference!(friendly_name:, call_sid:)

enterprise/app/models/channel/voice.rb

@@ -42,13 +42,11 @@ class Channel::Voice < ApplicationRecord
     false
   end
 
-  def initiate_call(to:, conference_sid: nil, agent_id: nil)
+  def initiate_call(to:)
     case provider
     when 'twilio'
-      Voice::Provider::Twilio::Adapter.new(self).initiate_call(
-        to: to,
-        conference_sid: conference_sid,
-        agent_id: agent_id
+      Voice::Provider::TwilioAdapter.new(self).initiate_call(
+        to: to
       )
     else
       raise "Unsupported voice provider: #{provider}"
@@ -58,12 +56,12 @@ class Channel::Voice < ApplicationRecord
   # Public URLs used to configure Twilio webhooks
   def voice_call_webhook_url
     digits = phone_number.delete_prefix('+')
-    Rails.application.routes.url_helpers.twilio_voice_call_url(phone: digits)
+    "#{ENV.fetch('FRONTEND_URL', nil)}/twilio/voice/call/#{digits}"
   end
 
   def voice_status_webhook_url
     digits = phone_number.delete_prefix('+')
-    Rails.application.routes.url_helpers.twilio_voice_status_url(phone: digits)
+    "#{ENV.fetch('FRONTEND_URL', nil)}/twilio/voice/status/#{digits}"
   end
 
   private
@@ -89,6 +87,7 @@ class Channel::Voice < ApplicationRecord
       errors.add(:provider_config, "#{key} is required for Twilio provider") if config[key].blank?
     end
   end
+  # twilio_client and initiate_twilio_call moved to Voice::Provider::TwilioAdapter
 
   def provider_config_hash
     if provider_config.is_a?(Hash)

enterprise/app/services/voice/provider/twilio/adapter.rb

@@ -1,52 +0,0 @@
-class Voice::Provider::Twilio::Adapter
-  def initialize(channel)
-    @channel = channel
-  end
-
-  def initiate_call(to:, conference_sid: nil, agent_id: nil)
-    call = twilio_client.calls.create(**call_params(to))
-
-    {
-      provider: 'twilio',
-      call_sid: call.sid,
-      status: call.status,
-      call_direction: 'outbound',
-      requires_agent_join: true,
-      agent_id: agent_id,
-      conference_sid: conference_sid
-    }
-  end
-
-  private
-
-  def call_params(to)
-    phone_digits = @channel.phone_number.delete_prefix('+')
-
-    {
-      from: @channel.phone_number,
-      to: to,
-      url: twilio_call_twiml_url(phone_digits),
-      status_callback: twilio_call_status_url(phone_digits),
-      status_callback_event: %w[
-        initiated ringing answered completed failed busy no-answer canceled
-      ],
-      status_callback_method: 'POST'
-    }
-  end
-
-  def twilio_call_twiml_url(phone_digits)
-    Rails.application.routes.url_helpers.twilio_voice_call_url(phone: phone_digits)
-  end
-
-  def twilio_call_status_url(phone_digits)
-    Rails.application.routes.url_helpers.twilio_voice_status_url(phone: phone_digits)
-  end
-
-  def twilio_client
-    Twilio::REST::Client.new(config['account_sid'], config['auth_token'])
-  end
-
-  def config
-    @config ||= @channel.provider_config_hash
-  end
-end

enterprise/app/services/voice/provider/twilio/conference_service.rb

@@ -1,46 +0,0 @@
-class Voice::Provider::Twilio::ConferenceService
-  pattr_initialize [:conversation!, { twilio_client: nil }]
-
-  def ensure_conference_sid
-    existing = conversation.additional_attributes&.dig('conference_sid')
-    return existing if existing.present?
-
-    sid = Voice::Conference::Name.for(conversation)
-    merge_attributes('conference_sid' => sid)
-    sid
-  end
-
-  def mark_agent_joined(user:)
-    merge_attributes(
-      'agent_joined' => true,
-      'joined_at' => Time.current.to_i,
-      'joined_by' => { id: user.id, name: user.name }
-    )
-  end
-
-  def end_conference
-    twilio_client
-      .conferences
-      .list(friendly_name: Voice::Conference::Name.for(conversation), status: 'in-progress')
-      .each { |conf| twilio_client.conferences(conf.sid).update(status: 'completed') }
-  end
-
-  private
-
-  def merge_attributes(attrs)
-    current = conversation.additional_attributes || {}
-    conversation.update!(additional_attributes: current.merge(attrs))
-  end
-
-  def twilio_client
-    @twilio_client ||= ::Twilio::REST::Client.new(account_sid, auth_token)
-  end
-
-  def account_sid
-    @account_sid ||= conversation.inbox.channel.provider_config_hash['account_sid']
-  end
-
-  def auth_token
-    @auth_token ||= conversation.inbox.channel.provider_config_hash['auth_token']
-  end
-end

enterprise/app/services/voice/provider/twilio/token_service.rb

@@ -1,62 +0,0 @@
-class Voice::Provider::Twilio::TokenService
-  pattr_initialize [:inbox!, :user!, :account!]
-
-  def generate
-    {
-      token: access_token.to_jwt,
-      identity: identity,
-      voice_enabled: true,
-      account_sid: config['account_sid'],
-      agent_id: user.id,
-      account_id: account.id,
-      inbox_id: inbox.id,
-      phone_number: inbox.channel.phone_number,
-      twiml_endpoint: twiml_url,
-      has_twiml_app: config['twiml_app_sid'].present?
-    }
-  end
-
-  private
-
-  def config
-    @config ||= inbox.channel.provider_config_hash || {}
-  end
-
-  def identity
-    @identity ||= "agent-#{user.id}-account-#{account.id}"
-  end
-
-  def access_token
-    Twilio::JWT::AccessToken.new(
-      config['account_sid'],
-      config['api_key_sid'],
-      config['api_key_secret'],
-      identity: identity,
-      ttl: 1.hour.to_i
-    ).tap { |token| token.add_grant(voice_grant) }
-  end
-
-  def voice_grant
-    Twilio::JWT::AccessToken::VoiceGrant.new.tap do |grant|
-      grant.incoming_allow = true
-      grant.outgoing_application_sid = config['twiml_app_sid']
-      grant.outgoing_application_params = outgoing_params
-    end
-  end
-
-  def outgoing_params
-    {
-      account_id: account.id,
-      agent_id: user.id,
-      identity: identity,
-      client_name: identity,
-      accountSid: config['account_sid'],
-      is_agent: 'true'
-    }
-  end
-
-  def twiml_url
-    digits = inbox.channel.phone_number.delete_prefix('+')
-    Rails.application.routes.url_helpers.twilio_voice_call_url(phone: digits)
-  end
-end

enterprise/app/services/voice/provider/twilio_adapter.rb

@@ -0,0 +1,32 @@
+class Voice::Provider::TwilioAdapter
+  def initialize(channel)
+    @channel = channel
+  end
+
+  def initiate_call(to:, _conference_sid: nil, _agent_id: nil)
+    cfg = @channel.provider_config_hash
+
+    host = ENV.fetch('FRONTEND_URL')
+    phone_digits = @channel.phone_number.delete_prefix('+')
+    callback_url = "#{host}/twilio/voice/call/#{phone_digits}"
+
+    params = {
+      from: @channel.phone_number,
+      to: to,
+      url: callback_url,
+      status_callback: "#{host}/twilio/voice/status/#{phone_digits}",
+      status_callback_event: %w[initiated ringing answered completed],
+      status_callback_method: 'POST'
+    }
+
+    call = twilio_client(cfg).calls.create(**params)
+
+    { call_sid: call.sid }
+  end
+
+  private
+
+  def twilio_client(config)
+    Twilio::REST::Client.new(config['account_sid'], config['auth_token'])
+  end
+end

enterprise/lib/enterprise/integrations/openai_processor_service.rb

@@ -1,82 +0,0 @@
-module Enterprise::Integrations::OpenaiProcessorService
-  ALLOWED_EVENT_NAMES = %w[rephrase summarize reply_suggestion label_suggestion fix_spelling_grammar shorten expand
-                           make_friendly make_formal simplify].freeze
-  CACHEABLE_EVENTS = %w[label_suggestion].freeze
-
-  def label_suggestion_message
-    payload = label_suggestion_body
-    return nil if payload.blank?
-
-    response = make_api_call(label_suggestion_body)
-
-    return response if response[:error].present?
-
-    # LLMs are not deterministic, so this is bandaid solution
-    # To what you ask? Sometimes, the response includes
-    # "Labels:" in it's response in some format. This is a hacky way to remove it
-    # TODO: Fix with with a better prompt
-    { message: response[:message] ? response[:message].gsub(/^(label|labels):/i, '') : '' }
-  end
-
-  private
-
-  def labels_with_messages
-    return nil unless valid_conversation?(conversation)
-
-    labels = hook.account.labels.pluck(:title).join(', ')
-    character_count = labels.length
-
-    messages = init_messages_body(false)
-    add_messages_until_token_limit(conversation, messages, false, character_count)
-
-    return nil if messages.blank? || labels.blank?
-
-    "Messages:\n#{messages}\nLabels:\n#{labels}"
-  end
-
-  def valid_conversation?(conversation)
-    return false if conversation.nil?
-    return false if conversation.messages.incoming.count < 3
-
-    # Think Mark think, at this point the conversation is beyond saving
-    return false if conversation.messages.count > 100
-
-    # if there are more than 20 messages, only trigger this if the last message is from the client
-    return false if conversation.messages.count > 20 && !conversation.messages.last.incoming?
-
-    true
-  end
-
-  def summarize_body
-    {
-      model: self.class::GPT_MODEL,
-      messages: [
-        { role: 'system',
-          content: prompt_from_file('summary', enterprise: true) },
-        { role: 'user', content: conversation_messages }
-      ]
-    }.to_json
-  end
-
-  def label_suggestion_body
-    return unless label_suggestions_enabled?
-
-    content = labels_with_messages
-    return value_from_cache if content.blank?
-
-    {
-      model: self.class::GPT_MODEL,
-      messages: [
-        {
-          role: 'system',
-          content: prompt_from_file('label_suggestion', enterprise: true)
-        },
-        { role: 'user', content: content }
-      ]
-    }.to_json
-  end
-
-  def label_suggestions_enabled?
-    hook.settings['label_suggestion'].present?
-  end
-end

lib/captain/base_editor_service.rb

@@ -0,0 +1,121 @@
+class Captain::BaseEditorService
+  include Integrations::LlmInstrumentation
+
+  # gpt-4o-mini supports 128,000 tokens
+  # 1 token is approx 4 characters
+  # sticking with 120000 to be safe
+  # 120000 * 4 = 480,000 characters (rounding off downwards to 400,000 to be safe)
+  TOKEN_LIMIT = 400_000
+  GPT_MODEL = Llm::Config::DEFAULT_MODEL
+
+  pattr_initialize [:account!, { conversation_display_id: nil }]
+
+  private
+
+  def event_name
+    raise NotImplementedError, "#{self.class} must implement #event_name"
+  end
+
+  def conversation
+    @conversation ||= account.conversations.find_by(display_id: conversation_display_id)
+  end
+
+  def api_base
+    endpoint = InstallationConfig.find_by(name: 'CAPTAIN_OPEN_AI_ENDPOINT')&.value.presence || 'https://api.openai.com/'
+    endpoint = endpoint.chomp('/')
+    "#{endpoint}/v1"
+  end
+
+  def make_api_call(model:, messages:)
+    instrumentation_params = build_instrumentation_params(model, messages)
+
+    instrument_llm_call(instrumentation_params) do
+      execute_ruby_llm_request(model: model, messages: messages)
+    end
+  end
+
+  def execute_ruby_llm_request(model:, messages:)
+    Llm::Config.with_api_key(api_key, api_base: api_base) do |context|
+      chat = context.chat(model: model)
+      system_msg = messages.find { |m| m[:role] == 'system' }
+      chat.with_instructions(system_msg[:content]) if system_msg
+
+      conversation_messages = messages.reject { |m| m[:role] == 'system' }
+      return { error: 'No conversation messages provided', error_code: 400, request_messages: messages } if conversation_messages.empty?
+
+      add_messages_if_needed(chat, conversation_messages)
+      response = chat.ask(conversation_messages.last[:content])
+      build_ruby_llm_response(response, messages)
+    end
+  rescue StandardError => e
+    ChatwootExceptionTracker.new(e, account: account).capture_exception
+    { error: e.message, request_messages: messages }
+  end
+
+  def add_messages_if_needed(chat, conversation_messages)
+    return if conversation_messages.length == 1
+
+    conversation_messages[0...-1].each do |msg|
+      chat.add_message(role: msg[:role].to_sym, content: msg[:content])
+    end
+  end
+
+  def build_ruby_llm_response(response, messages)
+    {
+      message: response.content,
+      usage: {
+        'prompt_tokens' => response.input_tokens,
+        'completion_tokens' => response.output_tokens,
+        'total_tokens' => (response.input_tokens || 0) + (response.output_tokens || 0)
+      },
+      request_messages: messages
+    }
+  end
+
+  def build_instrumentation_params(model, messages)
+    {
+      span_name: "llm.#{event_name}",
+      account_id: account.id,
+      conversation_id: conversation&.display_id,
+      feature_name: event_name,
+      model: model,
+      messages: messages,
+      temperature: nil
+    }
+  end
+
+  def conversation_messages(start_from: 0)
+    messages = []
+    character_count = start_from
+
+    conversation.messages
+                .where(message_type: [:incoming, :outgoing])
+                .where(private: false)
+                .reorder('id desc')
+                .each do |message|
+      content = message.content_for_llm
+      break unless content.present? && character_count + content.length <= TOKEN_LIMIT
+
+      messages.prepend({ role: (message.incoming? ? 'user' : 'assistant'), content: content })
+      character_count += content.length
+    end
+
+    messages
+  end
+
+  def api_key
+    @api_key ||= openai_hook&.settings&.dig('api_key') || system_api_key
+  end
+
+  def openai_hook
+    @openai_hook ||= account.hooks.find_by(app_id: 'openai', status: 'enabled')
+  end
+
+  def system_api_key
+    @system_api_key ||= InstallationConfig.find_by(name: 'CAPTAIN_OPEN_AI_API_KEY')&.value
+  end
+
+  def prompt_from_file(file_name)
+    Rails.root.join('lib/integrations/openai/openai_prompts', "#{file_name}.liquid").read
+  end
+end

lib/captain/label_suggestion_service.rb

@@ -0,0 +1,89 @@
+class Captain::LabelSuggestionService < Captain::BaseEditorService
+  pattr_initialize [:account!, :conversation_display_id!]
+
+  def perform
+    # Check cache first
+    cached_response = read_from_cache
+    return cached_response if cached_response.present?
+
+    # Build content
+    content = labels_with_messages
+    return nil if content.blank?
+
+    # Make API call
+    response = make_api_call(
+      model: GPT_MODEL, # TODO: Use separate model for label suggestion
+      messages: [
+        { role: 'system', content: prompt_from_file('label_suggestion') },
+        { role: 'user', content: content }
+      ]
+    )
+    return response if response[:error].present?
+
+    # Clean up response
+    result = { message: response[:message] ? response[:message].gsub(/^(label|labels):/i, '') : '' }
+
+    # Cache successful result
+    write_to_cache(result)
+
+    result
+  end
+
+  private
+
+  def cache_key
+    return nil unless conversation
+
+    format(
+      ::Redis::Alfred::OPENAI_CONVERSATION_KEY,
+      event_name: 'label_suggestion',
+      conversation_id: conversation.id,
+      updated_at: conversation.last_activity_at.to_i
+    )
+  end
+
+  def read_from_cache
+    return nil unless cache_key
+
+    cached = Redis::Alfred.get(cache_key)
+    JSON.parse(cached, symbolize_names: true) if cached.present?
+  rescue JSON::ParserError
+    nil
+  end
+
+  def write_to_cache(response)
+    Redis::Alfred.setex(cache_key, response.to_json) if cache_key
+  end
+
+  def labels_with_messages
+    return nil unless valid_conversation?(conversation)
+
+    labels = account.labels.pluck(:title).join(', ')
+    messages = format_messages_as_string(start_from: labels.length)
+
+    return nil if messages.blank? || labels.blank?
+
+    "Messages:\n#{messages}\nLabels:\n#{labels}"
+  end
+
+  def format_messages_as_string(start_from: 0)
+    messages = conversation_messages(start_from: start_from)
+    messages.map do |msg|
+      sender_type = msg[:role] == 'user' ? 'Customer' : 'Agent'
+      "#{sender_type}: #{msg[:content]}\n"
+    end.join
+  end
+
+  def valid_conversation?(conversation)
+    return false if conversation.nil?
+    return false if conversation.messages.incoming.count < 3
+    return false if conversation.messages.count > 100
+    return false if conversation.messages.count > 20 && !conversation.messages.last.incoming?
+
+    true
+  end
+
+  def event_name
+    'label_suggestion'
+  end
+end

lib/captain/reply_suggestion_service.rb

@@ -0,0 +1,18 @@
+class Captain::ReplySuggestionService < Captain::BaseEditorService
+  pattr_initialize [:account!, :conversation_display_id!]
+
+  def perform
+    make_api_call(
+      model: GPT_MODEL,
+      messages: [
+        { role: 'system', content: prompt_from_file('reply') }
+      ].concat(conversation_messages)
+    )
+  end
+
+  private
+
+  def event_name
+    'reply_suggestion'
+  end
+end

lib/captain/rewrite_service.rb

@@ -0,0 +1,67 @@
+class Captain::RewriteService < Captain::BaseEditorService
+  pattr_initialize [:account!, :content!, :operation!, { conversation_display_id: nil }]
+
+  def perform
+    send(operation)
+  end
+
+  private
+
+  def fix_spelling_grammar
+    call_llm_with_prompt(prompt_from_file('fix_spelling_grammar'))
+  end
+
+  def casual
+    call_llm_with_prompt(tone_rewrite_prompt('casual'))
+  end
+
+  def professional
+    call_llm_with_prompt(tone_rewrite_prompt('professional'))
+  end
+
+  def friendly
+    call_llm_with_prompt(tone_rewrite_prompt('friendly'))
+  end
+
+  def confident
+    call_llm_with_prompt(tone_rewrite_prompt('confident'))
+  end
+
+  def straightforward
+    call_llm_with_prompt(tone_rewrite_prompt('straightforward'))
+  end
+
+  def improve
+    template = prompt_from_file('improve')
+
+    system_prompt = render_liquid_template(template, {
+                                             'conversation_context' => conversation.to_llm_text(include_contact_details: true),
+                                             'draft_message' => content
+                                           })
+
+    call_llm_with_prompt(system_prompt, content)
+  end
+
+  def call_llm_with_prompt(system_content, user_content = content)
+    make_api_call(
+      model: GPT_MODEL,
+      messages: [
+        { role: 'system', content: system_content },
+        { role: 'user', content: user_content }
+      ]
+    )
+  end
+
+  def render_liquid_template(template_content, variables = {})
+    Liquid::Template.parse(template_content).render(variables)
+  end
+
+  def tone_rewrite_prompt(tone)
+    template = prompt_from_file('tone_rewrite')
+    render_liquid_template(template, 'tone' => tone)
+  end
+
+  def event_name
+    operation
+  end
+end

lib/captain/summary_service.rb

@@ -0,0 +1,19 @@
+class Captain::SummaryService < Captain::BaseEditorService
+  pattr_initialize [:account!, :conversation_display_id!]
+
+  def perform
+    make_api_call(
+      model: GPT_MODEL,
+      messages: [
+        { role: 'system', content: prompt_from_file('summary') },
+        { role: 'user', content: conversation.to_llm_text(include_contact_details: false) }
+      ]
+    )
+  end
+
+  private
+
+  def event_name
+    'summarize'
+  end
+end

lib/integrations/llm_base_service.rb

@@ -7,7 +7,8 @@ class Integrations::LlmBaseService
   # 120000 * 4 = 480,000 characters (rounding off downwards to 400,000 to be safe)
   TOKEN_LIMIT = 400_000
   GPT_MODEL = Llm::Config::DEFAULT_MODEL
-  ALLOWED_EVENT_NAMES = %w[rephrase summarize reply_suggestion fix_spelling_grammar shorten expand make_friendly make_formal simplify].freeze
+  ALLOWED_EVENT_NAMES = %w[summarize reply_suggestion fix_spelling_grammar casual professional friendly confident
+                           straightforward improve].freeze
   CACHEABLE_EVENTS = %w[].freeze
 
   pattr_initialize [:hook!, :event!]

lib/integrations/openai/openai_prompts/fix_spelling_grammar.liquid

@@ -0,0 +1,17 @@
+You are an AI writing assistant integrated into Chatwoot, an omnichannel customer support platform. Your task is to fix grammar and spelling in a customer support message while preserving the original meaning, intent, and tone.
+
+You will receive a message and must return a corrected version with only grammar, spelling, and punctuation fixes applied.
+
+Important guidelines:
+- Preserve the original meaning, intent, and tone exactly
+- Do not rephrase, rewrite, or change wording beyond grammar, spelling, and punctuation
+- Do not add or remove any information
+- Do not simplify, shorten, or expand the message
+- Ensure the output remains appropriate for customer support
+
+Super Important:
+- If the message has some markdown formatting, keep the formatting as it is. 
+- Block quotes (lines starting with >) contain quoted text from the customer's previous message. Preserve this quoted text exactly as written (do not modify the customer's words inside the block quote), but DO improve the agent's reply that follows the block quote.
+- Ensure the output is in the user's original language
+
+Output only the corrected message, with no preamble, tags, or explanation.

lib/integrations/openai/openai_prompts/improve.liquid

@@ -0,0 +1,43 @@
+You are a writing assistant for customer support agents. Your task is to improve a draft message by enhancing its language, clarity, and tone—not by adding new content.
+
+<conversation_context>
+{{ conversation_context }}
+</conversation_context>
+
+<draft_message>
+{{ draft_message }}
+</draft_message>
+
+## Your Task
+
+Rewrite the draft to be clearer, warmer, and more professional while preserving the agent's intent.
+
+## What "Improve" Means
+
+Improve the **quality** of the message, not the **quantity** of information:
+
+| DO | DON'T |
+|-----|--------|
+| Fix grammar, spelling, punctuation | Add new information or steps |
+| Improve sentence structure and flow | Expand scope beyond the draft |
+| Make tone warmer and more professional | Add offers ("I can also...", "Would you like...") |
+| Use contact's name naturally | Invent technical details, links, or examples |
+| Make vague phrases more natural | Turn a brief answer into a long one |
+
+## Using the Context
+
+Use the conversation context to:
+- Understand what's being discussed (so improvements make sense)
+- Gauge appropriate tone (formal/casual, frustrated customer, etc.)
+- Personalize with the contact's name when natural
+
+Do NOT use the context to fill in gaps or add information the agent didn't include.
+
+## Output Rules
+
+- Keep the improved message at a similar length to the draft (brief stays brief)
+- Preserve any markdown formatting
+- Block quotes (lines starting with `>`) contain quoted customer text—keep this unchanged, only improve the agent's reply
+- Output in the same language as the draft
+- Output only the improved message, no commentary
+

lib/integrations/openai/openai_prompts/label_suggestion.liquid

@@ -1 +1 @@
-Your role is as an assistant to a customer support agent. You will be provided with a transcript of a conversation between a customer and the support agent, along with a list of potential labels. Your task is to analyze the conversation and select the two labels from the given list that most accurately represent the themes or issues discussed.  Ensure you preserve the exact casing of the labels as they are provided in the list. Do not create new labels; only choose from those provided. Once you have made your selections, please provide your response as a comma-separated list of the provided labels. Remember, your response should only contain the labels you\'ve selected,in their original casing, and nothing else.
+Your role is as an assistant to a customer support agent. You will be provided with a transcript of a conversation between a customer and the support agent, along with a list of potential labels. Your task is to analyze the conversation and select the two labels from the given list that most accurately represent the themes or issues discussed.  Ensure you preserve the exact casing of the labels as they are provided in the list. Do not create new labels; only choose from those provided. Once you have made your selections, please provide your response as a comma-separated list of the provided labels. Remember, your response should only contain the labels you've selected,in their original casing, and nothing else.

lib/integrations/openai/openai_prompts/summary.liquid

@@ -1,13 +1,13 @@
-As an AI-powered summarization tool, your task is to condense lengthy interactions between customer support agents and customers into brief, digestible summaries. The objective of these summaries is to provide a quick overview, enabling any agent, even those without prior context, to grasp the essence of the conversation promptly. 
+As an AI-powered summarization tool, your task is to condense lengthy interactions between customer support agents and customers into brief, digestible summaries. The objective of these summaries is to provide a quick overview, enabling any agent, even those without prior context, to grasp the essence of the conversation promptly.
 
 Make sure you strongly adhere to the following rules when generating the summary
 
-1. Be brief and concise. The shorter the summary the better. 
-2. Aim to summarize the conversation in approximately 200 words, formatted as multiple small paragraphs that are easier to read. 
+1. Be brief and concise. The shorter the summary the better.
+2. Aim to summarize the conversation in approximately 200 words, formatted as multiple small paragraphs that are easier to read.
 3. Describe the customer intent in around 50 words.
 4. Remove information that is not directly relevant to the customer's problem or the agent's solution. For example, personal anecdotes, small talk, etc.
 5. Don't include segments of the conversation that didn't contribute meaningful content, like greetings or farewell.
-6. The 'Action Items' should be a bullet list, arranged in order of priority if possible. 
+6. The 'Action Items' should be a bullet list, arranged in order of priority if possible.
 7. 'Action Items' should strictly encapsulate tasks committed to by the agent or left incomplete. Any suggestions made by the agent should not be included.
 8. The 'Action Items' should be brief and concise
 9. Mark important words or parts of sentences as bold.
@@ -25,4 +25,4 @@ Reply in the user's language, as a markdown of the following format.
 
 **Action Items**
 
-**Follow-up Items**
+**Follow-up Items**

lib/integrations/openai/openai_prompts/summary.txt

@@ -1 +0,0 @@
-Please summarize the key points from the following conversation between support agents and customer as bullet points for the next support agent looking into the conversation. Reply in the user's language.

lib/integrations/openai/openai_prompts/tone_rewrite.liquid

@@ -0,0 +1,35 @@
+You are an AI writing assistant integrated into Chatwoot, an omnichannel customer support platform. Your task is to rewrite customer support message to match a specific tone while preserving the original meaning and intent.
+
+Here is the tone to apply to the message you will receive:
+<tone_instruction>
+{% case tone %}
+{% when 'friendly' %}
+Warm, approachable, and personable. Use conversational language, positive words, and show empathy. May include phrases like "Happy to help!" or "I'd be glad to..."
+{% when 'confident' %}
+Assertive and assured. Use definitive language, avoid hedging words like "maybe" or "I think". Be direct and authoritative while remaining helpful.
+{% when 'straightforward' %}
+Clear, direct, and to-the-point. Remove unnecessary words, get straight to the information or solution. No fluff or extra pleasantries.
+{% when 'casual' %}
+Relaxed and informal. Use contractions, simpler words, and a conversational style. Friendly but less formal than professional tone.
+{% when 'professional' %}
+Formal, polished, and business-appropriate. Use complete sentences, proper grammar, and maintain respectful distance. Avoid slang or overly casual language.
+{% else %}
+Warm, approachable, and personable. Use conversational language, positive words, and show empathy. May include phrases like "Happy to help!" or "I'd be glad to..."
+{% endcase %}
+</tone_instruction>
+
+Your task is to rewrite the message according to the specified tone instructions.
+
+Important guidelines:
+- Preserve the core meaning and all important information from the original message
+- Keep the rewritten message concise and appropriate for customer support
+- Maintain helpfulness and respect regardless of tone
+- Do not add information that wasn't in the original message
+- Do not remove critical details or instructions
+
+Super Important:
+- If the message has some markdown formatting, keep the formatting as it is. 
+- Block quotes (lines starting with >) contain quoted text from the customer's previous message. Preserve this quoted text exactly as written (do not modify the customer's words inside the block quote), but DO improve the agent's reply that follows the block quote.
+- Ensure the output is in the user's original language
+
+Output only the rewritten message without any preamble, tags or explanation.

lib/integrations/openai/processor_service.rb

@@ -1,6 +1,4 @@
 class Integrations::Openai::ProcessorService < Integrations::LlmBaseService
-  AGENT_INSTRUCTION = 'You are a helpful support agent.'.freeze
-  LANGUAGE_INSTRUCTION = 'Ensure that the reply should be in user language.'.freeze
   def reply_suggestion_message
     make_api_call(reply_suggestion_body)
   end
@@ -9,58 +7,74 @@ class Integrations::Openai::ProcessorService < Integrations::LlmBaseService
     make_api_call(summarize_body)
   end
 
-  def rephrase_message
-    make_api_call(build_api_call_body("#{AGENT_INSTRUCTION} Please rephrase the following response. " \
-                                      "#{LANGUAGE_INSTRUCTION}"))
-  end
-
   def fix_spelling_grammar_message
-    make_api_call(build_api_call_body("#{AGENT_INSTRUCTION} Please fix the spelling and grammar of the following response. " \
-                                      "#{LANGUAGE_INSTRUCTION}"))
+    call_llm_with_prompt(fix_spelling_grammar_prompt)
   end
 
-  def shorten_message
-    make_api_call(build_api_call_body("#{AGENT_INSTRUCTION} Please shorten the following response. " \
-                                      "#{LANGUAGE_INSTRUCTION}"))
+  def confident_message
+    call_llm_with_prompt(tone_rewrite_prompt('confident'))
   end
 
-  def expand_message
-    make_api_call(build_api_call_body("#{AGENT_INSTRUCTION} Please expand the following response. " \
-                                      "#{LANGUAGE_INSTRUCTION}"))
+  def straightforward_message
+    call_llm_with_prompt(tone_rewrite_prompt('straightforward'))
   end
 
-  def make_friendly_message
-    make_api_call(build_api_call_body("#{AGENT_INSTRUCTION} Please make the following response more friendly. " \
-                                      "#{LANGUAGE_INSTRUCTION}"))
+  def casual_message
+    call_llm_with_prompt(tone_rewrite_prompt('casual'))
   end
 
-  def make_formal_message
-    make_api_call(build_api_call_body("#{AGENT_INSTRUCTION} Please make the following response more formal. " \
-                                      "#{LANGUAGE_INSTRUCTION}"))
+  def friendly_message
+    call_llm_with_prompt(tone_rewrite_prompt('friendly'))
   end
 
-  def simplify_message
-    make_api_call(build_api_call_body("#{AGENT_INSTRUCTION} Please simplify the following response. " \
-                                      "#{LANGUAGE_INSTRUCTION}"))
+  def professional_message
+    call_llm_with_prompt(tone_rewrite_prompt('professional'))
+  end
+
+  def improve_message
+    template = prompt_from_file('improve')
+
+    system_prompt = render_liquid_template(template, {
+                                             'conversation_context' => conversation.to_llm_text(include_contact_details: true),
+                                             'draft_message' => event['data']['content']
+                                           })
+
+    call_llm_with_prompt(system_prompt, event['data']['content'])
   end
 
   private
 
-  def prompt_from_file(file_name, enterprise: false)
-    path = enterprise ? 'enterprise/lib/enterprise/integrations/openai_prompts' : 'lib/integrations/openai/openai_prompts'
-    Rails.root.join(path, "#{file_name}.txt").read
-  end
-
-  def build_api_call_body(system_content, user_content = event['data']['content'])
-    {
+  def call_llm_with_prompt(system_content, user_content = event['data']['content'])
+    body = {
       model: GPT_MODEL,
       messages: [
         { role: 'system', content: system_content },
         { role: 'user', content: user_content }
-      ]
+      ],
+      reasoning_effort: 'low' # TODO: make this configurable
     }.to_json
+    make_api_call(body)
   end
 
+  def prompt_from_file(file_name, enterprise: false)
+    path = enterprise ? 'enterprise/lib/enterprise/integrations/openai_prompts' : 'lib/integrations/openai/openai_prompts'
+    Rails.root.join(path, "#{file_name}.liquid").read
+  end
+
+  def render_liquid_template(template_content, variables = {})
+    Liquid::Template.parse(template_content).render(variables)
+  end
+
+  def tone_rewrite_prompt(tone)
+    template = prompt_from_file('tone_rewrite')
+    render_liquid_template(template, 'tone' => tone)
+  end
+
+  def fix_spelling_grammar_prompt
+    prompt_from_file('fix_spelling_grammar')
+  end
+
+  # TODO: Replace with LlmFormattable or enterprise/lib/captain/prompts/snippets/conversation.liquid
   def conversation_messages(in_array_format: false)
     messages = init_messages_body(in_array_format)
 

lib/llm/config.rb

@@ -1,7 +1,7 @@
 require 'ruby_llm'
 
 module Llm::Config
-  DEFAULT_MODEL = 'gpt-4o-mini'.freeze
+  DEFAULT_MODEL = 'gpt-5-mini'.freeze
   class << self
     def initialized?
       @initialized ||= false

package.json

@@ -39,6 +39,7 @@
     "@formkit/vue": "^1.6.7",
     "@hcaptcha/vue3-hcaptcha": "^1.3.0",
     "@highlightjs/vue-plugin": "^2.1.0",
+    "@iconify-json/fluent": "^1.2.32",
     "@iconify-json/material-symbols": "^1.2.10",
     "@lk77/vue3-color": "^3.0.6",
     "@radix-ui/colors": "^3.0.0",
@@ -69,8 +70,6 @@
     "flag-icons": "^7.2.3",
     "floating-vue": "^5.2.2",
     "highlight.js": "^11.10.0",
-    "html-to-image": "^1.11.13",
-    "html2canvas": "^1.4.1",
     "idb": "^8.0.0",
     "js-cookie": "^3.0.5",
     "json-logic-js": "^2.0.5",

pnpm-lock.yaml

@@ -37,6 +37,9 @@ importers:
       '@highlightjs/vue-plugin':
         specifier: ^2.1.0
         version: 2.1.0(highlight.js@11.10.0)(vue@3.5.12(typescript@5.6.2))
+      '@iconify-json/fluent':
+        specifier: ^1.2.32
+        version: 1.2.36
       '@iconify-json/material-symbols':
         specifier: ^1.2.10
         version: 1.2.10
@@ -127,12 +130,6 @@ importers:
       highlight.js:
         specifier: ^11.10.0
         version: 11.10.0
-      html-to-image:
-        specifier: ^1.11.13
-        version: 1.11.13
-      html2canvas:
-        specifier: ^1.4.1
-        version: 1.4.1
       idb:
         specifier: ^8.0.0
         version: 8.0.0
@@ -934,6 +931,9 @@ packages:
     resolution: {integrity: sha512-93zYdMES/c1D69yZiKDBj0V24vqNzB/koF26KPaagAfd3P/4gUlh3Dys5ogAK+Exi9QyzlD8x/08Zt7wIKcDcA==}
     deprecated: Use @eslint/object-schema instead
 
+  '@iconify-json/fluent@1.2.36':
+    resolution: {integrity: sha512-DhxwOu5Qiq09o2ehHeUK0I9lC01OeWFlxXP7pIslM0vbi8VuplrrJ7kMg21GJy87iOCevzxf6gTU7TLPGgSknw==}
+
   '@iconify-json/logos@1.2.3':
     resolution: {integrity: sha512-JLHS5hgZP1b55EONAWNeqBUuriRfRNKWXK4cqYx0PpVaJfIIMiiMxFfvoQiX/bkE9XgkLhcKmDUqL3LXPdXPwQ==}
 
@@ -1678,10 +1678,6 @@ packages:
   balanced-match@1.0.2:
     resolution: {integrity: sha512-3oSeUO0TMV67hN1AmbXsK4yaqU7tjiHlbxRDZOpH0KW9+CeX4bRAaX0Anxt0tx2MrpRpWwQaPwIlISEJhYU5Pw==}
 
-  base64-arraybuffer@1.0.2:
-    resolution: {integrity: sha512-I3yl4r9QB5ZRY3XuJVEPfc2XhZO6YweFPI+UovAzn+8/hb3oJ6lnysaFcjVpkCPfVWFUDvoZ8kmVDP7WyRtYtQ==}
-    engines: {node: '>= 0.6.0'}
-
   bidi-js@1.0.3:
     resolution: {integrity: sha512-RKshQI1R3YQ+n9YJz2QQ147P66ELpa1FQEg20Dk8oW9t2KgLbpDLLp9aGZ7y8WHSshDknG0bknqGw5/tyCs5tw==}
 
@@ -1928,9 +1924,6 @@ packages:
     peerDependencies:
       postcss: ^8.4
 
-  css-line-break@2.1.0:
-    resolution: {integrity: sha512-FHcKFCZcAha3LwfVBhCQbW2nCNbkZXn7KVUJcsT5/P8YmfsVja0FMPJr0B903j/E69HUphKiV9iQArX8SDYA4w==}
-
   css-prefers-color-scheme@8.0.2:
     resolution: {integrity: sha512-OvFghizHJ45x7nsJJUSYLyQNTzsCU8yWjxAc/nhPQg1pbs18LMoET8N3kOweFDPy0JV0OSXN2iqRFhPBHYOeMA==}
     engines: {node: ^14 || ^16 || >=18}
@@ -2699,13 +2692,6 @@ packages:
   html-escaper@2.0.2:
     resolution: {integrity: sha512-H2iMtd0I4Mt5eYiapRdIDjp+XzelXQ0tFE4JS7YFwFevXXMmOp9myNrUvCg0D6ws8iqkRPBfKHgbwig1SmlLfg==}
 
-  html-to-image@1.11.13:
-    resolution: {integrity: sha512-cuOPoI7WApyhBElTTb9oqsawRvZ0rHhaHwghRLlTuffoD1B2aDemlCruLeZrUIIdvG7gs9xeELEPm6PhuASqrg==}
-
-  html2canvas@1.4.1:
-    resolution: {integrity: sha512-fPU6BHNpsyIhr8yyMpTLLxAbkaK8ArIBcmZIRiBLiDhjeqvXolaEmDGmELFuX9I4xDcaKKcJl+TKZLqruBbmWA==}
-    engines: {node: '>=8.0.0'}
-
   htmlparser2@8.0.2:
     resolution: {integrity: sha512-GYdjWKDkbRLkZ5geuHs5NY1puJ+PXwP7+fHPRz06Eirsb9ugf6d8kkXav6ADhcODhFFPMIXyxkxSuMf3D6NCFA==}
 
@@ -4237,9 +4223,6 @@ packages:
     resolution: {integrity: sha512-pFYqmTw68LXVjeWJMST4+borgQP2AyMNbg1BpZh9LbyhUeNkeaPF9gzfPGUAnSMV3qPYdWUwDIjjCLiSDOl7vg==}
     engines: {node: '>=18'}
 
-  text-segmentation@1.0.3:
-    resolution: {integrity: sha512-iOiPUo/BGnZ6+54OsWxZidGCsdU8YbE4PSpdPinp7DeMtUJNJBoJ/ouUSTJjHkh1KntHaltHl/gDs2FC4i5+Nw==}
-
   text-table@0.2.0:
     resolution: {integrity: sha512-N+8UisAXDGk8PFXP4HAzVR9nbfmVJ3zYLAWiTIoqC5v5isinhr+r5uaO8+7r3BMfuNIufIsA7RdpVgacC2cSpw==}
 
@@ -4436,9 +4419,6 @@ packages:
     resolution: {integrity: sha512-pMZTvIkT1d+TFGvDOqodOclx0QWkkgi6Tdoa8gC8ffGAAqz9pzPTZWAybbsHHoED/ztMtkv/VoYTYyShUn81hA==}
     engines: {node: '>= 0.4.0'}
 
-  utrie@1.0.2:
-    resolution: {integrity: sha512-1MLa5ouZiOmQzUbjbu9VmjLzn1QLXBhwpUa7kdLUQK+KQ5KA9I1vk5U4YHe/X2Ch7PYnJfWuWT+VbuxbGwljhw==}
-
   video.js@7.18.1:
     resolution: {integrity: sha512-mnXdmkVcD5qQdKMZafDjqdhrnKGettZaGSVkExjACiylSB4r2Yt5W1bchsKmjFpfuNfszsMjTUnnoIWSSqoe/Q==}
 
@@ -5408,6 +5388,10 @@ snapshots:
 
   '@humanwhocodes/object-schema@2.0.3': {}
 
+  '@iconify-json/fluent@1.2.36':
+    dependencies:
+      '@iconify/types': 2.0.0
+
   '@iconify-json/logos@1.2.3':
     dependencies:
       '@iconify/types': 2.0.0
@@ -6274,8 +6258,6 @@ snapshots:
 
   balanced-match@1.0.2: {}
 
-  base64-arraybuffer@1.0.2: {}
-
   bidi-js@1.0.3:
     dependencies:
       require-from-string: 2.0.2
@@ -6558,10 +6540,6 @@ snapshots:
       postcss-selector-parser: 6.1.1
       postcss-value-parser: 4.2.0
 
-  css-line-break@2.1.0:
-    dependencies:
-      utrie: 1.0.2
-
   css-prefers-color-scheme@8.0.2(postcss@8.4.47):
     dependencies:
       postcss: 8.4.47
@@ -7496,13 +7474,6 @@ snapshots:
 
   html-escaper@2.0.2: {}
 
-  html-to-image@1.11.13: {}
-
-  html2canvas@1.4.1:
-    dependencies:
-      css-line-break: 2.1.0
-      text-segmentation: 1.0.3
-
   htmlparser2@8.0.2:
     dependencies:
       domelementtype: 2.3.0
@@ -9197,10 +9168,6 @@ snapshots:
       glob: 10.4.5
       minimatch: 9.0.5
 
-  text-segmentation@1.0.3:
-    dependencies:
-      utrie: 1.0.2
-
   text-table@0.2.0: {}
 
   thenify-all@1.6.0:
@@ -9401,10 +9368,6 @@ snapshots:
 
   utils-merge@1.0.1: {}
 
-  utrie@1.0.2:
-    dependencies:
-      base64-arraybuffer: 1.0.2
-
   video.js@7.18.1:
     dependencies:
       '@babel/runtime': 7.25.6

spec/builders/year_in_review_builder_spec.rb

@@ -1,64 +0,0 @@
-require 'rails_helper'
-
-RSpec.describe YearInReviewBuilder, type: :model do
-  subject(:builder) { described_class.new(account: account, user_id: user.id, year: year) }
-
-  let(:account) { create(:account) }
-  let(:user) { create(:user, account: account) }
-  let(:year) { 2025 }
-
-  describe '#build' do
-    context 'when there is no data for the year' do
-      it 'returns empty aggregates' do
-        result = builder.build
-
-        expect(result[:year]).to eq(year)
-        expect(result[:total_conversations]).to eq(0)
-        expect(result[:busiest_day]).to be_nil
-        expect(result[:support_personality]).to eq({ avg_response_time_seconds: 0 })
-      end
-    end
-
-    context 'when there is data for the year' do
-      let(:busiest_date) { Time.zone.local(year, 3, 10, 10, 0, 0) }
-      let(:other_date) { Time.zone.local(year, 3, 11, 10, 0, 0) }
-
-      before do
-        create(:conversation, account: account, assignee: user, created_at: busiest_date)
-        create(:conversation, account: account, assignee: user, created_at: busiest_date + 1.hour)
-        create(:conversation, account: account, assignee: user, created_at: other_date)
-
-        create(
-          :reporting_event,
-          account: account,
-          user: user,
-          name: 'first_response',
-          value: 12.7,
-          created_at: busiest_date
-        )
-      end
-
-      it 'returns total conversations count' do
-        expect(builder.build[:total_conversations]).to eq(3)
-      end
-
-      it 'returns busiest day data' do
-        expect(builder.build[:busiest_day]).to eq({ date: busiest_date.strftime('%b %d'), count: 2 })
-      end
-
-      it 'returns support personality data' do
-        expect(builder.build[:support_personality]).to eq({ avg_response_time_seconds: 12 })
-      end
-
-      it 'scopes data to the provided year' do
-        create(:conversation, account: account, assignee: user, created_at: Time.zone.local(year - 1, 6, 1))
-        create(:reporting_event, account: account, user: user, name: 'first_response', value: 99, created_at: Time.zone.local(year - 1, 6, 1))
-
-        result = builder.build
-
-        expect(result[:total_conversations]).to eq(3)
-        expect(result[:support_personality]).to eq({ avg_response_time_seconds: 12 })
-      end
-    end
-  end
-end

spec/enterprise/controllers/api/v1/accounts/conference_controller_spec.rb

@@ -1,142 +0,0 @@
-require 'rails_helper'
-
-RSpec.describe Api::V1::Accounts::ConferenceController, type: :request do
-  let(:account) { create(:account) }
-  let(:voice_channel) { create(:channel_voice, account: account) }
-  let(:voice_inbox) { voice_channel.inbox }
-  let(:conversation) { create(:conversation, account: account, inbox: voice_inbox, identifier: nil) }
-  let(:admin) { create(:user, :administrator, account: account) }
-  let(:agent) { create(:user, account: account, role: :agent) }
-
-  let(:webhook_service) { instance_double(Twilio::VoiceWebhookSetupService, perform: true) }
-  let(:voice_grant) { instance_double(Twilio::JWT::AccessToken::VoiceGrant) }
-  let(:conference_service) do
-    instance_double(
-      Voice::Provider::Twilio::ConferenceService,
-      ensure_conference_sid: 'CF123',
-      mark_agent_joined: true,
-      end_conference: true
-    )
-  end
-
-  before do
-    allow(Twilio::VoiceWebhookSetupService).to receive(:new).and_return(webhook_service)
-    allow(Twilio::JWT::AccessToken::VoiceGrant).to receive(:new).and_return(voice_grant)
-    allow(voice_grant).to receive(:outgoing_application_sid=)
-    allow(voice_grant).to receive(:outgoing_application_params=)
-    allow(voice_grant).to receive(:incoming_allow=)
-    allow(Voice::Provider::Twilio::ConferenceService).to receive(:new).and_return(conference_service)
-  end
-
-  describe 'GET /conference/token' do
-    context 'when unauthenticated' do
-      it 'returns unauthorized' do
-        get "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference/token"
-
-        expect(response).to have_http_status(:unauthorized)
-      end
-    end
-
-    context 'when authenticated agent with inbox access' do
-      before { create(:inbox_member, inbox: voice_inbox, user: agent) }
-
-      it 'returns token payload' do
-        fake_token = instance_double(Twilio::JWT::AccessToken, to_jwt: 'jwt-token', add_grant: nil)
-        allow(Twilio::JWT::AccessToken).to receive(:new).and_return(fake_token)
-
-        get "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference/token",
-            headers: agent.create_new_auth_token
-
-        expect(response).to have_http_status(:ok)
-        body = response.parsed_body
-        expect(body['token']).to eq('jwt-token')
-        expect(body['account_id']).to eq(account.id)
-        expect(body['inbox_id']).to eq(voice_inbox.id)
-      end
-    end
-  end
-
-  describe 'POST /conference' do
-    context 'when unauthenticated' do
-      it 'returns unauthorized' do
-        post "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference"
-
-        expect(response).to have_http_status(:unauthorized)
-      end
-    end
-
-    context 'when authenticated agent with inbox access' do
-      before { create(:inbox_member, inbox: voice_inbox, user: agent) }
-
-      it 'creates conference and sets identifier' do
-        post "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference",
-             headers: agent.create_new_auth_token,
-             params: { conversation_id: conversation.display_id, call_sid: 'CALL123' }
-
-        expect(response).to have_http_status(:ok)
-        body = response.parsed_body
-        expect(body['conference_sid']).to be_present
-        conversation.reload
-        expect(conversation.identifier).to eq('CALL123')
-        expect(conference_service).to have_received(:ensure_conference_sid)
-        expect(conference_service).to have_received(:mark_agent_joined)
-      end
-
-      it 'does not allow accessing conversations from inboxes without access' do
-        other_inbox = create(:inbox, account: account)
-        other_conversation = create(:conversation, account: account, inbox: other_inbox, identifier: nil)
-
-        post "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference",
-             headers: agent.create_new_auth_token,
-             params: { conversation_id: other_conversation.display_id, call_sid: 'CALL123' }
-
-        expect(response).to have_http_status(:not_found)
-        other_conversation.reload
-        expect(other_conversation.identifier).to be_nil
-      end
-
-      it 'returns conflict when call_sid missing' do
-        post "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference",
-             headers: agent.create_new_auth_token,
-             params: { conversation_id: conversation.display_id }
-
-        expect(response).to have_http_status(:unprocessable_content)
-      end
-    end
-  end
-
-  describe 'DELETE /conference' do
-    context 'when unauthenticated' do
-      it 'returns unauthorized' do
-        delete "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference"
-
-        expect(response).to have_http_status(:unauthorized)
-      end
-    end
-
-    context 'when authenticated agent with inbox access' do
-      before { create(:inbox_member, inbox: voice_inbox, user: agent) }
-
-      it 'ends conference and returns success' do
-        delete "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference",
-               headers: agent.create_new_auth_token,
-               params: { conversation_id: conversation.display_id }
-
-        expect(response).to have_http_status(:ok)
-        expect(response.parsed_body['id']).to eq(conversation.display_id)
-        expect(conference_service).to have_received(:end_conference)
-      end
-
-      it 'does not allow ending conferences for conversations from inboxes without access' do
-        other_inbox = create(:inbox, account: account)
-        other_conversation = create(:conversation, account: account, inbox: other_inbox, identifier: nil)
-
-        delete "/api/v1/accounts/#{account.id}/inboxes/#{voice_inbox.id}/conference",
-               headers: agent.create_new_auth_token,
-               params: { conversation_id: other_conversation.display_id }
-
-        expect(response).to have_http_status(:not_found)
-      end
-    end
-  end
-end

spec/enterprise/lib/integrations/openai/processor_service_spec.rb

@@ -1,120 +0,0 @@
-require 'rails_helper'
-
-RSpec.describe Integrations::Openai::ProcessorService do
-  subject { described_class.new(hook: hook, event: event) }
-
-  let(:account) { create(:account) }
-  let(:hook) { create(:integrations_hook, :openai, account: account) }
-
-  # Mock RubyLLM objects
-  let(:mock_chat) { instance_double(RubyLLM::Chat) }
-  let(:mock_context) { instance_double(RubyLLM::Context) }
-  let(:mock_config) { OpenStruct.new }
-  let(:mock_response) do
-    instance_double(
-      RubyLLM::Message,
-      content: 'This is a reply from openai.',
-      input_tokens: nil,
-      output_tokens: nil
-    )
-  end
-  let(:mock_empty_response) do
-    instance_double(
-      RubyLLM::Message,
-      content: '',
-      input_tokens: nil,
-      output_tokens: nil
-    )
-  end
-
-  let(:conversation) { create(:conversation, account: account) }
-
-  before do
-    allow(RubyLLM).to receive(:context).and_yield(mock_config).and_return(mock_context)
-    allow(mock_context).to receive(:chat).and_return(mock_chat)
-
-    allow(mock_chat).to receive(:with_instructions).and_return(mock_chat)
-    allow(mock_chat).to receive(:add_message).and_return(mock_chat)
-    allow(mock_chat).to receive(:ask).and_return(mock_response)
-  end
-
-  describe '#perform' do
-    context 'when event name is label_suggestion with labels with < 3 messages' do
-      let(:event) { { 'name' => 'label_suggestion', 'data' => { 'conversation_display_id' => conversation.display_id } } }
-
-      it 'returns nil' do
-        create(:label, account: account)
-        create(:label, account: account)
-
-        expect(subject.perform).to be_nil
-      end
-    end
-
-    context 'when event name is label_suggestion with labels with >3 messages' do
-      let(:event) { { 'name' => 'label_suggestion', 'data' => { 'conversation_display_id' => conversation.display_id } } }
-
-      before do
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent')
-        create(:message, account: account, conversation: conversation, message_type: :outgoing, content: 'hello customer')
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent 2')
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent 3')
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent 4')
-
-        create(:label, account: account)
-        create(:label, account: account)
-
-        hook.settings['label_suggestion'] = 'true'
-      end
-
-      it 'returns the label suggestions' do
-        result = subject.perform
-        expect(result).to eq({ message: 'This is a reply from openai.' })
-      end
-
-      it 'returns empty string if openai response is blank' do
-        allow(mock_chat).to receive(:ask).and_return(mock_empty_response)
-
-        result = subject.perform
-        expect(result[:message]).to eq('')
-      end
-    end
-
-    context 'when event name is label_suggestion with no labels' do
-      let(:event) { { 'name' => 'label_suggestion', 'data' => { 'conversation_display_id' => conversation.display_id } } }
-
-      it 'returns nil' do
-        result = subject.perform
-        expect(result).to be_nil
-      end
-    end
-
-    context 'when event name is not one that can be processed' do
-      let(:event) { { 'name' => 'unknown', 'data' => {} } }
-
-      it 'returns nil' do
-        expect(subject.perform).to be_nil
-      end
-    end
-
-    context 'when hook is not enabled' do
-      let(:event) { { 'name' => 'label_suggestion', 'data' => { 'conversation_display_id' => conversation.display_id } } }
-
-      before do
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent')
-        create(:message, account: account, conversation: conversation, message_type: :outgoing, content: 'hello customer')
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent 2')
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent 3')
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent 4')
-
-        create(:label, account: account)
-        create(:label, account: account)
-
-        hook.settings['label_suggestion'] = nil
-      end
-
-      it 'returns nil' do
-        expect(subject.perform).to be_nil
-      end
-    end
-  end
-end

spec/enterprise/models/captain/custom_tool_spec.rb

@@ -102,9 +102,8 @@ RSpec.describe Captain::CustomTool, type: :model do
         enabled_tool = create(:captain_custom_tool, account: account, enabled: true)
         disabled_tool = create(:captain_custom_tool, account: account, enabled: false)
 
-        enabled_ids = described_class.enabled.pluck(:id)
-        expect(enabled_ids).to include(enabled_tool.id)
-        expect(enabled_ids).not_to include(disabled_tool.id)
+        expect(described_class.enabled).to include(enabled_tool)
+        expect(described_class.enabled).not_to include(disabled_tool)
       end
     end
   end

spec/enterprise/services/voice/provider/twilio/adapter_spec.rb

@@ -1,43 +0,0 @@
-require 'rails_helper'
-
-describe Voice::Provider::Twilio::Adapter do
-  let(:account) { create(:account) }
-  let(:channel) { create(:channel_voice, account: account) }
-  let(:adapter) { described_class.new(channel) }
-  let(:webhook_service) { instance_double(Twilio::VoiceWebhookSetupService, perform: true) }
-  let(:calls_double) { instance_double(Twilio::REST::Api::V2010::AccountContext::CallList) }
-  let(:call_instance) do
-    instance_double(Twilio::REST::Api::V2010::AccountContext::CallInstance, sid: 'CA123', status: 'queued')
-  end
-  let(:client_double) { instance_double(Twilio::REST::Client, calls: calls_double) }
-
-  before do
-    allow(Twilio::VoiceWebhookSetupService).to receive(:new).and_return(webhook_service)
-  end
-
-  it 'initiates an outbound call with expected params' do
-    allow(calls_double).to receive(:create).and_return(call_instance)
-
-    allow(Twilio::REST::Client).to receive(:new)
-      .with(channel.provider_config_hash['account_sid'], channel.provider_config_hash['auth_token'])
-      .and_return(client_double)
-
-    result = adapter.initiate_call(to: '+15550001111', conference_sid: 'CF999', agent_id: 42)
-    phone_digits = channel.phone_number.delete_prefix('+')
-    expected_url = Rails.application.routes.url_helpers.twilio_voice_call_url(phone: phone_digits)
-    expected_status_callback = Rails.application.routes.url_helpers.twilio_voice_status_url(phone: phone_digits)
-
-    expect(calls_double).to have_received(:create).with(hash_including(
-                                                          from: channel.phone_number,
-                                                          to: '+15550001111',
-                                                          url: expected_url,
-                                                          status_callback: expected_status_callback,
-                                                          status_callback_event: array_including('completed', 'failed', 'busy', 'no-answer',
-                                                                                                 'canceled')
-                                                        ))
-    expect(result[:call_sid]).to eq('CA123')
-    expect(result[:conference_sid]).to eq('CF999')
-    expect(result[:agent_id]).to eq(42)
-    expect(result[:call_direction]).to eq('outbound')
-  end
-end

spec/enterprise/services/voice/provider/twilio/conference_service_spec.rb

@@ -1,60 +0,0 @@
-require 'rails_helper'
-
-describe Voice::Provider::Twilio::ConferenceService do
-  let(:account) { create(:account) }
-  let(:channel) { create(:channel_voice, account: account) }
-  let(:conversation) { create(:conversation, account: account, inbox: channel.inbox) }
-  let(:twilio_client) { instance_double(Twilio::REST::Client) }
-  let(:service) { described_class.new(conversation: conversation, twilio_client: twilio_client) }
-  let(:webhook_service) { instance_double(Twilio::VoiceWebhookSetupService, perform: true) }
-
-  before do
-    allow(Twilio::VoiceWebhookSetupService).to receive(:new).and_return(webhook_service)
-  end
-
-  describe '#ensure_conference_sid' do
-    it 'returns existing sid if present' do
-      conversation.update!(additional_attributes: { 'conference_sid' => 'CF_EXISTING' })
-
-      expect(service.ensure_conference_sid).to eq('CF_EXISTING')
-    end
-
-    it 'sets and returns generated sid when missing' do
-      allow(Voice::Conference::Name).to receive(:for).and_return('CF_GEN')
-
-      sid = service.ensure_conference_sid
-
-      expect(sid).to eq('CF_GEN')
-      expect(conversation.reload.additional_attributes['conference_sid']).to eq('CF_GEN')
-    end
-  end
-
-  describe '#mark_agent_joined' do
-    it 'stores agent join metadata' do
-      agent = create(:user, account: account)
-
-      service.mark_agent_joined(user: agent)
-
-      attrs = conversation.reload.additional_attributes
-      expect(attrs['agent_joined']).to be true
-      expect(attrs['joined_by']['id']).to eq(agent.id)
-    end
-  end
-
-  describe '#end_conference' do
-    it 'completes in-progress conferences' do
-      conferences_proxy = instance_double(Twilio::REST::Api::V2010::AccountContext::ConferenceList)
-      conf_instance = instance_double(Twilio::REST::Api::V2010::AccountContext::ConferenceInstance, sid: 'CF123')
-      conf_context = instance_double(Twilio::REST::Api::V2010::AccountContext::ConferenceInstance)
-
-      allow(twilio_client).to receive(:conferences).with(no_args).and_return(conferences_proxy)
-      allow(conferences_proxy).to receive(:list).and_return([conf_instance])
-      allow(twilio_client).to receive(:conferences).with('CF123').and_return(conf_context)
-      allow(conf_context).to receive(:update).with(status: 'completed')
-
-      service.end_conference
-
-      expect(conf_context).to have_received(:update).with(status: 'completed')
-    end
-  end
-end

spec/enterprise/services/voice/provider/twilio/token_service_spec.rb

@@ -1,33 +0,0 @@
-require 'rails_helper'
-
-describe Voice::Provider::Twilio::TokenService do
-  let(:account) { create(:account) }
-  let(:user) { create(:user, :administrator, account: account) }
-  let(:voice_channel) { create(:channel_voice, account: account) }
-  let(:inbox) { voice_channel.inbox }
-
-  let(:webhook_service) { instance_double(Twilio::VoiceWebhookSetupService, perform: true) }
-  let(:voice_grant) { instance_double(Twilio::JWT::AccessToken::VoiceGrant) }
-
-  before do
-    allow(Twilio::VoiceWebhookSetupService).to receive(:new).and_return(webhook_service)
-    allow(Twilio::JWT::AccessToken::VoiceGrant).to receive(:new).and_return(voice_grant)
-    allow(voice_grant).to receive(:outgoing_application_sid=)
-    allow(voice_grant).to receive(:outgoing_application_params=)
-    allow(voice_grant).to receive(:incoming_allow=)
-  end
-
-  it 'returns a token payload with expected keys' do
-    fake_token = instance_double(Twilio::JWT::AccessToken, to_jwt: 'jwt-token', add_grant: nil)
-    allow(Twilio::JWT::AccessToken).to receive(:new).and_return(fake_token)
-
-    payload = described_class.new(inbox: inbox, user: user, account: account).generate
-
-    expect(payload[:token]).to eq('jwt-token')
-    expect(payload[:identity]).to include("agent-#{user.id}")
-    expect(payload[:inbox_id]).to eq(inbox.id)
-    expect(payload[:account_id]).to eq(account.id)
-    expect(payload[:voice_enabled]).to be true
-    expect(payload[:twiml_endpoint]).to include(voice_channel.phone_number.delete_prefix('+'))
-  end
-end

spec/lib/captain/base_editor_service_spec.rb

@@ -0,0 +1,250 @@
+require 'rails_helper'
+
+RSpec.describe Captain::BaseEditorService do
+  let(:account) { create(:account) }
+  let(:inbox) { create(:inbox, account: account) }
+  let(:conversation) { create(:conversation, account: account, inbox: inbox) }
+
+  # Create a concrete test service class since BaseEditorService is abstract
+  let(:test_service_class) do
+    Class.new(described_class) do
+      def perform
+        { message: 'Test response' }
+      end
+
+      def event_name
+        'test_event'
+      end
+    end
+  end
+
+  let(:service) { test_service_class.new(account: account, conversation_display_id: conversation.display_id) }
+
+  before do
+    create(:installation_config, name: 'CAPTAIN_OPEN_AI_API_KEY', value: 'test-key')
+  end
+
+  describe '#perform' do
+    it 'returns the expected result' do
+      result = service.perform
+      expect(result).to eq({ message: 'Test response' })
+    end
+  end
+
+  describe '#event_name' do
+    it 'raises NotImplementedError for base class' do
+      base_service = described_class.new(account: account, conversation_display_id: conversation.display_id)
+      expect { base_service.send(:event_name) }.to raise_error(NotImplementedError, /must implement #event_name/)
+    end
+
+    it 'returns custom event name in subclass' do
+      expect(service.send(:event_name)).to eq('test_event')
+    end
+  end
+
+  describe '#conversation' do
+    it 'finds conversation by display_id' do
+      expect(service.send(:conversation)).to eq(conversation)
+    end
+
+    it 'memoizes the conversation' do
+      expect(account.conversations).to receive(:find_by).once.and_return(conversation)
+      service.send(:conversation)
+      service.send(:conversation)
+    end
+  end
+
+  describe '#conversation_messages' do
+    let(:message1) { create(:message, conversation: conversation, message_type: :incoming, content: 'Hello', created_at: 1.hour.ago) }
+    let(:message2) { create(:message, conversation: conversation, message_type: :outgoing, content: 'Hi there', created_at: 30.minutes.ago) }
+    let(:message3) { create(:message, conversation: conversation, message_type: :incoming, content: 'How are you?', created_at: 10.minutes.ago) }
+    let(:private_message) { create(:message, conversation: conversation, message_type: :incoming, content: 'Private', private: true) }
+
+    before do
+      message1
+      message2
+      message3
+      private_message
+    end
+
+    it 'returns messages in array format with role and content' do
+      messages = service.send(:conversation_messages)
+
+      expect(messages).to be_an(Array)
+      expect(messages.length).to eq(3)
+      expect(messages[0]).to eq({ role: 'user', content: 'Hello' })
+      expect(messages[1]).to eq({ role: 'assistant', content: 'Hi there' })
+      expect(messages[2]).to eq({ role: 'user', content: 'How are you?' })
+    end
+
+    it 'excludes private messages' do
+      messages = service.send(:conversation_messages)
+      contents = messages.pluck(:content)
+      expect(contents).not_to include('Private')
+    end
+
+    it 'respects token limit' do
+      # Create messages that collectively exceed token limit
+      # Message validation max is 150000, so create multiple large messages
+      10.times do |i|
+        create(:message, conversation: conversation, message_type: :incoming,
+                         content: 'a' * 100_000, created_at: i.minutes.ago)
+      end
+
+      messages = service.send(:conversation_messages)
+      total_length = messages.sum { |m| m[:content].length }
+      expect(total_length).to be <= Captain::BaseEditorService::TOKEN_LIMIT
+    end
+
+    it 'respects start_from offset for token counting' do
+      # With a start_from offset, fewer messages should fit
+      start_from = Captain::BaseEditorService::TOKEN_LIMIT - 100
+      messages = service.send(:conversation_messages, start_from: start_from)
+
+      total_length = messages.sum { |m| m[:content].length }
+      expect(total_length).to be <= 100
+    end
+  end
+
+  describe '#make_api_call' do
+    let(:model) { 'gpt-4' }
+    let(:messages) { [{ role: 'system', content: 'Test' }, { role: 'user', content: 'Hello' }] }
+    let(:mock_chat) { instance_double(RubyLLM::Chat) }
+    let(:mock_context) { instance_double(RubyLLM::Context, chat: mock_chat) }
+    let(:mock_response) { instance_double(RubyLLM::Message, content: 'Response', input_tokens: 10, output_tokens: 20) }
+
+    before do
+      allow(Llm::Config).to receive(:with_api_key).and_yield(mock_context)
+      allow(mock_chat).to receive(:with_instructions)
+      allow(mock_chat).to receive(:ask).and_return(mock_response)
+    end
+
+    it 'calls execute_ruby_llm_request with correct parameters' do
+      expect(service).to receive(:execute_ruby_llm_request).with(model: model, messages: messages).and_call_original
+      service.send(:make_api_call, model: model, messages: messages)
+    end
+
+    it 'instruments the LLM call' do
+      expect(service).to receive(:instrument_llm_call).and_call_original
+      service.send(:make_api_call, model: model, messages: messages)
+    end
+
+    it 'returns formatted response with tokens' do
+      result = service.send(:make_api_call, model: model, messages: messages)
+
+      expect(result[:message]).to eq('Response')
+      expect(result[:usage]['prompt_tokens']).to eq(10)
+      expect(result[:usage]['completion_tokens']).to eq(20)
+      expect(result[:usage]['total_tokens']).to eq(30)
+    end
+  end
+
+  describe 'chat setup' do
+    let(:model) { 'gpt-4' }
+    let(:mock_chat) { instance_double(RubyLLM::Chat) }
+    let(:mock_context) { instance_double(RubyLLM::Context, chat: mock_chat) }
+    let(:mock_response) { instance_double(RubyLLM::Message, content: 'Response', input_tokens: 10, output_tokens: 20) }
+
+    before do
+      allow(Llm::Config).to receive(:with_api_key).and_yield(mock_context)
+      allow(mock_response).to receive(:input_tokens).and_return(10)
+      allow(mock_response).to receive(:output_tokens).and_return(20)
+    end
+
+    context 'with system instructions' do
+      let(:messages) { [{ role: 'system', content: 'You are helpful' }, { role: 'user', content: 'Hello' }] }
+
+      it 'applies system instructions to chat' do
+        expect(mock_chat).to receive(:with_instructions).with('You are helpful')
+        expect(mock_chat).to receive(:ask).with('Hello').and_return(mock_response)
+
+        service.send(:make_api_call, model: model, messages: messages)
+      end
+    end
+
+    context 'with conversation history' do
+      let(:messages) do
+        [
+          { role: 'system', content: 'You are helpful' },
+          { role: 'user', content: 'First message' },
+          { role: 'assistant', content: 'First response' },
+          { role: 'user', content: 'Second message' }
+        ]
+      end
+
+      it 'adds conversation history before asking' do
+        expect(mock_chat).to receive(:with_instructions).with('You are helpful')
+        expect(mock_chat).to receive(:add_message).with(role: :user, content: 'First message').ordered
+        expect(mock_chat).to receive(:add_message).with(role: :assistant, content: 'First response').ordered
+        expect(mock_chat).to receive(:ask).with('Second message').and_return(mock_response)
+
+        service.send(:make_api_call, model: model, messages: messages)
+      end
+    end
+
+    context 'with single message' do
+      let(:messages) { [{ role: 'system', content: 'You are helpful' }, { role: 'user', content: 'Hello' }] }
+
+      it 'does not add conversation history' do
+        expect(mock_chat).to receive(:with_instructions).with('You are helpful')
+        expect(mock_chat).not_to receive(:add_message)
+        expect(mock_chat).to receive(:ask).with('Hello').and_return(mock_response)
+
+        service.send(:make_api_call, model: model, messages: messages)
+      end
+    end
+  end
+
+  describe 'error handling' do
+    let(:model) { 'gpt-4' }
+    let(:messages) { [{ role: 'user', content: 'Hello' }] }
+    let(:error) { StandardError.new('API Error') }
+    let(:exception_tracker) { instance_double(ChatwootExceptionTracker) }
+
+    before do
+      allow(Llm::Config).to receive(:with_api_key).and_raise(error)
+      allow(ChatwootExceptionTracker).to receive(:new).with(error, account: account).and_return(exception_tracker)
+      allow(exception_tracker).to receive(:capture_exception)
+    end
+
+    it 'tracks exceptions' do
+      expect(ChatwootExceptionTracker).to receive(:new).with(error, account: account).and_return(exception_tracker)
+      expect(exception_tracker).to receive(:capture_exception)
+
+      service.send(:make_api_call, model: model, messages: messages)
+    end
+
+    it 'returns error response' do
+      expect(exception_tracker).to receive(:capture_exception)
+      result = service.send(:make_api_call, model: model, messages: messages)
+
+      expect(result[:error]).to eq('API Error')
+      expect(result[:request_messages]).to eq(messages)
+    end
+  end
+
+  describe '#api_key' do
+    context 'when openai hook is configured' do
+      let(:hook) { create(:integrations_hook, account: account, app_id: 'openai', status: 'enabled', settings: { 'api_key' => 'hook-key' }) }
+
+      before { hook }
+
+      it 'uses api key from hook' do
+        expect(service.send(:api_key)).to eq('hook-key')
+      end
+    end
+
+    context 'when openai hook is not configured' do
+      it 'uses system api key' do
+        expect(service.send(:api_key)).to eq('test-key')
+      end
+    end
+  end
+
+  describe '#prompt_from_file' do
+    it 'reads prompt from file' do
+      allow(Rails.root).to receive(:join).and_return(instance_double(Pathname, read: 'Test prompt content'))
+      expect(service.send(:prompt_from_file, 'test')).to eq('Test prompt content')
+    end
+  end
+end

spec/lib/captain/label_suggestion_service_spec.rb

@@ -0,0 +1,165 @@
+require 'rails_helper'
+
+RSpec.describe Captain::LabelSuggestionService do
+  let(:account) { create(:account) }
+  let(:inbox) { create(:inbox, account: account) }
+  let(:conversation) { create(:conversation, account: account, inbox: inbox) }
+  let(:label1) { create(:label, account: account, title: 'bug') }
+  let(:label2) { create(:label, account: account, title: 'feature-request') }
+  let(:service) { described_class.new(account: account, conversation_display_id: conversation.display_id) }
+  let(:mock_chat) { instance_double(RubyLLM::Chat) }
+  let(:mock_context) { instance_double(RubyLLM::Context, chat: mock_chat) }
+  let(:mock_response) { instance_double(RubyLLM::Message, content: 'bug, feature-request', input_tokens: 100, output_tokens: 20) }
+
+  before do
+    create(:installation_config, name: 'CAPTAIN_OPEN_AI_API_KEY', value: 'test-key')
+    label1
+    label2
+    allow(Llm::Config).to receive(:with_api_key).and_yield(mock_context)
+    allow(mock_chat).to receive(:with_instructions)
+    allow(mock_chat).to receive(:ask).and_return(mock_response)
+  end
+
+  describe '#label_suggestion_message' do
+    context 'with valid conversation' do
+      before do
+        # Create enough incoming messages to pass validation
+        3.times do |i|
+          create(:message, conversation: conversation, message_type: :incoming,
+                           content: "Message #{i}", created_at: i.minutes.ago)
+        end
+      end
+
+      it 'returns label suggestions' do
+        result = service.perform
+
+        expect(result[:message]).to eq('bug, feature-request')
+      end
+
+      it 'removes "Labels:" prefix from response' do
+        allow(mock_response).to receive(:content).and_return('Labels: bug, feature-request')
+
+        result = service.perform
+
+        expect(result[:message]).to eq(' bug, feature-request')
+      end
+
+      it 'removes "Label:" prefix (singular) from response' do
+        allow(mock_response).to receive(:content).and_return('label: bug')
+
+        result = service.perform
+
+        expect(result[:message]).to eq(' bug')
+      end
+
+      it 'builds labels_with_messages format correctly' do
+        expect(service).to receive(:make_api_call) do |args|
+          user_message = args[:messages].find { |m| m[:role] == 'user' }[:content]
+
+          expect(user_message).to include('Messages:')
+          expect(user_message).to include('Labels:')
+          expect(user_message).to include('bug, feature-request')
+          { message: 'bug' }
+        end
+
+        service.perform
+      end
+    end
+
+    context 'with invalid conversation' do
+      it 'returns nil when conversation has less than 3 incoming messages' do
+        create(:message, conversation: conversation, message_type: :incoming, content: 'Message 1')
+        create(:message, conversation: conversation, message_type: :incoming, content: 'Message 2')
+
+        result = service.perform
+
+        expect(result).to be_nil
+      end
+
+      it 'returns nil when conversation has more than 100 messages' do
+        101.times do |i|
+          create(:message, conversation: conversation, message_type: :incoming, content: "Message #{i}")
+        end
+
+        result = service.perform
+
+        expect(result).to be_nil
+      end
+
+      it 'returns nil when conversation has >20 messages and last is not incoming' do
+        21.times do |i|
+          create(:message, conversation: conversation, message_type: :incoming, content: "Message #{i}")
+        end
+        create(:message, conversation: conversation, message_type: :outgoing, content: 'Agent reply')
+
+        result = service.perform
+
+        expect(result).to be_nil
+      end
+    end
+
+    context 'when caching' do
+      before do
+        3.times do |i|
+          create(:message, conversation: conversation, message_type: :incoming,
+                           content: "Message #{i}", created_at: i.minutes.ago)
+        end
+      end
+
+      it 'reads from cache on cache hit' do
+        # Warm up cache
+        service.perform
+
+        # Create new service instance to test cache read
+        new_service = described_class.new(account: account, conversation_display_id: conversation.display_id)
+
+        expect(new_service).not_to receive(:make_api_call)
+        result = new_service.perform
+
+        expect(result[:message]).to eq('bug, feature-request')
+      end
+
+      it 'writes to cache on cache miss' do
+        expect(Redis::Alfred).to receive(:setex).and_call_original
+
+        service.perform
+      end
+
+      it 'returns nil for invalid cached JSON' do
+        # Set invalid JSON in cache
+        cache_key = service.send(:cache_key)
+        Redis::Alfred.set(cache_key, 'invalid json')
+
+        result = service.perform
+
+        # Should make API call since cache read failed
+        expect(result[:message]).to eq('bug, feature-request')
+      end
+
+      it 'does not cache error responses' do
+        error_response = { error: 'API Error', request_messages: [] }
+        allow(service).to receive(:make_api_call).and_return(error_response)
+
+        expect(Redis::Alfred).not_to receive(:setex)
+
+        service.perform
+      end
+    end
+
+    context 'when no labels exist' do
+      before do
+        Label.destroy_all
+        3.times do |i|
+          create(:message, conversation: conversation, message_type: :incoming,
+                           content: "Message #{i}")
+        end
+      end
+
+      it 'returns nil' do
+        result = service.perform
+
+        expect(result).to be_nil
+      end
+    end
+  end
+end

spec/lib/captain/reply_suggestion_service_spec.rb

@@ -0,0 +1,67 @@
+require 'rails_helper'
+
+RSpec.describe Captain::ReplySuggestionService do
+  let(:account) { create(:account) }
+  let(:inbox) { create(:inbox, account: account) }
+  let(:conversation) { create(:conversation, account: account, inbox: inbox) }
+  let(:service) { described_class.new(account: account, conversation_display_id: conversation.display_id) }
+  let(:mock_chat) { instance_double(RubyLLM::Chat) }
+  let(:mock_context) { instance_double(RubyLLM::Context, chat: mock_chat) }
+  let(:mock_response) { instance_double(RubyLLM::Message, content: 'Suggested reply', input_tokens: 100, output_tokens: 50) }
+
+  before do
+    create(:installation_config, name: 'CAPTAIN_OPEN_AI_API_KEY', value: 'test-key')
+    allow(Llm::Config).to receive(:with_api_key).and_yield(mock_context)
+    allow(mock_chat).to receive(:with_instructions)
+    allow(mock_chat).to receive(:add_message)
+    allow(mock_chat).to receive(:ask).and_return(mock_response)
+  end
+
+  describe '#perform' do
+    let(:message1) { create(:message, conversation: conversation, message_type: :incoming, content: 'Hello') }
+    let(:message2) { create(:message, conversation: conversation, message_type: :outgoing, content: 'Hi there') }
+
+    before do
+      message1
+      message2
+    end
+
+    it 'uses conversation_messages to build message history' do
+      expect(service).to receive(:conversation_messages).and_call_original
+      service.perform
+    end
+
+    it 'concatenates system prompt with conversation history' do
+      allow(service).to receive(:prompt_from_file).with('reply').and_return('Help with reply')
+
+      expect(service).to receive(:make_api_call) do |args|
+        expected_messages = [
+          { role: 'system', content: 'Help with reply' },
+          { role: 'user', content: 'Hello' },
+          { role: 'assistant', content: 'Hi there' }
+        ]
+
+        expect(args[:messages]).to eq(expected_messages)
+        { message: 'Suggested reply' }
+      end
+
+      service.perform
+    end
+
+    it 'passes correct model to API' do
+      expect(service).to receive(:make_api_call).with(
+        hash_including(model: Captain::BaseEditorService::GPT_MODEL)
+      ).and_call_original
+
+      service.perform
+    end
+
+    it 'returns formatted response' do
+      result = service.perform
+
+      expect(result[:message]).to eq('Suggested reply')
+      expect(result[:usage]['prompt_tokens']).to eq(100)
+      expect(result[:usage]['completion_tokens']).to eq(50)
+    end
+  end
+end

spec/lib/captain/rewrite_service_spec.rb

@@ -0,0 +1,138 @@
+require 'rails_helper'
+
+RSpec.describe Captain::RewriteService do
+  let(:account) { create(:account) }
+  let(:inbox) { create(:inbox, account: account) }
+  let(:conversation) { create(:conversation, account: account, inbox: inbox) }
+  let(:content) { 'I need help with my order' }
+  let(:operation) { 'fix_spelling_grammar' }
+  let(:service) { described_class.new(account: account, content: content, operation: operation, conversation_display_id: conversation.display_id) }
+  let(:mock_chat) { instance_double(RubyLLM::Chat) }
+  let(:mock_context) { instance_double(RubyLLM::Context, chat: mock_chat) }
+  let(:mock_response) { instance_double(RubyLLM::Message, content: 'Rewritten text', input_tokens: 10, output_tokens: 5) }
+
+  before do
+    create(:installation_config, name: 'CAPTAIN_OPEN_AI_API_KEY', value: 'test-key')
+    allow(Llm::Config).to receive(:with_api_key).and_yield(mock_context)
+    allow(mock_chat).to receive(:with_instructions)
+    allow(mock_chat).to receive(:ask).and_return(mock_response)
+  end
+
+  describe '#perform with fix_spelling_grammar operation' do
+    let(:operation) { 'fix_spelling_grammar' }
+
+    it 'uses fix_spelling_grammar prompt' do
+      expect(service).to receive(:prompt_from_file).with('fix_spelling_grammar').and_return('Fix errors')
+
+      expect(service).to receive(:make_api_call) do |args|
+        expect(args[:messages][0][:content]).to eq('Fix errors')
+        expect(args[:messages][1][:content]).to eq(content)
+        { message: 'Fixed' }
+      end
+
+      service.perform
+    end
+  end
+
+  describe 'tone rewrite methods' do
+    let(:tone_prompt_template) { 'Rewrite in {{ tone }} tone' }
+
+    before do
+      allow(service).to receive(:prompt_from_file).with('tone_rewrite').and_return(tone_prompt_template)
+    end
+
+    describe '#perform with casual operation' do
+      let(:operation) { 'casual' }
+
+      it 'uses casual tone' do
+        expect(service).to receive(:make_api_call) do |args|
+          expect(args[:messages][0][:content]).to eq('Rewrite in casual tone')
+          { message: 'Hey, need help?' }
+        end
+
+        service.perform
+      end
+    end
+
+    describe '#perform with professional operation' do
+      let(:operation) { 'professional' }
+
+      it 'uses professional tone' do
+        expect(service).to receive(:make_api_call) do |args|
+          expect(args[:messages][0][:content]).to eq('Rewrite in professional tone')
+          { message: 'Professional text' }
+        end
+
+        service.perform
+      end
+    end
+
+    describe '#perform with friendly operation' do
+      let(:operation) { 'friendly' }
+
+      it 'uses friendly tone' do
+        expect(service).to receive(:make_api_call) do |args|
+          expect(args[:messages][0][:content]).to eq('Rewrite in friendly tone')
+          { message: 'Friendly text' }
+        end
+
+        service.perform
+      end
+    end
+
+    describe '#perform with confident operation' do
+      let(:operation) { 'confident' }
+
+      it 'uses confident tone' do
+        expect(service).to receive(:make_api_call) do |args|
+          expect(args[:messages][0][:content]).to eq('Rewrite in confident tone')
+          { message: 'Confident text' }
+        end
+
+        service.perform
+      end
+    end
+
+    describe '#perform with straightforward operation' do
+      let(:operation) { 'straightforward' }
+
+      it 'uses straightforward tone' do
+        expect(service).to receive(:make_api_call) do |args|
+          expect(args[:messages][0][:content]).to eq('Rewrite in straightforward tone')
+          { message: 'Straightforward text' }
+        end
+
+        service.perform
+      end
+    end
+  end
+
+  describe '#perform with improve operation' do
+    let(:operation) { 'improve' }
+    let(:improve_template) { 'Context: {{ conversation_context }}\nDraft: {{ draft_message }}' }
+
+    before do
+      create(:message, conversation: conversation, message_type: :incoming, content: 'Customer message')
+      allow(service).to receive(:prompt_from_file).with('improve').and_return(improve_template)
+    end
+
+    it 'uses conversation context and draft message with Liquid template' do
+      expect(service).to receive(:make_api_call) do |args|
+        system_content = args[:messages][0][:content]
+
+        expect(system_content).to include('Context:')
+        expect(system_content).to include('Draft: I need help with my order')
+        expect(args[:messages][1][:content]).to eq(content)
+        { message: 'Improved text' }
+      end
+
+      service.perform
+    end
+
+    it 'returns formatted response' do
+      result = service.perform
+
+      expect(result[:message]).to eq('Rewritten text')
+    end
+  end
+end

spec/lib/captain/summary_service_spec.rb

@@ -0,0 +1,51 @@
+require 'rails_helper'
+
+RSpec.describe Captain::SummaryService do
+  let(:account) { create(:account) }
+  let(:inbox) { create(:inbox, account: account) }
+  let(:conversation) { create(:conversation, account: account, inbox: inbox) }
+  let(:service) { described_class.new(account: account, conversation_display_id: conversation.display_id) }
+  let(:mock_chat) { instance_double(RubyLLM::Chat) }
+  let(:mock_context) { instance_double(RubyLLM::Context, chat: mock_chat) }
+  let(:mock_response) { instance_double(RubyLLM::Message, content: 'Summary of conversation', input_tokens: 100, output_tokens: 50) }
+
+  before do
+    create(:installation_config, name: 'CAPTAIN_OPEN_AI_API_KEY', value: 'test-key')
+    allow(Llm::Config).to receive(:with_api_key).and_yield(mock_context)
+    allow(mock_chat).to receive(:with_instructions)
+    allow(mock_chat).to receive(:ask).and_return(mock_response)
+  end
+
+  describe '#perform' do
+    it 'passes correct model to API' do
+      expect(service).to receive(:make_api_call).with(
+        hash_including(model: Captain::BaseEditorService::GPT_MODEL)
+      ).and_call_original
+
+      service.perform
+    end
+
+    it 'passes system prompt and conversation text as messages' do
+      allow(service).to receive(:prompt_from_file).with('summary').and_return('Summarize this')
+
+      expect(service).to receive(:make_api_call) do |args|
+        expect(args[:messages].length).to eq(2)
+        expect(args[:messages][0][:role]).to eq('system')
+        expect(args[:messages][0][:content]).to eq('Summarize this')
+        expect(args[:messages][1][:role]).to eq('user')
+        expect(args[:messages][1][:content]).to be_a(String)
+        { message: 'Summary' }
+      end
+
+      service.perform
+    end
+
+    it 'returns formatted response' do
+      result = service.perform
+
+      expect(result[:message]).to eq('Summary of conversation')
+      expect(result[:usage]['prompt_tokens']).to eq(100)
+      expect(result[:usage]['completion_tokens']).to eq(50)
+    end
+  end
+end

spec/lib/integrations/openai/processor_service_spec.rb

@@ -1,201 +0,0 @@
-require 'rails_helper'
-
-RSpec.describe Integrations::Openai::ProcessorService do
-  subject(:service) { described_class.new(hook: hook, event: event) }
-
-  let(:account) { create(:account) }
-  let(:hook) { create(:integrations_hook, :openai, account: account) }
-
-  # Mock RubyLLM objects
-  let(:mock_chat) { instance_double(RubyLLM::Chat) }
-  let(:mock_context) { instance_double(RubyLLM::Context) }
-  let(:mock_config) { OpenStruct.new }
-  let(:mock_response) do
-    instance_double(
-      RubyLLM::Message,
-      content: 'This is a reply from openai.',
-      input_tokens: nil,
-      output_tokens: nil
-    )
-  end
-  let(:mock_response_with_usage) do
-    instance_double(
-      RubyLLM::Message,
-      content: 'This is a reply from openai.',
-      input_tokens: 50,
-      output_tokens: 20
-    )
-  end
-
-  before do
-    allow(RubyLLM).to receive(:context).and_yield(mock_config).and_return(mock_context)
-    allow(mock_context).to receive(:chat).and_return(mock_chat)
-
-    allow(mock_chat).to receive(:with_instructions).and_return(mock_chat)
-    allow(mock_chat).to receive(:add_message).and_return(mock_chat)
-    allow(mock_chat).to receive(:ask).and_return(mock_response)
-  end
-
-  describe '#perform' do
-    describe 'text transformation operations' do
-      shared_examples 'text transformation operation' do |event_name|
-        let(:event) { { 'name' => event_name, 'data' => { 'content' => 'This is a test' } } }
-
-        it 'returns the transformed text' do
-          result = service.perform
-          expect(result[:message]).to eq('This is a reply from openai.')
-        end
-
-        it 'sends the user content to the LLM' do
-          service.perform
-          expect(mock_chat).to have_received(:ask).with('This is a test')
-        end
-
-        it 'sets system instructions' do
-          service.perform
-          expect(mock_chat).to have_received(:with_instructions).with(a_string_including('You are a helpful support agent'))
-        end
-      end
-
-      it_behaves_like 'text transformation operation', 'rephrase'
-      it_behaves_like 'text transformation operation', 'fix_spelling_grammar'
-      it_behaves_like 'text transformation operation', 'shorten'
-      it_behaves_like 'text transformation operation', 'expand'
-      it_behaves_like 'text transformation operation', 'make_friendly'
-      it_behaves_like 'text transformation operation', 'make_formal'
-      it_behaves_like 'text transformation operation', 'simplify'
-    end
-
-    describe 'conversation-based operations' do
-      let!(:conversation) { create(:conversation, account: account) }
-
-      before do
-        create(:message, account: account, conversation: conversation, message_type: :incoming, content: 'hello agent')
-        create(:message, account: account, conversation: conversation, message_type: :outgoing, content: 'hello customer')
-      end
-
-      context 'with reply_suggestion event' do
-        let(:event) { { 'name' => 'reply_suggestion', 'data' => { 'conversation_display_id' => conversation.display_id } } }
-
-        it 'returns the suggested reply' do
-          result = service.perform
-          expect(result[:message]).to eq('This is a reply from openai.')
-        end
-
-        it 'adds conversation history before asking' do
-          service.perform
-          # Should add the first message as history, then ask with the last message
-          expect(mock_chat).to have_received(:add_message).with(role: :user, content: 'hello agent')
-          expect(mock_chat).to have_received(:ask).with('hello customer')
-        end
-      end
-
-      context 'with summarize event' do
-        let(:event) { { 'name' => 'summarize', 'data' => { 'conversation_display_id' => conversation.display_id } } }
-
-        it 'returns the summary' do
-          result = service.perform
-          expect(result[:message]).to eq('This is a reply from openai.')
-        end
-
-        it 'sends formatted conversation as a single message' do
-          service.perform
-          # Summarize sends conversation as a formatted string in one user message
-          expect(mock_chat).to have_received(:ask).with(a_string_matching(/Customer.*hello agent.*Agent.*hello customer/m))
-        end
-      end
-
-      context 'with label_suggestion event and no labels' do
-        let(:event) { { 'name' => 'label_suggestion', 'data' => { 'conversation_display_id' => conversation.display_id } } }
-
-        it 'returns nil' do
-          expect(service.perform).to be_nil
-        end
-      end
-    end
-
-    describe 'edge cases' do
-      context 'with unknown event name' do
-        let(:event) { { 'name' => 'unknown', 'data' => {} } }
-
-        it 'returns nil' do
-          expect(service.perform).to be_nil
-        end
-      end
-    end
-
-    describe 'response structure' do
-      let(:event) { { 'name' => 'rephrase', 'data' => { 'content' => 'test message' } } }
-
-      context 'when response includes usage data' do
-        before do
-          allow(mock_chat).to receive(:ask).and_return(mock_response_with_usage)
-        end
-
-        it 'returns message with usage data' do
-          result = service.perform
-
-          expect(result[:message]).to eq('This is a reply from openai.')
-          expect(result[:usage]['prompt_tokens']).to eq(50)
-          expect(result[:usage]['completion_tokens']).to eq(20)
-          expect(result[:usage]['total_tokens']).to eq(70)
-        end
-
-        it 'includes request_messages in response' do
-          result = service.perform
-
-          expect(result[:request_messages]).to be_an(Array)
-          expect(result[:request_messages].length).to eq(2)
-        end
-      end
-
-      context 'when response does not include usage data' do
-        it 'returns message with zero total tokens' do
-          result = service.perform
-
-          expect(result[:message]).to eq('This is a reply from openai.')
-          expect(result[:usage]['total_tokens']).to eq(0)
-        end
-
-        it 'includes request_messages in response' do
-          result = service.perform
-
-          expect(result[:request_messages]).to be_an(Array)
-        end
-      end
-    end
-
-    describe 'endpoint configuration' do
-      let(:event) { { 'name' => 'rephrase', 'data' => { 'content' => 'test message' } } }
-
-      context 'without CAPTAIN_OPEN_AI_ENDPOINT configured' do
-        before { InstallationConfig.find_by(name: 'CAPTAIN_OPEN_AI_ENDPOINT')&.destroy }
-
-        it 'uses default OpenAI endpoint' do
-          expect(Llm::Config).to receive(:with_api_key).with(
-            hook.settings['api_key'],
-            api_base: 'https://api.openai.com/v1'
-          ).and_call_original
-
-          service.perform
-        end
-      end
-
-      context 'with CAPTAIN_OPEN_AI_ENDPOINT configured' do
-        before do
-          InstallationConfig.find_by(name: 'CAPTAIN_OPEN_AI_ENDPOINT')&.destroy
-          create(:installation_config, name: 'CAPTAIN_OPEN_AI_ENDPOINT', value: 'https://custom.azure.com/')
-        end
-
-        it 'uses custom endpoint' do
-          expect(Llm::Config).to receive(:with_api_key).with(
-            hook.settings['api_key'],
-            api_base: 'https://custom.azure.com/v1'
-          ).and_call_original
-
-          service.perform
-        end
-      end
-    end
-  end
-end

tailwind.config.js

@@ -41,7 +41,7 @@ const tailwindConfig = {
       fontFamily: {
         sans: defaultSansFonts,
         inter: ['Inter', ...defaultSansFonts],
-        interDisplay: ['InterDisplay', ...defaultSansFonts],
+        interDisplay: ['Inter Display', ...defaultSansFonts],
       },
       typography: {
         bubble: {
@@ -259,6 +259,7 @@ const tailwindConfig = {
           'ph',
           'material-symbols',
           'teenyicons',
+          'fluent',
         ]),
       },
     }),

theme/colors.js

@@ -210,6 +210,21 @@ export const colors = {
       12: 'rgb(var(--gray-12) / <alpha-value>)',
     },
 
+    violet: {
+      1: 'rgb(var(--violet-1) / <alpha-value>)',
+      2: 'rgb(var(--violet-2) / <alpha-value>)',
+      3: 'rgb(var(--violet-3) / <alpha-value>)',
+      4: 'rgb(var(--violet-4) / <alpha-value>)',
+      5: 'rgb(var(--violet-5) / <alpha-value>)',
+      6: 'rgb(var(--violet-6) / <alpha-value>)',
+      7: 'rgb(var(--violet-7) / <alpha-value>)',
+      8: 'rgb(var(--violet-8) / <alpha-value>)',
+      9: 'rgb(var(--violet-9) / <alpha-value>)',
+      10: 'rgb(var(--violet-10) / <alpha-value>)',
+      11: 'rgb(var(--violet-11) / <alpha-value>)',
+      12: 'rgb(var(--violet-12) / <alpha-value>)',
+    },
+
     black: '#000000',
     brand: '#2781F6',
     background: 'rgb(var(--background-color) / <alpha-value>)',