require 'test/unit'
require 'rubygems'
require 'open3'
require 'client'

# Test case for the options of the chain reactor executable.
class TestChainReactorStart < Test::Unit::TestCase

  if RUBY_PLATFORM != 'java'
    def setup
      @test_path = File.dirname(__FILE__) 
      @bin_path = @test_path + '/../bin/chain-reactor'
      @chainfile_path = @test_path + '/chainfile.test'
      @pid_path = @test_path + '/chain-reactor.pid'
    end

    def teardown
      _,_,_,t = stop_chain_reactor
      if t.nil?
        # Ruby 1.8
        sleep 2
      else
        # Ruby 1.9+
        t.value
      end
      
      $stdout = STDOUT
    end

    def start_chain_reactor(arg_string)
      Open3.popen3("#{@bin_path} start #{@chainfile_path} #{arg_string} --pidfile #{@pid_path}")
    end

    def stop_chain_reactor
      Open3.popen3("#{@bin_path} stop #{@chainfile_path} --pidfile #{@pid_path}")
    end

    def test_start_daemon
      if RUBY_VERSION.to_f < 1.9
        # Thread is not available
        return
      end
      _, stdout, _, thread = start_chain_reactor('')
      output = stdout.read

      assert_match(/Registered 1 reactions/,output)
      assert_match(/Starting daemon, PID file => #{@pid_path}/,output)
      assert_match(/Daemon has started successfully/,output)

      # Wait for thread to exit
      thread.value

      # Thread stopped as it's daemonized
      assert_equal true, thread.stop?

      assert File.file? @pid_path
      pid = File.new(@pid_path).read.to_i

      ps_output = `ps p #{pid} --no-heading`
      assert_not_equal "", ps_output

      assert_match(/chain\-reactor start/,ps_output)
    end

    def test_start_daemon_and_communicate_with_client
      _, stdout, stderr, _ = start_chain_reactor('')
      output = stdout.read
      assert_match(/Daemon has started successfully/,output)

      assert_nothing_raised ChainReactor::ClientError do
        $stdout = File.new('/dev/null','w')
        client = ChainReactor::Client.new('127.0.0.1',1987)
        client.send_as_json({:hello => :world})
      end
    end

    def test_start_daemon_with_port_override_and_communicate_with_client
      _, stdout, _, _ = start_chain_reactor('--port 20100')
      output = stdout.read
      assert_match(/Daemon has started successfully/,output)

      assert_nothing_raised ChainReactor::ClientError do
        $stdout = File.new('/dev/null','w')
        client = ChainReactor::Client.new('127.0.0.1',20100)
        client.send({:hello => :world})
      end
    end

    def test_start_daemon_with_address_override_and_communicate_with_client
      _, stdout, _, _ = start_chain_reactor('--address 0.0.0.0')
      output = stdout.read
      assert_match(/Daemon has started successfully/,output)

      assert_nothing_raised ChainReactor::ClientError do
        $stdout = File.new('/dev/null','w')
        client = ChainReactor::Client.new('0.0.0.0',1987)
        client.send({:hello => :world})
      end
    end
  end
    
end