Contents

$:.unshift File.expand_path('../lib', __FILE__)

require 'eventflit-client'

require 'logger'

TEST_APP_KEY = "TEST_APP_KEY"

module EventflitClient
  class TestLogger < Logger
    attr_reader :test_messages

    def initialize(logdev, shift_age = 0, shift_size = 1048576)
      @test_messages = []
      super
    end
    def test(msg)
      @test_messages << msg
      debug msg
    end
  end

  class Socket
    # Simulate a connection being established
    def connect(async = false)
      @connection_thread = Thread.new do
        @connection = TestConnection.new
        @global_channel.dispatch('eventflit:connection_established', JSON.dump({'socket_id' => '123abc'}))
      end
      @connection_thread.run
      @connection_thread.join unless async
      return self
    end

    def simulate_received(event_name, event_data, channel_name)
      send_local_event(event_name, event_data, channel_name)
    end
  end

  class TestConnection
    def send(payload)
      EventflitClient.logger.test("SEND: #{payload}")
    end

    def close
    end
  end

  EventflitClient.logger = TestLogger.new('test.log')

end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
eventflit-client-0.1.0	spec/spec_helper.rb