workbox-background-sync
Advanced tools
Comparing version 5.0.0 to 5.1.0
"use strict"; | ||
// @ts-ignore | ||
try { | ||
self['workbox:background-sync:5.0.0'] && _(); | ||
self['workbox:background-sync:5.1.0'] && _(); | ||
} | ||
catch (e) { } |
@@ -11,3 +11,3 @@ import { WorkboxPlugin } from 'workbox-core/types.js'; | ||
declare class BackgroundSyncPlugin implements WorkboxPlugin { | ||
private _queue; | ||
private readonly _queue; | ||
/** | ||
@@ -14,0 +14,0 @@ * @param {string} name See the [Queue]{@link module:workbox-background-sync.Queue} |
@@ -6,3 +6,3 @@ this.workbox = this.workbox || {}; | ||
try { | ||
self['workbox:background-sync:5.0.0'] && _(); | ||
self['workbox:background-sync:5.1.0'] && _(); | ||
} catch (e) {} | ||
@@ -242,2 +242,35 @@ | ||
/** | ||
* Accepts an object of request data that can be used to construct a | ||
* `Request` but can also be stored in IndexedDB. | ||
* | ||
* @param {Object} requestData An object of request data that includes the | ||
* `url` plus any relevant properties of | ||
* [requestInit]{@link https://fetch.spec.whatwg.org/#requestinit}. | ||
* @private | ||
*/ | ||
constructor(requestData) { | ||
{ | ||
assert_js.assert.isType(requestData, 'object', { | ||
moduleName: 'workbox-background-sync', | ||
className: 'StorableRequest', | ||
funcName: 'constructor', | ||
paramName: 'requestData' | ||
}); | ||
assert_js.assert.isType(requestData.url, 'string', { | ||
moduleName: 'workbox-background-sync', | ||
className: 'StorableRequest', | ||
funcName: 'constructor', | ||
paramName: 'requestData.url' | ||
}); | ||
} // If the request's mode is `navigate`, convert it to `same-origin` since | ||
// navigation requests can't be constructed via script. | ||
if (requestData['mode'] === 'navigate') { | ||
requestData['mode'] = 'same-origin'; | ||
} | ||
this._requestData = requestData; | ||
} | ||
/** | ||
* Converts a Request object to a plain object that can be structured | ||
@@ -251,2 +284,4 @@ * cloned or JSON-stringified. | ||
*/ | ||
static async fromRequest(request) { | ||
@@ -281,37 +316,2 @@ const requestData = { | ||
/** | ||
* Accepts an object of request data that can be used to construct a | ||
* `Request` but can also be stored in IndexedDB. | ||
* | ||
* @param {Object} requestData An object of request data that includes the | ||
* `url` plus any relevant properties of | ||
* [requestInit]{@link https://fetch.spec.whatwg.org/#requestinit}. | ||
* @private | ||
*/ | ||
constructor(requestData) { | ||
{ | ||
assert_js.assert.isType(requestData, 'object', { | ||
moduleName: 'workbox-background-sync', | ||
className: 'StorableRequest', | ||
funcName: 'constructor', | ||
paramName: 'requestData' | ||
}); | ||
assert_js.assert.isType(requestData.url, 'string', { | ||
moduleName: 'workbox-background-sync', | ||
className: 'StorableRequest', | ||
funcName: 'constructor', | ||
paramName: 'requestData.url' | ||
}); | ||
} // If the request's mode is `navigate`, convert it to `same-origin` since | ||
// navigation requests can't be constructed via script. | ||
if (requestData['mode'] === 'navigate') { | ||
requestData['mode'] = 'same-origin'; | ||
} | ||
this._requestData = requestData; | ||
} | ||
/** | ||
* Returns a deep clone of the instances `_requestData` object. | ||
@@ -374,2 +374,24 @@ * | ||
/** | ||
* Converts a QueueStore entry into the format exposed by Queue. This entails | ||
* converting the request data into a real request and omitting the `id` and | ||
* `queueName` properties. | ||
* | ||
* @param {Object} queueStoreEntry | ||
* @return {Object} | ||
* @private | ||
*/ | ||
const convertEntry = queueStoreEntry => { | ||
const queueEntry = { | ||
request: new StorableRequest(queueStoreEntry.requestData).toRequest(), | ||
timestamp: queueStoreEntry.timestamp | ||
}; | ||
if (queueStoreEntry.metadata) { | ||
queueEntry.metadata = queueStoreEntry.metadata; | ||
} | ||
return queueEntry; | ||
}; | ||
/** | ||
* A class to manage storing failed requests in IndexedDB and retrying them | ||
@@ -382,2 +404,3 @@ * later. All parts of the storing and replaying process are observable via | ||
class Queue { | ||
@@ -753,26 +776,3 @@ /** | ||
} | ||
/** | ||
* Converts a QueueStore entry into the format exposed by Queue. This entails | ||
* converting the request data into a real request and omitting the `id` and | ||
* `queueName` properties. | ||
* | ||
* @param {Object} queueStoreEntry | ||
* @return {Object} | ||
* @private | ||
*/ | ||
const convertEntry = queueStoreEntry => { | ||
const queueEntry = { | ||
request: new StorableRequest(queueStoreEntry.requestData).toRequest(), | ||
timestamp: queueStoreEntry.timestamp | ||
}; | ||
if (queueStoreEntry.metadata) { | ||
queueEntry.metadata = queueStoreEntry.metadata; | ||
} | ||
return queueEntry; | ||
}; | ||
/* | ||
@@ -779,0 +779,0 @@ Copyright 2018 Google LLC |
@@ -1,2 +0,2 @@ | ||
this.workbox=this.workbox||{},this.workbox.backgroundSync=function(t,e,s,i,n){"use strict";try{self["workbox:background-sync:5.0.0"]&&_()}catch(t){}const a=3,r="workbox-background-sync",c="requests",h="queueName";class o{constructor(t){this.t=t,this.s=new n.DBWrapper(r,a,{onupgradeneeded:this.i})}async pushEntry(t){delete t.id,t.queueName=this.t,await this.s.add(c,t)}async unshiftEntry(t){const[e]=await this.s.getAllMatching(c,{count:1});e?t.id=e.id-1:delete t.id,t.queueName=this.t,await this.s.add(c,t)}async popEntry(){return this.h({direction:"prev"})}async shiftEntry(){return this.h({direction:"next"})}async getAll(){return await this.s.getAllMatching(c,{index:h,query:IDBKeyRange.only(this.t)})}async deleteEntry(t){await this.s.delete(c,t)}async h({direction:t}){const[e]=await this.s.getAllMatching(c,{direction:t,index:h,query:IDBKeyRange.only(this.t),count:1});if(e)return await this.deleteEntry(e.id),e}i(t){const e=t.target.result;t.oldVersion>0&&t.oldVersion<a&&e.objectStoreNames.contains(c)&&e.deleteObjectStore(c),e.createObjectStore(c,{autoIncrement:!0,keyPath:"id"}).createIndex(h,h,{unique:!1})}}const u=["method","referrer","referrerPolicy","mode","credentials","cache","redirect","integrity","keepalive"];class y{static async fromRequest(t){const e={url:t.url,headers:{}};"GET"!==t.method&&(e.body=await t.clone().arrayBuffer());for(const[s,i]of t.headers.entries())e.headers[s]=i;for(const s of u)void 0!==t[s]&&(e[s]=t[s]);return new y(e)}constructor(t){"navigate"===t.mode&&(t.mode="same-origin"),this.o=t}toObject(){const t=Object.assign({},this.o);return t.headers=Object.assign({},this.o.headers),t.body&&(t.body=t.body.slice(0)),t}toRequest(){return new Request(this.o.url,this.o)}clone(){return new y(this.toObject())}}const w="workbox-background-sync",f=10080,d=new Set;class l{constructor(t,{onSync:s,maxRetentionTime:i}={}){if(this.u=!1,this.l=!1,d.has(t))throw new e.WorkboxError("duplicate-queue-name",{name:t});d.add(t),this.q=t,this.m=s||this.replayRequests,this.p=i||f,this.g=new o(this.q),this.R()}get name(){return this.q}async pushRequest(t){await this.k(t,"push")}async unshiftRequest(t){await this.k(t,"unshift")}async popRequest(){return this.D("pop")}async shiftRequest(){return this.D("shift")}async getAll(){const t=await this.g.getAll(),e=Date.now(),s=[];for(const i of t){const t=60*this.p*1e3;e-i.timestamp>t?await this.g.deleteEntry(i.id):s.push(q(i))}return s}async k({request:t,metadata:e,timestamp:s=Date.now()},i){const n={requestData:(await y.fromRequest(t.clone())).toObject(),timestamp:s};e&&(n.metadata=e),await this.g[`${i}Entry`](n),this.u?this.l=!0:await this.registerSync()}async D(t){const e=Date.now(),s=await this.g[`${t}Entry`]();if(s){const i=60*this.p*1e3;return e-s.timestamp>i?this.D(t):q(s)}}async replayRequests(){let t;for(;t=await this.shiftRequest();)try{await fetch(t.request.clone())}catch(s){throw await this.unshiftRequest(t),new e.WorkboxError("queue-replay-failed",{name:this.q})}}async registerSync(){if("sync"in self.registration)try{await self.registration.sync.register(`${w}:${this.q}`)}catch(t){}}R(){"sync"in self.registration?self.addEventListener("sync",t=>{if(t.tag===`${w}:${this.q}`){const e=async()=>{let e;this.u=!0;try{await this.m({queue:this})}catch(t){throw e=t}finally{!this.l||e&&!t.lastChance||await this.registerSync(),this.u=!1,this.l=!1}};t.waitUntil(e())}}):this.m({queue:this})}static get _(){return d}}const q=t=>{const e={request:new y(t.requestData).toRequest(),timestamp:t.timestamp};return t.metadata&&(e.metadata=t.metadata),e};return t.BackgroundSyncPlugin=class{constructor(t,e){this.fetchDidFail=(async({request:t})=>{await this.v.pushRequest({request:t})}),this.v=new l(t,e)}},t.Queue=l,t}({},workbox.core._private,workbox.core._private,workbox.core._private,workbox.core._private); | ||
this.workbox=this.workbox||{},this.workbox.backgroundSync=function(t,e,s,i,n){"use strict";try{self["workbox:background-sync:5.1.0"]&&_()}catch(t){}class a{constructor(t){this.t=t,this.s=new n.DBWrapper("workbox-background-sync",3,{onupgradeneeded:this.i})}async pushEntry(t){delete t.id,t.queueName=this.t,await this.s.add("requests",t)}async unshiftEntry(t){const[e]=await this.s.getAllMatching("requests",{count:1});e?t.id=e.id-1:delete t.id,t.queueName=this.t,await this.s.add("requests",t)}async popEntry(){return this.h({direction:"prev"})}async shiftEntry(){return this.h({direction:"next"})}async getAll(){return await this.s.getAllMatching("requests",{index:"queueName",query:IDBKeyRange.only(this.t)})}async deleteEntry(t){await this.s.delete("requests",t)}async h({direction:t}){const[e]=await this.s.getAllMatching("requests",{direction:t,index:"queueName",query:IDBKeyRange.only(this.t),count:1});if(e)return await this.deleteEntry(e.id),e}i(t){const e=t.target.result;t.oldVersion>0&&t.oldVersion<3&&e.objectStoreNames.contains("requests")&&e.deleteObjectStore("requests"),e.createObjectStore("requests",{autoIncrement:!0,keyPath:"id"}).createIndex("queueName","queueName",{unique:!1})}}const r=["method","referrer","referrerPolicy","mode","credentials","cache","redirect","integrity","keepalive"];class c{constructor(t){"navigate"===t.mode&&(t.mode="same-origin"),this.u=t}static async fromRequest(t){const e={url:t.url,headers:{}};"GET"!==t.method&&(e.body=await t.clone().arrayBuffer());for(const[s,i]of t.headers.entries())e.headers[s]=i;for(const s of r)void 0!==t[s]&&(e[s]=t[s]);return new c(e)}toObject(){const t=Object.assign({},this.u);return t.headers=Object.assign({},this.u.headers),t.body&&(t.body=t.body.slice(0)),t}toRequest(){return new Request(this.u.url,this.u)}clone(){return new c(this.toObject())}}const h=new Set,u=t=>{const e={request:new c(t.requestData).toRequest(),timestamp:t.timestamp};return t.metadata&&(e.metadata=t.metadata),e};class o{constructor(t,{onSync:s,maxRetentionTime:i}={}){if(this.o=!1,this.q=!1,h.has(t))throw new e.WorkboxError("duplicate-queue-name",{name:t});h.add(t),this.l=t,this.m=s||this.replayRequests,this.p=i||10080,this.g=new a(this.l),this.R()}get name(){return this.l}async pushRequest(t){await this.k(t,"push")}async unshiftRequest(t){await this.k(t,"unshift")}async popRequest(){return this.D("pop")}async shiftRequest(){return this.D("shift")}async getAll(){const t=await this.g.getAll(),e=Date.now(),s=[];for(const i of t){const t=60*this.p*1e3;e-i.timestamp>t?await this.g.deleteEntry(i.id):s.push(u(i))}return s}async k({request:t,metadata:e,timestamp:s=Date.now()},i){const n={requestData:(await c.fromRequest(t.clone())).toObject(),timestamp:s};e&&(n.metadata=e),await this.g[`${i}Entry`](n),this.o?this.q=!0:await this.registerSync()}async D(t){const e=Date.now(),s=await this.g[`${t}Entry`]();if(s){const i=60*this.p*1e3;return e-s.timestamp>i?this.D(t):u(s)}}async replayRequests(){let t;for(;t=await this.shiftRequest();)try{await fetch(t.request.clone())}catch(s){throw await this.unshiftRequest(t),new e.WorkboxError("queue-replay-failed",{name:this.l})}}async registerSync(){if("sync"in self.registration)try{await self.registration.sync.register(`workbox-background-sync:${this.l}`)}catch(t){}}R(){"sync"in self.registration?self.addEventListener("sync",t=>{if(t.tag===`workbox-background-sync:${this.l}`){const e=async()=>{let e;this.o=!0;try{await this.m({queue:this})}catch(t){throw e=t,e}finally{!this.q||e&&!t.lastChance||await this.registerSync(),this.o=!1,this.q=!1}};t.waitUntil(e())}}):this.m({queue:this})}static get _(){return h}}return t.BackgroundSyncPlugin=class{constructor(t,e){this.fetchDidFail=async({request:t})=>{await this.v.pushRequest({request:t})},this.v=new o(t,e)}},t.Queue=o,t}({},workbox.core._private,workbox.core._private,workbox.core._private,workbox.core._private); | ||
//# sourceMappingURL=workbox-background-sync.prod.js.map |
@@ -20,4 +20,4 @@ import { RequestData } from './StorableRequest.js'; | ||
export declare class QueueStore { | ||
private _queueName; | ||
private _db; | ||
private readonly _queueName; | ||
private readonly _db; | ||
/** | ||
@@ -24,0 +24,0 @@ * Associates this instance with a Queue instance, so entries added can be |
@@ -17,3 +17,3 @@ import '../_version.js'; | ||
declare class StorableRequest { | ||
private _requestData; | ||
private readonly _requestData; | ||
/** | ||
@@ -20,0 +20,0 @@ * Converts a Request object to a plain object that can be structured |
@@ -29,2 +29,33 @@ /* | ||
/** | ||
* Accepts an object of request data that can be used to construct a | ||
* `Request` but can also be stored in IndexedDB. | ||
* | ||
* @param {Object} requestData An object of request data that includes the | ||
* `url` plus any relevant properties of | ||
* [requestInit]{@link https://fetch.spec.whatwg.org/#requestinit}. | ||
* @private | ||
*/ | ||
constructor(requestData) { | ||
if (process.env.NODE_ENV !== 'production') { | ||
assert.isType(requestData, 'object', { | ||
moduleName: 'workbox-background-sync', | ||
className: 'StorableRequest', | ||
funcName: 'constructor', | ||
paramName: 'requestData', | ||
}); | ||
assert.isType(requestData.url, 'string', { | ||
moduleName: 'workbox-background-sync', | ||
className: 'StorableRequest', | ||
funcName: 'constructor', | ||
paramName: 'requestData.url', | ||
}); | ||
} | ||
// If the request's mode is `navigate`, convert it to `same-origin` since | ||
// navigation requests can't be constructed via script. | ||
if (requestData['mode'] === 'navigate') { | ||
requestData['mode'] = 'same-origin'; | ||
} | ||
this._requestData = requestData; | ||
} | ||
/** | ||
* Converts a Request object to a plain object that can be structured | ||
@@ -64,33 +95,2 @@ * cloned or JSON-stringified. | ||
/** | ||
* Accepts an object of request data that can be used to construct a | ||
* `Request` but can also be stored in IndexedDB. | ||
* | ||
* @param {Object} requestData An object of request data that includes the | ||
* `url` plus any relevant properties of | ||
* [requestInit]{@link https://fetch.spec.whatwg.org/#requestinit}. | ||
* @private | ||
*/ | ||
constructor(requestData) { | ||
if (process.env.NODE_ENV !== 'production') { | ||
assert.isType(requestData, 'object', { | ||
moduleName: 'workbox-background-sync', | ||
className: 'StorableRequest', | ||
funcName: 'constructor', | ||
paramName: 'requestData', | ||
}); | ||
assert.isType(requestData.url, 'string', { | ||
moduleName: 'workbox-background-sync', | ||
className: 'StorableRequest', | ||
funcName: 'constructor', | ||
paramName: 'requestData.url', | ||
}); | ||
} | ||
// If the request's mode is `navigate`, convert it to `same-origin` since | ||
// navigation requests can't be constructed via script. | ||
if (requestData['mode'] === 'navigate') { | ||
requestData['mode'] = 'same-origin'; | ||
} | ||
this._requestData = requestData; | ||
} | ||
/** | ||
* Returns a deep clone of the instances `_requestData` object. | ||
@@ -97,0 +97,0 @@ * |
{ | ||
"name": "workbox-background-sync", | ||
"version": "5.0.0", | ||
"version": "5.1.0", | ||
"license": "MIT", | ||
@@ -32,5 +32,5 @@ "author": "Google's Web DevRel Team", | ||
"dependencies": { | ||
"workbox-core": "^5.0.0" | ||
"workbox-core": "^5.1.0" | ||
}, | ||
"gitHead": "571ffded1872309a305f108a99a5a36982fde342" | ||
"gitHead": "2a6b84b892b5c404671b898e926bf37b65d261da" | ||
} |
@@ -6,3 +6,3 @@ import './_version.js'; | ||
interface OnSyncCallback { | ||
(options: OnSyncCallbackOptions): void; | ||
(options: OnSyncCallbackOptions): void | Promise<void>; | ||
} | ||
@@ -26,6 +26,6 @@ export interface QueueOptions { | ||
declare class Queue { | ||
private _name; | ||
private _onSync; | ||
private _maxRetentionTime; | ||
private _queueStore; | ||
private readonly _name; | ||
private readonly _onSync; | ||
private readonly _maxRetentionTime; | ||
private readonly _queueStore; | ||
private _syncInProgress; | ||
@@ -56,3 +56,3 @@ private _requestsAddedDuringSync; | ||
*/ | ||
readonly name: string; | ||
get name(): string; | ||
/** | ||
@@ -161,4 +161,4 @@ * Stores the passed request in IndexedDB (with its timestamp and any | ||
*/ | ||
static readonly _queueNames: Set<unknown>; | ||
static get _queueNames(): Set<unknown>; | ||
} | ||
export { Queue }; |
38
Queue.js
@@ -19,2 +19,21 @@ /* | ||
/** | ||
* Converts a QueueStore entry into the format exposed by Queue. This entails | ||
* converting the request data into a real request and omitting the `id` and | ||
* `queueName` properties. | ||
* | ||
* @param {Object} queueStoreEntry | ||
* @return {Object} | ||
* @private | ||
*/ | ||
const convertEntry = (queueStoreEntry) => { | ||
const queueEntry = { | ||
request: new StorableRequest(queueStoreEntry.requestData).toRequest(), | ||
timestamp: queueStoreEntry.timestamp, | ||
}; | ||
if (queueStoreEntry.metadata) { | ||
queueEntry.metadata = queueStoreEntry.metadata; | ||
} | ||
return queueEntry; | ||
}; | ||
/** | ||
* A class to manage storing failed requests in IndexedDB and retrying them | ||
@@ -348,21 +367,2 @@ * later. All parts of the storing and replaying process are observable via | ||
} | ||
/** | ||
* Converts a QueueStore entry into the format exposed by Queue. This entails | ||
* converting the request data into a real request and omitting the `id` and | ||
* `queueName` properties. | ||
* | ||
* @param {Object} queueStoreEntry | ||
* @return {Object} | ||
* @private | ||
*/ | ||
const convertEntry = (queueStoreEntry) => { | ||
const queueEntry = { | ||
request: new StorableRequest(queueStoreEntry.requestData).toRequest(), | ||
timestamp: queueStoreEntry.timestamp, | ||
}; | ||
if (queueStoreEntry.metadata) { | ||
queueEntry.metadata = queueStoreEntry.metadata; | ||
} | ||
return queueEntry; | ||
}; | ||
export { Queue }; |
// @ts-ignore | ||
try{self['workbox:background-sync:5.0.0']&&_()}catch(e){} | ||
try{self['workbox:background-sync:5.1.0']&&_()}catch(e){} |
@@ -20,3 +20,3 @@ /* | ||
class BackgroundSyncPlugin implements WorkboxPlugin { | ||
private _queue: Queue; | ||
private readonly _queue: Queue; | ||
@@ -23,0 +23,0 @@ /** |
@@ -39,4 +39,4 @@ /* | ||
export class QueueStore { | ||
private _queueName: string; | ||
private _db: DBWrapper; | ||
private readonly _queueName: string; | ||
private readonly _db: DBWrapper; | ||
@@ -207,3 +207,3 @@ /** | ||
private _upgradeDb(event: IDBVersionChangeEvent) { | ||
const db = (<IDBOpenDBRequest> event.target).result; | ||
const db = (event.target as IDBOpenDBRequest).result; | ||
@@ -210,0 +210,0 @@ if (event.oldVersion > 0 && event.oldVersion < DB_VERSION) { |
@@ -43,3 +43,3 @@ /* | ||
class StorableRequest { | ||
private _requestData: RequestData; | ||
private readonly _requestData: RequestData; | ||
@@ -46,0 +46,0 @@ /** |
@@ -19,3 +19,3 @@ /* | ||
// Give TypeScript the correct global. | ||
declare var self: ServiceWorkerGlobalScope; | ||
declare let self: ServiceWorkerGlobalScope; | ||
@@ -27,3 +27,3 @@ interface OnSyncCallbackOptions { | ||
interface OnSyncCallback { | ||
(options: OnSyncCallbackOptions): void; | ||
(options: OnSyncCallbackOptions): void|Promise<void>; | ||
} | ||
@@ -48,2 +48,22 @@ | ||
/** | ||
* Converts a QueueStore entry into the format exposed by Queue. This entails | ||
* converting the request data into a real request and omitting the `id` and | ||
* `queueName` properties. | ||
* | ||
* @param {Object} queueStoreEntry | ||
* @return {Object} | ||
* @private | ||
*/ | ||
const convertEntry = (queueStoreEntry: UnidentifiedQueueStoreEntry): QueueEntry => { | ||
const queueEntry: QueueEntry = { | ||
request: new StorableRequest(queueStoreEntry.requestData).toRequest(), | ||
timestamp: queueStoreEntry.timestamp, | ||
}; | ||
if (queueStoreEntry.metadata) { | ||
queueEntry.metadata = queueStoreEntry.metadata; | ||
} | ||
return queueEntry; | ||
}; | ||
/** | ||
* A class to manage storing failed requests in IndexedDB and retrying them | ||
@@ -56,8 +76,8 @@ * later. All parts of the storing and replaying process are observable via | ||
class Queue { | ||
private _name: string; | ||
private _onSync: OnSyncCallback; | ||
private _maxRetentionTime: number; | ||
private _queueStore: QueueStore; | ||
private _syncInProgress: boolean = false; | ||
private _requestsAddedDuringSync: boolean = false; | ||
private readonly _name: string; | ||
private readonly _onSync: OnSyncCallback; | ||
private readonly _maxRetentionTime: number; | ||
private readonly _queueStore: QueueStore; | ||
private _syncInProgress = false; | ||
private _requestsAddedDuringSync = false; | ||
@@ -416,23 +436,2 @@ /** | ||
/** | ||
* Converts a QueueStore entry into the format exposed by Queue. This entails | ||
* converting the request data into a real request and omitting the `id` and | ||
* `queueName` properties. | ||
* | ||
* @param {Object} queueStoreEntry | ||
* @return {Object} | ||
* @private | ||
*/ | ||
const convertEntry = (queueStoreEntry: UnidentifiedQueueStoreEntry): QueueEntry => { | ||
const queueEntry: QueueEntry = { | ||
request: new StorableRequest(queueStoreEntry.requestData).toRequest(), | ||
timestamp: queueStoreEntry.timestamp, | ||
}; | ||
if (queueStoreEntry.metadata) { | ||
queueEntry.metadata = queueStoreEntry.metadata; | ||
} | ||
return queueEntry; | ||
}; | ||
export {Queue}; |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Unidentified License
License(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.
Found 3 instances in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Unidentified License
License(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.
Found 1 instance in 1 package
261553
5
Updatedworkbox-core@^5.1.0