upload-webjob.js

module.exports = {

  friendlyName: 'Upload Webjob',
  description: 'Uploads a webjob to a given website, overwriting if it already exists.',
  extendedDescription: '',

  inputs: {
    deploymentUser: {
      description: 'The deployment username for the website',
      example: 'johndoe',
      required: true
    },
    deploymentPassword: {
      description: 'The deployment password for the website',
      example: 'p@ssw0rd',
      required: true
    },
    fileLocation: {
      description: 'The path to the script that should be uploaded',
      example: '/mypath/myscript.sh',
      required: true
    },
    website: {
      description: 'The name of the website the file should be uploaded to',
      example: 'mysite',
      required: true
    }
  },

  defaultExit: 'success',
  exits: { 
    error: { 
      description: 'Unexpected error occurred.' 
    },
    success: { 
      description: 'Done.' 
    } 
  },

  fn: function (inputs,exits) {

    var child_process = require('child_process');
    var cliPath = require('path').resolve(__dirname, '../node_modules/azure-cli/bin/azure');
    var _ = require('lodash');
    var request = require('request');
    var fs = require('fs');

    var checkForError = function (response) {
      response = (response[0] && response[0].headers) ? response[0] : response;

      if (response.headers && response.headers['content-type'] && response.headers['content-type'] === 'text/html') {
        // 'Azure returned text/html (which it shouldn't), checking for errors
        if (response.body && response.body.indexOf('401 - Unauthorized') > -1) {
          return 'Invalid Credentials: The Azure Website rejected the given username or password.';
        }
      }

      return false;
    }

    var n = (/^win/.test(process.platform)) ? inputs.fileLocation.lastIndexOf('\\') : inputs.fileLocation.lastIndexOf('/');
    var jobName = (n > -1) ? inputs.fileLocation.substring(n + 1) : inputs.fileLocation;
    var fileStream = fs.createReadStream(inputs.fileLocation);
    var targetUrl = 'https://' + inputs.website + '.scm.azurewebsites.net/api/triggeredwebjobs/' + jobName;

    request.del(targetUrl, {
      'auth': {
        'user': inputs.deploymentUser,
        'pass': inputs.deploymentPassword
      }
    }, function (err) {
      if (err) {
        return exits.error(err);
      }

      fileStream.pipe(request.put(targetUrl, {
          'auth': {
            'user': inputs.deploymentUser,
            'pass': inputs.deploymentPassword
          },
          'headers': {
            'Content-Disposition': 'attachment; filename=' + jobName
          }
        },
        function (err, result) {
          if (err) {
            return exits.error(err);
          }

          errorCheck = checkForError(result);
          if (errorCheck) {
            return exits.error(errorCheck);
          }

          return exits.success('Done');
        }));
    });
  },
};