Realm Web: Refresh access token

packages/realm-network-transport/package.json

@@ -1,6 +1,6 @@
 {
   "name": "realm-network-transport",
-  "version": "0.4.0",
+  "version": "0.6.0",
   "description": "Implements cross-platform fetching used by Realm JS",
   "main": "dist/bundle.cjs.js",
   "module": "dist/bundle.es.js",

packages/realm-network-transport/src/MongoDBRealmError.ts

@@ -16,25 +16,39 @@
 //
 ////////////////////////////////////////////////////////////////////////////
 
+import { Method } from "./types";
+
 /**
  * TODO: Determine if the shape of an error response is specific to each service or widely used
  */
 
 export class MongoDBRealmError extends Error {
+    public readonly method: Method;
+    public readonly url: string;
     public readonly statusCode: number;
     public readonly statusText: string;
     public readonly errorCode: string | undefined;
     public readonly link: string | undefined;
 
-    constructor(statusCode: number, statusText: string, response: any) {
+    constructor(
+        method: Method,
+        url: string,
+        statusCode: number,
+        statusText: string,
+        response: any,
+    ) {
         if (
             typeof response === "object" &&
             typeof response.error === "string"
         ) {
             const statusSummary = statusText
                 ? `status ${statusCode} ${statusText}`
                 : `status ${statusCode}`;
-            super(`${response.error} (${statusSummary})`);
+            super(
+                `Request failed (${method} ${url}): ${response.error} (${statusSummary})`,
+            );
+            this.method = method;
+            this.url = url;
             this.statusText = statusText;
             this.statusCode = statusCode;
             this.errorCode = response.error_code;

packages/realm-network-transport/src/NetworkTransport.ts

@@ -17,49 +17,13 @@
 ////////////////////////////////////////////////////////////////////////////
 
 import { MongoDBRealmError } from "./MongoDBRealmError";
+import { NetworkTransport, Request, ResponseHandler, Headers } from "./types";
 
 declare const process: any;
 declare const require: ((id: string) => any) | undefined;
 
 const isNodeProcess = typeof process === "object";
 
-export type Method = "GET" | "POST" | "DELETE" | "PUT";
-
-export type Headers = { [name: string]: string };
-
-export interface Request<RequestBody> {
-    method: Method;
-    url: string;
-    timeoutMs?: number;
-    headers?: Headers;
-    body?: RequestBody | string;
-}
-
-export interface Response {
-    statusCode: number;
-    headers: Headers;
-    body: string;
-}
-
-export type SuccessCallback = (response: Response) => void;
-
-export type ErrorCallback = (err: Error) => void;
-
-export interface ResponseHandler {
-    onSuccess: SuccessCallback;
-    onError: ErrorCallback;
-}
-
-export interface NetworkTransport {
-    fetchAndParse<RequestBody extends any, ResponseBody extends any>(
-        request: Request<RequestBody>,
-    ): Promise<ResponseBody>;
-    fetchWithCallbacks<RequestBody extends any>(
-        request: Request<RequestBody>,
-        handler: ResponseHandler,
-    ): void;
-}
-
 export class DefaultNetworkTransport implements NetworkTransport {
     public static fetch: typeof fetch;
     public static AbortController: typeof AbortController;
@@ -128,6 +92,8 @@ export class DefaultNetworkTransport implements NetworkTransport {
                 contentType.startsWith("application/json")
             ) {
                 throw new MongoDBRealmError(
+                    request.method,
+                    request.url,
                     response.status,
                     response.statusText,
                     await response.json(),
@@ -138,9 +104,13 @@ export class DefaultNetworkTransport implements NetworkTransport {
                 );
             }
         } catch (err) {
-            throw new Error(
-                `Request failed (${request.method} ${request.url}): ${err.message}`,
-            );
+            if (err instanceof MongoDBRealmError) {
+                throw err;
+            } else {
+                throw new Error(
+                    `Request failed (${request.method} ${request.url}): ${err.message}`,
+                );
+            }
         }
     }
 

packages/realm-network-transport/src/index.ts

@@ -17,12 +17,13 @@
 ////////////////////////////////////////////////////////////////////////////
 
 export {
-    DefaultNetworkTransport,
     NetworkTransport,
     Request,
     Response,
     Method,
     SuccessCallback,
     ErrorCallback,
     ResponseHandler,
-} from "./NetworkTransport";
+} from "./types";
+export { DefaultNetworkTransport } from "./NetworkTransport";
+export { MongoDBRealmError } from "./MongoDBRealmError";

packages/realm-network-transport/src/types.ts

@@ -0,0 +1,54 @@
+////////////////////////////////////////////////////////////////////////////
+//
+// Copyright 2020 Realm Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+////////////////////////////////////////////////////////////////////////////
+
+export type Method = "GET" | "POST" | "DELETE" | "PUT";
+
+export type Headers = { [name: string]: string };
+
+export interface Request<RequestBody> {
+    method: Method;
+    url: string;
+    timeoutMs?: number;
+    headers?: Headers;
+    body?: RequestBody | string;
+}
+
+export interface Response {
+    statusCode: number;
+    headers: Headers;
+    body: string;
+}
+
+export type SuccessCallback = (response: Response) => void;
+
+export type ErrorCallback = (err: Error) => void;
+
+export interface ResponseHandler {
+    onSuccess: SuccessCallback;
+    onError: ErrorCallback;
+}
+
+export interface NetworkTransport {
+    fetchAndParse<RequestBody extends any, ResponseBody extends any>(
+        request: Request<RequestBody>,
+    ): Promise<ResponseBody>;
+    fetchWithCallbacks<RequestBody extends any>(
+        request: Request<RequestBody>,
+        handler: ResponseHandler,
+    ): void;
+}