v0.4.0-beta.1

Author: Artem-K-Koltunov

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "quickblox-react-ui-kit",
-  "version": "0.3.1",
+  "version": "0.4.0-beta.1",
   "main": "dist/index-ui.js",
   "license": "MIT",
   "dependencies": {
@@ -12,7 +12,7 @@
     "qb-ai-core": "^0.1.3",
     "qb-ai-rephrase": "^0.1.2",
     "qb-ai-translate": "^0.1.2",
-    "quickblox": "^2.16.4",
+    "quickblox": "^2.17.0-beta.1",
     "react": "^18.2.0",
     "react-dom": "^18.2.0",
     "react-router-dom": "^6.11.1",

package.json

@@ -21,6 +21,7 @@ export interface WidgetConfig {
   maxTokens: number;
   useDefault: boolean;
   proxyConfig: ProxyConfig;
+  smartChatAssistantId: string;
 }
 
 export interface AITranslateWidgetConfig extends WidgetConfig {

src/CommonTypes/CommonTypes.ts

@@ -147,6 +147,7 @@ export class DefaultConfigurations {
         AIAnswerAssistWidgetConfig: {
           organizationName: 'Quickblox',
           openAIModel: 'gpt-3.5-turbo',
+          smartChatAssistantId: '',
           apiKey: '',
           maxTokens: 3584,
           useDefault: true,
@@ -159,6 +160,7 @@ export class DefaultConfigurations {
         AITranslateWidgetConfig: {
           organizationName: 'Quickblox',
           openAIModel: 'gpt-3.5-turbo',
+          smartChatAssistantId: '',
           apiKey: '',
           maxTokens: 3584,
           useDefault: true,
@@ -178,7 +180,8 @@ export class DefaultConfigurations {
         AIRephraseWidgetConfig: {
           organizationName: 'Quickblox',
           openAIModel: 'gpt-3.5-turbo',
-          apiKey: '',
+          smartChatAssistantId: '',
+          apiKey: '6633a1300fea600001bd6e71',
           maxTokens: 3584,
           useDefault: true,
           defaultTone: 'Professional',

src/Data/DefaultConfigurations.ts

@@ -104,7 +104,8 @@ export default class ConnectionRepository extends SubscriptionPerformer<boolean>
     const pingChat = (): Promise<string> => {
       return new Promise<string>((resolve, reject) => {
         try {
-          QB.chat.ping((error) => {
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-call
+          QB.chat.pingchat((error) => {
             if (error) {
               console.log('ping failed: ', stringifyError(error));
               resolve('failed');

src/Data/repository/ConnectionRepository.ts

@@ -1,3 +1,7 @@
+import { ChatMessage } from 'qb-ai-core';
+import { AIAnswerAssistantSettings } from 'qb-ai-answer-assistant';
+import { AITranslateSettings } from 'qb-ai-translate';
+import {AIChatHistory, AIChatMessage} from 'quickblox';
 import { RemoteDialogDTO } from '../../dto/dialog/RemoteDialogDTO';
 import { RemoteDialogsDTO } from '../../dto/dialog/RemoteDialogsDTO';
 import { RemoteUserDTO } from '../../dto/user/RemoteUserDTO';
@@ -8,6 +12,7 @@ import { RemoteFileDTO } from '../../dto/file/RemoteFileDTO';
 import { Pagination } from '../../../Domain/repository/Pagination';
 import { CallBackFunction } from '../../../Domain/use_cases/base/IUseCase';
 import { NotificationTypes } from '../../../Domain/entity/NotificationTypes';
+import {AIAnswerResponse} from "../../../qb-api-calls";
 // todo list of all actions - for what we need to create tests
 /*
  0!!! не реализованы эксепшены для createDialog RemouteDataSource и
@@ -111,4 +116,16 @@ export interface IRemoteDataSource extends IRemoteMessaging<RemoteMessageDTO> {
   subscribeToChatConnectionEvents(fileId: string): Promise<void>;
 
   updateCurrentDialog(dto: RemoteDialogDTO): void;
+
+  createAnswer(
+    text: string,
+    messages: AIChatHistory,
+    smartChatAssistantId: string,
+  ): Promise<AIAnswerResponse>;
+
+  translate(
+    text: string,
+    languageCode: string,
+    smartChatAssistantId: string,
+  ): Promise<AIAnswerResponse>;
 }

src/Data/source/remote/IRemoteDataSource.ts

@@ -14,6 +14,7 @@ import QB, {
   QBSystemMessage,
   QBUser,
   QBMessageStatusParams,
+  AIChatHistory,
 } from 'quickblox/quickblox';
 import { RemoteDialogDTO } from '../../dto/dialog/RemoteDialogDTO';
 import {
@@ -34,6 +35,8 @@ import { DialogDTOMapper } from './Mapper/DialogDTOMapper';
 import { IDTOMapper } from './Mapper/IDTOMapper';
 import { Stubs } from '../../Stubs';
 import {
+  AIAnswerResponse,
+  QBAnswerAssist,
   QBChatConnect,
   QBChatDisconnect,
   qbChatGetMessagesExtended,
@@ -56,6 +59,7 @@ import {
   QBLogout,
   QBSendIsStopTypingStatus,
   QBSendIsTypingStatus,
+  QBTranslate,
   QBUpdateDialog,
   QBUsersGet,
   QBUsersGetById,
@@ -179,6 +183,24 @@ export class RemoteDataSource implements IRemoteDataSource {
       new SubscriptionPerformer<RemoteMessageDTO>();
   }
 
+  // eslint-disable-next-line class-methods-use-this
+  createAnswer(
+    text: string,
+    messages: AIChatHistory,
+    smartChatAssistantId: string,
+  ): Promise<AIAnswerResponse> {
+    return QBAnswerAssist(smartChatAssistantId, text, messages);
+  }
+
+  // eslint-disable-next-line class-methods-use-this
+  translate(
+    text: string,
+    languageCode: string,
+    smartChatAssistantId: string,
+  ): Promise<AIAnswerResponse> {
+    return QBTranslate(smartChatAssistantId, text, languageCode);
+  }
+
   async updateCurrentDialog(dto: RemoteDialogDTO): Promise<void> {
     this.currentDialog = dto;
     //

src/Data/source/remote/RemoteDataSource.ts

@@ -0,0 +1,52 @@
+// eslint-disable-next-line import/extensions
+import { AIChatMessage, AIRole } from 'quickblox';
+import { IChatMessage } from '../../../Data/source/AISource';
+import { IUseCase } from '../base/IUseCase';
+import { IRemoteDataSource } from '../../../Data/source/remote/IRemoteDataSource';
+import { AIAnswerResponse } from '../../../qb-api-calls';
+
+interface AIChatMessageEx extends AIChatMessage {
+  content: string;
+}
+export class AIAnswerAssistWithSDKUseCase implements IUseCase<void, string> {
+  private textToSend: string;
+
+  private dialogMessages: IChatMessage[];
+
+  private dataSource: IRemoteDataSource;
+
+  private smartChatAssistantId: string;
+
+  constructor(
+    textToSend: string,
+    dialogMessages: IChatMessage[],
+    dataSource: IRemoteDataSource,
+    smartChatAssistantId: string,
+  ) {
+    console.log('CONSTRUCTOR AIAnswerAssistWithSDKUseCase');
+    this.textToSend = textToSend;
+    this.dialogMessages = dialogMessages;
+    this.dataSource = dataSource;
+    this.smartChatAssistantId = smartChatAssistantId;
+  }
+
+  async execute(): Promise<string> {
+    console.log('execute AIAnswerAssistWithSDKUseCase');
+    const history: AIChatMessageEx[] = this.dialogMessages.map(
+      (msg: IChatMessage) => {
+        return {
+          role: msg.role as AIRole,
+          message: msg.content,
+          content: msg.content,
+        } as AIChatMessageEx;
+      },
+    );
+    const response: AIAnswerResponse = await this.dataSource.createAnswer(
+      this.textToSend,
+      history,
+      this.smartChatAssistantId,
+    );
+
+    return response.answer;
+  }
+}

src/Domain/use_cases/ai/AIAnswerAssistWithSDKUseCase.ts

@@ -0,0 +1,107 @@
+// eslint-disable-next-line import/extensions
+import { IUseCase } from '../base/IUseCase';
+import { IRemoteDataSource } from '../../../Data/source/remote/IRemoteDataSource';
+import { AIAnswerResponse } from '../../../qb-api-calls';
+
+export class AITranslateWithSDKUseCase implements IUseCase<void, string> {
+  private languageCodes: { [key: string]: string } = {
+    English: 'en',
+    Spanish: 'es',
+    'Chinese simplified': 'zh-Hans',
+    'Chinese traditional': 'zh-Hant',
+    French: 'fr',
+    German: 'de',
+    Japanese: 'ja',
+    Korean: 'ko',
+    Italian: 'it',
+    Russian: 'ru',
+    Portuguese: 'pt',
+    Arabic: 'ar',
+    Hindi: 'hi',
+    Turkish: 'tr',
+    Dutch: 'nl',
+    Polish: 'pl',
+    Ukrainian: 'uk',
+    Albanian: 'sq',
+    Armenian: 'hy',
+    Azerbaijani: 'az',
+    Basque: 'eu',
+    Belarusian: 'be',
+    Bengali: 'bn',
+    Bosnian: 'bs',
+    Bulgarian: 'bg',
+    Catalan: 'ca',
+    Croatian: 'hr',
+    Czech: 'cs',
+    Danish: 'da',
+    Estonian: 'et',
+    Finnish: 'fi',
+    Galician: 'gl',
+    Georgian: 'ka',
+    Greek: 'el',
+    Gujarati: 'gu',
+    Hungarian: 'hu',
+    Indonesian: 'id',
+    Irish: 'ga',
+    Kannada: 'kn',
+    Kazakh: 'kk',
+    Latvian: 'lv',
+    Lithuanian: 'lt',
+    Macedonian: 'mk',
+    Malay: 'ms',
+    Maltese: 'mt',
+    Mongolian: 'mn',
+    Nepali: 'ne',
+    Norwegian: 'no',
+    Pashto: 'ps',
+    Persian: 'fa',
+    Punjabi: 'pa',
+    Romanian: 'ro',
+    Sanskrit: 'sa',
+    Serbian: 'sr',
+    Sindhi: 'sd',
+    Sinhala: 'si',
+    Slovak: 'sk',
+    Slovenian: 'sl',
+    Uzbek: 'uz',
+    Vietnamese: 'vi',
+    Welsh: 'cy',
+  };
+
+  private textToSend: string;
+
+  private language: string;
+
+  private dataSource: IRemoteDataSource;
+
+  private smartChatAssistantId: string;
+
+  constructor(
+    textToSend: string,
+    language: string,
+    dataSource: IRemoteDataSource,
+    smartChatAssistantId: string,
+  ) {
+    console.log('CONSTRUCTOR AITranslateWithSDKUseCase');
+    this.dataSource = dataSource;
+    this.textToSend = textToSend;
+    this.language = language;
+    this.smartChatAssistantId = smartChatAssistantId;
+  }
+
+  getLanguageCode(language: string): string {
+    return this.languageCodes[language] || 'en';
+  }
+
+  async execute(): Promise<string> {
+    console.log('execute AITranslateWithSDKUseCase');
+
+    const response: AIAnswerResponse = await this.dataSource.translate(
+      this.textToSend,
+      this.getLanguageCode(this.language),
+      this.smartChatAssistantId,
+    );
+
+    return response.answer;
+  }
+}