--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/spec/symphony/tasks/ssh_spec.rb	Tue May 13 14:38:21 2014 -0700
@@ -0,0 +1,64 @@
+
+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'
+			]
+
+			expect( Process ).to receive( :spawn ).with(
+				*[ ssh.to_s, described_class.opts, args ].flatten,
+				:out => pipe, :in => pipe, :close_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
+