Updated package installation stream handling (#28)

Author: andersevenrud

src/packages.js

@@ -98,11 +98,11 @@ class Packages {
    * Loads all packages
    * @return {Promise<Package[]>}
    */
-  createLoader() {
+  async createLoader() {
     let result = [];
     const {discoveredFile, manifestFile} = this.options;
-    const discovered = readOrDefault(discoveredFile);
-    const manifest = readOrDefault(manifestFile);
+    const discovered = await readOrDefault(discoveredFile);
+    const manifest = await readOrDefault(manifestFile);
     const sources = discovered.map(d => path.join(d, 'metadata.json'));
 
     logger.info('Using package discovery file', relative(discoveredFile));
@@ -204,6 +204,7 @@ class Packages {
     const target = await realpath(`${userRoot}/${name}`, user);
 
     if (await fs.exists(target)) {
+      // FIXME: Secure this
       await fs.remove(target);
       await this.writeUserManifest(userRoot, user);
     } else {
@@ -226,7 +227,7 @@ class Packages {
     // TODO: Check conflicts ?
     const root = await realpath(userRoot, user);
     const manifest = await realpath(`${userRoot}/metadata.json`, user);
-    const filenames = await fg(root + '/*/metadata.json'); // FIXME: Windows!
+    const filenames = await fg(root.replace(/\\/g, '/') + '/*/metadata.json');
     const metadatas = await Promise.all(filenames.map(f => fs.readJson(f)));
 
     await fs.writeJson(manifest, metadatas);

src/utils/packages.js

@@ -44,14 +44,14 @@ const fetchSteam = (url, options) => bent()(url, null, {
   headers: options.headers || {}
 });
 
-const readOrDefault = filename => fs.existsSync(filename)
-  ? fs.readJsonSync(filename)
-  : [];
+const readOrDefault = async (filename) => await fs.exists(filename)
+  ? fs.readJson(filename)
+  : Promise.resolve([]);
 
 const extract = (stream, target) => new Promise((resolve, reject) => {
-  stream.once('end', () => resolve());
-  stream.once('error', error => reject(error));
-  stream.pipe(tar.extract({C: target}));
+  const s = stream.pipe(tar.extract({C: target}));
+  s.once('end', () => resolve());
+  s.once('error', error => reject(error));
 });
 
 module.exports = {