Implement the upload method.

Author: Eddie Flores

lib/ssh-adapter.js

@@ -138,11 +138,115 @@ var list = function () {
   });
 };
 
+var createDirectory = function (conn, revisionDir) {
+  return new Promise(function (resolve, reject) {
+    conn.exec('mkdir ' + revisionDir, function (error, mkdirStream) {
+      if (error) {
+        reject(error);
+        return;
+      }
+      mkdirStream.on('error', reject);
+      mkdirStream.on('close', resolve);
+    });
+  });
+};
+
+var uploadIndex = function (sftp, indexPath, indexBuffer) {
+  return new Promise(function (resolve, reject){
+    var stream = sftp.createWriteStream(indexPath);
+    stream.on('error', reject);
+    stream.on('end', reject);
+    stream.on('close', resolve);
+
+    stream.write(indexBuffer);
+    stream.end();
+  });
+};
+var uploadMeta = function (sftp, metaPath, metaBuffer) {
+  return new Promise(function (resolve, reject){
+    var stream = sftp.createWriteStream(metaPath);
+    stream.on('error', reject);
+    stream.on('end', reject);
+    stream.on('close', resolve);
+
+    stream.write(metaBuffer);
+    stream.end();
+  });
+};
+
+var uploadRevisionFiles = function (conn, revisionId, indexContents, metaContents) {
+  var _this = this,
+      revisionDir = _this.config.remoteDir + revisionId,
+      indexPath = revisionDir + '/index.html',
+      metaPath = revisionDir + '/meta.json';
+
+  return new Promise(function (resolve, reject) {
+    conn.sftp(function (err, sftp) {
+
+      if (err) {
+        reject(err);
+        return;
+      }
+
+      Promise.all([
+        uploadIndex(sftp, indexPath, indexContents),
+        uploadMeta(sftp,  metaPath, metaContents)
+      ]).then(resolve, reject);
+
+    });
+  });
+
+};
+
 /**
  * Upload the latest revision.
  */
-var upload = function () {
-  console.log('Upload will be implemented');
+var upload = function (indexBuffer) {
+
+  var _this = this;
+  return new Promise(function (resolve, reject) {
+
+    var syncExec = _this.syncExec || require('sync-exec'),
+        commandResult = syncExec("git log -n 1 --pretty=format:'{%n  \"commit\": \"%H\",%n  \"author\": \"%an <%ae>\",%n  \"date\": \"%ad\",%n  \"message\": \"%f\"%n},'     $@ |     perl -pe 'BEGIN{print \"[\"}; END{print \"]\n\"}' |     perl -pe 's/},]/}]/'").stdout,
+        commandResultJSON = JSON.parse(commandResult),
+        shortCommitId = commandResultJSON[0].commit.slice(0, 7),
+        commitMessage = commandResultJSON[0].message,
+        conn = _this.conn,
+        config = _this.config,
+        revisionDir = config.remoteDir + shortCommitId,
+        host = config.host,
+        username = config.username;
+
+
+    conn.on('ready', function () {
+      console.log('+- Connected.');
+      var creatingDir = createDirectory(conn, revisionDir);
+      creatingDir.then(function () {
+
+        console.log('+- Created directory at ' + revisionDir + '.');
+
+        var uploadingFiles = uploadRevisionFiles.call(_this, conn, shortCommitId, indexBuffer, commandResult);
+
+        uploadingFiles.then(function (){
+          console.log('+- Uploaded revision ' + shortCommitId + ': "' + commitMessage.replace(/-/g, ' ') + '".\n');
+          resolve();
+        }, function(err) {
+          console.log('x- Uploaded nothing - error: ', err + '\n');
+          reject(err);
+        });
+
+      }, reject);
+    });
+
+    conn.on('error', reject);
+
+    conn.connect({
+      host: host,
+      username: username,
+      privateKey: require('fs').readFileSync(config.privateKeyFile)
+    });
+
+  });
 };
 
 /**