tornado-packages/ethers.js
1
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add response handling and 304 support to fetchJson.

Browse Source
This commit is contained in:
Richard Moore 2019-09-27 21:55:40 -04:00
parent a12030ad29
commit 3d25882d6b
No known key found for this signature in database
GPG Key ID: 665176BE8E9DC651
2 changed files with 56 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/ethers/src.ts/utils.ts
View File

@ -33,7 +33,7 @@ import { UnicodeNormalizationForm } from "@ethersproject/strings";
import { CoerceFunc } from "@ethersproject/abi";
import { Bytes, BytesLike, Hexable } from "@ethersproject/bytes"
import { ConnectionInfo, OnceBlockable, PollOptions } from "@ethersproject/web";
import { ConnectionInfo, FetchJsonResponse, OnceBlockable, PollOptions } from "@ethersproject/web";
import { EncryptOptions, ProgressCallback } from "@ethersproject/json-wallets";
////////////////////////
@ -164,6 +164,7 @@ export {
ConnectionInfo,
OnceBlockable,
PollOptions,
FetchJsonResponse,
EncryptOptions,
ProgressCallback

49
packages/web/src.ts/index.ts
View File

@ -33,11 +33,16 @@ export type PollOptions = {
onceBlock?: OnceBlockable
};
export type FetchJsonResponse = {
statusCode: number;
status: string;
headers: { [ header: string ]: string };
};
type Header = { key: string, value: string };
export function fetchJson(connection: string | ConnectionInfo, json?: string, processFunc?: (value: any) => any): Promise<any> {
export function fetchJson(connection: string | ConnectionInfo, json?: string, processFunc?: (value: any, response: FetchJsonResponse) => any): Promise<any> {
let headers: { [key: string]: Header } = { };
let url: string = null;
@ -52,6 +57,8 @@ export function fetchJson(connection: string | ConnectionInfo, json?: string, pr
referrer: "client", // no-referrer, *client
};
let allow304 = false;
let timeout = 2 * 60 * 1000;
if (typeof(connection) === "string") {
@ -71,6 +78,9 @@ export function fetchJson(connection: string | ConnectionInfo, json?: string, pr
if (connection.headers) {
for (let key in connection.headers) {
headers[key.toLowerCase()] = { key: key, value: String(connection.headers[key]) };
if (["if-none-match", "if-modified-since"].indexOf(key.toLowerCase()) >= 0) {
allow304 = true;
}
}
}
@ -124,33 +134,49 @@ export function fetchJson(connection: string | ConnectionInfo, json?: string, pr
return fetch(url, options).then((response) => {
return response.text().then((body) => {
if (!response.ok) {
let json: any = null;
if (allow304 && response.status === 304) {
// Leave json as null
} else if (!response.ok) {
logger.throwError("bad response", Logger.errors.SERVER_ERROR, {
status: response.status,
body: body,
type: response.type,
url: response.url
});
}
return body;
});
}).then((text) => {
let json: any = null;
} else {
try {
json = JSON.parse(text);
json = JSON.parse(body);
} catch (error) {
logger.throwError("invalid JSON", Logger.errors.SERVER_ERROR, {
body: text,
body: body,
error: error,
url: url
});
}
}
if (processFunc) {
try {
json = processFunc(json);
const headers: { [ header: string ]: string } = { };
if (response.headers.forEach) {
response.headers.forEach((value, key) => {
headers[key.toLowerCase()] = value;
});
} else {
(<() => Array<string>>((<any>(response.headers)).keys))().forEach((key) => {
headers[key.toLowerCase()] = response.headers.get(key);
});
}
json = processFunc(json, {
statusCode: response.status,
status: response.statusText,
headers: headers
});
} catch (error) {
logger.throwError("processing response error", Logger.errors.SERVER_ERROR, {
body: json,
@ -160,6 +186,7 @@ export function fetchJson(connection: string | ConnectionInfo, json?: string, pr
}
return json;
});
}, (error) => {
throw error;