Jak korzystać obserwowane dane z zewnętrznego interfejsu api w nestjs?

0

Pytanie

Staram się korzystać z zewnętrznego api w nestjs z 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));
  }
}

I moja klasa obsługi wygląda tak:

@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;
    }
}

Jednak, jeśli nie pocieszę.wprowadź wartość "infoPrestacion", to wynik:

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

i to nie dochodzi do drugiego, tak jak ja, jeszcze nie zdecydowano. Czy mogę się doczekać rezultatu, dopóki nie zostanie dopuszczony (u mnie nie ma konfiguracji dla HttpModule) ? Zwrot faktycznie zwraca sam obiekt "infoPrestacion", ale muszę pracować z wartościami, a nie zwracać obiekt.

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

Najlepsza odpowiedź

0

Postanowiłem swój problem z tym, mam nadzieję, że to może dopasowane do twoich potrzeb.

Jeśli akceptujesz swoje obserwująca jak obietnica, są dwa rozwiązania, które mogą ci odpowiadać.

W klasie używasz zewnętrznego api:

Dodaj wartość lastValueFrom, która konwertuje obserwowane w obietnicę, logując się na obserwacji, czekając na jego zakończenie i rozwiązanie zwrócona obietnica ostatnim wartością z obserwowanego strumienia.

firstValueFrom może być również rozwiązaniem, przeciwnie, lastValuefrom, otrzymującej pierwszy element, kiedy twoja obietnica zostanie wykonana.

@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

W innych językach

Ta strona jest w innych językach

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