From 4a053a8d291da9019bda20415576c9035eea6e98 Mon Sep 17 00:00:00 2001
From: Pranav <pranavrajs@gmail.com>
Date: Thu, 22 May 2025 17:24:45 -0700
Subject: [PATCH] remove copilot channel

---
 app/channels/copilot_channel.rb               | 35 ---------
 .../components/copilot/CopilotContainer.vue   | 74 +++++++------------
 .../helpers/CopilotActionCableConnector.js    | 49 ------------
 3 files changed, 26 insertions(+), 132 deletions(-)
 delete mode 100644 app/channels/copilot_channel.rb
 delete mode 100644 app/javascript/dashboard/helpers/CopilotActionCableConnector.js

diff --git a/app/channels/copilot_channel.rb b/app/channels/copilot_channel.rb
deleted file mode 100644
index 2fde1c32f..000000000
--- a/app/channels/copilot_channel.rb
+++ /dev/null
@@ -1,35 +0,0 @@
-class CopilotChannel < ApplicationCable::Channel
-  def subscribed
-    current_user
-    current_account
-    ensure_stream
-  end
-
-  def message(data)
-    return if @current_account.blank?
-
-    Captain::ProcessCopilotMessageJob.perform_later(
-      assistant_id: data['assistant_id'],
-      message: data['message'],
-      options: {
-        user_id: @current_user.id,
-        conversation_id: data['conversation_id'],
-        previous_history: data['previous_history']
-      }
-    )
-  end
-
-  def ensure_stream
-    stream_from "copilot_#{@current_account.id}_#{@current_user.id}"
-  end
-
-  def current_user
-    @current_user ||= User.find(params[:user_id])
-  end
-
-  def current_account
-    return if current_user.blank?
-
-    @current_account ||= @current_user.accounts.find(params[:account_id])
-  end
-end
diff --git a/app/javascript/dashboard/components/copilot/CopilotContainer.vue b/app/javascript/dashboard/components/copilot/CopilotContainer.vue
index 42a281aea..43bf8d44b 100644
--- a/app/javascript/dashboard/components/copilot/CopilotContainer.vue
+++ b/app/javascript/dashboard/components/copilot/CopilotContainer.vue
@@ -1,11 +1,10 @@
 <script setup>
-import { ref, computed, onMounted, onBeforeUnmount } from 'vue';
+import { ref, computed, onMounted } from 'vue';
 import { useStore } from 'dashboard/composables/store';
 import Copilot from 'dashboard/components-next/copilot/Copilot.vue';
-import CopilotActionCableConnector from 'dashboard/helpers/CopilotActionCableConnector';
 import { useMapGetter } from 'dashboard/composables/store';
 import { useUISettings } from 'dashboard/composables/useUISettings';
-import { emitter } from 'shared/helpers/mitt';
+
 const store = useStore();
 const currentUser = useMapGetter('getCurrentUser');
 const assistants = useMapGetter('captainAssistants/getRecords');
@@ -81,55 +80,34 @@ const sendMessage = message => {
   });
 };
 
-const initializeWebSocket = () => {
-  copilotConnector.value = new CopilotActionCableConnector({
-    accountId: currentUser.value.account_id,
-    userId: currentUser.value.id,
-    onDisconnect: () => {
-      // copilotConnector.value = null;
-    },
-    onCopilotResponse: data => {
-      if (data.type === 'final_response') {
-        messages.value.push({
-          id: new Date().getTime(),
-          role: 'assistant',
-          content: data.response.response,
-        });
-        isCaptainTyping.value = false;
-      } else if (data.type === 'ui_event') {
-        if (data.event === 'ui:linear_ticket_create') {
-          emitter.emit('ui:linear_ticket_create');
-          setTimeout(() => {
-            emitter.emit('ui:linear_ticket_create_data', data.response);
-          }, 100);
-        }
-      } else {
-        messages.value.push({
-          id: new Date().getTime(),
-          role: 'assistant_thinking',
-          content: data.response.response,
-          reasoning: data.response.reasoning,
-        });
-      }
-    },
-  });
-};
-
-const disconnectWebSocket = () => {
-  if (copilotConnector.value) {
-    copilotConnector.value.disconnect();
-    copilotConnector.value = null;
-  }
-};
-
 onMounted(() => {
-  initializeWebSocket();
   store.dispatch('captainAssistants/get');
 });
 
-onBeforeUnmount(() => {
-  disconnectWebSocket();
-});
+// const onCopilotResponse = data => {
+//   if (data.type === 'final_response') {
+//     messages.value.push({
+//       id: new Date().getTime(),
+//       role: 'assistant',
+//       content: data.response.response,
+//     });
+//     isCaptainTyping.value = false;
+//   } else if (data.type === 'ui_event') {
+//     if (data.event === 'ui:linear_ticket_create') {
+//       emitter.emit('ui:linear_ticket_create');
+//       setTimeout(() => {
+//         emitter.emit('ui:linear_ticket_create_data', data.response);
+//       }, 100);
+//     }
+//   } else {
+//     messages.value.push({
+//       id: new Date().getTime(),
+//       role: 'assistant_thinking',
+//       content: data.response.response,
+//       reasoning: data.response.reasoning,
+//     });
+//   }
+// };
 
 const handleClose = () => {
   store.dispatch('uiState/set', { isCopilotSidebarOpen: false });
diff --git a/app/javascript/dashboard/helpers/CopilotActionCableConnector.js b/app/javascript/dashboard/helpers/CopilotActionCableConnector.js
deleted file mode 100644
index 6a64ee59f..000000000
--- a/app/javascript/dashboard/helpers/CopilotActionCableConnector.js
+++ /dev/null
@@ -1,49 +0,0 @@
-import { createConsumer } from '@rails/actioncable';
-
-class CopilotActionCableConnector {
-  constructor(
-    { accountId, userId, onDisconnect, onCopilotResponse },
-    websocketHost = ''
-  ) {
-    const websocketURL = websocketHost ? `${websocketHost}/cable` : undefined;
-
-    this.consumer = createConsumer(websocketURL);
-    this.subscription = this.consumer.subscriptions.create(
-      {
-        channel: 'CopilotChannel',
-        account_id: accountId,
-        user_id: userId,
-      },
-      {
-        received: this.onReceived,
-        disconnected: onDisconnect,
-      }
-    );
-
-    this.events = {
-      'copilot.response': onCopilotResponse,
-    };
-  }
-
-  onReceived = ({ event, data } = {}) => {
-    if (this.events[event] && typeof this.events[event] === 'function') {
-      this.events[event](data);
-    }
-  };
-
-  disconnect() {
-    this.subscription.unsubscribe();
-    this.consumer.disconnect();
-  }
-
-  sendMessage({ message, assistantId, conversationId, previousHistory }) {
-    this.subscription.perform('message', {
-      message,
-      assistant_id: assistantId,
-      conversation_id: conversationId,
-      previous_history: previousHistory,
-    });
-  }
-}
-
-export default CopilotActionCableConnector;