require_relative '../../helpers'

require 'symphony/tasks/sshscript'

context Symphony::Task::SSHScript do

	before( :each ) do

		described_class.configure(

			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 ) {

			{ 'template' => 'script', 'host' => 'example.com' }

		}

		let( :opts ) {

			opts = described_class::DEFAULT_SSH_OPTIONS

			opts.merge!(

				:port    => 22,

				:keys    => ['/tmp/sekrit.rsa']

			)

			opts

		}

		let( :template ) { Inversion::Template.new("Hi there, <?attr name?>!") }

		before( :each ) do

			allow( Inversion::Template ).to receive( :load ).and_return( template )

			allow( Dir::Tmpname ).to receive( :make_tmpname ).and_return( "script_temp" )

		end

		it "aborts if there is no template in the payload" do

			expect {

				instance.work( {}, {} )

			}.to raise_exception( ArgumentError, /missing required option 'template'/i )

		end

		it "aborts if there is no host in the payload" do

			expect {

				instance.work({ 'template' => 'boop' }, {} )

			}.to raise_exception( ArgumentError, /missing required option 'host'/i )

		end

		it "adds debugging output if specified in the payload" do

			payload[ 'debug' ] = true

			options = opts.dup

			options.merge!(

				:logger  => Loggability[ Net::SSH ],

				:verbose => :debug

			)

			expect( Net::SSH ).to receive( :start ).with( 'example.com', 'symphony', options )

			instance.work( payload, {} )

		end

		it "attaches attributes to the scripts from the payload" do

			payload[ 'attributes' ] = { :name => 'Handsome' }

			conn = double( :ssh_connection )

			expect( instance ).to receive( :upload_script ).

				with( conn, "Hi there, Handsome!", "/tmp/script_temp" )

			expect( conn ).to receive( :exec! ).with( "/tmp/script_temp" )

			expect( conn ).to receive( :exec! ).with( "rm /tmp/script_temp" )

			expect( Net::SSH ).to receive( :start ).

				with( 'example.com', 'symphony', opts ).and_yield( conn )

			instance.work( payload, {} )

		end

		it "uploads the file and sets it executable" do

			conn = double( :ssh_connection )

			sftp = double( :sftp_connection )

			file = double( :remote_file_obj )

			fh   = double( :remote_filehandle )

			expect( conn ).to receive( :sftp ).and_return( sftp )

			expect( sftp ).to receive( :file ).and_return( file )

			expect( file ).to receive( :open ).

				with( "/tmp/script_temp", "w", 0755 ).and_yield( fh )

			expect( fh ).to receive( :print ).with( "Hi there, !" )

			expect( conn ).to receive( :exec! ).with( "/tmp/script_temp" )

			expect( conn ).to receive( :exec! ).with( "rm /tmp/script_temp" )

			expect( Net::SSH ).to receive( :start ).

				with( 'example.com', 'symphony', opts ).and_yield( conn )

			instance.work( payload, {} )

		end

		it "leaves the remote script in place if asked" do

			payload[ 'nocleanup' ] = true

			conn = double( :ssh_connection )

			expect( instance ).to receive( :upload_script ).

				with( conn, "Hi there, !", "/tmp/script_temp" )

			expect( conn ).to receive( :exec! ).with( "/tmp/script_temp" )

			expect( conn ).to_not receive( :exec! ).with( "rm /tmp/script_temp" )

			expect( Net::SSH ).to receive( :start ).

				with( 'example.com', 'symphony', opts ).and_yield( conn )

			instance.work( payload, {} )

		end

		it "remembers the output of the remote script" do

			conn = double( :ssh_connection )

			expect( instance ).to receive( :upload_script ).

				with( conn, "Hi there, !", "/tmp/script_temp" )

			expect( conn ).to receive( :exec! ).with( "/tmp/script_temp" ).and_return( "Hi there, !" )

			expect( conn ).to receive( :exec! ).with( "rm /tmp/script_temp" )

			expect( Net::SSH ).to receive( :start ).

				with( 'example.com', 'symphony', opts ).and_yield( conn )

			instance.work( payload, {} )

			output = instance.instance_variable_get( :@output )

			expect( output ).to eq( 'Hi there, !' )

		end

	end

end