slackupdate.js

'use strict';

const request = require('request');
const aws = require('aws-sdk');
const https = require('https');
const qs = require('querystring');
const s3 = new aws.S3();

const getSignedUrl = function(bucket, key) {
    return new Promise((resolve, reject) => {
        const params = {Bucket: bucket, Key: key, Expires: 604800};
        var url = s3.getSignedUrl('getObject', params);
        resolve(url);
    });
};

const getShortUrl = function(url) {
  console.log('LONG URL', url);
  console.log(process.env.SHORTENER_API_URL + qs.stringify({key: process.env.SHORTENER_API_KEY}));

  return new Promise((resolve, reject) => {
      var req = {
          uri: process.env.SHORTENER_API_URL + qs.stringify({key: process.env.SHORTENER_API_KEY}),
          method: 'POST',
          json: true,
          body: {
              longUrl: url
          }
      }

      request(req, (err, res, body) => {
          console.log(res.statusCode);
          console.log(err);
          if (err && res.statusCode !== 200) {
              console.log(err);
              reject(err);
          } else {
              resolve(body.id);
          }
      });
  });
}

const writeToSlack = function(url) {
  return new Promise((resolve, reject) => {
    const response = {
        token: process.env.BOT_ACCESS_TOKEN,
        channel: process.env.CHANNEL_ID,
        text: url
      }

      const slackurl = process.env.POST_MESSAGE_URL + qs.stringify(response);

      https.get(slackurl, (res) => {
        const statusCode = res.statusCode;
        resolve();
      })
  });
}

module.exports.execute = (event, context, callback) => {
  const bucket = event.Records[0].s3.bucket.name;
  const key = decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g, " "));

  console.log('executing');
  getSignedUrl(bucket, key)
    .then((url) => getShortUrl(url))
    .then((url) => writeToSlack(url))
    .then(() => callback(null))
    .catch((err) => callback(err))
};