Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
d1f3117376 | |||
14cca11c55 | |||
f4374942ad | |||
12dc003226 |
4
package-lock.json
generated
4
package-lock.json
generated
@ -1,12 +1,12 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/webrequest",
|
"name": "@pushrocks/webrequest",
|
||||||
"version": "3.0.5",
|
"version": "3.0.7",
|
||||||
"lockfileVersion": 2,
|
"lockfileVersion": 2,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"packages": {
|
"packages": {
|
||||||
"": {
|
"": {
|
||||||
"name": "@pushrocks/webrequest",
|
"name": "@pushrocks/webrequest",
|
||||||
"version": "3.0.5",
|
"version": "3.0.7",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@pushrocks/smartdelay": "^2.0.13",
|
"@pushrocks/smartdelay": "^2.0.13",
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/webrequest",
|
"name": "@pushrocks/webrequest",
|
||||||
"version": "3.0.5",
|
"version": "3.0.7",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "securely request from browsers",
|
"description": "securely request from browsers",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@pushrocks/webrequest',
|
name: '@pushrocks/webrequest',
|
||||||
version: '3.0.5',
|
version: '3.0.7',
|
||||||
description: 'securely request from browsers'
|
description: 'securely request from browsers'
|
||||||
}
|
}
|
||||||
|
15
ts/index.ts
15
ts/index.ts
@ -44,11 +44,12 @@ export class WebRequest {
|
|||||||
/**
|
/**
|
||||||
* postJson
|
* postJson
|
||||||
*/
|
*/
|
||||||
public async postJson(urlArg: string, requestBody?: any, useStoreAsFallback: boolean = false) {
|
public async postJson(urlArg: string, requestBody?: any, useCacheArg: boolean = false) {
|
||||||
await WebRequest.neededPolyfillsLoadedDeferred.promise;
|
await WebRequest.neededPolyfillsLoadedDeferred.promise;
|
||||||
const response: Response = await this.request(urlArg, {
|
const response: Response = await this.request(urlArg, {
|
||||||
body: plugins.smartjson.stringify(requestBody),
|
body: plugins.smartjson.stringify(requestBody),
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
|
useCache: useCacheArg,
|
||||||
});
|
});
|
||||||
const responseText = await response.text();
|
const responseText = await response.text();
|
||||||
const responseResult = plugins.smartjson.parse(responseText);
|
const responseResult = plugins.smartjson.parse(responseText);
|
||||||
@ -102,12 +103,12 @@ export class WebRequest {
|
|||||||
let cachedResponseDeferred = plugins.smartpromise.defer<Response>();
|
let cachedResponseDeferred = plugins.smartpromise.defer<Response>();
|
||||||
let cacheUsed = false;
|
let cacheUsed = false;
|
||||||
if (optionsArg.useCache && this.cacheStore.check(urlArg)) {
|
if (optionsArg.useCache && this.cacheStore.check(urlArg)) {
|
||||||
const responseBuffer: ArrayBuffer = await this.cacheStore.get(urlArg)
|
const responseBuffer: ArrayBuffer = await this.cacheStore.get(urlArg);
|
||||||
cachedResponseDeferred.resolve(new Response(responseBuffer, {}));
|
cachedResponseDeferred.resolve(new Response(responseBuffer, {}));
|
||||||
} else {
|
} else {
|
||||||
cachedResponseDeferred.resolve(null);
|
cachedResponseDeferred.resolve(null);
|
||||||
}
|
}
|
||||||
const response: Response = await fetch(urlArg, {
|
let response: Response = await fetch(urlArg, {
|
||||||
signal: controller.signal,
|
signal: controller.signal,
|
||||||
method: optionsArg.method,
|
method: optionsArg.method,
|
||||||
headers: {
|
headers: {
|
||||||
@ -115,8 +116,8 @@ export class WebRequest {
|
|||||||
...(optionsArg.headers || {}),
|
...(optionsArg.headers || {}),
|
||||||
},
|
},
|
||||||
body: optionsArg.body,
|
body: optionsArg.body,
|
||||||
}).catch(async err => {
|
}).catch(async (err) => {
|
||||||
if (optionsArg.useCache && await cachedResponseDeferred.promise) {
|
if (optionsArg.useCache && (await cachedResponseDeferred.promise)) {
|
||||||
cacheUsed = true;
|
cacheUsed = true;
|
||||||
const cachedResponse = cachedResponseDeferred.promise;
|
const cachedResponse = cachedResponseDeferred.promise;
|
||||||
return cachedResponse;
|
return cachedResponse;
|
||||||
@ -124,6 +125,10 @@ export class WebRequest {
|
|||||||
return err;
|
return err;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
if (optionsArg.useCache && (await cachedResponseDeferred.promise) && response.status === 500) {
|
||||||
|
cacheUsed = true;
|
||||||
|
response = await cachedResponseDeferred.promise;
|
||||||
|
}
|
||||||
if (!cacheUsed && optionsArg.useCache && response.status < 300) {
|
if (!cacheUsed && optionsArg.useCache && response.status < 300) {
|
||||||
const buffer = await response.clone().arrayBuffer();
|
const buffer = await response.clone().arrayBuffer();
|
||||||
await this.cacheStore.set(urlArg, buffer);
|
await this.cacheStore.set(urlArg, buffer);
|
||||||
|
Reference in New Issue
Block a user