app.rb

require './lib/dotenv'
require './lib/particle'
require 'bundler/setup'
require 'awesome_print'
require 'pg'
require 'active_record'
require 'sinatra'
require 'sinatra/reloader' if development?
require 'sinatra/cookies'
require 'slim'
require 'httparty'

ActiveRecord::Base.establish_connection ENV['POOLED_DATABASE_URL'] || ENV['DATABASE_URL']

require 'que'
Que.connection = ActiveRecord
Que.migrate!

require './jobs/thermostat_function_job'

include Particle

get '/' do
  begin
    @upcoming_targets = Que.execute("select * from que_jobs where job_class = 'ThermostatFunctionJob'")
    @error = cookies.delete 'error'
    @notice = cookies.delete 'notice'
    @thermostat = JSON.parse particle_var 'info'
    puts @thermostat
    slim :thermostat
  rescue => e
    puts e
    @error = "Error! Could not connect to thermostat. Is it online?"
    slim :thermostat
  end
end


get '/set_mode/:mode' do
  begin
    response = particle_func "setMode", params[:mode]
    cookies['notice'] = "Mode set to #{params[:mode].capitalize}"
    redirect to('/')
  rescue => e
    puts e
    cookies['error'] = "Error! Mode not set."
    redirect to('/')
  end
end

get '/upcoming_targets/:id/delete' do
  Que.execute "DELETE FROM que_jobs where job_id = $1;", [params[:id]]
  redirect to('/')
end

get '/thermostat_events' do
  @tzo = "-05:00"
  @thermostat_events = ThermostatEvent.order(created_at: :desc).limit 200
  slim :thermostat_events
end

post '/thermostat_events/:event' do
  thermostat = JSON.parse particle_var 'info'
  forecast = JSON.parse HTTParty.get("https://api.forecast.io/forecast/#{ENV.fetch 'FORECAST_IO_API_KEY'}/#{ENV.fetch 'FORECAST_IO_LAT_LON'}").body rescue nil

  if event = ThermostatEvent.find_by(ended_at: nil)
    event.ended_at = Time.now.utc
    event.end_temperature = thermostat['temperature']
    event.end_target_temperature = thermostat['targetTemperature']
    event.end_thermostat_info = thermostat
    event.end_forecast = forecast
    event.duration_in_minutes = (event.ended_at - event.started_at) / 60
  else
    event = ThermostatEvent.new
    event.mode = thermostat['mode']
    event.started_at = Time.now.utc
    event.start_temperature = thermostat['temperature']
    event.start_target_temperature = thermostat['targetTemperature']
    event.start_thermostat_info = thermostat
    event.start_forecast = forecast
  end

  if (params[:event] == "on" && event.new_record?) || (params[:event] == "off" && !event.new_record?)
    event.save
  end

  status 200
end

# post '/smartthings/:mode' do
#   st_base_url = "https://graph.api.smartthings.com/api/smartapps/installations/#{ENV.fetch 'SMARTTHINGS_APPLICATION_ID'}/switches/#{ENV.fetch 'SMARTTHINGS_SWITCH_ID'}"
#   headers = { "Authorization" => "Bearer #{ENV.fetch('SMARTTHINGS_ACCESS_TOKEN')}" }
#
#   if params[:mode] == "cool_on"
#     HTTParty.post(
#       "#{st_base_url}/on", timeout: 5, headers: headers
#     ).tap { |response| raise response.code.to_s unless response.code == 201 }
#   end
#
#   if params[:mode] == "cool_off"
#     HTTParty.post(
#       "#{st_base_url}/off", timeout: 5, headers: headers
#     ).tap { |response| raise response.code.to_s unless response.code == 201 }
#   end
#
#   status 200
# end

post '/' do
  begin
    run_at = Time.at(Time.now.utc.to_i + params[:set_in_minutes].to_i * 60).utc
    ThermostatFunctionJob.enqueue "targetTemp", params[:target_temp], run_at: run_at
    if params[:set_in_minutes] == "0"
      cookies['notice'] = "Temperature set to #{params[:target_temp]}F"
    else
      cookies['notice'] = "Temperature will be set to #{params[:target_temp]}F in #{params[:set_in_minutes]} minutes"
    end
    redirect to('/')
  rescue => e
    puts e
    cookies['error'] = "Error! Temperature not set."
    redirect to('/')
  end
end

get 'apple-touch.png' do
  send_file File.join(settings.public_folder, 'apple-touch.png')
end

class ThermostatEvent < ActiveRecord::Base
end