All files / Errors ErrorsHandler.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
1x
1x
 
1x
1x
 
 
28x
7x
7x
 
7x
 
 
 
1x
 
 
 
 
 
1x
 
 
7x
 
 
 
 
 
 
 
 
 
import { BehaviorSubject, Subject } from 'rxjs';
import { map } from 'rxjs/operators';
 
import ErrorType from './Constants/Error.type';
import mapToConsumerError from './Utils/ConsumerOutput/mapToConsumerError';
 
class ErrorsHandler {
    constructor() {
        this.reportError$ = new Subject();
        this.consumerError$ = new BehaviorSubject(null);
 
        this.consumerSubscription = this.subscribeToConsumerErrors();
    }
 
    handleError = error => {
        Iif (typeof error.type !== 'string' || !error.type) {
            this.handleError({
                type: ErrorType.UNKNOWN_ERROR,
                source: error,
            });
        }
        this.reportError$.next(error);
    }
 
    subscribeToConsumerErrors = () =>
        this.reportError$
            .pipe(
                map(mapToConsumerError)
            )
            .subscribe(this.consumerError$);
}
 
export default ErrorsHandler;