Initial commit

Author: thomasboyt

Diff for: .gitignore

@@ -0,0 +1,5 @@
+node_modules/
+src/secret.js
+lambda-config.js
+dist/
+dist.zip

Diff for: README.md

@@ -0,0 +1,3 @@
+# @randomcoasters
+
+A bot that tweets a random coaster from [RCDB](https://rcdb.com/) on the regular. Based on [Erin McKean's template](https://github.com/emckean/blank-lambda-bot). Her guide [here](https://twitter.com/emckean?ref_src=twsrc%5Egoogle%7Ctwcamp%5Eserp%7Ctwgr%5Eauthor) can be used to figure out how to configure AWS to run it.

Diff for: gulpfile.js

@@ -0,0 +1,42 @@
+var gulp = require('gulp');
+var zip = require('gulp-zip');
+var del = require('del');
+var install = require('gulp-install');
+var runSequence = require('run-sequence');
+var awsLambda = require("node-aws-lambda");
+
+gulp.task('clean', function() {
+  return del(['./dist', './dist.zip']);
+});
+
+gulp.task('js', function() {
+  //this is the name of your main function file
+  return gulp.src('src/*.js')
+    .pipe(gulp.dest('dist/'));
+});
+
+gulp.task('node-mods', function() {
+  return gulp.src('./package.json')
+    .pipe(gulp.dest('dist/'))
+    .pipe(install({production: true}));
+});
+
+gulp.task('zip', function() {
+  return gulp.src(['dist/**/*', '!dist/package.json'])
+    .pipe(zip('dist.zip'))
+    .pipe(gulp.dest('./'));
+});
+
+gulp.task('upload', function(callback) {
+  awsLambda.deploy('./dist.zip', require("./lambda-config.js"), callback);
+});
+
+gulp.task('deploy', function(callback) {
+  return runSequence(
+    ['clean'],
+    ['js', 'node-mods'],
+    ['zip'],
+    ['upload'],
+    callback
+  );
+});

Diff for: jsconfig.json

@@ -0,0 +1,16 @@
+{
+	// See https://go.microsoft.com/fwlink/?LinkId=759670
+	// for the documentation about the jsconfig.json format
+	"compilerOptions": {
+		"target": "es6",
+		"module": "commonjs",
+		"allowSyntheticDefaultImports": true
+	},
+	"exclude": [
+		"node_modules",
+		"bower_components",
+		"jspm_packages",
+		"tmp",
+		"temp"
+	]
+}

Diff for: lambda-config.template.js

@@ -0,0 +1,11 @@
+module.exports = {
+  profile: 'your-profile-name',  // load your AWS credentials from a custom profile
+  region: 'us-east-1',  //the region of your Lambda function
+  handler: 'index.handler',  //the name of the handler function: index because the main file is index.js
+  role: 'arn:aws:iam::youraccountid:role/lambda_basic_execution',
+  functionName: 'randomcoasters',  //name
+  timeout: 10,  // how many seconds your function should run before it times out
+  memorySize: 128,  // how much memory your function needs (shouldn't need more than this)
+  publish: true,  // this creates a new version of your Lambda function every time you update it
+  runtime: 'nodejs4.3',
+}

Diff for: package.json

@@ -0,0 +1,25 @@
+{
+  "name": "coasterbot",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "Thomas Boyt <[email protected]>",
+  "license": "MIT",
+  "dependencies": {
+    "axios": "^0.14.0",
+    "cheerio": "^0.22.0",
+    "lodash.samplesize": "^4.2.0",
+    "twit": "^2.2.4"
+  },
+  "devDependencies": {
+    "del": "^2.2.2",
+    "gulp": "^3.9.1",
+    "gulp-install": "^0.6.0",
+    "gulp-zip": "^3.2.0",
+    "node-aws-lambda": "^0.1.8",
+    "run-sequence": "^1.2.2"
+  }
+}

Diff for: src/index.js

@@ -0,0 +1,91 @@
+'use strict';
+
+process.on('unhandledRejection', (err) => {
+  if (err.stack) {
+    console.error(err.stack);
+  } else {
+    console.error(err);
+  }
+  process.exit(1);
+});
+
+const sampleSize = require('lodash.samplesize');
+const Twit = require('twit');
+const axios = require('axios');
+const cheerio = require('cheerio');
+const secret = require('./secret');
+
+const T = new Twit({
+  consumer_key: secret.consumer_key,
+  consumer_secret: secret.consumer_secret,
+  access_token: secret.access_token,
+  access_token_secret: secret.access_token_secret,
+});
+
+function getCoaster() {
+  return axios.get('https://rcdb.com/')
+    .then((resp) => {
+      const $ = cheerio.load(resp.data);
+
+      const link = $('#rrc #rrc_text p a').first().attr('href');
+
+      return axios.get(`https://rcdb.com${link}`);
+
+    }).then((resp) => {
+      const $ = cheerio.load(resp.data);
+      const name = $('#feature h1').text();
+      const park = $('#feature a').first().text();
+      const url = resp.config.url;
+
+      const pictureUrls = $('#pic_data div').map((i, el) => $(el).data('url')).get();
+
+      return {name, park, url, pictureUrls};
+    });
+}
+
+function getImage(pictureUrl) {
+  return axios.get(`https://rcdb.com${pictureUrl}`, {
+    responseType: 'arraybuffer',
+  }).then((resp) => {
+    const image = resp.data.toString('base64');
+    return image;
+  });
+}
+
+function uploadImage(pictureUrl) {
+  return getImage(pictureUrl).then((b64Image) => {
+    return T.post('media/upload', {media_data: b64Image});
+  }).then((result) => {
+    return result.data.media_id_string;
+  });
+}
+
+function tweetCoaster(params) {
+  const urls = sampleSize(params.pictureUrls, 3)
+
+  return Promise.all(urls.map(uploadImage)).then((imageIds) => {
+    // TODO: Ensure there is always room for url, status is not truncated
+    return T.post('/statuses/update', {
+      status: `${params.name} in ${params.park} - ${params.url}`,
+      media_ids: imageIds
+    });
+  });
+}
+
+exports.handler = function(event, context) {
+  getCoaster().then(tweetCoaster).then((result) => {
+    console.log(result.data);
+    context.succeed();
+
+  }).catch((err) => {
+    console.log('errored:');
+
+    if (err.stack) {
+      console.log(err.stack);
+    } else {
+      console.log(err);
+    }
+
+    context.fail();
+  })
+}

Diff for: src/secret.template.js

@@ -0,0 +1,6 @@
+module.exports = {
+  "consumer_key": "",
+  "consumer_secret": "",
+  "access_token": "",
+  "access_token_secret": ""
+};