Example uploaded file to azure with Q and without Q

azure_upload_async.js

var blob   = require('azure').createBlobService()
  , fs     = require('fs')
  , Q      = require('q');
 
var options = { publicAccessLevel: 'blob' };
 
// With Q
var fsLstat      = Q.nbind(fs.lstat, fs);
var getContainer = Q.nbind(blob.createContainerIfNotExists, blob);
var streamFile   = Q.nbind(blob.createBlockBlobFromStream, blob);

// ES6 \o/
async function upload(container, name, path) {
  await getContainer(container, options);
  var stat = await sLstat(path);
  await streamFile(
    scontainer, name, fs.createReadStream(path), stat.size
  );
  return lob.getBlobUrl(container, name).url();
}

azure_upload_gen.js

var blob   = require('azure').createBlobService()
  , fs     = require('fs')
  , Q      = require('q');
 
var options = { publicAccessLevel: 'blob' };
 
// With Q
var fsLstat      = Q.nbind(fs.lstat, fs);
var getContainer = Q.nbind(blob.createContainerIfNotExists, blob);
var streamFile   = Q.nbind(blob.createBlockBlobFromStream, blob);

function upload(container, name, path) {
  return Q.async(function* {
    yield getContainer(container, options);
    var stat = yield sLstat(path);
    yield streamFile(
      scontainer, name, fs.createReadStream(path), stat.size
    );
    return lob.getBlobUrl(container, name).url();
  })();
}

azure_upload_multi.js

var blob   = require('azure').createBlobService()
  , fs     = require('fs')
  , Q      = require('q')

var options = { publicAccessLevel: 'blob' }

// With Q
var fsLstat      = Q.nbind(fs.lstat, fs);
var getContainer = Q.nbind(blob.createContainerIfNotExists, blob);
var streamFile   = Q.nbind(blob.createBlockBlobFromStream, blob);

function upload(container, name, path, callback) {
  var promise = getContainer(container, options)
  .then(function() {
    return fsLstat(path);
  })
  .then(function(stats) {
    return streamFile(
      scontainer, name, fs.createReadStream(path), stats.size
    );
  })
  .then(function() {
    return blob.getBlobUrl(container, name).url();
  });
  
  if (typeof(callback) != "undefined") {
    promise.then(callback)
  } else {
    return promise;
  }
}

azure_upload_normal.js

var blob   = require('azure').createBlobService()
  , fs     = require('fs')

var options = { publicAccessLevel: 'blob' }

function upload(container, name, path, callback) {
  blob.createContainerIfNotExists(container, options, function(err) {
    if (!err) {
      fs.lstat(path, function(stats) {
        if (!err) {
          var stream = fs.createReadStream(path);
          blob.createBlockBlobFromStream(container, name, stream, stats.size, function(err) {
            if (!err) {
              var url = blob.getBlobUrl(container, name).url();
              callback(null, error);
            } else {
              callback(err);
            }
          });
        } else {
          callback(err);
        }
      });
    } else {
      callback(err);
    }
  });
}

azure_upload_promised.js

var blob   = require('azure').createBlobService()
  , fs     = require('fs')
  , Q      = require('q')

var options = { publicAccessLevel: 'blob' }

// With Q
var fsLstat      = Q.nbind(fs.lstat, fs);
var getContainer = Q.nbind(blob.createContainerIfNotExists, blob);
var streamFile   = Q.nbind(blob.createBlockBlobFromStream, blob);

function upload(container, name, path) {
  return getContainer(container, options)
  .then(function() {
    return fsLstat(path);
  })
  .then(function(stats) {
    return streamFile(
      scontainer, name, fs.createReadStream(path), stats.size
    );
  })
  .then(function() {
    return blob.getBlobUrl(container, name).url();
  })
  .catch(function(err) {
    console.log("Error");
  })
}