#!/usr/bin/env ruby
require 'optparse'

# This hash will hold all of the options
# parsed from the command-line by
# OptionParser.
options = {}

optparse = OptionParser.new do|opts|
  # This displays the help screen, all programs are
  # assumed to have this option.
  opts.on( '-h', '--help', 'Display this screen' ) do
    puts opts
    exit
  end

  opts.on( '-p', '--pid FILE', 'pid_file' ) do |a|
    options[:pid_file] = a
  end

  opts.on( '-l', '--log FILE', 'log_file' ) do |a|
    options[:log_file] = a
  end

  opts.on( '-L', '--lock FILE', 'lock_file' ) do |a|
    options[:lock_file] = a
  end

  opts.on( '-d', '--daemonize', 'Daemonize' ) do
    options[:daemonize] = true
  end

  opts.on( '-s', '--daemonize_delay DELAY', 'Daemonized time' ) do |d|
    options[:daemonize_delay] = d
  end

  opts.on( '-r', '--raise', 'Raised execution' ) do
    options[:raise] = true
  end

  opts.on( '-w', '--watch_file FILE', 'Exit on touched file' ) do |w|
    options[:watch_file] = w
  end

  opts.on( '-W', '--watch_file_delay DELAY', 'Exit on touched file, after delay' ) do |w|
    options[:watch_file_delay] = w
  end

end

optparse.parse!

module Sample
  def puts(mes = "")
    tm = Time.now
    STDOUT.puts "#{tm.to_s} (#{tm.to_f}) - #{mes}"
    STDOUT.flush
  end

  def daemonize(pid_file, log_file, daemonize_delay = 0)
    puts "daemonize start #{pid_file}, #{log_file}, #{daemonize_delay}"

    if daemonize_delay && daemonize_delay.to_f > 0
      puts "daemonize delay start #{daemonize_delay}"
      sleep daemonize_delay.to_f
      puts "daemonize delay end"
    end

    daemon
    STDOUT.reopen(log_file, "a")
    STDERR.reopen(log_file, "a")
    File.open(pid_file, 'w'){|f| f.write $$.to_s}

    puts "daemonized"
  end

  def daemon
    exit if fork                     # Parent exits, child continues.
    Process.setsid                   # Become session leader.
    exit if fork                     # Zap session leader. See [1].

    STDIN.reopen "/dev/null"         # Free file descriptors and
    STDOUT.reopen "/dev/null", "a"   # point them somewhere sensible.
    STDERR.reopen '/dev/null', 'a'
    return 0
  end
end

extend Sample

if options[:daemonize]
  daemonize(options[:pid_file], options[:log_file], options[:daemonize_delay])
end

puts "Started #{ARGV.inspect}, #{options.inspect}, #{ENV["ENV1"]}"

if options[:lock_file]
  if File.exists?(options[:lock_file])
    puts "Lock file exists, exiting"
    exit 1
  else
    File.open(options[:lock_file], 'w'){|f| f.write $$ }
  end
end

if options[:raise]
  puts "Raised"
  File.unlink(options[:lock_file]) if options[:lock_file]
  exit 1
end

trap("USR1") do
  puts "USR1 signal!"
end

trap("USR2") do
  puts "USR2 start memory leak"
  $ar = []
  300_000.times{|i| $ar << "memory leak #{i}" * 10}
end

loop do
  sleep 0.1
  puts "tick"

  if options[:watch_file]
    if File.exists?(options[:watch_file])
      puts "watch file finded"
      File.unlink(options[:watch_file])

      if options[:watch_file_delay]
        puts "watch_file delay start"
        sleep options[:watch_file_delay].to_f
        puts "watch_file delay end"
      end

      break
    end
  end
end

puts "exit"
File.unlink(options[:lock_file]) if options[:lock_file]
exit 0