Contents

require 'spec_helper'

describe Firehose::Producer do
  let(:channel)       { "/channel-awesome" }
  let(:url)           { "#{Firehose::Default::URI}#{channel}"}
  let(:publish_stub)  { stub_request(:put, url) }
  let(:message)       { "hey dude" }

  before(:all) do
    Firehose::Producer.adapter = :net_http
  end

  after(:all) do
    Firehose::Producer.adapter = nil
  end

  it "should publish message to channel" do
    publish_stub.to_return(:body => "", :status => 202)

    Firehose::Producer.new.publish(message).to(channel)
    WebMock.should have_requested(:put, url).with { |req| req.body == message }
  end

  describe "connection error handling" do
    it "should raise PublishError if not 201" do
      publish_stub.to_return(:body => "", :status => 500)

      lambda{
        Firehose::Producer.new.publish(message).to(channel)
      }.should raise_exception(Firehose::Producer::PublishError)
    end

    it "should use .error_handler if not 201" do
      publish_stub.to_return(:body => "", :status => 500)

      producer = Firehose::Producer.new
      producer.on_error do |e|
        e.message.should =~ /could not publish.+to/i
      end
      producer.publish(message).to(channel)
    end

    it "should raise TimeoutError if timed out" do
      publish_stub.to_timeout

      lambda{
        Firehose::Producer.new.publish(message).to(channel)
      }.should raise_exception(Firehose::Producer::TimeoutError)
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
firehose-0.2.alpha.3	spec/lib/producer_spec.rb
firehose-0.2.alpha.2	spec/lib/producer_spec.rb
firehose-0.1.1	spec/lib/producer_spec.rb
firehose-0.1.0	spec/lib/producer_spec.rb
firehose-0.0.16	spec/lib/producer_spec.rb
firehose-0.0.15	spec/lib/producer_spec.rb