require 'spec_helper'

describe Weeter::Twitter::TweetConsumer do


  describe "auth" do
    it 'should use connect to JSON stream with auth options for the configuration' do
      @mock_stream = mock('JSONStream', :each_item => nil, :on_error => nil, :on_max_reconnects => nil)
      Twitter::JSONStream.stub!(:connect).and_return(@mock_stream)

      Weeter::Configuration::TwitterConfig.instance.stub!(:auth_options).and_return(:foo => :bar)
      consumer = Weeter::Twitter::TweetConsumer.new(Weeter::Configuration::TwitterConfig.instance, mock('NotificationPlugin'))
      Twitter::JSONStream.should_receive(:connect).with(hash_including(:foo => :bar))
      consumer.connect({'follow' => ['1','2']})
    end
  end

  describe "connecting to twitter" do

    before(:each) do
      @filter_params = {'follow' => ['1','2','3']}
      Weeter::Configuration::TwitterConfig.instance.stub!(:auth_options).and_return(:foo => :bar)
      @tweet_values = {'text' => "Hey", 'id_str' => "123", 'user' => {'id_str' => "1"}}
      @mock_stream = mock('JSONStream', :on_error => nil, :on_max_reconnects => nil)
      @mock_stream.stub!(:each_item).and_yield(MultiJson.encode(@tweet_values))
      Twitter::JSONStream.stub!(:connect).and_return(@mock_stream)
      @client_proxy = mock('NotificationPlugin', :publish_tweet => nil)
      @consumer = Weeter::Twitter::TweetConsumer.new(Weeter::Configuration::TwitterConfig.instance, @client_proxy)
    end

    after(:each) do
      @consumer.connect(@filter_params)
    end

    it "should instantiate a TweetItem" do
      tweet_item = Weeter::TweetItem.new(@tweet_values)
      Weeter::TweetItem.should_receive(:new).with({'text' => "Hey", 'id_str' => "123", 'user' => {'id_str' => "1"}}).and_return(tweet_item)
    end

    it "should connect to a Twitter JSON stream" do
      Twitter::JSONStream.should_receive(:connect).
        with(:ssl => true, :foo => :bar, :params => {'follow' => [1,2,3]}, :method => 'POST')
    end

    it "should publish new tweet if publishable" do
      mock_tweet = mock('tweet', :deletion? => false, :publishable? => true)
      tweet_item = Weeter::TweetItem.stub!(:new).and_return mock_tweet
      @client_proxy.should_receive(:publish_tweet).with(mock_tweet)
    end

    it "should not publish unpublishable tweets" do
      mock_tweet = mock('tweet', :deletion? => false, :publishable? => false, :[] => '')
      tweet_item = Weeter::TweetItem.stub!(:new).and_return mock_tweet
      @client_proxy.should_not_receive(:publish_tweet).with(mock_tweet)
    end

    it "should delete deletion tweets" do
      mock_tweet = mock('tweet', :deletion? => true, :publishable? => false)
      tweet_item = Weeter::TweetItem.stub!(:new).and_return mock_tweet
      @client_proxy.should_receive(:delete_tweet).with(mock_tweet)
    end
  end

end