ФІ
Size: a a a
ФІ
ФІ
ФІ
7
ФІ
ФІ
7
ФІ
ФІ
ФІ
В
ФІ
В
В
ФІ
ФІ
В
ФІ
AI
read$ = createEffect(() => this.actions$.pipe(
ofType(actions.readAction),
switchMap((action) =>
forkJoin(
this.subscribersDs.getAuthorSubscribers(),
this.subscribersDs.getInvitations(),
this.subscribersDs.getRequests(),
).pipe(
map(([subscribersDp, invitationsDp, requestsDp]) => {
// TODO this should works, but somehow it doesn't...
console.log('requests', subscribersDp);
return actions.readSuccessAction({
invitations: invitationsDp?.data,
requests: requestsDp?.data,
subscribers: subscribersDp?.data,
});
}),
catchError((error) => of(actions.readFailureAction({ error })))
)
),
));
AI
getAuthorSubscribers({ uid }: { uid?: string } = {}): Observable<DataPage<SubscriberV1>> {
const req = (id) => this.http.get<DataPage<SubscriberV1>>(`${this.cs.config.auth.serverUrl}/api/v1/subscribers/${id}/mode/author`);
return uid ? req(uid) : this.authService.userId$.pipe(switchMap((id) => req(id)));
}