squidex/src/Squidex/app/framework/angular/http-extensions-impl.ts

/*
 * Squidex Headless CMS
 *
 * @license
 * Copyright (c) Sebastian Stehle. All rights reserved
 */

import { HttpClient, HttpErrorResponse, HttpHeaders, HttpResponse } from '@angular/common/http';
import { Observable } from 'rxjs';

import { Version } from './../utils/version';

export class ErrorDto {
    public get displayMessage(): string {
        let result = this.message;
        let lastChar: string;

        if (this.details && this.details.length > 0) {
            const detailMessage = this.details[0];

            lastChar = result[result.length - 1];

            if (lastChar !== '.' && lastChar !== ',') {
                result += '.';
            }

            result += ' ';
            result += detailMessage;
        }

        lastChar = result[result.length - 1];

        if (lastChar !== '.') {
            result += '.';
        }

        return result;
    }

    constructor(
        public readonly statusCode: number,
        public readonly message: string,
        public readonly details: string[] = []
    ) {
    }
}

export module HTTP {
    export function getVersioned(http: HttpClient, url: string, version?: Version): Observable<any> {
        const headers = createHeaders(version);

        return handleVersion(http.get(url, { observe: 'response', headers }), version);
    }

    export function postVersioned(http: HttpClient, url: string, body: any, version?: Version): Observable<any> {
        const headers = createHeaders(version);

        return handleVersion(http.post(url, body, { observe: 'response', headers }), version);
    }

    export function putVersioned(http: HttpClient, url: string, body: any, version?: Version): Observable<any> {
        const headers = createHeaders(version);

        return handleVersion(http.put(url, body, { observe: 'response', headers }), version);
    }

    export function deleteVersioned(http: HttpClient, url: string, version?: Version): Observable<any> {
        const headers = createHeaders(version);

        return handleVersion(http.delete(url, { observe: 'response', headers }), version);
    }

    function createHeaders(version?: Version): HttpHeaders {
        if (version && version.value && version.value.length > 0) {
            return new HttpHeaders().set('If-Match', version.value);
        } else {
            return new HttpHeaders();
        }
    }

    function handleVersion(httpRequest: Observable<HttpResponse<any>>, version: Version): Observable<any> {
        return httpRequest.do((response: HttpResponse<any>) => {
                if (version && response.status.toString().indexOf('2') === 0 && response.headers) {
                    const etag = response.headers.get('etag');

                    if (etag) {
                        version.update(etag);
                    }
                }
            }).map((response: HttpResponse<any>) => response.body);
    }
}

export function pretifyError(message: string): Observable<any> {
    return this.catch((response: HttpErrorResponse) => {
        let result = new ErrorDto(500, message);

        if (!(response.error instanceof Error)) {
            try {
                if (response.status === 412) {
                    result = new ErrorDto(response.status, 'Failed to make the update. Another user has made a change. Please reload.');
                } else if (response.status !== 500) {
                    result = new ErrorDto(response.status, response.error.message, response.error.details);
                }
            } catch (e) {
                /* Ignore */
            }
        }

        return Observable.throw(result);
    });
}