Merge pull request #7 from centrifugal/feature-broadcast

Add broadcast method

lib/centrifuge/client.rb

@@ -39,6 +39,10 @@ def url(path = nil)
       })
     end
 
+    def broadcast(channels, data)
+      Centrifuge::Builder.new('broadcast', { channels: channels, data: data }, self).process
+    end
+
     def publish(channel, data)
       Centrifuge::Builder.new('publish', { channel: channel, data: data }, self).process
     end

lib/centrifuge/version.rb

@@ -1,3 +1,3 @@
 module Centrifuge
-  VERSION = "1.0.1"
+  VERSION = "1.1.0"
 end

spec/client_spec.rb

@@ -1,19 +1,25 @@
 require 'spec_helper'
 
 describe Centrifuge::Client do
-  let(:options) { { scheme: :https, host: 'centrifugo-dev.herokuapp.com', port: 443, secret: 'secret' } }
+  let(:options) { { scheme: :https, host: 'centrifugo.herokuapp.com', port: 443, secret: 'secret' } }
   let(:client) { Centrifuge::Client.new(options) }
   let(:data) { { action: :test } }
 
   it 'generates url' do
-    expect(client.url.to_s).to eq "https://centrifugo-dev.herokuapp.com:443/api/"
+    expect(client.url.to_s).to eq "https://centrifugo.herokuapp.com:443/api/"
   end
 
   it 'publishes data' do
     channel = SecureRandom.hex
     expect(client.publish(channel, data)).to eq [{"body" => nil, "error" => nil, "method" => "publish"}]
   end
 
+  it 'broadcasts data' do
+    channel = SecureRandom.hex
+    channel1 = SecureRandom.hex
+    expect(client.broadcast([channel, channel1], data)).to eq [{"body" => nil, "error" => nil, "method" => "broadcast"}]
+  end
+
   it 'unsubscribes user' do
     channel = SecureRandom.hex
     expect(client.unsubscribe(channel, "23")).to eq [{"body"=>nil, "error"=>nil, "method"=>"unsubscribe"}]