event_spec.rb in fnordmetric-0.5.0

- old
+ new
@@ -1,46 +1,127 @@
 require ::File.expand_path('../spec_helper.rb', __FILE__)
 
-include FnordMetric
+describe FnordMetric::Event do
 
-describe "event" do
+  include FnordMetric
 
-  before(:each) do
-    Event.destroy_all
-  end
+  before(:all) do
+    @now = Time.utc(1992,01,13,5,23,23).to_i   
+    @redis = Redis.new
+    @redis_wrap = RedisWrap.new(@redis)
 
-  it "should track an event" do
-    event = Event.track!('_referral', :foobar => "fnord")
-    Event.last[:type].should == "_referral"
-    Event.last[:foobar].should == "fnord"
-  end
+    @namespace = "fnordmetric-test-ns123" 
+    @timeline = "#{@namespace}-timeline"
 
-  it "should track an event via the proxy method" do
-    FnordMetric.track('blubb', :foo => "bar")
-    FnordMetric::Event.last.foo.should == "bar"
+    @opts = {         
+      :namespace_prefix => "#{@namespace}",
+      :redis_prefix => "fnordmetric-test",
+      :redis => @redis
+    }  
   end
 
-  it "should access info like a 'ostruct' object" do
-    event = Event.track!('_referral', :foobar => "fnord")
-    Event.last.type.should == "_referral"
-    Event.last.foobar.should == "fnord"
-  end
+  describe "finding events" do
 
-  it "should insert a data point in the past" do
-    my_time = 23.minutes.ago
-    event = Event.track!('_referral', :foobar => "fnord", :time => my_time)
-    Event.last[:type].should == "_referral"
-    Event.last[:foobar].should == "fnord"
-    Event.last[:time].should == my_time.to_i
-  end
+    before(:each) do        
+      @redis.keys("fnordmetric-test-*").each { |k| @redis.del(k) }     
+    end
 
-  it "should save integer data" do
-    event = Event.track!('_test', :num => 23)
-    Event.last.num.should == 23
-  end
+    it "should find all events" do
+      create_event("242342", {:_type => "foo", :_time => @now})
+      create_event("453484", {:_type => "foo", :_time => @now})
+      Event.all(@opts).length.should == 2
+    end
 
-  it "should save float data" do
-    event = Event.track!('_test', :num => 42.5)
-    Event.last.num.should == 42.5
+    it "should find all events and return event objects" do
+      create_event("434454", {:_type => "foo", :_time => @now})
+      Event.all(@opts).first.should be_a(FnordMetric::Event)
+    end
+
+    it "should find all events and returnevent objects with time" do
+      create_event("352234", {:_type => "Fn0rd", :blah => :blubb, :_time => @now})
+      events = Event.all(@opts) 
+      events.first.time.to_i.should == @now
+    end
+
+    it "should find an event and return a event object" do
+      create_event("756753", {:_type => "Fn0rd", :_time => @now})
+      event = Event.find("756753", @opts)
+      event.should be_a(FnordMetric::Event)
+      event.type.should == "Fn0rd"
+    end
+
+    it "should find an event and return a event object with data" do
+      create_event("53454", {:_type => "Fn0rd", :blah => :blubb, :_time => @now})
+      event = Event.find("53454", @opts)  
+      event.data(:blah).should == "blubb"
+    end
+
+    it "should find an event and return a event object with id" do
+      create_event("5262435", {:_type => "Fn0rd", :blah => :blubb, :_time => @now})
+      event = Event.find("5262435", @opts) 
+      event.id.should == "5262435"
+    end
+
+    it "should find all in the correct order" do
+      create_event("5645642", {:_type => "foo", :_time => @now-17})
+      create_event("2342366", {:_type => "foo", :_time => @now-23})
+      create_event("3452345", {:_type => "foo", :_time => @now-42})
+      create_event("6345345", {:_type => "foo", :_time => @now-5})
+      Event.all(@opts).length.should == 4
+      Event.all(@opts)[0].id.should == "6345345"
+      Event.all(@opts)[1].id.should == "5645642"
+      Event.all(@opts)[2].id.should == "2342366"
+      Event.all(@opts)[3].id.should == "3452345"
+    end
+
+    it "should find all events since a given time, including that exact time" do
+      create_event("3452345", {:_type => "foo", :_time => @now-42})
+      create_event("2342366", {:_type => "foo", :_time => @now-23})
+      create_event("5645642", {:_type => "foo", :_time => @now-17})
+      create_event("6345345", {:_type => "foo", :_time => @now-5})
+      Event.all(@opts).length.should == 4
+      Event.all(@opts.merge(:since => @now-42)).length.should == 4
+      Event.all(@opts.merge(:since => @now-23)).length.should == 3
+      Event.all(@opts.merge(:since => @now-22)).length.should == 2
+      Event.all(@opts.merge(:since => @now-17)).length.should == 2
+      Event.all(@opts.merge(:since => @now-16)).length.should == 1
+      Event.all(@opts.merge(:since => @now-5)).length.should == 1
+    end
+
+    it "should find a maximum number of events" do
+      create_event("3452345", {:_type => "foo", :_time => @now-42})
+      create_event("2342366", {:_type => "foo", :_time => @now-23})
+      create_event("5645642", {:_type => "foo", :_time => @now-17})
+      create_event("6345345", {:_type => "foo", :_time => @now-5})
+      Event.all(@opts).length.should == 4
+      Event.all(@opts.merge(:limit => 2)).length.should == 2
+      Event.all(@opts.merge(:limit => 2)).first.id.should == "6345345"
+      Event.all(@opts.merge(:limit => 2)).last.id.should == "5645642"
+    end
+
+    it "should find all events by type" do
+      namespace = Namespace.new(:ns123, :redis_prefix => "fnordmetric-test")
+      namespace.ready!(@redis_wrap).announce(
+        :_type => "fn0rd",
+        :_time => @now
+      )
+      namespace.ready!(@redis_wrap).announce(
+        :_type => "f00bar",
+        :_time => @now
+      )
+      namespace.ready!(@redis_wrap).announce(
+        :_type => "fn0rd",
+        :_time => @now
+      )
+      Event.by_type('fn0rd', @opts).length.should == 2
+      Event.by_type('f00bar', @opts).length.should == 1
+    end
+
+    def create_event(event_id, event_data)
+      @redis_wrap.zadd(@timeline, event_data.delete(:_time), event_id)
+      @redis.set("fnordmetric-test-event-#{event_id}", event_data.to_json)        
+    end
+
   end
-  
+
+
 end
\ No newline at end of file