feat(read-chunk): module to read data from stream

@vates/read-chunk/README.md

@@ -0,0 +1,44 @@
+<!-- DO NOT EDIT MANUALLY, THIS FILE HAS BEEN GENERATED -->
+
+# @vates/read-chunk [![Build Status](https://travis-ci.org/vatesfr/xen-orchestra.png?branch=master)](https://travis-ci.org/vatesfr/xen-orchestra)
+
+> Read a chunk of a Node stream
+
+## Install
+
+Installation of the [npm package](https://npmjs.org/package/@vates/read-chunk):
+
+```
+> npm install --save @vates/read-chunk
+```
+
+## Usage
+
+- returns the next available chunk of data
+- like `stream.read()`, a number of bytes can be specified
+- returns `null` if the stream has ended
+
+```js
+import { readChunk } from '@xen-orchestra/read-chunk'
+;(async () => {
+  let chunk
+  while ((chunk = await readChunk(stream, 1024)) !== null) {
+    // do something with chunk
+  }
+})()
+```
+
+## Contributions
+
+Contributions are _very_ welcomed, either on the documentation or on
+the code.
+
+You may:
+
+- report any [issue](https://github.com/vatesfr/xen-orchestra/issues)
+  you've encountered;
+- fork and create a pull request.
+
+## License
+
+ISC © [Vates SAS](https://vates.fr)

@vates/read-chunk/USAGE.md

@@ -0,0 +1,13 @@
+- returns the next available chunk of data
+- like `stream.read()`, a number of bytes can be specified
+- returns `null` if the stream has ended
+
+```js
+import { readChunk } from '@xen-orchestra/read-chunk'
+;(async () => {
+  let chunk
+  while ((chunk = await readChunk(stream, 1024)) !== null) {
+    // do something with chunk
+  }
+})()
+```

@vates/read-chunk/index.js

@@ -0,0 +1,27 @@
+export const readChunk = (stream, size) =>
+  new Promise((resolve, reject) => {
+    function onEnd() {
+      resolve(null)
+      removeListeners()
+    }
+    function onError(error) {
+      reject(error)
+      removeListeners()
+    }
+    function onReadable() {
+      const data = stream.read(size)
+      if (data !== null) {
+        resolve(data)
+        removeListeners()
+      }
+    }
+    function removeListeners() {
+      stream.removeListener('end', onEnd)
+      stream.removeListener('error', onError)
+      stream.removeListener('readable', onReadable)
+    }
+    stream.on('end', onEnd)
+    stream.on('error', onError)
+    stream.on('readable', onReadable)
+    onReadable()
+  })

@vates/read-chunk/package.json

@@ -0,0 +1,29 @@
+{
+  "private": false,
+  "name": "@vates/read-chunk",
+  "homepage": "https://github.com/vatesfr/xen-orchestra/tree/master/@vates/read-chunk",
+  "description": "Read a chunk of a Node stream",
+  "license": "ISC",
+  "keywords": [
+    "async",
+    "chunk",
+    "data",
+    "node",
+    "promise",
+    "read",
+    "stream"
+  ],
+  "bugs": "https://github.com/vatesfr/xen-orchestra/issues",
+  "repository": {
+    "directory": "@vates/read-chunk",
+    "type": "git",
+    "url": "https://github.com/vatesfr/xen-orchestra.git"
+  },
+  "version": "0.0.0",
+  "engines": {
+    "node": ">=8.10"
+  },
+  "scripts": {
+    "postversion": "npm publish --access public"
+  }
+}

scripts/utils.js

@@ -17,21 +17,23 @@ const _getPackages = scope => {
 }
 
 exports.getPackages = (readPackageJson = false) => {
-  const p = Promise.all([_getPackages(), _getPackages('@xen-orchestra')]).then(
+  const p = Promise.all([
-    pkgs => {
+    _getPackages(),
-      pkgs = [].concat(...pkgs) // flatten
+    _getPackages('@vates'),
-      return readPackageJson
+    _getPackages('@xen-orchestra'),
-        ? Promise.all(
+  ]).then(pkgs => {
-            pkgs.map(pkg =>
+    pkgs = [].concat(...pkgs) // flatten
-              readFile(`${pkg.dir}/package.json`).then(data => {
+    return readPackageJson
-                pkg.package = JSON.parse(data)
+      ? Promise.all(
-                return pkg
+          pkgs.map(pkg =>
-              }, noop)
+            readFile(`${pkg.dir}/package.json`).then(data => {
-            )
+              pkg.package = JSON.parse(data)
-          ).then(pkgs => pkgs.filter(pkg => pkg !== undefined))
+              return pkg
-        : pkgs
+            }, noop)
-    }
+          )
-  )
+        ).then(pkgs => pkgs.filter(pkg => pkg !== undefined))
+      : pkgs
+  })
   p.forEach = fn => p.then(pkgs => forEach.call(pkgs, fn))
   p.map = fn => p.then(pkgs => Promise.all(pkgs.map(fn))).then(noop)
   return p