gistfile1.txt

var request = require('request');

/**
 *   Feed to create a webhook on Github
 *  @param {object} params - information about the trigger
 *  @param {string} repository - repository to create webhook
 *  @param {string} username - github username
 *  @param {string} accessToken - github access token
 *  @param {string} events - list of the events the webhook should fire on
 *  @return {object} whisk async
 */
function main(params) {
  var username = params.username;
  var accessToken = params.accessToken;

  var organization,
    repository;

  if (params.repository) {
    var repoSegments = params.repository.split('/');
    if (repoSegments.length === 2) {
      organization = repoSegments[0];
      repository = repoSegments[1];
    } else {
      repository = params.repository;
    }
  }

  var lifecycleEvent = params.lifecycleEvent;
  var triggerName = params.triggerName.split("/");

    // URL of the whisk system. The calls of github will go here.
  var whiskCallbackUrl = 'https://' + process.env.__OW_API_KEY + "@" + params.endpoint + '/api/v1/namespaces/' + encodeURIComponent(triggerName[1]) + '/triggers/' + encodeURIComponent(triggerName[2]);

    // The URL to create the webhook on Github
  var registrationEndpoint = 'https://api.github.com/repos/' + (organization ? organization : username) + '/' + repository + '/hooks';
  console.log("Using endpoint: " + registrationEndpoint);

  var authorizationHeader = 'Basic ' + new Buffer(username + ':' +
  accessToken).toString('base64');

  if (lifecycleEvent === 'CREATE') {
    var events = params.events.split(',');

    var body = {
      name: 'web',
      active: true,
      events: events,
      config: {
        url: whiskCallbackUrl,
        content_type: 'json'
      }
    };

    var options = {
      method: 'POST',
      url: registrationEndpoint,
      body: JSON.stringify(body),
      headers: {
        'Content-Type': 'application/json',
        'Authorization': authorizationHeader,
        'User-Agent': 'whisk'
      }
    };
    var promise = new Promise(function(resolve, reject) {
      request(options, function (error, response, body) {
        if (error) {
          reject({
            response: response,
            error: error,
            body: body
          });
        } else {
          console.log("Status code: " + response.statusCode);

          if (response.statusCode >= 400) {
            console.log("Response from Github: " + body);
            reject({
              statusCode: response.statusCode,
              response: body
            });
          } else {
            resolve({response: body});
          }
        }
      });
    });

    return promise;
  } else if(lifecycleEvent === 'DELETE') {
    //list all the existing webhooks first.
    var deleteOptions = {
        method: 'GET',
        url: registrationEndpoint,
        json: true,
        headers: {
            'Content-Type': 'application/json',
            'Authorization': authorizationHeader,
            'User-Agent': 'whisk'
        }
    };

    var deletePromise = new Promise(function(resolve, reject) {
      request(deleteOptions, function(error, response, body){
        // the URL that comes back from GitHub does not include auth info
        var foundWebhookToDelete = false;

        if (error){
          reject({
            response: response,
            error:error,
            body:body
          });
        } else {
          for (var i=0; i<body.length;i++){
              if (decodeURI(body[i].config.url) === whiskCallbackUrl) {
                  foundWebhookToDelete = true;

                  console.log('DELETE Webhook URL: ' + body[i].url);
                  var options = {
                      method: 'DELETE',
                      url: body[i].url,
                      headers: {
                          'Content-Type': 'application/json',
                          'Authorization': authorizationHeader,
                          'User-Agent': 'whisk'
                      }
                  };

                  request(options, function(error, response, body) {
                      if (error) {
                          reject({
                            response: response,
                            error:error,
                            body:body
                          });
                      } else {
                          console.log("Status code: " + response.statusCode);
                          if (response.statusCode >= 400) {
                              console.log("Response from Github: " + body);

                              // a 404 is common and confusing enough to warrant an extra message
                              if(response.statusCode === 404) {
                                console.log('Please ensure your accessToken is authorized to delete webhooks.');
                              }

                              reject({
                                  statusCode: response.statusCode,
                                  response: body
                              });
                          } else {
                            resolve();
                          }
                      }
                  });
              }
          }

          if (!foundWebhookToDelete) {
            reject('Found no existing webhooks for trigger URL ' + whiskCallbackUrl);
          }
        }
      });
    });

    return deletePromise;
  }
}