Add subchannel specs in.

lib/backbone_sync-rails/faye/event.rb

@@ -49,7 +49,9 @@ def data
         end
 
         def subchannel
-          @subchannel || @model.class.try(:faye_channel) || @model.class.table_name
+          @subchannel || @model.faye_channel
+        rescue NoMethodError => e
+          @model.class.table_name
         end
       end
     end

lib/backbone_sync-rails/faye/observer.rb

@@ -5,25 +5,25 @@ module Rails
     module Faye
       module Observer
         def after_update(model)
-          Event.new(model, :update, subchannel(model)).broadcast
+          Event.new(model, :update).broadcast
         rescue *NET_HTTP_EXCEPTIONS => e
           handle_net_http_exception(e)
         end
 
         def after_create(model)
-          Event.new(model, :create, subchannel(model)).broadcast
+          Event.new(model, :create).broadcast
         rescue *NET_HTTP_EXCEPTIONS => e
           handle_net_http_exception(e)
         end
 
         def after_destroy(model)
-          Event.new(model, :destroy, subchannel(model)).broadcast
+          Event.new(model, :destroy).broadcast
         rescue *NET_HTTP_EXCEPTIONS => e
           handle_net_http_exception(e)
         end
 
         def after_touch(model)
-          Event.new(model, :update, subchannel(model)).broadcast
+          Event.new(model, :update).broadcast
         rescue *NET_HTTP_EXCEPTIONS => e
           handle_net_http_exception(e)
         end
@@ -36,10 +36,6 @@ def handle_net_http_exception(exception)
           ::Rails.logger.error(exception.backtrace.join("\n"))
           ::Rails.logger.error("")
         end
-
-        def subchannel(model)
-          nil
-        end
       end
     end
   end

spec/dummy/app/models/backbone_sync_observer.rb

@@ -0,0 +1,4 @@
+class BackboneSyncObserver < ActiveRecord::Observer
+  observe :task, :comment
+  include BackboneSync::Rails::Faye::Observer
+end

spec/dummy/app/models/comment.rb

@@ -0,0 +1,7 @@
+class Comment < ActiveRecord::Base
+  belongs_to :task
+
+  def faye_channel
+    "tasks/#{task.id}/comments"
+  end
+end

spec/dummy/app/models/task.rb

@@ -1,2 +1,3 @@
 class Task < ActiveRecord::Base
+  has_many :comments
 end

spec/dummy/config/application.rb

@@ -25,7 +25,7 @@ class Application < Rails::Application
     # config.plugins = [ :exception_notification, :ssl_requirement, :all ]
 
     # Activate observers that should always be running.
-    config.active_record.observers = :task_observer
+    config.active_record.observers = :backbone_sync_observer
 
     # Set Time.zone default to the specified zone and make Active Record auto-convert to this zone.
     # Run "rake -D time" for a list of tasks for finding time zone names. Default is UTC.

spec/dummy/config/initializers/backbone_sync.rb

@@ -3,8 +3,4 @@
 BackboneSync::Rails::Faye.root_address = {
   'test' => 'http://localhost:9293',
 }[Rails.env]
-
-  def self.faye_channel
-    "#{table_name}"
-  end
 end

spec/dummy/db/migrate/20111128203027_create_comments.rb

@@ -0,0 +1,10 @@
+class CreateComments < ActiveRecord::Migration
+  def change
+    create_table :comments do |t|
+      t.text :body
+      t.integer :task_id
+
+      t.timestamps
+    end
+  end
+end

spec/faye/observer_spec.rb

@@ -1,50 +1,103 @@
 require 'spec_helper'
 
 describe BackboneSync::Rails::Faye::Observer do
-  it 'broadcasts updates over a Faye channel' do
-    task = Factory(:task, title: 'Old Title')
-    new_attributes = Factory.attributes_for(:task, title: 'New Title')
-    task.update_attributes(new_attributes)
-
-    expected_attributes = JSON.parse(task.to_json)
-
-    FakeFayeServer.messages.should include({
-      "channel" => "/sync/tasks",
-      "data" => {
-        "update" => {
-          task.id.to_s => expected_attributes
+  context 'Default model subchannel settings' do
+    it 'broadcasts updates over a Faye channel' do
+      task = Factory(:task, title: 'Old Title')
+      new_attributes = Factory.attributes_for(:task, title: 'New Title')
+      task.update_attributes(new_attributes)
+
+      expected_attributes = JSON.parse(task.to_json)
+
+      FakeFayeServer.messages.should include({
+        "channel" => "/sync/tasks",
+        "data" => {
+          "update" => {
+            task.id.to_s => expected_attributes
+          }
         }
-      }
-    })
-  end
+      })
+    end
+
+    it 'broadcasts destroys over a Faye channel' do
+      task = Factory(:task, title: 'Old Title')
+      task.destroy
 
-  it 'broadcasts destroys over a Faye channel' do
-    task = Factory(:task, title: 'Old Title')
-    task.destroy
+      expected_attributes = JSON.parse(task.to_json)
 
-    expected_attributes = JSON.parse(task.to_json)
+      FakeFayeServer.messages.should include({
+        "channel" => "/sync/tasks",
+        "data" => {
+          "destroy" => {
+            task.id.to_s => expected_attributes
+          }
+        }
+      })
+    end
+
+    it 'broadcasts creates over a Faye channel' do
+      task = Factory(:task)
+      expected_attributes = JSON.parse(task.to_json)
 
-    FakeFayeServer.messages.should include({
-      "channel" => "/sync/tasks",
-      "data" => {
-        "destroy" => {
-          task.id.to_s => expected_attributes
+      FakeFayeServer.messages.should include({
+        "channel" => "/sync/tasks",
+        "data" => {
+          "create" => {
+            task.id.to_s => expected_attributes
+          }
         }
-      }
-    })
+      })
+    end
   end
 
-  it 'broadcasts creates over a Faye channel' do
-    task = Factory(:task)
-    expected_attributes = JSON.parse(task.to_json)
+  context 'Model that is set in a child relationship' do
+    let(:task) { Factory(:task) }
+
+    it 'broadcasts updates over a Faye channel' do
+      comment = Factory(:comment, task: task, body: 'this body isn\'t too great')
+      new_attributes = Factory.attributes_for(:comment, body: 'I like this body')
+      comment.update_attributes(new_attributes)
+
+      expected_attributes = JSON.parse(comment.to_json)
+
+      FakeFayeServer.messages.should include({
+        "channel" => "/sync/tasks/#{task.id}/comments",
+        "data" => {
+          "update" => {
+            comment.id.to_s => expected_attributes
+          }
+        }
+      })
+    end
+
+    it 'broadcasts destroys over a Faye channel' do
+      comment = Factory(:comment, task: task)
+      comment.destroy
+
+      expected_attributes = JSON.parse(comment.to_json)
+
+      FakeFayeServer.messages.should include({
+        "channel" => "/sync/tasks/#{task.id}/comments",
+        "data" => {
+          "destroy" => {
+            comment.id.to_s => expected_attributes
+          }
+        }
+      })
+    end
+
+    it 'broadcasts creates over a Faye channel' do
+      comment = Factory(:comment, task: task)
+      expected_attributes = JSON.parse(comment.to_json)
 
-    FakeFayeServer.messages.should include({
-      "channel" => "/sync/tasks",
-      "data" => {
-        "create" => {
-          task.id.to_s => expected_attributes
+      FakeFayeServer.messages.should include({
+        "channel" => "/sync/tasks/#{task.id}/comments",
+        "data" => {
+          "create" => {
+            comment.id.to_s => expected_attributes
+          }
         }
-      }
-    })
+      })
+    end
   end
 end

spec/support/factories.rb

@@ -3,4 +3,9 @@
     title "An entirely relevent task"
     completed false
   end
+
+  factory :comment do
+    body "This body is hot."
+    association :task
+  end
 end