Jak používat pozorovatelná data z externího rozhraní api v nestjs?

0

Otázka

Im snaží používat z externího rozhraní api v nestjs s 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));
  }
}

A moje služby třídy vypadá takto:

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

Nicméně, pokud mám konzoli.protokolu hodnota "infoPrestacion" toto je výsledek:

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

a to doesnt dostat na druhý, protože to není vyřešen dosud. Je možné čekat na výsledek, dokud není vyřešen (nemám config pro Modul) ? Návrat skutečně dostane samotný objekt "infoPrestacion" ale musím pracovat s hodnotami a ne vrátit objektu.

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

Nejlepší odpověď

0

Já jsem vyřešil můj problém s tímto, doufám, že tohle by mohlo odpovídat vašim potřebám.

Pokud budete mít pozorovatelné jako slib, že existují dvě řešení, která by odpovídala pro vás.

Ve třídě používáte externí api:

Přidat lastValueFrom, který převádí pozorovatelný na slib, že se přihlásíte k odběru pozorovatelné, čeká na dokončení, a řešení se vrátil slib s poslední hodnotou z pozorované proud.

firstValueFrom by mohlo být také řešení, dělá opak toho, lastValuefrom se dostat na první prvek jako váš slib je vyřešen.

@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

V jiných jazycích

Tato stránka je v jiných jazycích

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