coffee-list.store.ts

import {Injectable, OnDestroy} from '@angular/core';
import {Store} from 'rxjs-observable-store';
import {Subject, Observable} from 'rxjs';
import {takeUntil, tap, switchMap, retry} from 'rxjs/operators';

import {CoffeeListStoreState} from './coffee-list.store.state';
import {CoffeeListEndpoint} from './coffee-list.endpoint';
import {ModalComponent} from '../../../shared/components/modal/modal.component';
import {Candidate} from '../types/candidate';
import * as candidateHelpers from '../helpers/candidate.helpers';
import {UserStore} from '../../../core/user/services/user.store';
import {User} from '../../../core/user/types/user';
import {UserAction} from '../coffee-list.constants';
import * as endpointHelpers from '../../../shared/helpers/endpoint.helpers';
import {StoreRequestStateUpdater} from '../../../shared/types/store-request-state-updater';
import {CustomRequestStateUpdater} from '../../../shared/types/custom-request-state-updater';
import {Sort} from '../../../shared/types/sort';

@Injectable()
export class CoffeeListStore extends Store<CoffeeListStoreState>
    implements OnDestroy {
    private ngUnsubscribe$: Subject<undefined> = new Subject();
    private reloadCandidates$: Subject<undefined> = new Subject();
    private detailsModal: ModalComponent;
    private storeRequestStateUpdater: StoreRequestStateUpdater;

    constructor(
        private endpoint: CoffeeListEndpoint,
        private userStore: UserStore
    ) {
        super(new CoffeeListStoreState());
    }

    init(): void {
        this.initReloadCandidates$();
        this.subscribeToUserUpdates();

        this.storeRequestStateUpdater = endpointHelpers.getStoreRequestStateUpdater(
            this
        );
    }

    ngOnDestroy(): void {
        this.ngUnsubscribe$.next();
        this.ngUnsubscribe$.complete();
    }

    reloadCandidates(): void {
        this.reloadCandidates$.next();
    }

    setDetailsModal(detailsModal: ModalComponent): void {
        this.detailsModal = detailsModal;
    }

    openDetailsModal(candidate: Candidate): void {
        this.setDetailsModalState(candidate);
        this.detailsModal.open();
    }

    closeDetailsModal(): void {
        this.setDetailsModalState(null);
        this.detailsModal.close();
    }

    setDetailsModalState(candidate: Candidate): void {
        this.setState({
            ...this.state,
            detailsModal: {
                candidate: candidate,
            },
        });
    }

    submitUserAction(candidate: Candidate, action: UserAction): void {
        let request$: Observable<null>;
        const requestStateUpdater = this.getUpdateCandidateRequestStateUpdater(
            candidate
        );

        if (action === UserAction.AddVote) {
            request$ = this.endpoint.addVote(candidate, requestStateUpdater);
        }
        if (action === UserAction.RemoveVote) {
            request$ = this.endpoint.removeVote(candidate, requestStateUpdater);
        }
        request$
            .pipe(
                tap(() => {
                    this.reloadCandidates();
                })
            )
            .subscribe();
    }

    sortCandidates(sort: Sort): void {
        this.setState({
            ...this.state,
            candidateList: {
                ...this.state.candidateList,
                sort: sort,
            },
        });
        this.reloadCandidates();
    }

    private initReloadCandidates$(): void {
        this.reloadCandidates$
            .pipe(
                switchMap(() => {
                    return this.endpoint.listCandidates(
                        this.state.candidateList.sort,
                        this.storeRequestStateUpdater
                    );
                }),
                tap(candidates => {
                    this.updateCandidatesState(candidates, this.userStore.user);
                }),
                retry(),
                takeUntil(this.ngUnsubscribe$)
            )
            .subscribe();
    }

    private subscribeToUserUpdates(): void {
        this.userStore.user$
            .pipe(takeUntil(this.ngUnsubscribe$))
            .subscribe(user => {
                this.updateCandidatesState(
                    this.state.candidateList.candidates,
                    user
                );
            });
    }

    private updateCandidatesState(candidates: Candidate[], user: User): void {
        this.setState({
            ...this.state,
            candidateList: {
                ...this.state.candidateList,
                candidates: candidateHelpers.getCandidatesInStoreFormat(
                    candidates,
                    user
                ),
            },
        });
    }

    private getUpdateCandidateRequestStateUpdater(
        candidate: Candidate
    ): CustomRequestStateUpdater {
        return requestState => {
            this.setState({
                ...this.state,
                candidateList: {
                    ...this.state.candidateList,
                    candidates: this.state.candidateList.candidates.map(c => {
                        if (c.id === candidate.id) {
                            return {...c, updateRequest: requestState};
                        }
                        return c;
                    }),
                },
            });
        };
    }
}