req-then - npm Package Compare versions

Comparing version 0.6.2 to 0.6.3

index.js

@@ -70,14 +70,26 @@ 'use strict'
   const req = transport.request(reqOptions, function (res) {
-    const streamReadAll = require('stream-read-all')
-    streamReadAll(res).then(data => {
-      /* statusCode will be zero if the request was disconnected, so don't resolve */
-      if (res.statusCode !== 0) {
-        const pick = require('lodash.pick')
-        deferred.resolve({
-          data: data,
-          res: pick(res, [ 'headers', 'method', 'statusCode', 'statusMessage', 'url' ]),
-          req: reqOptions
-        })
+    const pick = require('lodash.pick')
+    if (/text\/event-stream/.test(res.headers['content-type'])) {
+      const util = require('util')
+      res[util.inspect.custom] = function (depth, options) {
+        return options.stylize('[ SSE event-stream ]', 'special')
       }
-    })
+      deferred.resolve({
+        data: res,
+        res: pick(res, [ 'headers', 'method', 'statusCode', 'statusMessage', 'url' ]),
+        req: reqOptions
+      })
+    } else {
+      const streamReadAll = require('stream-read-all')
+      streamReadAll(res).then(data => {
+        /* statusCode will be zero if the request was disconnected, so don't resolve */
+        if (res.statusCode !== 0) {
+          deferred.resolve({
+            data: res,
+            res: pick(res, [ 'headers', 'method', 'statusCode', 'statusMessage', 'url' ]),
+            req: reqOptions
+          })
+        }
+      })
+    }
   })
@@ -84,0 +96,0 @@

package.json

 {
   "name": "req-then",
   "author": "Lloyd Brookes <[e-mail]>",
-  "version": "0.6.2",
+  "version": "0.6.3",
   "description": "Simple http(s) request function, returning a promise. ",
@@ -28,3 +28,3 @@ "repository": "https://github.com/75lb/req-then",
   "dependencies": {
-    "array-back": "^1.0.4",
+    "array-back": "^2.0.0",
     "defer-promise": "^1.0.1",
@@ -31,0 +31,0 @@ "lodash.pick": "^4.4.0",

test.js

@@ -64,1 +64,8 @@ 'use strict'
 })
+
+runner.skip('SSE stream', function () {
+  return request('http://127.0.0.1:8000/sse')
+    .then(response => {
+      console.error(require('util').inspect(response, { depth: 6, colors: true }))
+    })
+})

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

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

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

108108

increased by0.8%

Lines of code

586

increased by3.17%

Number of medium supply chain risk alerts

2

decreased by-33.33%

Dependency changes

• + Addedarray-back@2.0.0(transitive)

• - Removedarray-back@1.0.4(transitive)

• Updatedarray-back@^2.0.0