40 lines
1.1 KiB
TypeScript
40 lines
1.1 KiB
TypeScript
|
import { Injectable } from '@angular/core';
|
||
|
|
import { Effect, Actions, ofType } from '@ngrx/effects';
|
||
|
|
import { of } from 'rxjs';
|
||
|
|
import { catchError, exhaustMap, map, tap } from 'rxjs/operators';
|
||
|
|
|
||
|
|
import { MetaProbePackageService } from '../../../service/meta-probe-package.service';
|
||
|
|
|
||
|
|
import {
|
||
|
|
ReadAllByOs,
|
||
|
|
ReadAllByOsSuccess,
|
||
|
|
ReadAllByOsFailure,
|
||
|
|
ActionType,
|
||
|
|
} from './meta-probe-package.action';
|
||
|
|
import { MetaProbePackage, MetaProbeOs } from '@overflow/commons-typescript/model/meta';
|
||
|
|
|
||
|
|
@Injectable()
|
||
|
|
export class Effects {
|
||
|
|
|
||
|
|
constructor(
|
||
|
|
private actions$: Actions,
|
||
|
|
private metaProbePackageService: MetaProbePackageService,
|
||
|
|
) { }
|
||
|
|
|
||
|
|
@Effect()
|
||
|
|
readAllByOs$ = this.actions$.pipe(
|
||
|
|
ofType(ActionType.ReadAllByOs),
|
||
|
|
map((action: ReadAllByOs) => action.payload),
|
||
|
|
exhaustMap((metaProbeOs: MetaProbeOs) =>
|
||
|
|
this.metaProbePackageService
|
||
|
|
.readAllByOs(metaProbeOs)
|
||
|
|
.pipe(
|
||
|
|
map((result: MetaProbePackage[]) => {
|
||
|
|
return new ReadAllByOsSuccess(result);
|
||
|
|
}),
|
||
|
|
catchError(error => of(new ReadAllByOsFailure(error)))
|
||
|
|
)
|
||
|
|
)
|
||
|
|
);
|
||
|
|
}
|