From 9d6860b5ed8d77490e1c679e9be626775b101298 Mon Sep 17 00:00:00 2001
From: Stefan Andres Charsley <charsleysa@gmail.com>
Date: Thu, 8 Dec 2016 12:11:04 +1300
Subject: [PATCH 1/2] - Added upload buffer

---
 lib/index.js | 73 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 73 insertions(+)

diff --git a/lib/index.js b/lib/index.js
index 526f5f1..d477577 100644
--- a/lib/index.js
+++ b/lib/index.js
@@ -422,6 +422,79 @@ Client.prototype.uploadFile = function(params) {
   }
 };
 
+Client.prototype.uploadBuffer = function(params) {
+  var self = this;
+  var uploader = new EventEmitter();
+  uploader.progressAmount = 0;
+  uploader.progressTotal = 0;
+  uploader.abort = handleAbort;
+  uploader.getPublicUrl = function() {
+    return getPublicUrl(s3Params.Bucket, s3Params.Key, self.s3.config.region, self.s3.config.endpoint);
+  }
+  uploader.getPublicUrlHttp = function() {
+    return getPublicUrlHttp(s3Params.Bucket, s3Params.Key, self.s3.config.endpoint);
+  }
+
+  var buffer = params.buffer;
+  uploader.progressTotal = buffer.length;
+  var s3Params = extend({}, params.s3Params);
+  if (s3Params.ContentType === undefined) {
+    s3Params.ContentType = params.defaultContentType || 'application/octet-stream';
+  }
+  var fatalError = false;
+
+  startPuttingObject();
+
+  return uploader;
+
+  function handleError(err) {
+    if (fatalError) return;
+    fatalError = true;
+    uploader.emit('error', err);
+  }
+
+  function handleAbort() {
+    fatalError = true;
+  }
+
+  function startPuttingObject() {
+    doWithRetry(tryPuttingObject, self.s3RetryCount, self.s3RetryDelay, onPutObjectDone);
+
+    function onPutObjectDone(err, data) {
+      if (fatalError) return;
+      if (err) return handleError(err);
+      uploader.emit('end', data);
+    }
+  }
+
+  function tryPuttingObject(cb) {
+    self.s3Pend.go(function(pendCb) {
+      if (fatalError) return pendCb();
+      var pend = new Pend();
+      s3Params.ContentLength = buffer.length;
+      uploader.progressAmount = 0;
+      s3Params.Body = buffer;
+
+      self.s3.putObject(s3Params, function(err, data) {
+        pendCb();
+        if (fatalError) return;
+        if (err) {
+          cb(err);
+          return;
+        }
+        pend.wait(function() {
+          if (fatalError) return;
+          if (cleanETag(data.ETag) === crypto.createHash('md5').update(buffer).digest('hex')) {
+            cb(new Error("ETag does not match MD5 checksum"));
+            return;
+          }
+          cb(null, data);
+        });
+      });
+    });
+  }
+};
+
 Client.prototype.downloadFile = function(params) {
   var self = this;
   var downloader = new EventEmitter();

From 51ad89390adea15b33383932e1f4b94bbb80d2cc Mon Sep 17 00:00:00 2001
From: Stefan Andres Charsley <charsleysa@gmail.com>
Date: Thu, 8 Dec 2016 14:23:03 +1300
Subject: [PATCH 2/2] - Fix comparison

---
 lib/index.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/index.js b/lib/index.js
index d477577..70387a2 100644
--- a/lib/index.js
+++ b/lib/index.js
@@ -484,7 +484,7 @@ Client.prototype.uploadBuffer = function(params) {
         }
         pend.wait(function() {
           if (fatalError) return;
-          if (cleanETag(data.ETag) === crypto.createHash('md5').update(buffer).digest('hex')) {
+          if (cleanETag(data.ETag) !== crypto.createHash('md5').update(buffer).digest('hex')) {
             cb(new Error("ETag does not match MD5 checksum"));
             return;
           }