spec/twitter/json_stream_spec.rb in twitter-stream-0.1.12 vs spec/twitter/json_stream_spec.rb in twitter-stream-0.1.13

@@ -19,76 +19,95 @@
 end
 
 
 
 describe JSONStream do
-  
+
+  context "authentication" do
+    it "should connect with basic auth credentials" do
+      connect_stream :auth => "username:password"
+      $recieved_data.should include('Authorization: Basic')
+    end
+
+    it "should connect with oauth credentials" do
+      oauth = {
+        :consumer_key => '1234567890',
+        :consumer_secret => 'abcdefghijklmnopqrstuvwxyz',
+        :access_key => 'ohai',
+        :access_secret => 'ohno'
+      }
+      connect_stream :oauth => oauth
+      $recieved_data.should include('Authorization: OAuth')
+    end
+  end
+
   context "on create" do
-    
+
     it "should return stream" do
       EM.should_receive(:connect).and_return('TEST INSTANCE')
       stream = JSONStream.connect {}
       stream.should == 'TEST INSTANCE'
     end
-    
+
     it "should define default properties" do
       EM.should_receive(:connect).with do |host, port, handler, opts|
         host.should == 'stream.twitter.com'
         port.should == 80
         opts[:path].should == '/1/statuses/filter.json'
         opts[:method].should == 'GET'
       end
       stream = JSONStream.connect {}
     end
-    
+
     it "should connect to the proxy if provided" do
       EM.should_receive(:connect).with do |host, port, handler, opts|
         host.should == 'my-proxy'
         port.should == 8080
         opts[:host].should == 'stream.twitter.com'
         opts[:port].should == 80
         opts[:proxy].should == 'http://my-proxy:8080'
       end
       stream = JSONStream.connect(:proxy => "http://my-proxy:8080") {}
     end
+
   end
-  
+
   context "on valid stream" do
     attr_reader :stream
     before :each do
       $data_to_send = read_fixture('twitter/basic_http.txt')
       $recieved_data = ''
       $close_connection = false
     end
-    
+
     it "should add no params" do
       connect_stream
       $recieved_data.should include('/1/statuses/filter.json HTTP')
     end
-    
+
     it "should add custom params" do
       connect_stream :params => {:name => 'test'}
       $recieved_data.should include('?name=test')
     end
-    
+
     it "should parse headers" do
       connect_stream
       stream.code.should == 200
       stream.headers[0].downcase.should include('content-type')
     end
-    
+
     it "should parse headers even after connection close" do
       connect_stream
       stream.code.should == 200
       stream.headers[0].downcase.should include('content-type')
     end
-    
+
     it "should extract records" do
       connect_stream :user_agent => 'TEST_USER_AGENT'
       $recieved_data.upcase.should include('USER-AGENT: TEST_USER_AGENT')
     end
-    
+
     it "should send correct user agent" do
       connect_stream
     end
   end
 
@@ -96,99 +115,99 @@
     it "should reconnect on network failure" do
       connect_stream do
         stream.should_receive(:reconnect)
       end
     end
-    
+
     it "should reconnect with 0.25 at base" do
       connect_stream do
         stream.should_receive(:reconnect_after).with(0.25)
       end
     end
-    
+
     it "should reconnect with linear timeout" do
       connect_stream do
         stream.nf_last_reconnect = 1
         stream.should_receive(:reconnect_after).with(1.25)
       end
     end
-    
+
     it "should stop reconnecting after 100 times" do
       connect_stream do
         stream.reconnect_retries = 100
         stream.should_not_receive(:reconnect_after)
       end
     end
-    
+
     it "should notify after reconnect limit is reached" do
       timeout, retries = nil, nil
       connect_stream do
         stream.on_max_reconnects do |t, r|
           timeout, retries = t, r
         end
         stream.reconnect_retries = 100
       end
       timeout.should == 0.25
       retries.should == 101
-    end    
+    end
   end
-  
+
   context "on network failure" do
     attr_reader :stream
     before :each do
       $data_to_send = ''
       $close_connection = true
     end
-    
+
     it "should timeout on inactivity" do
       connect_stream :stop_in => 1.5 do
-        stream.should_receive(:reconnect)        
+        stream.should_receive(:reconnect)
       end
-    end    
-    
+    end
+
     it_should_behave_like "network failure"
   end
-  
+
   context "on server unavailable" do
-    
+
     attr_reader :stream
-    
-    # This is to make it so the network failure specs which call connect_stream  
-    # can be reused. This way calls to connect_stream won't actually create a 
+
+    # This is to make it so the network failure specs which call connect_stream
+    # can be reused. This way calls to connect_stream won't actually create a
     # server to listen in.
     def connect_stream_without_server(opts={},&block)
       connect_stream_default(opts.merge(:start_server=>false),&block)
     end
     alias_method :connect_stream_default, :connect_stream
     alias_method :connect_stream, :connect_stream_without_server
-    
+
     it_should_behave_like "network failure"
-  end  
-  
+  end
+
   context "on application failure" do
     attr_reader :stream
     before :each do
       $data_to_send = 'HTTP/1.1 401 Unauthorized\r\nWWW-Authenticate: Basic realm="Firehose"\r\n\r\n1'
       $close_connection = true
     end
-    
+
     it "should reconnect on application failure 10 at base" do
       connect_stream do
         stream.should_receive(:reconnect_after).with(10)
       end
     end
-    
+
     it "should reconnect with exponential timeout" do
       connect_stream do
         stream.af_last_reconnect = 160
         stream.should_receive(:reconnect_after).with(320)
       end
     end
-    
+
     it "should not try to reconnect after limit is reached" do
       connect_stream do
         stream.af_last_reconnect = 320
         stream.should_not_receive(:reconnect_after)
       end
     end
-  end  
+  end
 end