Contents

module FayeSupport
  class FakeFaye
    def on(type, &block)
      @events ||= {}
      @events[type] ||= []
      @events[type] << block
    end

    def send_event(type, data)
      Array(Hash(@events)[type]).each do |block| block.call(data) end
    end

    def message(message, extra_args = {})
      send_event(
        :message,
        OpenStruct.new(
          data: {
            "type" => "message",
            "text" => message
          }.merge(extra_args).to_json
        )
      )
    end
  end

  def self.included(base)
    base.instance_eval do
      let(:faye) { FakeFaye.new }

      before do
        allow(Faye::WebSocket::Client).to receive(:new).and_return faye
      end

      around(&:run)
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
boty-1.0.1	spec/support/faye_support.rb
boty-1.0.0	spec/support/faye_support.rb
boty-0.2.0	spec/support/faye_support.rb
boty-0.1.2	spec/support/faye_support.rb
boty-0.1.1	spec/support/faye_support.rb