#48: Support pinning files to cache [partial]

src/helpers.js

@@ -840,6 +840,89 @@ module.exports.grabSkynetFileTree = version => {
   });
 };
 
+module.exports.grabDirectoryItems = (path, version, provider, remote, s3) => {
+  return new Promise((resolve, reject) => {
+    const repertoryExec = _getRepertoryExec(version);
+    const processOptions = {
+      cwd: repertoryExec.working,
+      detached: true,
+      shell: false,
+      windowsHide: true,
+    };
+
+    const args = _getDefaultRepertoryArgs(provider, remote, s3);
+    args.push('-gdi');
+    args.push(path);
+
+    let result = '';
+    const process = new spawn(repertoryExec.cmd, args, processOptions);
+
+    process.on('error', (err) => {
+      reject(err);
+    });
+
+    process.stdout.on('data', (d) => {
+      result += d;
+    });
+
+    process.stderr.on('data', (d) => {
+      result += d;
+    });
+
+    process.on('exit', code => {
+      if (code === 0) {
+        result = result.substr(result.indexOf('{'));
+        resolve(JSON.parse(result));
+      } else {
+        reject(new Error('Failed to import: ' + code + ':' + result));
+      }
+    });
+
+    process.unref();
+  });
+};
+
+module.exports.setPinned = (path, pinned, version, provider, remote, s3) => {
+  return new Promise((resolve, reject) => {
+    const repertoryExec = _getRepertoryExec(version);
+    const processOptions = {
+      cwd: repertoryExec.working,
+      detached: true,
+      shell: false,
+      windowsHide: true,
+    };
+
+    const args = _getDefaultRepertoryArgs(provider, remote, s3);
+    args.push(pinned ? '-pf' : '-uf');
+    args.push(path);
+
+    let result = '';
+    const process = new spawn(repertoryExec.cmd, args, processOptions);
+
+    process.on('error', (err) => {
+      reject(err);
+    });
+
+    process.stdout.on('data', (d) => {
+      result += d;
+    });
+
+    process.stderr.on('data', (d) => {
+      result += d;
+    });
+
+    process.on('exit', code => {
+      if (code === 0) {
+        resolve(JSON.parse(result).success);
+      } else {
+        reject(new Error('Failed to import: ' + code + ':' + result));
+      }
+    });
+
+    process.unref();
+  });
+};
+
 module.exports.importSkylinks = (version, jsonArray) => {
   return new Promise((resolve, reject) => {
     const repertoryExec = _getRepertoryExec(version);