pkgcloud · morsh · Dec 12, 2016 · Dec 13, 2016 · Dec 13, 2016 · Dec 13, 2016
diff --git a/.gitignore b/.gitignore
@@ -12,4 +12,6 @@ azure_error
 coverage.html
 .coveralls.yml
 pkgcloud.lcov*
-node-jscoverage
+node-jscoverage
+*.private.*
+*.vscode/launch.json
diff --git a/examples/compute/azure-v2.js b/examples/compute/azure-v2.js
@@ -0,0 +1,64 @@
+var pkgcloud = require('../../lib/pkgcloud');
+var client;
+var options;
+
+//
+// Create a pkgcloud compute instance
+//
+options = {
+  provider: 'azure-v2',
+  subscriptionId: '{subscriptionId}',  
+  resourceGroup: '{resourceGroup}',
+
+  servicePrincipal: {
+    clientId: '{spClientId}',
+    secret: '{spSecret}',
+    domain: '{spDomain}'
+  }
+};
+client = pkgcloud.compute.createClient(options);
+
+//
+// Create a server.
+// This may take several minutes.
+//
+var createVMOfferOptions = {
+  name:  'ms-pkgc-vm-test',
+  flavor: 'Standard_D1',
+  username:  'pkgcloud',
+  password:  'Pkgclo
EE5B
ud!!',
+
+  storageOSDiskName: 'osdisk',
+  storageDataDiskNames: [ 'datadisk1' ],
+
+  imagePublisher: 'Canonical',
+  imageOffer: 'UbuntuServer',
+  imageSku: '16.04.0-LTS',
+  imageVersion: 'latest'
+};
+
+console.log('creating server...');
+
+client.createServer(createVMOfferOptions, function (err, server) {
+
+  console.log('servre created successfully:');
+  console.dir(server);
+
+  if (err) {
+    console.log(err);
+  } else {
+    client.destroyServer(createVMOfferOptions, { 
+      destroyNics: true,
+      destroyPublicIP: true,
+      destroyVnet: true, 
+      destroyStorage: true 
+    }, function (err, server) {
+      if (err) {
+        console.log(err);
+      } else {
+        console.log('deleted successfully');
+        console.dir(server);
+      }
+    });
+  }
+});
diff --git a/examples/storage/azure-v2.js b/examples/storage/azure-v2.js
@@ -0,0 +1,76 @@
+var path = require('path');
+var pkgcloud = require('../../lib/pkgcloud');
+
+var client = pkgcloud.storage.createClient({
+  provider: 'azure-v2',
+  subscriptionId: '{subscriptionId}',  
+  resourceGroup: '{resourceGroup}',
+
+  servicePrincipal: {
+    clientId: '{spClientId}',
+    secret: '{spSecret}',
+    domain: '{spDomain}'
+  }
+});
+
+// client.getFiles('storageacountname', null, function (err, files) (function (err) {
+
+//   var file = files[0];
+//   client.getFile('storageacountname', file, null, function (err, file) (function (err) {
+//     console.dir(file);
+//   })
+// });
+
+client.getFiles('storageacountname', { container: 'container-name' }, function (err, files) {
+
+  if (err) {
+    return console.error(err);
+  }
+
+  var file = files[0];
+  console.dir(file);
+
+  var download = client.download({
+    container: 'storageacountname',
+    storage: { container: 'container-name' },
+    remote: 'file.name.to.download.ext',
+    local: path.join(__dirname, 'file.name.to.download.ext')
+  }, function (err) {
+    return err ? console.dir(err) : null;
+  });
+
+  download.on('error', function(err) {
+    console.error(err);
+  });
+
+  download.on('end', function(file) {
+    console.log('file write has ended:');
+    console.dir(file);
+  });
+
+  download.on('data', function(data) {
+    console.log(data && data.length);
+  });
+});
+
+// client.createContainer('storageacountname', function (err, container) {
+//   console.log('created: ', container.toJSON());
+
+//   client.getContainer('storageacountname', function (err, container) {
+//     console.log('found: ', container.toJSON());
+//   });
+// });
+
+// client.getContainers(function (err, containers) {
+//   if (err) {
+//     console.error(err);
+//   }
+
+//   client.getContainer(containers[0], function (err, container) {
+//     console.log('found: ', container.toJSON());
+//   });
+
+//   containers.forEach(function (container) {
+//     console.log(container.toJSON());
+//   });
+// });
diff --git a/lib/pkgcloud.js b/lib/pkgcloud.js
@@ -21,6 +21,7 @@ var components = [
 var providers = [
   'amazon',
   'azure',
+  'azure-v2',
   'digitalocean',
   'google',
   'iriscouch',

diff --git a/lib/pkgcloud/azure-v2/azure-api.js b/lib/pkgcloud/azure-v2/azure-api.js
@@ -0,0 +1,112 @@
+var errs = require('errs');
+
+var msRestAzure = require('ms-rest-azure');
+var resourceManagement = require('azure-arm-resource');
+
+var templates = require('./templates');
+var constants = require('./constants');
+
+/**
+ * This callback type is called `requestCallback` and is displayed as a global symbol.
+ *
+ * @callback requestCallback
+ * @param {object} error
+ * @param {object} result
+ */
+
+/**
+ * Request and save credentials for accessing azure ARM resources.
+ * @param {object} client object containing configuration.
+ * @param {boolean} setupLocation Should setup a location from the resource group.
+ * @param {requestCallback} callback to respond to when complete.
+ */
+function login(setupLocation, callback) {
+
+  var self = this;
+  if (typeof setupLocation == 'function' && typeof callback === 'undefined') {
+    callback = setupLocation;
+    setupLocation = null;
+  }
+
+  // Make sure credentials are refreshed by intervals
+  if (self.azure && self.azure.credentials && self.azure.lastRefresh) {
+    var now = new Date();
+    if (now - self.azure.lastRefresh < constants.CREDENTIALS_LIFESPAN) {
+      return callback(null, self.azure.credentials);
+    }
+  }
+
+  var config = self.config;
+  var servicePrincipal = config.servicePrincipal;
+  msRestAzure.loginWithServicePrincipalSecret(
+    servicePrincipal.clientId, 
+    servicePrincipal.secret, 
+    servicePrincipal.domain, 
+    function (err, credentials) {
+
+      if (err) {
+        errs.handle(
+          errs.create({
+              message: 'There was a problem connecting to azure: ' + err
+          }),
+          callback
+        );
+      }
+
+      self.azure = self.azure || {};
+      self.azure.credentials = credentials;
+      self.azure.lastRefresh = new Date();
+
+      if (setupLocation) {
+        return self.setupLocation(credentials, function (err) { 
+          return callback(err, credentials); 
+        });
+      } else {
+        return callback(null, credentials);
+      }
+    });
+}
+
+/**
+ * Setting up an azure session including querying the default location from the resource group
+ * used by the current configuration
+ * @param {object} credentials object containing azure credentials
+ * @param {requestCallback} callback to respond to when complete.
+ */
+function setupLocation(credentials, callback) {
+  var self = this;
+
+  self.azure = self.azure || {};
+  self.azure.location = self.azure.location || self.config.location;
+  if (self.azure.location) {
+    return callback();
+  }
+
+  if (self.config.resourceGroup) {
+    var resourceClient = new resourceManagement.ResourceManagementClient(credentials, self.config.subscriptionId);
+    resourceClient.resourceGroups.get(self.config.resourceGroup, function (err, result) {
+
+      if (err) {
+        return callback(err);
+      }
+
+      self.azure.location = result.location;
+      return callback();
+    });
+  }
+}
+
+/**
+ * Binding common methods to be available to all clients
+ * @param {object} credentials object containing azure credentials
+ * @param {requestCallback} callback to respond to when complete.
+ */
+function bind(client) {
+  client.login = login.bind(client);
+  client.setupLocation = setupLocation.bind(client);
+  client.deploy = templates.deploy.bind(client);
+}
+
+module.exports = {
+  bind: bind
+};
diff --git a/lib/pkgcloud/azure-v2/client.js b/lib/pkgcloud/azure-v2/client.js
@@ -0,0 +1,56 @@
+/*
+ * client.js: Base client from which all Azure clients inherit from
+ *
+ *  (C) Microsoft Open Technologies, Inc.   All rights reserved.
+ *
+ */
+
+var util = require('util');
+
+var base = require('../core/base');
+var azureApi = require('./azure-api');
+
+var Client = exports.Client = function (options) {
+  base.Client.call(this, options);
+
+  options = options || {};
+
+  // Allow overriding serversUrl in child classes
+  this.provider   = 'azure-v2';
+  azureApi.bind(this);
+
+  if (!this.before) {
+    this.before = [];
+  }
+};
+
+util.inherits(Client, base.Client);
+
+Client.prototype._toArray = function toArray(obj) {
+  if (typeof obj === 'undefined') {
+    return [];
+  }
+
+  return Array.isArray(obj) ? obj : [obj];
+};
+
+Client.prototype.failCodes = {
+  400: 'Bad Request',
+  401: 'Unauthorized',
+  403: 'Forbidden',
+  404: 'Item not found',
+  409: 'Already exists or in progress',
+  412: 'Lease error',
+  413: 'Request Entity Too Large',
+  415: 'Bad Media Type',
+  500: 'Fault',
+  503: 'Service Unavailable'
+};
+
+Client.prototype.successCodes = {
+  200: 'OK',
+  201: 'Created',
+  202: 'Accepted',
+  203: 'Non-authoritative information',
+  204: 'No content'
+};
diff --git a/lib/pkgcloud/azure-v2/compute/client/flavors.js b/lib/pkgcloud/azure-v2/compute/client/flavors.js
@@ -0,0 +1,60 @@
+/*
+ * flavors.js: Implementation of Azure Flavors Client.
+ *
+ * (C) Microsoft Open Technologies, Inc.
+ *
+ */
+
+var _ = require('lodash');
+var ComputeManagementClient = require('azure-arm-compute');
+
+/**
+ * Lists all flavors available to your account.
+ * @param {function} callback - cb(err, flavors). `flavors` is an array that
+ * represents the flavors that are available to your account
+ */
+function getFlavors(callback) {
+  var self = this;
+
+  self.login(true, function (err) {
+
+    if (err) {
+      return callback(err);
+    }
+
+    var client = new ComputeManagementClient(self.azure.credentials, self.config.subscriptionId);
+    client.virtualMachineSizes.list(self.azure.location, function (err, results) {
+      return err
+        ? callback(err)
+        : callback(null, results.map(function (res) {
+            return new self.models.Flavor(self, res);
+          }));
+    });
+  });
+}
+
+/**
+ * Gets a specified flavor of AWS DataSets using the provided details object.
+ * @param {Flavor|String} image - Flavor ID or an Flavor
+ * @param {function} callback cb(err, flavor). `flavor` is an object that
+ * represents the flavor that was retrieved.
+ */
+function getFlavor(flavor, callback) {
+  var self = this;
+  var flavorId = flavor instanceof self.models.Flavor ? flavor.id : flavor;
+
+  if (flavor instanceof self.models.Flavor) {
+    return callback(null, flavor);
+  }
+
+  self.getFlavors(function (err, flavors) {
+    return err ?
+      callback(err) :
+      callback(null, _.find(flavors, { id: flavorId }));
+  });
+}
+
+module.exports = {
+  getFlavors: getFlavors,
+  getFlavor: getFlavor
+};