Work on detailed list.

Author: Eddie Flores

lib/ssh-adapter.js

@@ -24,7 +24,32 @@ module.exports = CoreObject.extend({
   },
 
   list: function() {
-    return this._list().then(this._printRevisions.bind(this));
+    var _this = this;
+    return new Promise(function (resolve, reject) {
+      _this._list().then(function (list) {
+        console.log('Got this list ');
+        _this._printRevisions(list).then(function () {
+          console.log('Print revisions ended');
+        });
+      }, function (error) {
+        console.error('Got this error ', error);
+        reject(error);
+      });
+
+      // return this._list().then(this._printRevisions.bind(this));
+
+      // var listPromise = _this._list();
+
+      // listPromise.then(function (list) {
+      //   var printRevisions = _this._printRevisions(list);
+      //   printRevisions.then(function (data) {
+      //     console.log('Print revisions resolved');
+      //     resolve(data);
+      //   }, function (error) {
+      //     reject(error);
+      //   })
+      // });
+    });
   },
 
   upload: function(buffer) {
@@ -85,12 +110,14 @@ module.exports = CoreObject.extend({
     };
 
     var startFind = function (resolve, reject) {
+
       conn.on('ready', function () {
         findRevisions(function (error, list) {
           if (error) {
             return reject(error);
           }
           resolve(list);
+          conn.end();
         });
       });
 
@@ -275,14 +302,115 @@ module.exports = CoreObject.extend({
 
     return new Promise(startUpload);
   },
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
 
   _printRevisions: function(list) {
     var header = 'Found the following revisions:';
+    var remoteDir = this.config.remoteDir;
+    var _this = this;
+    var config = this.config;
+    var conn = this.client;
+    var filePromises = [];
+
     var revisionsList = list.join('\n');
     // TODO: Print the details for each revisions (found in meta).
-    return this._printSuccessMessage('\n' + header + '\n\n' + revisionsList + '\n');
+    // return this._printSuccessMessage('\n' + header + '\n\n' + revisionsList + '\n');
+    return new Promise(function (resolve, reject) {
+
+      /**
+       * Reads a remote file. Returns a promise.
+       */
+      var readFile = function (metaPath, sftp, options) {
+
+        var promiseHandler = function (fileResolve, fileReject) {
+          sftp.readFile(metaPath, options, function (error, data) {
+            if (error) {
+              fileReject(error);
+              return;
+            }
+            console.log('Got this data ', data);
+            fileResolve({filename: metaPath, data: data});
+          });
+        };
+        return new Promise(promiseHandler);
+      };
+
+      conn.on('ready', function () {
+
+        conn.sftp(function (error, sftp) {
+
+          list.forEach(function (revisionId) {
+            var metaPath = remoteDir + revisionId + '/meta.json';
+            filePromises.push(readFile(metaPath, sftp));
+          });
+
+          Promise.all(filePromises).then(function (data) {
+            console.log('Got those files')
+            resolve(data);
+          }, function (error) {
+            console.error('Got an error with those files ', error);
+            reject(error);
+          });
+
+        }); // conn.sftp
+      });
+
+      conn.on('error', function (error) {
+        console.error('A connection error');
+        reject(error);
+      });
+
+      conn.connect({
+        host: config.host,
+        username: config.username,
+        privateKey: require('fs').readFileSync(config.privateKeyFile),
+      });
+
+    });
   },
 
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
   _printSuccessMessage: function (message) {
     return this.ui.writeLine(message);
   },