Skip to content

Commit a132d52

Browse files
committed
Update errorLoggingLink.ts
1 parent a1a3686 commit a132d52

File tree

1 file changed

+33
-27
lines changed

1 file changed

+33
-27
lines changed

packages/faustwp-core/src/apollo/errorLoggingLink.ts

Lines changed: 33 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -41,33 +41,39 @@ export class ErrorLoggingLink extends ApolloLink {
4141
operation: Operation,
4242
forward: NextLink,
4343
): Observable<FetchResult> | null {
44-
return new Observable<FetchResult>((observer: { next: (value: FetchResult) => void; error: (error: unknown) => void; complete: () => void }) => {
45-
const subscription = forward(operation).subscribe({
46-
next: (result: FetchResult) => {
47-
// Check if there are GraphQL errors in the result
48-
if (result.errors && result.errors.length > 0) {
49-
errorLog('GraphQL errors:', result.errors);
50-
}
51-
observer.next(result);
52-
},
53-
error: (error: unknown) => {
54-
// Check if the error is a server error
55-
if (isServerError(error)) {
56-
errorLog('Server error:', error);
57-
errorLog('Fetch result:', error.result);
58-
} else {
59-
errorLog('Network error:', error);
60-
}
61-
observer.error(error);
62-
},
63-
complete: () => {
64-
observer.complete();
65-
},
66-
});
44+
return new Observable<FetchResult>(
45+
(observer: {
46+
next: (value: FetchResult) => void;
47+
error: (error: unknown) => void;
48+
complete: () => void;
49+
}) => {
50+
const subscription = forward(operation).subscribe({
51+
next: (result: FetchResult) => {
52+
// Check if there are GraphQL errors in the result
53+
if (result.errors && result.errors.length > 0) {
54+
errorLog('GraphQL errors:', result.errors);
55+
}
56+
observer.next(result);
57+
},
58+
error: (error: unknown) => {
59+
// Check if the error is a server error
60+
if (isServerError(error)) {
61+
errorLog('Server error:', error);
62+
errorLog('Fetch result:', error.result);
63+
} else {
64+
errorLog('Network error:', error);
65+
}
66+
observer.error(error);
67+
},
68+
complete: () => {
69+
observer.complete();
70+
},
71+
});
6772

68-
return () => {
69-
subscription.unsubscribe();
70-
};
71-
});
73+
return () => {
74+
subscription.unsubscribe();
75+
};
76+
},
77+
);
7278
}
7379
}

0 commit comments

Comments
 (0)