chore: packages update

Author: sebastianmusial

apps/api/src/app/chat/agents/currency/get-currency.agent.ts

@@ -1,11 +1,11 @@
 import { Injectable } from '@nestjs/common';
-import { AssistantCreateParams } from 'openai/resources/beta';
+import { FunctionTool } from 'openai/resources/beta';
 import { AgentBase, AgentData, AgentService } from '@boldare/openai-assistant';
 import { CurrencyService } from './currency.service';
 
 @Injectable()
 export class GetCurrencyAgent extends AgentBase {
-  override definition: AssistantCreateParams.AssistantToolsFunction = {
+  override definition: FunctionTool = {
     type: 'function',
     function: {
       name: this.constructor.name,

apps/api/src/app/chat/agents/pokemon/get-pokemon-list.agent.ts

@@ -1,11 +1,11 @@
 import { Injectable } from '@nestjs/common';
-import { AssistantCreateParams } from 'openai/resources/beta';
 import { AgentBase, AgentService } from '@boldare/openai-assistant';
 import { PokemonService } from './pokemon.service';
+import { FunctionTool } from 'openai/resources/beta';
 
 @Injectable()
 export class GetPokemonListAgent extends AgentBase {
-  override definition: AssistantCreateParams.AssistantToolsFunction = {
+  override definition: FunctionTool = {
     type: 'function',
     function: {
       name: this.constructor.name,

apps/api/src/app/chat/agents/pokemon/get-pokemon-stats.agent.ts

@@ -1,11 +1,11 @@
 import { Injectable } from '@nestjs/common';
-import { AssistantCreateParams } from 'openai/resources/beta';
+import { FunctionTool } from 'openai/resources/beta';
 import { AgentBase, AgentData, AgentService } from '@boldare/openai-assistant';
 import { PokemonService } from './pokemon.service';
 
 @Injectable()
 export class GetPokemonStatsAgent extends AgentBase {
-  override definition: AssistantCreateParams.AssistantToolsFunction = {
+  override definition: FunctionTool = {
     type: 'function',
     function: {
       name: this.constructor.name,

apps/api/src/app/chat/agents/weather/get-current-weather.agent.ts

@@ -1,11 +1,11 @@
 import { Injectable } from '@nestjs/common';
-import { AssistantCreateParams } from 'openai/resources/beta';
+import { FunctionTool } from 'openai/resources/beta';
 import { AgentBase, AgentData, AgentService } from '@boldare/openai-assistant';
 import { WeatherService } from './weather.service';
 
 @Injectable()
 export class GetCurrentWeatherAgent extends AgentBase {
-  override definition: AssistantCreateParams.AssistantToolsFunction = {
+  override definition: FunctionTool = {
     type: 'function',
     function: {
       name: this.constructor.name,

apps/spa/src/app/components/chat/chat-audio/chat-audio.component.ts

@@ -1,6 +1,6 @@
 import { Component, Input, OnInit } from '@angular/core';
 import { ChatClientService } from '../../../modules/+chat/shared/chat-client.service';
-import { Message, SpeechVoice } from '../../../modules/+chat/shared/chat.model';
+import { ChatMessage, SpeechVoice } from '../../../modules/+chat/shared/chat.model';
 import { environment } from '../../../../environments/environment';
 import { MatIconModule } from '@angular/material/icon';
 import { delay } from 'rxjs';
@@ -15,7 +15,7 @@ import { NgClass } from '@angular/common';
   styleUrl: './chat-audio.component.scss',
 })
 export class ChatAudioComponent implements OnInit {
-  @Input() message!: Message;
+  @Input() message!: ChatMessage;
   isAudioEnabled = environment.isAudioEnabled;
   isStarted = false;
   audio = new Audio();

apps/spa/src/app/components/chat/chat-message/chat-message.component.ts

@@ -1,5 +1,5 @@
 import { Component, HostBinding, Input } from '@angular/core';
-import { ChatRole, Message } from '../../../modules/+chat/shared/chat.model';
+import { ChatRole, ChatMessage } from '../../../modules/+chat/shared/chat.model';
 import { MarkdownComponent } from 'ngx-markdown';
 import { ChatAudioComponent } from '../chat-audio/chat-audio.component';
 import { NgClass } from '@angular/common';
@@ -18,7 +18,7 @@ import { ChatAvatarComponent } from '../chat-avatar/chat-avatar.component';
   ],
 })
 export class ChatMessageComponent {
-  @Input() message!: Message;
+  @Input() message!: ChatMessage;
   @Input() class = '';
   chatRole = ChatRole;
 

apps/spa/src/app/components/chat/chat-messages/chat-messages.component.ts

@@ -10,7 +10,7 @@ import {
   SimpleChanges,
   ViewChildren,
 } from '@angular/core';
-import { Message } from '../../../modules/+chat/shared/chat.model';
+import { ChatMessage } from '../../../modules/+chat/shared/chat.model';
 import { ChatMessageComponent } from '../chat-message/chat-message.component';
 import { ChatTypingComponent } from '../chat-typing/chat-typing.component';
 import { ChatContentComponent } from '../chat-content/chat-content.component';
@@ -29,7 +29,7 @@ import { ChatTipsComponent } from '../chat-tips/chat-tips.component';
   ],
 })
 export class ChatMessagesComponent implements AfterViewInit, OnChanges {
-  @Input() messages: Message[] = [];
+  @Input() messages: ChatMessage[] = [];
   @Input() isTyping = false;
   @Input() tips: string[] = [];
   @Output() tipSelected$ = new EventEmitter<string>();

apps/spa/src/app/modules/+chat/shared/chat.model.ts

@@ -8,7 +8,7 @@ export enum ChatRole {
   System = 'system',
 }
 
-export interface Message {
+export interface ChatMessage {
   metadata?: Record<string, unknown>;
   content: string;
   role: ChatRole;
@@ -19,7 +19,7 @@ export enum ChatEvents {
   MessageReceived = 'message_received',
 }
 
-export enum MessageStatus {
+export enum ChatMessageStatus {
   Invisible = 'invisible',
 }
 

apps/spa/src/app/modules/+chat/shared/chat.service.ts

@@ -9,23 +9,23 @@ import {
   take,
   tap,
 } from 'rxjs';
-import { ChatRole, Message, MessageStatus } from './chat.model';
+import { ChatRole, ChatMessage, ChatMessageStatus } from './chat.model';
 import { ChatGatewayService } from './chat-gateway.service';
 import { ChatClientService } from './chat-client.service';
 import { ThreadService } from './thread.service';
 import { ChatFilesService } from './chat-files.service';
 import { environment } from '../../../../environments/environment';
 import { OpenAiFile, GetThreadResponseDto } from '@boldare/openai-assistant';
-import { Threads } from 'openai/resources/beta';
-import MessageContentText = Threads.MessageContentText;
-import { ThreadMessage } from 'openai/resources/beta/threads';
+import { Message } from 'openai/resources/beta/threads/messages';
+import { TextContentBlock } from 'openai/resources/beta/threads/messages/messages';
+
 
 @Injectable({ providedIn: 'root' })
 export class ChatService {
   isLoading$ = new BehaviorSubject<boolean>(false);
   isVisible$ = new BehaviorSubject<boolean>(environment.isAutoOpen);
   isTyping$ = new BehaviorSubject<boolean>(false);
-  messages$ = new BehaviorSubject<Message[]>([]);
+  messages$ = new BehaviorSubject<ChatMessage[]>([]);
 
   constructor(
     private readonly chatGatewayService: ChatGatewayService,
@@ -40,24 +40,28 @@ export class ChatService {
     this.watchVisibility();
   }
 
-  isMessageInvisible(message: ThreadMessage): boolean {
+  isMessageInvisible(message: Message): boolean {
     const metadata = message.metadata as Record<string, unknown>;
-    return metadata?.['status'] === MessageStatus.Invisible;
+    return metadata?.['status'] === ChatMessageStatus.Invisible;
   }
 
-  isTextMessage(message: ThreadMessage): boolean {
+  isTextMessage(message: Message): boolean {
     return message.content?.[0]?.type === 'text';
   }
 
-  parseMessages(thread: GetThreadResponseDto): Message[] {
+  parseMessages(thread: GetThreadResponseDto): ChatMessage[] {
+    if (!thread.messages) {
+      return [];
+    }
+
     return thread.messages
       .reverse()
       .filter(
         message =>
           this.isTextMessage(message) && !this.isMessageInvisible(message),
       )
       .map(message => ({
-        content: (message.content[0] as MessageContentText).text.value,
+        content: (message.content[0] as TextContentBlock).text.value,
         role: message.role as ChatRole,
       }));
   }
@@ -92,7 +96,7 @@ export class ChatService {
     this.messages$.next([]);
   }
 
-  addMessage(message: Message): void {
+  addMessage(message: ChatMessage): void {
     this.messages$.next([...this.messages$.value, message]);
   }
 

apps/spa/src/app/modules/+chat/shared/thread.service.ts

@@ -1,5 +1,5 @@
 import { Injectable } from '@angular/core';
-import { BehaviorSubject, Observable, Subject, take, tap } from 'rxjs';
+import { BehaviorSubject, catchError, Observable, Subject, take, tap } from 'rxjs';
 import { environment } from '../../../../environments/environment';
 import { ThreadClientService } from './thread-client.service';
 import { ConfigurationFormService } from '../../+configuration/shared/configuration-form.service';
@@ -43,6 +43,11 @@ export class ThreadService {
   }
 
   getThread(id: string): Observable<GetThreadResponseDto> {
-    return this.threadClientService.getThread(id).pipe(take(1));
+    return this.threadClientService
+      .getThread(id)
+      .pipe(
+        take(1),
+        catchError(() => this.start()),
+      );
   }
 }