subway.rb

# subway.rb - alexa nyc mta subway 
#

require 'sinatra'
require 'nokogiri'
require 'json'
require 'alexa_verifier'

require_relative 'lib/alexa_nyc_mta'

def lines_from_state(lines) 
   line_text = String.new
   # for line in delayed_lines do
   lines.each_with_index do |line, idx|
     if (idx != (lines.count-1))
        line_text << line.gsub(/(.{1})/, '\1 ')
        if (idx != lines.count-2) then line_text << ", " end
        puts "idx is #{idx} lines count is #{lines.count}"
        puts line
     else
        line_text << " and the " + line.gsub(/(.{1})/, '\1 ') 
        puts line
      end
   end
   line_text
end

verifier = AlexaVerifier.build do |c|
  c.verify_signatures = true
  c.verify_timestamps = true
  c.timestamp_tolerance = 60 # seconds
end

get '/subway/' do
    "app is alive"
end

post '/subway/v1.0' do 
   begin
       subway = AlexaNYCMTA.new 
       status = subway.subway_status

       request_body_unparsed = request.body.read

       authentic = verifier.verify!(
           request.env['HTTP_SIGNATURECERTCHAINURL'], 
           request.env['HTTP_SIGNATURE'],
           request_body_unparsed
       )

       puts "authenticity is #{authentic}"
           
       request_body = JSON.parse request_body_unparsed
       puts "request body is #{request_body}"
#       puts "subway #{status}"
       intent = request_body["request"]["intent"]["name"] if request_body["request"]["intent"]
       puts "intent #{intent}"
       say_this = ""
       if (intent == "GetAllStatus" || intent == nil)
          good_lines = status.select { |key, value| value.match("GOOD SERVICE")}.transpose[0]
          delayed_lines = status.select { |key, value| value.match("DELAYS")}.transpose[0]
          planned_work_lines = status.select { |key, value| value.match("PLANNED WORK")}.transpose[0]
          service_change_lines = status.select { |key, value| value.match("SERVICE CHANGE")}.transpose[0]
          puts "good lines are #{good_lines}"
          if (delayed_lines || planned_work_lines || service_change_lines)
             say_this = "ok. here's the situation... "
             if (delayed_lines && delayed_lines.count > 0)
                if (delayed_lines.count == 1)
                   delayed_line = delayed_lines[0].gsub(/(.{1})/, '\1 ')
                   say_this << "The #{delayed_line} is currently experiencing delays. " 
                else
                   say_this << "The #{lines_from_state(delayed_lines)} are currently experiencing delays.  " 
                end
             end
             if (planned_work_lines && planned_work_lines.count > 0)
                puts "planned_work_lines are #{planned_work_lines}"
                if (planned_work_lines.count == 1)
                   planned_work_line = planned_work_lines[0].gsub(/(.{1})/, '\1 ')
                   say_this << "The #{planned_work_line} is currently undergoing planned work.  " 
                else
                   say_this << "The #{lines_from_state(planned_work_lines)} are currently undergoing planned work.  " 
                end
             end
             if (service_change_lines && service_change_lines.count > 0)
                if (service_change_lines.count == 1)
                   service_change_line = service_change_lines[0].gsub(/(.{1})/, '\1 ')
                   say_this << "The #{service_change_line} has a major service change.  " 
                else
                   say_this << "The #{lines_from_state(service_change_lines)} have major service changes.  " 
                end
             end

             say_this << "All other lines are currently running smoothly."
          else
             say_this = "ok. Great news. "
             say_this << "All lines are currently running smoothly."
          end
          
          #say_this = "The #{delayed_lines}" 
       else
     
         say_this = "I can't do status of individual lines yet. Please check back in a few days."
         
       end

   rescue
     say_this = "rut roh. something failed"

   end 
   text = {"outputSpeech" => {"type" => "PlainText", "text" => say_this}}

   if (authentic)
      response = {
          "version" => "1.0",
          "response" => text,
          "shouldEndSession" => true
      } 
   else
      response = {
         "error" => "your response does not appear to be from a real alexa"
      }
   end 

   puts "response: #{response.to_json}"
 
   response.to_json
end