integration_spec.rb in ar-async-counter-cache-0.1.1

- old
+ new
@@ -3,53 +3,94 @@
 describe "integration" do
 
   before(:each) do
     @worker = Resque::Worker.new(:testing)
     @worker.register_worker
-    # Models...
     @user1 = User.create(:name => "Susan")
     @user2 = User.create(:name => "Bob")
     @post1 = @user1.posts.create(:body => "I have a cat!")
     @post2 = @user1.posts.create(:body => "I have a mouse!")
     @comment1 = @post1.comments.create(:body => "Your cat sucks!", :user => @user2)
     @comment2 = @post1.comments.create(:body => "No it doesn't!", :user => @user1)
     @comment3 = @post2.comments.create(:body => "Your mouse also sucks!", :user => @user2)
   end
 
-  it "should set countercache asynchronously" do
+  it "should increment/decrement counter caches asynchronously in batches" do
+    # Should be asynchronous...
     @user1.posts_count.should == 0
     @user1.comments_count.should == 0
     @user2.posts_count.should == 0
     @user2.comments_count.should == 0
     @post1.count_of_comments.should == 0
     @post2.count_of_comments.should == 0
-  end
 
-  it "should perform one at a time" do
+    # 2 for posts incrementing users' posts counts
+    # 3 for comments incrementing users' comments counts
+    # 3 for comments incrementing posts' comments counts
+    Resque.size(:testing).should == 8
+
+    # [ArAsyncCounterCache::IncrementCountersWorker, "User", 1, "posts_count"]
     perform_next_job
-    @user1.reload.posts_count.should == 1
+    @user1.reload.posts_count.should == 2
     @user1.reload.comments_count.should == 0
     @user2.reload.posts_count.should == 0
     @user2.reload.comments_count.should == 0
     @post1.reload.count_of_comments.should == 0
     @post2.reload.count_of_comments.should == 0
-  end
 
-  it "should update all counters once the jobs are done" do
-    perform_all_jobs
+    # [ArAsyncCounterCache::IncrementCountersWorker, "User", 2, "comments_count"]
+    perform_next_job
     @user1.reload.posts_count.should == 2
+    @user1.reload.comments_count.should == 0
+    @user2.reload.posts_count.should == 0
+    @user2.reload.comments_count.should == 2
+    @post1.reload.count_of_comments.should == 0
+    @post2.reload.count_of_comments.should == 0
+
+    # [ArAsyncCounterCache::IncrementCountersWorker, "Post", 1, "count_of_comments"]
+    perform_next_job
+    @user1.reload.posts_count.should == 2
+    @user1.reload.comments_count.should == 0
+    @user2.reload.posts_count.should == 0
+    @user2.reload.comments_count.should == 2
+    @post1.reload.count_of_comments.should == 2
+    @post2.reload.count_of_comments.should == 0
+
+    # [ArAsyncCounterCache::IncrementCountersWorker, "User", 1, "comments_count"]
+    perform_next_job
+    @user1.reload.posts_count.should == 2
     @user1.reload.comments_count.should == 1
     @user2.reload.posts_count.should == 0
     @user2.reload.comments_count.should == 2
     @post1.reload.count_of_comments.should == 2
+    @post2.reload.count_of_comments.should == 0
+
+    # [ArAsyncCounterCache::IncrementCountersWorker, "Post", 2, "count_of_comments"]
+    perform_next_job
+    @user1.reload.posts_count.should == 2
+    @user1.reload.comments_count.should == 1
+    @user2.reload.posts_count.should == 0
+    @user2.reload.comments_count.should == 2
+    @post1.reload.count_of_comments.should == 2
     @post2.reload.count_of_comments.should == 1
-  end
 
-  it "should decrement synchronously" do
-    perform_all_jobs
+    # Should be done...
+    Resque.size(:testing).should == 0
+
     @comment1.destroy
     @comment2.destroy
     @comment3.destroy
+
+    # Should be asynchronous...
+    @user1.reload.posts_count.should == 2
+    @user1.reload.comments_count.should == 1
+    @user2.reload.posts_count.should == 0
+    @user2.reload.comments_count.should == 2
+    @post1.reload.count_of_comments.should == 2
+    @post2.reload.count_of_comments.should == 1
+
+    perform_all_jobs
+
     @user1.reload.posts_count.should == 2
     @user1.reload.comments_count.should == 0
     @user2.reload.posts_count.should == 0
     @user2.reload.comments_count.should == 0
     @post1.reload.count_of_comments.should == 0