Sha256: e43b8ac3c7e0ccbb11da4e0a532684576bccdfbde3faf7508fd4a0b71bdacf25

Contents?: true

Size: 930 Bytes

Versions: 3

Compression:

Stored size: 930 Bytes

Contents

require ::File.expand_path('../spec_helper.rb', __FILE__)

describe FnordMetric::InboundDatagram do

  let(:inbound_datagram) { FnordMetric::InboundDatagram.new(nil) }

  before(:all) do
    @redis = Redis.new
    @redis_wrap = RedisWrap.new(@redis)
    FnordMetric::InboundDatagram.opts = {
      :redis_url => "redis://localhost:6379",
      :redis_prefix => "fnordmetric-test",
      :event_queue_ttl => 120
    }
  end

  describe "pushing new events" do
    it "should add parsable event to the queue" do
      data = %Q{{"_type": "started"}}

      lambda {
        inbound_datagram.receive_data data
      }.should change { @redis.llen("fnordmetric-test-queue") }.by +1
    end

    it "should reject non parsable events" do
      broken_data = %Q{{"_type" => "started"}}

      lambda {
        inbound_datagram.receive_data broken_data
      }.should_not change { @redis.llen("fnordmetric-test-queue") }
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
fnordmetric-0.7.5 spec/inbound_datagram_spec.rb
fnordmetric-0.7.4 spec/inbound_datagram_spec.rb
fnordmetric-0.7.3 spec/inbound_datagram_spec.rb