Как использовать наблюдаемые данные из внешнего api в nestjs?

0

Вопрос

Я пытаюсь использовать внешний api в nestjs с axios.

@Injectable()
export class PIntegration {
  constructor(private httpService: HttpService) { }
  API = process.env.API || 'http://localhost:3000';
  header = { headers: { 'Content-Type': 'application/json' } };

  async getPrestacionById(id: string): Promise<Observable<IPrestacion>>{
   
    return this.httpService.get(`${this.API}/prestacion/${id}`, this.header).pipe(map((res) => res.data));
  }
}

И мой класс обслуживания выглядит так:

@Injectable()
export class ProductService{
    constructor(private pIntegration: PIntegration){}
    async producto(id: string) {
        const infoPrestacion = await  this.pIntegration.getPrestacionById(id);
        console.log({ infoPrestacion })
        if (infoPrestacion)
        {
             if (infoPrestacion.detalles) {
                console.log(infoPrestacion.detalles)
                console.log("tiene detalles")
            }
        }
        return infoPrestacion;
    }
}

Однако, если я утешу.введите значение "infoPrestacion", это результат:

{
  infoPrestacion: Observable {
    source: Observable { _subscribe: [Function (anonymous)] },
    operator: [Function (anonymous)]
  }
}

и это не доходит до второго, так как оно еще не решено. Можно ли дождаться результата, пока он не будет разрешен (у меня нет конфигурации для HttpModule) ? Возврат фактически возвращает сам объект "infoPrestacion", но мне нужно работать со значениями, а не возвращать этот объект.

axios nestjs nestjs-config
2021-11-23 15:25:15
1

Лучший ответ

0

Я решил свою проблему с этим, я надеюсь, что это может соответствовать вашим потребностям.

Если вы принимаете свое наблюдаемое как обещание, есть два решения, которые могут вам подойти.

В классе вы используете внешний api:

Добавьте значение lastValueFrom, которое преобразует наблюдаемое в обещание, подписавшись на наблюдаемое, дождавшись его завершения и разрешив возвращенное обещание последним значением из наблюдаемого потока.

firstValueFrom также может быть решением, противоположным lastValuefrom, получающему первый элемент, когда ваше обещание будет выполнено.

@Injectable()

export class PIntegration {
  constructor(private httpService: HttpService) { }
  API = process.env.API || 'http://localhost:3000';
  header = { headers: { 'Content-Type': 'application/json' } };

  async getPrestacionById(id: string): Promise<Observable<IPrestacion>>{
   
    return lastValueFrom(this.httpService.get(`${this.API}/prestacion/${id}`, this.header).pipe(map((res) => res.data)));
  }
}
2021-11-26 13:34:41

На других языках

Эта страница на других языках

Italiano
..................................................................................................................
Polski
..................................................................................................................
Română
..................................................................................................................
한국어
..................................................................................................................
हिन्दी
..................................................................................................................
Français
..................................................................................................................
Türk
..................................................................................................................
Česk
..................................................................................................................
Português
..................................................................................................................
ไทย
..................................................................................................................
中文
..................................................................................................................
Español
..................................................................................................................
Slovenský
..................................................................................................................