workbox-streams - npm Package Compare versions

Comparing version 6.3.0 to 6.4.0

_version.js

 "use strict";
 // @ts-ignore
 try {
-    self['workbox:streams:6.2.4'] && _();
+    self['workbox:streams:6.3.0'] && _();
 }
 catch (e) { }

build/workbox-streams.dev.js

@@ -6,3 +6,3 @@ this.workbox = this.workbox || {};
     try {
-      self['workbox:streams:6.2.4'] && _();
+      self['workbox:streams:6.3.0'] && _();
     } catch (e) {}
@@ -9,0 +9,0 @@

build/workbox-streams.prod.js

@@ -1,2 +0,2 @@
-this.workbox=this.workbox||{},this.workbox.streams=function(e,n,t){"use strict";try{self["workbox:streams:6.2.4"]&&_()}catch(e){}function s(e){const t=e.map((e=>Promise.resolve(e).then((e=>function(e){return e instanceof Response?e.body.getReader():e instanceof ReadableStream?e.getReader():new Response(e).body.getReader()}(e))))),s=new n.Deferred;let r=0;const o=new ReadableStream({pull(e){return t[r].then((e=>e.read())).then((n=>{if(n.done)return r++,r>=t.length?(e.close(),void s.resolve()):this.pull(e);e.enqueue(n.value)})).catch((e=>{throw s.reject(e),e}))},cancel(){s.resolve()}});return{done:s.promise,stream:o}}function r(e={}){const n=new Headers(e);return n.has("content-type")||n.set("content-type","text/html"),n}function o(e,n){const{done:t,stream:o}=s(e),c=r(n);return{done:t,response:new Response(o,{headers:c})}}function c(){return t.canConstructReadableStream()}return e.concatenate=s,e.concatenateToResponse=o,e.isSupported=c,e.strategy=function(e,n){return async({event:t,request:s,url:a,params:u})=>{const i=e.map((e=>Promise.resolve(e({event:t,request:s,url:a,params:u}))));if(c()){const{done:e,response:s}=o(i,n);return t&&t.waitUntil(e),s}const f=i.map((async e=>{const n=await e;return n instanceof Response?n.blob():new Response(n).blob()})),p=await Promise.all(f),w=r(n);return new Response(new Blob(p),{headers:w})}},e}({},workbox.core._private,workbox.core._private);
+this.workbox=this.workbox||{},this.workbox.streams=function(e,n,t){"use strict";try{self["workbox:streams:6.3.0"]&&_()}catch(e){}function s(e){const t=e.map((e=>Promise.resolve(e).then((e=>function(e){return e instanceof Response?e.body.getReader():e instanceof ReadableStream?e.getReader():new Response(e).body.getReader()}(e))))),s=new n.Deferred;let r=0;const o=new ReadableStream({pull(e){return t[r].then((e=>e.read())).then((n=>{if(n.done)return r++,r>=t.length?(e.close(),void s.resolve()):this.pull(e);e.enqueue(n.value)})).catch((e=>{throw s.reject(e),e}))},cancel(){s.resolve()}});return{done:s.promise,stream:o}}function r(e={}){const n=new Headers(e);return n.has("content-type")||n.set("content-type","text/html"),n}function o(e,n){const{done:t,stream:o}=s(e),c=r(n);return{done:t,response:new Response(o,{headers:c})}}function c(){return t.canConstructReadableStream()}return e.concatenate=s,e.concatenateToResponse=o,e.isSupported=c,e.strategy=function(e,n){return async({event:t,request:s,url:a,params:u})=>{const i=e.map((e=>Promise.resolve(e({event:t,request:s,url:a,params:u}))));if(c()){const{done:e,response:s}=o(i,n);return t&&t.waitUntil(e),s}const f=i.map((async e=>{const n=await e;return n instanceof Response?n.blob():new Response(n).blob()})),p=await Promise.all(f),w=r(n);return new Response(new Blob(p),{headers:w})}},e}({},workbox.core._private,workbox.core._private);
 //# sourceMappingURL=workbox-streams.prod.js.map

concatenate.js

@@ -66,4 +66,6 @@ /*
                     if (process.env.NODE_ENV !== 'production') {
-                        logMessages.push(['Reached the end of source:',
-                            sourcePromises[i]]);
+                        logMessages.push([
+                            'Reached the end of source:',
+                            sourcePromises[i],
+                        ]);
                     }
@@ -96,3 +98,4 @@ i++;
                 }
-            }).catch((error) => {
+            })
+                .catch((error) => {
                 if (process.env.NODE_ENV !== 'production') {
@@ -99,0 +102,0 @@ logger.error('An error occurred:', error);

index.d.ts

@@ -9,2 +9,3 @@ import { concatenate } from './concatenate.js';
  */
-export { concatenate, concatenateToResponse, isSupported, strategy, };
+export { concatenate, concatenateToResponse, isSupported, strategy };
+export * from './_types.js';

index.js

@@ -16,2 +16,3 @@ /*
  */
-export { concatenate, concatenateToResponse, isSupported, strategy, };
+export { concatenate, concatenateToResponse, isSupported, strategy };
+export * from './_types.js';

package.json

 {
   "name": "workbox-streams",
-  "version": "6.3.0",
+  "version": "6.4.0",
   "license": "MIT",
@@ -26,6 +26,6 @@ "author": "Google's Web DevRel Team",
   "dependencies": {
-    "workbox-core": "6.3.0",
-    "workbox-routing": "6.3.0"
+    "workbox-core": "6.4.0",
+    "workbox-routing": "6.4.0"
   },
-  "gitHead": "03055e64014a46f6cc977a3a50ad814c6409d36a"
+  "gitHead": "cdad230c678a3626c217615d5792eb0f1c77194c"
 }

src/_types.ts

@@ -11,3 +11,2 @@ /*
 
-
 export type StreamSource = Response | ReadableStream | BodyInit;
@@ -14,0 +13,0 @@

src/_version.ts

 // @ts-ignore
-try{self['workbox:streams:6.3.0']&&_()}catch(e){}
+try{self['workbox:streams:6.4.0']&&_()}catch(e){}

src/concatenate.ts

@@ -24,3 +24,5 @@ /*
  */
-function _getReaderFromSource(source: StreamSource): ReadableStreamReader {
+function _getReaderFromSource(
+  source: StreamSource,
+): ReadableStreamReader<unknown> {
   if (source instanceof Response) {
@@ -73,44 +75,48 @@ return source.body!.getReader();
       return readerPromises[i]
-          .then((reader) => reader.read())
-          .then((result) => {
-            if (result.done) {
-              if (process.env.NODE_ENV !== 'production') {
-                logMessages.push(['Reached the end of source:',
-                  sourcePromises[i]]);
-              }
+        .then((reader) => reader.read())
+        .then((result) => {
+          if (result.done) {
+            if (process.env.NODE_ENV !== 'production') {
+              logMessages.push([
+                'Reached the end of source:',
+                sourcePromises[i],
+              ]);
+            }
 
-              i++;
-              if (i >= readerPromises.length) {
+            i++;
+            if (i >= readerPromises.length) {
               // Log all the messages in the group at once in a single group.
-                if (process.env.NODE_ENV !== 'production') {
-                  logger.groupCollapsed(
-                      `Concatenating ${readerPromises.length} sources.`);
-                  for (const message of logMessages) {
-                    if (Array.isArray(message)) {
-                      logger.log(...message);
-                    } else {
-                      logger.log(message);
-                    }
+              if (process.env.NODE_ENV !== 'production') {
+                logger.groupCollapsed(
+                  `Concatenating ${readerPromises.length} sources.`,
+                );
+                for (const message of logMessages) {
+                  if (Array.isArray(message)) {
+                    logger.log(...message);
+                  } else {
+                    logger.log(message);
                   }
-                  logger.log('Finished reading all sources.');
-                  logger.groupEnd();
                 }
-
-                controller.close();
-                streamDeferred.resolve();
-                return;
+                logger.log('Finished reading all sources.');
+                logger.groupEnd();
               }
 
-              // The `pull` method is defined because we're inside it.
-              return this.pull!(controller);
-            } else {
-              controller.enqueue(result.value);
+              controller.close();
+              streamDeferred.resolve();
+              return;
             }
-          }).catch((error) => {
-            if (process.env.NODE_ENV !== 'production') {
-              logger.error('An error occurred:', error);
-            }
-            streamDeferred.reject(error);
-            throw error;
-          });
+
+            // The `pull` method is defined because we're inside it.
+            return this.pull!(controller);
+          } else {
+            controller.enqueue(result.value);
+          }
+        })
+        .catch((error) => {
+          if (process.env.NODE_ENV !== 'production') {
+            logger.error('An error occurred:', error);
+          }
+          streamDeferred.reject(error);
+          throw error;
+        });
     },
@@ -117,0 +123,0 @@

src/concatenateToResponse.ts

@@ -14,3 +14,2 @@ /*
 
-
 /**
@@ -34,4 +33,5 @@ * Takes multiple source Promises, each of which could resolve to a Response, a
 function concatenateToResponse(
-    sourcePromises: Promise<StreamSource>[],
-    headersInit: HeadersInit): {done: Promise<void>; response: Response} {
+  sourcePromises: Promise<StreamSource>[],
+  headersInit: HeadersInit,
+): {done: Promise<void>; response: Response} {
   const {done, stream} = concatenate(sourcePromises);
@@ -38,0 +38,0 @@

src/index.ts

@@ -15,3 +15,2 @@ /*
 
-
 /**
@@ -21,7 +20,4 @@ * @module workbox-streams
 
-export {
-  concatenate,
-  concatenateToResponse,
-  isSupported,
-  strategy,
-};
+export {concatenate, concatenateToResponse, isSupported, strategy};
+
+export * from './_types.js';

src/isSupported.ts

@@ -12,3 +12,2 @@ /*
 
-
 /**
@@ -29,2 +28,2 @@ * This is a utility method that determines whether the current browser supports
 
-export {isSupported}
+export {isSupported};

src/strategy.ts

@@ -10,3 +10,6 @@ /*
 import {logger} from 'workbox-core/_private/logger.js';
-import {RouteHandlerCallback, RouteHandlerCallbackOptions} from 'workbox-core/types.js';
+import {
+  RouteHandlerCallback,
+  RouteHandlerCallbackOptions,
+} from 'workbox-core/types.js';
 import {createHeaders} from './utils/createHeaders.js';
@@ -18,5 +21,6 @@ import {concatenateToResponse} from './concatenateToResponse.js';
 
-
 interface StreamsHandlerCallback {
-  ({url, request, event, params}: RouteHandlerCallbackOptions): Promise<StreamSource> | StreamSource;
+  ({url, request, event, params}: RouteHandlerCallbackOptions):
+    | Promise<StreamSource>
+    | StreamSource;
 }
@@ -51,4 +55,6 @@
     if (isSupported()) {
-      const {done, response} =
-          concatenateToResponse(sourcePromises, headersInit);
+      const {done, response} = concatenateToResponse(
+        sourcePromises,
+        headersInit,
+      );
 
@@ -62,4 +68,6 @@ if (event) {
     if (process.env.NODE_ENV !== 'production') {
-      logger.log(`The current browser doesn't support creating response ` +
-        `streams. Falling back to non-streaming response instead.`);
+      logger.log(
+        `The current browser doesn't support creating response ` +
+          `streams. Falling back to non-streaming response instead.`,
+      );
     }
@@ -90,2 +98,2 @@
 
-export {strategy}
+export {strategy};

tsconfig.json

@@ -8,8 +8,4 @@ {
   },
-  "include": [
-    "src/**/*.ts"
-  ],
-  "references": [
-    { "path": "../workbox-core/" }
-  ]
+  "include": ["src/**/*.ts"],
+  "references": [{"path": "../workbox-core/"}]
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Mixed license

License

(Experimental) Package contains multiple licenses.

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 6 instances in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Lines of code

1040

increased by1.27%

Worsened metrics

Total package byte prevSize

96720

decreased by-46.14%

Number of low license alerts

7

increased byInfinity%

License quality

60

decreased by-40%

Dependency changes

• + Addedworkbox-core@6.4.0(transitive)

• + Addedworkbox-routing@6.4.0(transitive)

• - Removedworkbox-core@6.3.0(transitive)

• - Removedworkbox-routing@6.3.0(transitive)

• Updatedworkbox-core@6.4.0

• Updatedworkbox-routing@6.4.0