initial checkin azure v2

pkgcloud · morsh · Dec 12, 2016 · Dec 13, 2016 · Dec 13, 2016 · Dec 13, 2016
commit bcbccbf162278c8c3f662fcf18f97e25327741e5
diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -0,0 +1,29 @@
+{
+  // Use IntelliSense to learn about possible Node.js debug attributes.
+  // Hover to view descriptions of existing attributes.
+  // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "type": "node",
+      "request": "launch",
+      "name": "Launch Program",
+      "program": "${workspaceRoot}\\lib\\pkgcloud",
+      "cwd": "${workspaceRoot}"
+    },
+    {
+      "type": "node",
+      "request": "launch",
+      "name": "Launch Azure V2",
+      "program": "${workspaceRoot}\\examples\\compute\\azure-v2.js",
+      "cwd": "${workspaceRoot}",
+      "stopOnEntry": true
+    },
+    {
+      "type": "node",
+      "request": "attach",
+      "name": "Attach to Process",
+      "port": 5858
+    }
+  ]
+}
diff --git a/examples/compute/azure-v2.js b/examples/compute/azure-v2.js
@@ -0,0 +1,63 @@
+var pkgcloud = require('../../lib/pkgcloud'),
+  fs = require('fs'),
+  client,
+  options;
+
+//
+// Create a pkgcloud compute instance
+//
+options = {
+  resourceGroup: '{resourceGroup}',
+  provider: 'azure-v2',
+  storageAccount: '{storeName}',
+  storageAccessKey: '{storeKey}',
+  subscriptionId: '{subscriptionId}',
+  spClientId: "{spClientId}",
+  spSecret: "{spSecret}",
+  spDomain: "{spDomain}",
+  spSubscriptionId: "{spSubscriptionId}"
+};
+client = pkgcloud.compute.createClient(options);
+
+//
+// Create a server.
+// This may take several minutes.
+//
+options = {
+  // pkgcloud compute properties
+  name:  'ms-pkgc-test2',   // name of the server
+  flavor: 'Standard_D1',     // azure vm size
+  //image: '5112500ae3b842c8b9c604889f8753c3__OpenLogic-CentOS63DEC20121220', // OS Image to use
+  image: {
+    uri: 'https://{storename}.blob.core.windows.net/osdiks/ms-pkgc-test-os2.vhd', 
+    OS: 'linux' 
+  },
+  nic: '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroup}/providers/Microsoft.Network/networkInterfaces/{nicName}',
+
+  // Azure vm properties
+  location:  'West Europe',       // Azure location for server
+  username:  'pkgcloud',      // Username for server
+  password:  'Pkgcloud!!'    // Password for server
+};
+
+console.log('creating server...');
+
+client.createServer(options, function (err, server) {
+  if (err) {
+    console.log(err);
+  } else {
+    // Wait for the server to reach the RUNNING state.
+    // This may take several minutes.
+    console.log('waiting for server RUNNING state...');
+    server.setWait({ status: server.STATUS.running }, 10000, function (err, server) {
+      if (err) {
+        console.log(err);
+      } else {
+        console.dir(server);
+      }
+    });
+  }
+});
+
+
+
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/client.js b/lib/pkgcloud/azure-v2/client.js
@@ -0,0 +1,54 @@
+/*
+ * client.js: Base client from which all Azure clients inherit from
+ *
+ *  (C) Microsoft Open Technologies, Inc.   All rights reserved.
+ *
+ */
+
+var util = require('util'),
+    base = require('../core/base');
+
+var Client = exports.Client = function (options) {
+  base.Client.call(this, options);
+
+  options = options || {};
+
+  // Allow overriding serversUrl in child classes
+  this.provider   = 'azure-v2';
+  this.protocol   = options.protocol || 'https://';
+
+  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,44 @@
+/*
+ * flavors.js: Implementation of Azure Flavors Client.
+ *
+ * (C) Microsoft Open Technologies, Inc.
+ *
+ */
+
+var pkgcloud = require('../../../../../lib/pkgcloud'),
+    base     = require('../../../core/compute'),
+    compute  = pkgcloud.providers.azure.compute;
+
+//
+// ### function getFlavors (callback)
+// #### @callback {function} f(err, flavors). `flavors` is an array that
+// represents the flavors that are available to your account
+//
+// Lists all flavors available to your account.
+//
+exports.getFlavors = function getFlavors(callback) {
+  var self = this;
+
+  callback(null, Object.keys(compute.Flavor.options).map(function (name) {
+    return new compute.Flavor(self, { name: name });
+  }));
+};
+
+//
+// ### function getFlavor (flavor, callback)
+// #### @image    {Flavor|String} Flavor ID or an Flavor
+// #### @callback {function} f(err, flavor). `flavor` is an object that
+// represents the flavor that was retrieved.
+//
+// Gets a specified flavor of AWS DataSets using the provided details
+// object.
+//
+exports.getFlavor = function getFlavor(flavor, callback) {
+  var flavorId = flavor instanceof base.Flavor ? flavor.id : flavor;
+
+  if (flavor instanceof base.Flavor) {
+    return callback(null, flavor);
+  }
+
+  callback(null, new compute.Flavor(this, { id : flavorId }));
+};
diff --git a/lib/pkgcloud/azure-v2/compute/client/images.js b/lib/pkgcloud/azure-v2/compute/client/images.js
@@ -0,0 +1,121 @@
+/*
+ * images.js: Implementation of Azure Images Client.
+ *
+ * (C) Microsoft Open Technologies, Inc.
+ *
+ */
+var pkgcloud = require('../../../../../lib/pkgcloud'),
+  base     = require('../../../core/compute'),
+  compute  = pkgcloud.providers.azure.compute,
+  azureApi = require('../../utils/azureApiV2');
+
+//
+// ### function getImages (callback)
+// #### @callback {function} f(err, images). `images` is an array that
+// represents the images that are available to your account
+//
+// Lists all images available to your account.
+//
+exports.getImages = function getImages(options, callback) {
+  if (!callback && typeof options === 'function') {
+    callback = options;
+    options = null;
+  }
+
+  var path = this.config.subscriptionId + '/services/images',
+    self = this;
+
+  return this.get(path, function (err, body, res) {
+    return err
+      ? callback(err)
+      : callback(null, self._toArray(body.OSImage).map(function (image) {
+          return new compute.Image(self, image);
+        }), res);
+  });
+};
+
+// ### function getImage (image, callback)
+// #### @image    {Image|String} Image id or an Image
+// #### @callback {function} f(err, image). `image` is an object that
+// represents the image that was retrieved.
+//
+// Gets a specified image of Azure using the provided details
+// object.
+//
+exports.getImage = function getImage(image, callback) {
+  var self = this,
+    imageId = image instanceof base.Image ? image.id : image,
+    path = this.config.subscriptionId + '/services/images/' + imageId;
+
+  this.get(path, function (err, body, res) {
+
+    if (err) {
+      return callback(err);
+    }
+
+    var result = null;
+    if (body) {
+      result = new compute.Image(self, body);
+    }
+
+    return result
+      ? callback(null, result, res)
+      : callback(new Error('Image not found'));
+  });
+};
+
+//
+// ### function createImage(options, callback)
+// #### @id {Object} an object literal with options
+// ####     @name    {String}  String name of the image
+// ####     @server  {Server} the server to use
+// #### @callback {function} f(err, image). `image` is an object that
+// represents the image that was created.
+//
+// Creates an image in Azure based on a server
+//
+exports.createImage = function createImage(options, callback) {
+  options || (options = {});
+
+  if (!options.name) {
+    throw new TypeError('`name` is a required option');
+  }
+
+  if (!options.server) {
+    throw new TypeError('`server` is a required option');
+  }
+
+  var self    = this,
+    serverId  = options.server instanceof base.Server
+      ? options.server.id
+      : options.server;
+
+  azureApi.createImage(this, serverId, options.name, function (err, result) {
+    return !err
+      ? self.getImage(result, callback)
+      : callback(err);
+  });
+};
+
+//
+// ### function destroyImage(image, callback)
+// #### @image    {Image|String} Image id or an Image
+// #### @callback {function} f(err, image). `image` is an object that
+// represents the image that was deleted.
+//
+// Destroys an image in Azure
+//
+exports.destroyImage = function destroyImage(image, callback) {
+  var self = this,
+      imageId = image instanceof base.Image ? image.id : image,
+      path = self.config.subscriptionId + '/services/images/' + imageId;
+
+  self._xmlRequest({
+    method: 'DELETE',
+    path: path
+  }, function (err, body, res) {
+    return err
+      ? callback(err)
+      : callback(null, { ok: imageId }, res);
+  });
+};