Module: Toot

Defined in:
lib/toot.rb,
lib/toot/event.rb,
lib/toot/rails.rb,
lib/toot/config.rb,
lib/toot/source.rb,
lib/toot/version.rb,
lib/toot/subscription.rb,
lib/toot/calls_handlers.rb,
lib/toot/handler_service.rb,
lib/toot/publishes_event.rb,
lib/toot/calls_event_callback.rb,
lib/toot/subscriptions_service.rb,
lib/toot/registers_subscriptions.rb

Defined Under Namespace

Classes: CallbackFailure, CallsEventCallback, CallsHandlers, Config, ConfigError, Error, Event, HandlerService, PublishesEvent, Rails, RegisterSubscriptionFailure, RegistersSubscriptions, Source, Subscription, SubscriptionsService

Constant Summary collapse

CONFIG_ATTRS = 
%i[
  channel_prefix
  http_connection
  redis_connection
  callback_url
]
VERSION = 
"0.4.0"

Class Method Summary collapse

Class Method Details

.config ⇒ Object 



25
26
27
28
29
30
31
 
# File 'lib/toot.rb', line 25

def self.config
  if block_given?
    yield config
  else
    @config ||= Config.new
  end
end

.publish(channel, payload, prefix: config.channel_prefix) ⇒ Object 



37
38
39
40
41
42
 
# File 'lib/toot.rb', line 37

def self.publish(channel, payload, prefix: config.channel_prefix)
  Event.new(
    channel: [prefix, channel].join,
    payload: payload
  ).publish
end

.redis(connection = config.redis_connection, &block) ⇒ Object 



48
49
50
 
# File 'lib/toot.rb', line 48

def self.redis(connection=config.redis_connection, &block)
  connection.call(&block)
end

.reset_config ⇒ Object 



33
34
35
 
# File 'lib/toot.rb', line 33

def self.reset_config
  @config = Config.new
end

.subscribe(*args) ⇒ Object 



44
45
46
 
# File 'lib/toot.rb', line 44

def self.subscribe(*args)
  config.subscribe(*args)
end