[squash] where is this fraking callback

lib/api/apiUtils/object/prepareStream.js

@@ -13,10 +13,12 @@ const V4Transform = require('../../../auth/streamingV4/V4Transform');
 function prepareStream(stream, streamingV4Params, log, cb) {
     if (stream.headers['x-amz-content-sha256'] ===
         'STREAMING-AWS4-HMAC-SHA256-PAYLOAD') {
+        console.log('\n\n-----BEFORE V4TRANSFORM-----\n\n');
         const v4Transform = new V4Transform(streamingV4Params, log, cb);
         stream.pipe(v4Transform);
         return v4Transform;
     }
+    console.log('\n\n-----NO V4TRANSFORM----\n\n');
     return stream;
 }
 

lib/api/apiUtils/object/storeObject.js

@@ -52,18 +52,20 @@ function checkHashMatchMD5(stream, hashedStream, dataRetrievalInfo, log, cb) {
 function dataStore(objectContext, cipherBundle, stream, size,
     streamingV4Params, backendInfo, log, cb) {
     const dataStream = prepareStream(stream, streamingV4Params, log, cb);
-    data.put(cipherBundle, dataStream, size, objectContext, backendInfo, log,
+    return data.put(cipherBundle, dataStream, size, objectContext, backendInfo,
-        (err, dataRetrievalInfo, hashedStream) => {
+        log, (err, dataRetrievalInfo, hashedStream) => {
             if (err) {
                 log.error('error in datastore', {
                     error: err,
                 });
+                console.log('\n\n-----ERROR CB-----\n\n')
                 return cb(err);
             }
             if (!dataRetrievalInfo) {
                 log.fatal('data put returned neither an error nor a key', {
                     method: 'storeObject::dataStore',
                 });
+                console.log('\n\n-----NO DATA RETRIEVAL INFO ERROR CB-----\n\n');
                 return cb(errors.InternalError);
             }
             log.trace('dataStore: backend stored key', {

lib/auth/streamingV4/V4Transform.js

@@ -268,6 +268,9 @@ class V4Transform extends Transform {
             // final callback
             err => {
                 if (err) {
+                    this.log.error('error preparing stream', {
+                        error: err,
+                    });
                     return this.cb(err);
                 }
                 // get next chunk

lib/data/wrapper.js

@@ -167,6 +167,7 @@ const data = {
                                 'following object PUT failure',
                                 { error: error.message });
                         }
+                        console.log('\n\n----ERROR ON PUT----\n\n');
                         return cb(err);
                     });
                 }
@@ -180,6 +181,7 @@ const data = {
                     });
                     return undefined;
                 }
+                console.log('\n\n-----SHOULD NOT RETURN LE CB-----\n\n');
                 return cb(null, dataRetrievalInfo);
             });
         });