import { Inject, Injectable } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';

import { ClientProxy } from '@nestjs/microservices';
import { firstValueFrom } from 'rxjs';

@Injectable()
export class RagService {
  constructor(@Inject('RAG') private client: ClientProxy) { }

  async getAnswerRag(transcript: string, chat_history?: string) {
    try {
      let response = await firstValueFrom(
        this.client.send('get-answer', { content: transcript, chat_history: chat_history })
      );
      // console.log('response', response);
      return response;
    } catch (error) {
      throw error;
    }
  }

  async chatSummrize(chat: string) {
    try {
      let response = await firstValueFrom(
        this.client.send('chat-summrize', { chat: chat })
      );
      // console.log('response', response);
      return response;
    } catch (error) {
      throw error;
    }
  }

  async chatEmotion(chat_history: string) {
    try {
      let response = await firstValueFrom(
        this.client.send('get-emotion', { chat_history: chat_history })
      );
      return response;
    } catch (error) {
      throw error;
    }
  }

}