read_and_reply.js

const {scaleLinear} = require('d3-scale')
const {format} = require('d3-format')
const {ascending, max} = require('d3-array')

require('dotenv').config()
const request = require('request-promise')

const auth = {}

// twitter info
auth.twitter_oauth = {
  consumer_key: process.env.CONSUMER_KEY,
  consumer_secret: process.env.CONSUMER_SECRET,
  token: process.env.USER_TOKEN, // USER SPECIFIC
  token_secret: process.env.USER_TOKEN_SECRET, // USER SPECIFIC
}

const digits = (arr) => {
	return Math.max(...arr.map(e => e === 0 
		? 1 
		: e === 1000 
			? 4 
			: Math.floor(Math.log(e) / Math.LN10 + 1)))
}

const parse = (text) => {
	console.log('parsing...')
	const data = text.split('\n').filter(e => e.slice(0,4).search(/\d{4}/) === 0)

	const delimeter = data[0][4]
	const parsed = [...data].map(d => d.split(delimeter).map(e => +e.trim().replace(/[^\.\d]+/g,'')))
	return parsed
}

const makeViz = (data) => {
	console.log('vizing... ')

	const xScale = scaleLinear()
    .domain([data[0][0], data[data.length-1][0]])
    .range([0, 10])
	const xTicks = xScale.ticks( data.length/2 ).map(d => d.toString().slice(2,4))

	const makeVizRow = (values, init='') => {
		if(values.length === 0){
		    return init
		} else {
		    return makeVizRow(values.slice(1), init+'\u3000'.repeat(Math.max(0, xScale(values[0][0]) - init.length))+'\uff0a')
		}
	}

	const yScale = scaleLinear().domain([max(data, d => d[1]), 0])
	const yTicks = yScale.ticks( data.length/2 )
	const yStep = yTicks[0] - yTicks[1]

	const xStep = Math.round(xScale.range()[1] / xTicks.length) - 2
	let viz = yTicks.map(e => {
	  let filtered = data.filter(d => d[1] >= +e && d[1] < +e + yStep)
	  return `${e.toString().padStart(digits(yTicks),'0')}| ${makeVizRow(filtered)}`
	}).join('\n')
	viz += '\n' + '\u3000'.repeat(2) + xScale.domain()[0].toString().slice(2,4) + '\uffe3'.repeat(xScale.range()[1]) + xScale.domain()[1].toString().slice(2,4)
	return viz
}

const createRequestOps = (tweet, id) => {
	const request_options = {
		oauth: auth.twitter_oauth,
		url: 'https://api.twitter.com/1.1/statuses/update.json?status=' + encodeURIComponent(tweet) + '&in_reply_to_status_id=' + id,
	}
	return request_options
}

const postResponse = (request_options) => {
	request.post(request_options).then(function (body) {
		console.log(body)
	}).catch(function (body) {
		console.log(body)
	})
}

module.exports.read_and_reply = read_and_reply = (tweetEvent) => {

	let tweeter = tweetEvent.tweet_create_events[0].user.id
	console.log(tweetEvent.tweet_create_events[0])

	if (tweeter !== 1031985269984165900) {
		const quoteStatus = tweetEvent.tweet_create_events[0].is_quote_status
		const replyStatus = !!+tweetEvent.tweet_create_events[0].in_reply_to_status_id
		const id = tweetEvent.tweet_create_events[0].id_str
		const user = tweetEvent.tweet_create_events[0].user.screen_name

		if (quoteStatus) {
			const user2 = tweetEvent.tweet_create_events[0].quoted_status.user.screen_name
			const tweet = '@' + user + ' ' + '@' + user2 + ' ' + makeViz(parse(tweetEvent.tweet_create_events[0].quoted_status.text))
			postResponse(createRequestOps(tweet, id));		
		} else if (replyStatus) {
			const origTweetId = tweetEvent.tweet_create_events[0].in_reply_to_status_id_str
			// request options for the reply 
			const request_options_reply = {
				oauth: auth.twitter_oauth,
				url: 'https://api.twitter.com/1.1/statuses/show.json?id=' + origTweetId,
			}
			// GET request for the original tweet text
			request.get(request_options_reply).then(function (body) {
  			const tweet = '@' + user + ' ' + makeViz(parse(JSON.parse(body).text))
  			//post the response
				postResponse(createRequestOps(tweet, id));
			}) 
		} else {
			const tweet = '@' + user + ' ' + makeViz(parse(tweetEvent.tweet_create_events[0].text))
			postResponse(createRequestOps(tweet, id));
		}
	}
}