feat: long term memory

apps/cloud/src/app/features/xpert/studio/features/features.component.html

@@ -56,7 +56,7 @@
 
         <mat-slide-toggle [ngModel]="enabledSummarize()" (ngModelChange)="toggleSummarize($event)"
           labelPosition="before"
-          ngm-density="xs"
+          ngm-density small
           [matTooltip]="'PAC.Xpert.SensitiveAgentTip' | translate: {Default: 'Sensitive agents require user confirmation before execution'}"
           matTooltipPosition="above"
         />
@@ -67,4 +67,38 @@
       <xpert-studio-features-summary class="w-full px-3 mt-4"></xpert-studio-features-summary>
     }
   </div>
+
+  <div class="bg-gray-50 rounded-xl">
+    <div class="flex items-center px-3 h-12 overflow-hidden">
+      <div class="shrink-0 flex items-center justify-center mr-1 w-6 h-6">
+        <i class="ri-brain-fill shrink-0 text-lg text-lime-600"></i>
+      </div>
+      <div class="shrink-0 mr-2 whitespace-nowrap text-gray-800 font-semibold">Long-term Memory</div>
+      <div class="grow"></div>
+
+      <div class="flex items-center">
+        <button type="button" class="btn flex items-center h-8 rounded-lg"
+          [class.text-primary-500]="view() === 'memory' && enabledMemory()"
+          [disabled]="!enabledMemory()"
+          (click)="toggleView('memory')"
+        >
+          <i class="ri-settings-5-line text-lg"></i>
+          <div class="ml-1 leading-[18px] text-sm font-medium">Settings</div>
+        </button>
+        <div class="ml-4 mr-3 w-[1px] h-3.5 bg-gray-200"></div>
+
+        <mat-slide-toggle [ngModel]="enabledMemory()" (ngModelChange)="toggleMemory($event)"
+          labelPosition="before"
+          ngm-density small
+          [matTooltip]="'PAC.Xpert.SensitiveAgentTip' | translate: {Default: 'Sensitive agents require user confirmation before execution'}"
+          matTooltipPosition="above"
+        />
+      </div>
+    </div>
+
+    @if (view() === 'memory' && enabledMemory()) {
+      <xpert-studio-features-memory class="w-full px-3 mt-4" />
+    }
+  </div>
+
 </div>

apps/cloud/src/app/features/xpert/studio/features/features.component.ts

@@ -9,6 +9,8 @@ import { TranslateModule } from '@ngx-translate/core'
 import { XpertStudioFeaturesSummaryComponent } from './summary/summary.component'
 import { XpertStudioApiService } from '../domain'
 import { FormsModule } from '@angular/forms'
+import { XpertStudioFeaturesMemoryComponent } from './memory/memory.component'
+import { NgmDensityDirective } from '@metad/ocap-angular/core'
 
 
 @Component({
@@ -21,7 +23,9 @@ import { FormsModule } from '@angular/forms'
     TranslateModule,
     MatSlideToggleModule,
     MatTooltipModule,
-    XpertStudioFeaturesSummaryComponent
+    NgmDensityDirective,
+    XpertStudioFeaturesSummaryComponent,
+    XpertStudioFeaturesMemoryComponent
   ],
   templateUrl: './features.component.html',
   styleUrl: './features.component.scss',
@@ -31,16 +35,18 @@ export class XpertStudioFeaturesComponent {
   readonly #dialogRef = inject(DialogRef)
   readonly apiService = inject(XpertStudioApiService)
 
-  readonly view = signal<'summarize' | 'image_upload'>(null)
+  readonly view = signal<'summarize' | 'image_upload' | 'memory'>(null)
   readonly xpert = this.apiService.xpert
   readonly summarize = computed(() => this.xpert()?.summarize)
   readonly enabledSummarize = computed(() => this.summarize()?.enabled)
+  readonly memory = computed(() => this.xpert()?.memory)
+  readonly enabledMemory = computed(() => this.memory()?.enabled)
 
   close() {
     this.#dialogRef.close()
   }
 
-  toggleView(view: 'summarize' | 'image_upload') {
+  toggleView(view: 'summarize' | 'image_upload' | 'memory') {
     this.view.update((state) => state === view ? null : view)
   }
 
@@ -52,4 +58,13 @@ export class XpertStudioFeaturesComponent {
       }
     })
   }
+
+  toggleMemory(enabled?: boolean) {
+    this.apiService._updateXpert({
+      memory: {
+        ...(this.memory() ?? {}),
+        enabled,
+      }
+    })
+  }
 }

apps/cloud/src/app/features/xpert/studio/features/memory/memory.component.html

@@ -0,0 +1,5 @@
+
+<copilot-prompt-editor class="relative shadow-md ngm-card-border-gradient self-stretch"
+  [tooltip]="'PAC.Xpert.SystemPromptTooltip' | translate: {Default: 'Prompts guide AI reponses with instructions and contraints. Insert parameters like {{input}}. This prompt won\'t be visible to users.'}"
+  [(prompt)]="prompt"
+/>

apps/cloud/src/app/features/xpert/studio/features/memory/memory.component.scss

@@ -0,0 +1,3 @@
+:host {
+  @apply flex flex-col gap-4;
+}

apps/cloud/src/app/features/xpert/studio/features/memory/memory.component.ts

@@ -0,0 +1,56 @@
+import { CdkMenuModule } from '@angular/cdk/menu'
+import { CommonModule } from '@angular/common'
+import { Component, computed, inject } from '@angular/core'
+import { FormsModule } from '@angular/forms'
+import { MatSliderModule } from '@angular/material/slider'
+import { MatTooltipModule } from '@angular/material/tooltip'
+import { TLongTermMemory } from '@metad/contracts'
+import { OverlayAnimations } from '@metad/core'
+import { NgmDensityDirective } from '@metad/ocap-angular/core'
+import { TranslateModule } from '@ngx-translate/core'
+import { XpertStudioApiService } from '../../domain'
+import { CopilotPromptEditorComponent } from '../../../../../@shared/copilot'
+
+@Component({
+  selector: 'xpert-studio-features-memory',
+  standalone: true,
+  imports: [
+    CommonModule,
+    FormsModule,
+    CdkMenuModule,
+    TranslateModule,
+    MatSliderModule,
+    MatTooltipModule,
+    NgmDensityDirective,
+
+    CopilotPromptEditorComponent
+  ],
+  templateUrl: './memory.component.html',
+  styleUrl: './memory.component.scss',
+  animations: [...OverlayAnimations]
+})
+export class XpertStudioFeaturesMemoryComponent {
+  readonly apiService = inject(XpertStudioApiService)
+
+  readonly xpert = this.apiService.xpert
+  readonly memory = computed(() => this.xpert()?.memory)
+
+  get prompt() {
+    return this.memory()?.prompt
+  }
+  set prompt(value) {
+    this.updateMemory({ prompt: value })
+  }
+
+  updateMemory(memory: Partial<TLongTermMemory>) {
+    this.apiService.updateXpert((xpert) => {
+      return {
+        ...xpert,
+        memory: {
+          ...(xpert.memory ?? {}),
+          ...memory
+        }
+      }
+    })
+  }
+}

apps/cloud/src/app/features/xpert/studio/panel/preview/ai-message/message.component.ts

@@ -1,7 +1,7 @@
 import { CommonModule } from '@angular/common'
 import { Component, computed, effect, input } from '@angular/core'
 import { TranslateModule } from '@ngx-translate/core'
-import { CopilotChatMessage } from 'apps/cloud/src/app/@core'
+import { CopilotBaseMessage } from 'apps/cloud/src/app/@core'
 import { MarkdownModule } from 'ngx-markdown'
 
 @Component({
@@ -12,7 +12,7 @@ import { MarkdownModule } from 'ngx-markdown'
   styleUrls: ['message.component.scss']
 })
 export class XpertPreviewAiMessageComponent {
-  readonly message = input<CopilotChatMessage>()
+  readonly message = input<CopilotBaseMessage>()
 
   readonly contents = computed(() => {
     if (typeof this.message()?.content === 'string') {

apps/cloud/src/app/features/xpert/studio/panel/preview/preview.component.html

@@ -92,6 +92,8 @@
                     <div class="hidden group-hover:block h-[28px] p-0.5 rounded-lg bg-white border-[0.5px] border-gray-100 shadow-sm shrink-0">
                       <div class="shrink-0 p-1 flex items-center justify-center rounded-[6px] font-medium
                         bg-components-card-bg text-gray-500 hover:bg-gray-50 cursor-pointer hover:text-gray-700"
+                        [matTooltip]="'Copy'"
+                        matTooltipPosition="above"
                         (click)="copy(message)"
                       >
                         <svg xmlns="http://www.w3.org/2000/svg" width="16" height="16" viewBox="0 0 16 16" fill="none">
@@ -101,7 +103,7 @@
                     </div>
 
                   @if (message.executionId) {
-                    <div class="hidden group-hover:flex items-center w-max h-[28px] p-0.5 rounded-lg bg-white border-[0.5px] border-gray-100 shadow-sm shrink-0">
+                    <div class="hidden group-hover:flex items-center w-max h-[28px] p-1 rounded-lg bg-white border-[0.5px] border-gray-100 shadow-sm shrink-0">
                       <div class="shrink-0 p-1 flex items-center justify-center rounded-[6px] font-medium text-gray-500 hover:bg-gray-50 cursor-pointer hover:text-gray-700"
                         (click)="openExecution(message)"
                       >
@@ -115,6 +117,21 @@
                       <div class="mx-1 w-[1px] h-[14px] bg-gray-200"></div>
                     </div>
                   }
+
+                  <div class="hidden group-hover:flex shrink-0 items-center px-1 bg-white border-[0.5px] border-gray-100 shadow-md text-gray-500 rounded-lg">
+                    <div class="flex items-center justify-center mr-0.5 w-6 h-6 rounded-md hover:bg-black/5 hover:text-gray-800 cursor-pointer"
+                      [matTooltip]="'like'"
+                      matTooltipPosition="above"
+                    >
+                      <i class="ri-thumb-up-line"></i>
+                    </div>
+                    <div class="flex items-center justify-center w-6 h-6 rounded-md hover:bg-black/5 hover:text-gray-800 cursor-pointer"
+                      [matTooltip]="'dislike'"
+                      matTooltipPosition="above"
+                    >
+                      <i class="ri-thumb-down-line"></i>
+                    </div>
+                  </div>
                     <!-- 
                     <div class="hidden group-hover:block h-[28px] p-0.5 rounded-lg bg-white border-[0.5px] border-gray-100 shadow-sm shrink-0">
                       <div class="box-border p-0.5 flex items-center justify-center rounded-md bg-white cursor-pointer">

apps/cloud/src/app/features/xpert/studio/panel/preview/preview.component.ts

@@ -10,6 +10,7 @@ import {
   ChatConversationService,
   ChatMessageEventTypeEnum,
   ChatMessageTypeEnum,
+  CopilotBaseMessage,
   CopilotChatMessage,
   ToastrService,
   uuid,
@@ -77,18 +78,18 @@ export class XpertStudioPreviewComponent {
 
   readonly conversation = this.executionService.conversation
 
-  readonly currentMessage = signal<CopilotChatMessage>(null)
+  readonly currentMessage = signal<Partial<CopilotChatMessage>>(null)
   readonly messages = computed<CopilotChatMessage[]>(() => {
     if (this.currentMessage()) {
       const messages = this.executionService.messages()
       const lastMessage = messages[messages.length - 1]
       // Skip the last interrupted message when continuing the chat conversation
       if (lastMessage.status === XpertAgentExecutionStatusEnum.INTERRUPTED) {
-        return [...messages.slice(0, messages.length - 1), this.currentMessage()]
+        return [...messages.slice(0, messages.length - 1), this.currentMessage()] as CopilotChatMessage[]
       }
-      return [...this.executionService.messages(), this.currentMessage()]
+      return [...this.executionService.messages(), this.currentMessage()] as CopilotChatMessage[]
     }
-    return this.executionService.messages()
+    return this.executionService.messages() as CopilotChatMessage[]
   })
 
   readonly lastMessage = computed(() => {

apps/cloud/src/app/features/xpert/studio/services/execution.service.ts

@@ -16,10 +16,10 @@ export class XpertExecutionService {
 
   readonly conversation = signal<IChatConversation>(null)
 
-  readonly #messages = signal<CopilotChatMessage[]>([])
+  readonly #messages = signal<Partial<CopilotChatMessage>[]>([])
 
   readonly messages = computed(() => {
-    const messages = this.conversation()?.messages
+    const messages = this.conversation()?._messages
     if (messages) {
       return [...messages.filter((_) => !this.#messages().some((m) => m.id === _.id)), ...this.#messages()]
     }
@@ -53,7 +53,7 @@ export class XpertExecutionService {
 
   // Subsribe conversation
   private conversationSub = toObservable(this.conversationId).pipe(
-    switchMap((id) => id ? this.conversationService.getById(this.conversationId(), { relations: [] }) : of(null))
+    switchMap((id) => id ? this.conversationService.getById(this.conversationId(), { relations: ['_messages'] }) : of(null))
   ).subscribe((conv) => {
     this.conversation.set(conv)
   })
@@ -70,7 +70,7 @@ export class XpertExecutionService {
     }, { allowSignalWrites: true })
   }
 
-  appendMessage(message: CopilotChatMessage) {
+  appendMessage(message: Partial<CopilotChatMessage>) {
     this.#messages.update(
       (state) => {
         const messages = state?.filter((_) => _.id !== message.id)

package.json

@@ -94,7 +94,7 @@
     "@foblex/utils": "^1.1.0",
     "@langchain/community": "0.3.11",
     "@langchain/core": "0.3.13",
-    "@langchain/langgraph": "0.2.17",
+    "@langchain/langgraph": "0.2.33",
     "@langchain/ollama": "0.1.0",
     "@langchain/openai": "0.3.11",
     "@microsoft/fetch-event-source": "^2.0.1",

packages/contracts/src/ai/chat-message-feedback.model.ts

@@ -0,0 +1,25 @@
+import { IBasePerTenantAndOrganizationEntityModel } from '../base-entity.model'
+import { IChatMessage } from './chat-message.model'
+import { IChatConversation } from './chat.model'
+
+/**
+ * 
+ */
+export interface IChatMessageFeedback extends IBasePerTenantAndOrganizationEntityModel {
+
+  rating: string
+
+  content?: string
+
+  // Many to one
+  /**
+   * Chat conversation
+   */
+  conversation?: IChatConversation
+  conversationId?: string | null
+  /**
+   * Chat conversation message
+   */
+  message?: IChatMessage
+  messageId?: string | null
+}

packages/contracts/src/ai/chat-message.model.ts

@@ -0,0 +1,17 @@
+import { IBasePerTenantAndOrganizationEntityModel } from '../base-entity.model'
+import { CopilotBaseMessage, IChatConversation } from './chat.model'
+
+/**
+ * 
+ */
+export interface IChatMessage extends IBasePerTenantAndOrganizationEntityModel, Omit<Omit<CopilotBaseMessage, 'createdAt'>, 'id'> {
+
+  // Many to one
+  /**
+   * Chat conversation
+   */
+  conversation?: IChatConversation
+  conversationId?: string | null
+
+  executionId?: string
+}

packages/contracts/src/ai/chat.model.ts

@@ -5,6 +5,7 @@ import { JSONValue } from '../core.model'
 import { IXpertAgentExecution, XpertAgentExecutionStatusEnum } from './xpert-agent-execution.model'
 import { IXpert } from './xpert.model'
 import { I18nObject } from '../types'
+import { IChatMessage } from './chat-message.model'
 
 export type TChatConversationOptions = {
   knowledgebases?: string[]
@@ -46,7 +47,8 @@ export interface IChatConversation extends IBasePerTenantAndOrganizationEntityMo
 
   options?: TChatConversationOptions
 
-  messages?: CopilotBaseMessage[] | null
+  messages?: CopilotBaseMessage[]
+  _messages?: IChatMessage[] | null
   /**
    * The last operation when interrupted
    */

packages/contracts/src/ai/copilot-store.model.ts

@@ -0,0 +1,19 @@
+import { IBasePerTenantAndOrganizationEntityModel } from '../base-entity.model'
+
+export interface ICopilotStore extends TCopilotStore, IBasePerTenantAndOrganizationEntityModel {}
+
+export interface ICopilotStoreVector extends TCopilotStoreVector, IBasePerTenantAndOrganizationEntityModel {
+}
+
+export type TCopilotStore = {
+  prefix: string
+  key: string
+  value: any
+}
+
+export type TCopilotStoreVector = {
+  prefix: string
+  key: string
+  field_name: any
+  embedding: string
+}