require_relative '../../helpers'
require 'symphony/tasks/ssh'

context Symphony::Task::SSH do
	let( :ssh ) { (Pathname( __FILE__ ).dirname.parent.parent + 'fake_ssh').realpath }

	before( :each ) do
		described_class.configure(
			path: ssh.to_s,
			key:  '/tmp/sekrit.rsa',
			user: 'symphony'
		)
	end

	it_should_behave_like "an object with Configurability"

	describe 'subclassed' do
		let( :instance ) { Class.new(described_class).new('queue') }
		let( :payload ) {
			{ 'command' => 'woohoo', 'host' => 'example.com' }
		}

		it "aborts if there is no command in the payload" do
			expect {
				instance.work( {}, {} )
			}.to raise_exception( ArgumentError, /missing required option 'command'/i )
		end

		it "aborts if there is no host in the payload" do
			expect {
				instance.work({ 'command' => 'boop' }, {} )
			}.to raise_exception( ArgumentError, /missing required option 'host'/i )
		end

		it "builds the proper command line" do
			pipe = double( :fake_pipes ).as_null_object
			allow( IO ).to receive( :pipe ).and_return([ pipe, pipe ])

			args = [
				'-p', '22', '-i', '/tmp/sekrit.rsa', '-l', 'symphony', 'example.com', 'woohoo'
			]

			expect( Process ).to receive( :spawn ).with(
				*[ {}, ssh.to_s, described_class.opts, args ].flatten,
				out: pipe, in: pipe, close_others: true, unsetenv_others: true
			).and_return( 12 )

			expect( Process ).to receive( :waitpid2 ).with( 12 ).and_return([ 12, 1 ])

			code = instance.work( payload, {} )
			expect( code ).to eq( 1 )
		end

		it "execs and captures output" do
			code = instance.work( payload, {} )
			expect( code ).to eq( 0 )

			output = instance.instance_variable_get( :@output )
			expect( output ).to eq( 'Hi there!' )
		end
	end
end