rename render-message event into agen-message

src/background/session.ts

@@ -23,7 +23,7 @@ interface TextMessage {
     content: string;
 }
 
-const ip = 'ws://localhost';
+const ip = 'ws://127.0.0.1';
 const port = 8760;
 const reconnectTimeout = 3000; //ms
 let socket: WebSocket;
@@ -70,7 +70,7 @@ const receiveMessage = (message: string): void => {
         backgroundMitt.emit('message-res', parsed);
     } else if (parsed.modifier === "ai") {
         backgroundMitt.emit('ipc-renderer', {
-            endpoint: 'render-message',
+            endpoint: 'agent-message',
             message: parsed
         });
     }
@@ -103,7 +103,7 @@ export const sendAudio = async (content: Buffer) => {
     const res = await asyncSend(null, content);
 
     backgroundMitt.emit('ipc-renderer', {
-        endpoint: 'render-message',
+        endpoint: 'agent-message',
         message: res
     });
 }

src/components/messageView/index.vue

@@ -22,25 +22,19 @@
 </template>
 
 <script lang="ts">
-
 import TextBubble from "@/components/textBubble/index.vue";
-
 import { Message } from "@/types/message/index";
 import { useIpc } from "@/modules/ipc";
-import { Queue } from '@/modules/queue';
-
+import { Queue } from "@/modules/queue";
 import useTransitions from "./viewDetails/transitions";
 import useScrollView from "@/modules/scrollView";
-
 import useMitt from "@/modules/mitt";
-
-import { defineComponent, reactive, onMounted, onUnmounted, watch, ref } from "vue";
+import { defineComponent, reactive, onMounted, onUnmounted, watch } from "vue";
 
 export default defineComponent({
-  
   name: "MessageView",
   components: { TextBubble },
-  
+
   setup() {
     const { emitter } = useMitt();
     const renderArr: Message[] = reactive([]);
@@ -60,19 +54,18 @@ export default defineComponent({
       } else {
         renderArr.push(m);
       }
-    }
+    };
 
     watch(rendering, (rendering, _prevRendering) => {
       if (!rendering) {
-          const m = renderQ.dequeue() as Message | null;
-          if (m) renderArr.push(m);
+        const m = renderQ.dequeue() as Message | null;
+        if (m) renderArr.push(m);
       }
-    })
+    });
 
     onMounted(() => {
-
-      // Call render function on event "render-message."
-      window.ipcRenderer.on("render-message", (event, payload) => {
+      // Call render function on event "agent-message."
+      window.ipcRenderer.on("agent-message", (event, payload) => {
         const m = payload.message;
         if (m.content) render(m);
       });
@@ -80,7 +73,7 @@ export default defineComponent({
       emitter.on("user-message", async (message) => {
         try {
           const res = await invoke(message);
-          render(res)
+          render(res);
         } catch (e) {
           console.log("No response. Do not render.");
         }
@@ -88,7 +81,7 @@ export default defineComponent({
     });
 
     onUnmounted(() => {
-      window.ipcRenderer.removeAllListeners("render-message");
+      window.ipcRenderer.removeAllListeners("agent-message");
       emitter.all.clear();
     });
 
@@ -104,11 +97,9 @@ export default defineComponent({
 </script>
 
 <style lang="scss" scoped>
-
-  #messageView {
-    width: 1000px;
-    height: 100vh;
-    color: red;
-  }
-
+#messageView {
+  width: 1000px;
+  height: 100vh;
+  color: red;
+}
 </style>

tests/server.js

@@ -1,7 +1,7 @@
 const WebSocket = require("ws");
 
 const wss = new WebSocket.Server({
-  port: 8081
+  port: 8760
 });
 
 wss.on("connection", function connection(ws, req) {