# -------------------------------------------------------------
# To run this script we need:
# --------------------------------------------------------------
# - Mediapackage parameters like title, creator and subject
#   to search  workflows in Matterhorn and get their status.
#
# - Matterhorn server url, user and password.
#
# -------------------------------------------------------------
# Script output:
# --------------------------------------------------------------
# STATUS: INSTANTIATED
# STATUS: RUNNING
# STATUS: SUCCEEDED
#

require "rubygems"
require "curb"
require "nokogiri"
require "cgi"
require 'trollop'
require 'yaml'

opts = Trollop::options do
  opt :title, :type => String
  opt :creator, :type => String
  opt :subject, :type => String
end

title = opts[:title]
creator = opts[:creator]
subject = opts[:subject]

# This script lives in scripts while matterhorn.yml lives in scripts/
matt_props = YAML::load(File.open('matterhorn.yml'))
rest_server = matt_props['rest_server']

#Zipped file parameters to search a workflow in Matterhorn
title = "Business Ecosystem"
creator = "Richard Alam"
subject = "TTMG 5001"

#Create URI
encoded_params = CGI.escape("sort=DATE_CREATED_DESC&title=#{title}&creator=#{creator}&subject=#{subject}")

#Request Authentication
c = Curl::Easy.new("#{rest_server}/workflow/instances.xml?#{encoded_params}")
c.http_auth_types = :digest
c.username = 'matterhorn_system_account'
c.password = 'CHANGE_ME'
c.headers["X-Requested-Auth"] = "Digest"

#Ask for workflow status to Matterhorn.
#Stops when status is SUCCEEDED.
state = ""
begin  
  sleep 20
  tmp = state
  c.perform
  xml_response = c.body_str
  xml_doc  = Nokogiri::XML(xml_response)
  workflow  = xml_doc.xpath("//workflow")
  state = workflow[-1].attribute('state')
  if !tmp.to_str.eql? state.to_str
    puts "STATUS:  " + state
  end
end while !state.to_str.eql? "SUCCEEDED"