module Pubsubstub

# File lib/pubsubstub.rb, line 56
def handle_error(error)
  logger.error("Uncaught exception: #{error.class}: #{error.message}\n#{error.backtrace.join("\n\t")}\n")
  error_handler && error_handler.call(error)
end

# File lib/pubsubstub.rb, line 52
def heartbeat_event
  Event.new('ping', name: 'heartbeat', retry_after: reconnect_timeout)
end

# File lib/pubsubstub.rb, line 44
def new_redis
  Redis.new(url: redis_url)
end

# File lib/pubsubstub.rb, line 26
def publish(channel_name, *args)
  Channel.new(channel_name).publish(Event.new(*args))
  nil
end

# File lib/pubsubstub.rb, line 36
def redis
  @redis || @mutex.synchronize { @redis ||= new_redis }
end

# File lib/pubsubstub.rb, line 40
def redis=(client)
  @mutex.synchronize { @redis = client }
end

# File lib/pubsubstub.rb, line 31
def redis_url=(url)
  @redis_url = url.to_s
  @redis = nil
end

# File lib/pubsubstub.rb, line 61
def report_errors
  yield
rescue => error
  handle_error(error)
  raise
end

# File lib/pubsubstub.rb, line 48
def subscriber
  @subscriber || @mutex.synchronize { @subscriber ||= Subscriber.new }
end