#!/usr/bin/env ruby
#
# Copyright (C) 2006 SIPfoundry Inc.
# Licensed by SIPfoundry under the LGPL license.
# 
# Copyright (C) 2006 Pingtel Corp.
# Licensed to SIPfoundry under a Contributor Agreement.
#
##############################################################################

# system requires
require 'getoptlong'
require 'parsedate'

# set up the load path
thisdir = File.dirname(__FILE__)    # directory in which this file is located
$:.unshift(thisdir)

# application requires
require 'call_resolver'
require 'call_direction_plugin'
require 'stunnel_connection'


# Create a Call Resolver
resolver = CallResolver.new

if resolver.log.debug?
  resolver.log.debug("main called with these args: #{ARGV.join(' ')}")
end

# Parse command-line options
#   start: date/time from which to start analyzing call events
#   end:   date/time at which to end the analysis (defaults to 1 day later)
#   daily: perform daily processing based on the configuration -- resolve
#          calls and/or purge old data
# :TODO: Print out a helpful message if the caller enters no options or screws up
opts = GetoptLong.new(
  [ "--start", "-s", GetoptLong::OPTIONAL_ARGUMENT ],
  [ "--end",   "-e", GetoptLong::OPTIONAL_ARGUMENT ],
  [ "--daily", "-d", GetoptLong::NO_ARGUMENT ],
  [ "--help",  "-h", GetoptLong::NO_ARGUMENT ]
)

# Init options
start_time = end_time = nil
purge_flag = false
purge_time = 0
daily_flag = false

# Extract option values
# Convert start and end strings to date/time values.
opts.each do |opt, arg|
  case opt

  when "--start"
    start_time = Time.parse(arg)

  when "--end"
    end_time = Time.parse(arg)

  when "--daily"
    daily_flag = true
 
  when "--help"
    print <<EOT
usage: sipxcallresolver.sh [--start "time" [--end "time"]] [--daily] [--help]

  --start "time"  Specifies the start time of the window in which calls are to 
                  be resolved. The time format is ISO 8601.
  --end "time"    Specifies the end time of the window in which call are to be
                  resolved. The time format is ISO 8601.
  --daily         Indicates that the call resolver is called in "daily" mode:
                  * Create CDRs for calls in the previous 24 hours
                  * Purge CSE and CDR data older than 35 days
                  You can change the purge age by setting the configuration
                  parameter SIP_CALLRESOLVER_PURGE_AGE_CDR (units are days).
                  In daily mode, the "start" and "end" args are not used.
EOT
    exit

  end
end 

# Print out the location of the config file for troubleshooting.
# We can't just log it, because if the config is messed up then it may be hard
# to find the log file.
config_file = resolver.config.config_file
if config_file
  puts("Reading config from #{config_file}")
else
  puts("Unable to locate config file, using default settings")
end


stunnel_connection = StunnelConnection.new(resolver)

puts("Logging to #{resolver.log_device == STDOUT ? 'the console' : resolver.log_device}")

begin
  stunnel_connection.open(resolver.config)

  # Add the Call Direction Plugin as an observer so that it can compute call direction
  if CallDirectionPlugin.call_direction?(resolver.config)
    resolver.log.info("Call direction is enabled")
    resolver.add_observer(CallDirectionPlugin.new(resolver))
  end

  if daily_flag
    resolver.daily_run
  else
    # Resolve calls that occurred during the specified time window
    resolver.resolve(start_time, end_time)
  end  
  
rescue
  # Backstop exception handler: don't let any exceptions propagate back
  # to the caller.  Log the error and the stack trace.  The log message has to
  # go on a single line, unfortunately.  Embed "\n" for syslogviewer.
  start_line = "\n        from "    # start each backtrace line with this
  resolver.log.error"Exiting because of error: \"#{$!}\"" + start_line +
                    $!.backtrace.inject{|trace, line| trace + start_line + line}
                
ensure
  stunnel_connection.close
                    
end