Switch support agent to mqtt

ci/ci-values.yaml

@@ -54,4 +54,4 @@ postgresql:
         - "management"
 
 ingress:
-  className: traefik
+  className: traefik

forge/db/views/ProjectTemplate.js

@@ -16,7 +16,7 @@ module.exports = function (app) {
                 name: result.name,
                 description: result.description,
                 active: result.active,
-                instanceCount: result.projectCount,
+                instanceCount: parseInt(result.projectCount) || 0,
                 settings: result.settings || {},
                 policy: result.policy || {},
                 createdAt: result.createdAt,
@@ -56,7 +56,7 @@ module.exports = function (app) {
                 name: result.name,
                 description: result.description,
                 active: result.active,
-                instanceCount: result.projectCount,
+                instanceCount: parseInt(result.projectCount) || 0,
                 createdAt: result.createdAt,
                 links: result.links
             }

frontend/src/api/user.js

@@ -239,6 +239,9 @@ const disableMFA = async () => {
 const verifyMFA = async (token) => {
     return client.put('/api/v1/user/mfa/verify', { token }).then(res => res.data)
 }
+const initiateExpertChat = async ({ sessionId }) => {
+    return client.post('/api/v1/user/expert-creds', { sessionId }).then(res => res.data)
+}
 
 export default {
     registerUser,
@@ -267,5 +270,6 @@ export default {
     updatePersonalAccessToken,
     enableMFA,
     verifyMFA,
-    disableMFA
+    disableMFA,
+    initiateExpertChat
 }

frontend/src/components/expert/Expert.vue

@@ -148,7 +148,8 @@ export default {
             'setAgentMode',
             'setAbortController',
             'resetSessionTimer',
-            'addWelcomeMessageIfNeeded'
+            'addWelcomeMessageIfNeeded',
+            'stopInflightChat'
         ]),
         ...mapActions(useProductExpertInsightsAgentStore, ['getCapabilities']),
         ...mapActions(useProductAssistantStore, ['reset']),
@@ -157,6 +158,7 @@ export default {
                 this.abortController.abort()
                 this.setAbortController(null)
             }
+            this.stopInflightChat()
         },
         handleScroll () {
             // Debounce scroll detection

frontend/src/components/expert/components/ExpertChatInput.vue

@@ -33,7 +33,7 @@
             />
 
             <div class="actions">
-                <div class="left">
+                <div class="left overflow-hidden">
                     <context-selector v-if="isImmersive && !isInsightsAgent" />
                 </div>
 
@@ -64,13 +64,13 @@
 <script>
 import { mapActions, mapState } from 'pinia'
 
-import { useResizingHelper } from '../../../composables/ResizingHelper.js'
-
 import ResizeBar from '../../ResizeBar.vue'
 
 import CapabilitiesSelector from './CapabilitiesSelector.vue'
 import ContextSelector from './context-selection/index.vue'
 
+import { useResizingHelper } from '@/composables/ResizingHelper.js'
+
 import { useProductAssistantStore } from '@/stores/product-assistant.js'
 import { useProductExpertStore } from '@/stores/product-expert.js'
 import { useUxDrawersStore } from '@/stores/ux-drawers.js'
@@ -113,8 +113,8 @@ export default {
     },
     computed: {
         ...mapState(useProductAssistantStore, [
-            'immersiveInstance',
-            'immersiveDevice'
+            'isImmersiveInstance',
+            'isImmersiveDevice'
         ]),
         ...mapState(useUxDrawersStore, ['rightDrawer']),
         ...mapState(useProductExpertStore, [
@@ -145,7 +145,7 @@ export default {
                 : 'Tell us what you need help with'
         },
         isImmersive () {
-            return this.immersiveDevice || this.immersiveInstance
+            return this.isImmersiveDevice || this.isImmersiveInstance
         }
     },
     mounted () {

frontend/src/components/expert/components/ExpertLoadingIndicator.vue

@@ -53,8 +53,12 @@ export default {
         }
     },
     computed: {
-        ...mapState(useProductExpertStore, ['loadingVariant']),
+        ...mapState(useProductExpertStore, ['loadingVariant', 'inFlightUpdates']),
         messages () {
+            if (this.inFlightUpdates.length > 0) {
+                return this.inFlightUpdates
+            }
+
             return this.messageVariants[this.loadingVariant]
         },
         currentMessage () {

frontend/src/components/expert/components/ExpertMessages.vue

@@ -22,6 +22,7 @@ import AiMessage from './messages/AiMessage.vue'
 import HumanMessage from './messages/HumanMessage.vue'
 import SystemMessage from './messages/SystemMessage.vue'
 
+import { downloadData } from '@/composables/Download.js'
 import { useProductExpertStore } from '@/stores/product-expert.js'
 
 export default {
@@ -46,11 +47,19 @@ export default {
     },
     mounted () {
         this.mountResizeObserver()
+        window.addEventListener('keydown', this.onKeyDown)
     },
     beforeUnmount () {
         this.unmountResizeObserver()
+        window.removeEventListener('keydown', this.onKeyDown)
     },
     methods: {
+        onKeyDown (e) {
+            if (e.altKey && e.shiftKey && e.key.toLowerCase() === 'd') {
+                e.preventDefault()
+                downloadData(this.messages, 'expert-messages.json')
+            }
+        },
         mountResizeObserver () {
             const el = this.$refs.messagesWrapper
             if (!el) return

frontend/src/components/expert/components/messages/AiMessage.vue

@@ -12,12 +12,13 @@
 </template>
 
 <script>
-import useStreamingList from '../../../../composables/StreamingListHelper.js'
-import { slugify } from '../../../../composables/strings/String.js'
-
 import AnswerWrapper from './components/AnswerWrapper.vue'
+
 import ToolCalls from './components/ToolCalls.vue'
 
+import useStreamingList from '@/composables/StreamingListHelper.js'
+import { slugify } from '@/composables/strings/String.js'
+
 export default {
     name: 'AiMessage',
     components: { ToolCalls, AnswerWrapper },