hhp_reward_watcher.rb

require 'twitter'
require 'influxdb'
require 'time'
require 'optparse'

params = ARGV.getopts('s:f:', 'debug')
debug_mode = params['debug']
series_name = params['s']
series_name ||= 'sample'
host = ENV['INFLUXDB_HOST']
user = ENV['INFLUXDB_USER']
pass = ENV['INFLUXDB_PASS']
db_name = ENV['INFLUXDB_DBNAME']

influxdb = InfluxDB::Client.new db_name, host: host, username: user, password: pass
sleep(1.5) unless debug_mode
real_time = Time.now
ret = influxdb.query "SELECT * FROM #{series_name} LIMIT 2"
curr = ret[series_name].first['reward_rank'].to_i
prev = ret[series_name].last['reward_rank'].to_i
current_time = Time.at ret[series_name].first['time']

if debug_mode
  puts "#{current_time.strftime('%m/%d %H:%M')}"
  puts prev
  puts curr
end

reward_detect = curr > prev
time_detect = debug_mode ? true : (['00'].include?(real_time.strftime('%M')))

if reward_detect || time_detect
  if debug_mode
    puts `ruby tweet_bot_hhp.rb -s #{series_name}  #{reward_detect ? '-r' : ''} -d`
  else
    puts `ruby tweet_bot_hhp.rb -s #{series_name} #{reward_detect ? '-r' : ''}`
  end
end