agent/electron/src/store/effects/app-update.effect.ts

import { Injectable } from '@angular/core';
import { Action } from '@ngrx/store';
import { Actions, Effect, toPayload } from '@ngrx/effects';
import { Observable } from 'rxjs/Observable';

import 'rxjs/add/operator/do';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/first';

import { ActionTypes } from '../../shared/store/actions/app-update.action';
import { ActionTypes as AutoUpdateActionTypes } from '../../shared/store/actions/auto-update-settings';
import { AppUpdateRendererService } from '../../services/app-update-renderer.service';
import { NotificationType } from '../../shared/models/notification';
import { ShowNotificationAction } from '../../shared/store/actions/app.action';

@Injectable()
export class AppUpdateEffect {
    @Effect({ dispatch: false })
    appStart$: Observable<Action> = this.actions$
        .ofType(ActionTypes.UPDATE_APP)
        .first()
        .do(() => {
            this.appUpdateRendererService.sendUpdateAndRestartApp();
        });

    @Effect({ dispatch: false }) checkForUpdate$: Observable<Action> = this.actions$
        .ofType(AutoUpdateActionTypes.CHECK_FOR_UPDATE_NOW)
        .do(() => {
            this.appUpdateRendererService.checkForUpdate();
        });

    @Effect() handleError$: Observable<Action> = this.actions$
        .ofType(ActionTypes.UPDATE_ERROR)
        .map(toPayload)
        .map((message: string) => {
            return new ShowNotificationAction({
                type: NotificationType.Error,
                message
            });
        });

    constructor(private actions$: Actions,
                private appUpdateRendererService: AppUpdateRendererService) {
    }

}