require 'spec_helper'

describe Firehose::Publisher do
  include EM::TestHelper

  let(:publisher)   { Firehose::Publisher.new }
  let(:channel_key) { "/firehose/publisher/test/#{Time.now.to_i}" }
  let(:message)     { "howdy friends!" }

  it "should have 100 MAX_MESSAGES" do
    Firehose::Publisher::MAX_MESSAGES.should == 100
  end

  it "should have 1 day TTL" do
    Firehose::Publisher::TTL.should == 86400
  end

  describe "#publish" do
    it "should publish message change" do
      em do
        hiredis = EM::Hiredis.connect
        hiredis.subscribe "firehose:channel_updates"
        hiredis.on(:message) {|_, msg|
          msg.should == "#{channel_key}\n1\n#{message}"
          em.next_tick { em.stop }
        }
        Firehose::Publisher.new.publish channel_key, message
      end
    end

    "\"'\r\t\n!@\#$%^&*()[]\v\f\a\b\e{}/=?+\\|".each_char do |char|
      it "should publish messages with the '#{char.inspect}' character" do
        msg = [char, message, char].join
        em 1 do
          Firehose::Publisher.new.publish(channel_key, msg).callback { em.stop }
        end
        redis_exec('lpop', "firehose:#{channel_key}:list").should == msg
      end
    end

    it "should add message to list" do
      em do
        Firehose::Publisher.new.publish(channel_key, message).callback { em.stop }
      end
      redis_exec('lpop', "firehose:#{channel_key}:list").should == message
    end

    it "should limit list to MAX_MESSAGES messages" do
      em do
        Firehose::Publisher::MAX_MESSAGES.times do |n|
          publisher.publish(channel_key, message)
        end
        publisher.publish(channel_key, message).callback { em.stop }
      end
      redis_exec('llen', "firehose:#{channel_key}:list").should == Firehose::Publisher::MAX_MESSAGES
    end

    it "should increment sequence" do
      sequence_key = "firehose:#{channel_key}:sequence"

      @done_counter = 0
      redis_exec('get', sequence_key).should be_nil
      em do
        publisher.publish(channel_key, message).callback { @done_counter += 1; em.next_tick { em.stop } if @done_counter > 1 }
        publisher.publish(channel_key, message).callback { @done_counter += 1; em.next_tick { em.stop } if @done_counter > 1 }
      end
      redis_exec('get', sequence_key).to_i.should == 2
    end

    it "should set expirery on sequence and list keys" do
      ttl = 78 # Why 78? Why not!

      em do
        publisher.publish(channel_key, message, :ttl => 78).callback do
          # Allow for 1 second of slippage/delay
          redis_exec('TTL', "firehose:#{channel_key}:sequence").should > (ttl- 1)
          redis_exec('TTL', "firehose:#{channel_key}:list").should > (ttl - 1)
          em.stop
        end
      end
    end

  end
end