highperfocused/mempool
1
0
Fork 0
mirror of https://github.com/mempool/mempool.git synced 2025-04-27 12:25:43 +02:00
Code Issues Packages Projects Releases Wiki Activity

Extend http interceptor to normalize errors

Browse Source
This commit is contained in:
Mononaut 2024-03-21 08:00:41 +00:00
parent 484e032775
commit 13fb75fec3
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
1 changed files with 37 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
frontend/src/app/services/http-cache.interceptor.ts
View File

@ -1,7 +1,7 @@
import { Inject, Injectable, PLATFORM_ID } from '@angular/core'; import { Inject, Injectable, PLATFORM_ID } from '@angular/core';
import { HttpInterceptor, HttpEvent, HttpRequest, HttpHandler, HttpResponse, HttpHeaders } from '@angular/common/http'; import { HttpInterceptor, HttpEvent, HttpRequest, HttpHandler, HttpResponse, HttpErrorResponse, HttpHeaders } from '@angular/common/http';
import { Observable, of } from 'rxjs'; import { Observable, of } from 'rxjs';
import { tap } from 'rxjs/operators'; import { catchError, tap } from 'rxjs/operators';
import { TransferState, makeStateKey } from '@angular/platform-browser'; import { TransferState, makeStateKey } from '@angular/platform-browser';
import { isPlatformBrowser } from '@angular/common'; import { isPlatformBrowser } from '@angular/common';
@ -36,15 +36,41 @@ export class HttpCacheInterceptor implements HttpInterceptor {
} }
return next.handle(request) return next.handle(request)
.pipe(tap((event: HttpEvent<any>) => { .pipe(
if (!this.isBrowser && event instanceof HttpResponse) { tap((event: HttpEvent<any>) => {
let keyId = request.url.split('/').slice(3).join('/'); if (!this.isBrowser && event instanceof HttpResponse) {
const headers = {}; let keyId = request.url.split('/').slice(3).join('/');
for (const k of event.headers.keys()) { const headers = {};
headers[k] = event.headers.getAll(k); for (const k of event.headers.keys()) {
headers[k] = event.headers.getAll(k);
}
this.transferState.set<any>(makeStateKey('/' + keyId), { response: event, headers });
} }
this.transferState.set<any>(makeStateKey('/' + keyId), { response: event, headers }); }),
} catchError((e) => {
})); if (e instanceof HttpErrorResponse) {
if (e.status === 0) {
throw new HttpErrorResponse({
error: 'Unknown error',
headers: e.headers,
status: 0,
statusText: 'Unknown error',
url: e.url,
});
} else {
throw e;
}
} else {
const msg = e?.['message'] || 'Unknown error';
throw new HttpErrorResponse({
error: msg,
headers: new HttpHeaders(),
status: 0,
statusText: msg,
url: '',
});
}
})
);
} }
} }