blob: 209c217b2300566c014a855a72f16fdf27301d8f [file] [log] [blame]
/********************************************************************************
* Copyright (c) 2020 Contributors to the Eclipse Foundation
*
* See the NOTICE file(s) distributed with this work for additional
* information regarding copyright ownership.
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License v. 2.0 which is available at
* http://www.eclipse.org/legal/epl-2.0.
*
* SPDX-License-Identifier: EPL-2.0
********************************************************************************/
import { Directive, OnDestroy, Input } from '@angular/core';
import { Store } from '@ngrx/store';
import * as store from '@grid-failure-information-app/shared/store';
import { Observable, Subject } from 'rxjs';
import { User } from '@grid-failure-information-app/shared/models/user';
import { PermissionsModel } from '@grid-failure-information-app/shared/models/permissions.model';
import { takeUntil, take } from 'rxjs/operators';
import { FormState } from 'ngrx-forms';
import { DisableAction } from 'ngrx-forms';
@Directive({
selector: 'form[ngrxFormState]',
})
export class FormDisableDirective implements OnDestroy {
@Input()
public set ngrxFormState(formState: FormState<any>) {
if (!!formState && formState.isDisabled) {
return;
}
this._permissions$.pipe(take(1), takeUntil(this._endSubscriptions$)).subscribe(permissions => {
if (!!permissions.reader) {
this._appState$.dispatch(new DisableAction(formState.id));
}
});
}
private _endSubscriptions$: Subject<boolean> = new Subject();
private _permissions$: Observable<PermissionsModel> = this._appState$
.select(store.getUser)
.pipe(takeUntil(this._endSubscriptions$))
.map((user: User) => {
return new PermissionsModel(user.roles);
});
constructor(private _appState$: Store<store.State>) {}
ngOnDestroy() {
this._endSubscriptions$.next(true);
}
}