Class: Textus::Hooks::Registry

Inherits:
Object
  • Object
show all
Defined in:
lib/textus/hooks/registry.rb

Constant Summary collapse

EVENTS = 
{
  # RPC: exactly 1 handler per name; return value flows into store; failure aborts.
  fetch: { mode: :rpc, args: %i[store config args] },
  reduce: { mode: :rpc, args: %i[store rows config] },
  check: { mode: :rpc, args: %i[store] },

  # Pub-sub: 0..N handlers per event; return discarded; failure logged to audit.
  put: { mode: :pubsub, args: %i[store key envelope] },
  delete: { mode: :pubsub, args: %i[store key] },
  refresh: { mode: :pubsub, args: %i[store key envelope change] },
  build: { mode: :pubsub, args: %i[store key envelope sources] },
  accept: { mode: :pubsub, args: %i[store key target_key] },
}.freeze

Instance Method Summary collapse

Constructor Details

#initialize(dispatcher: nil) ⇒ Registry

Returns a new instance of Registry.



18
19
20
21
22
 
# File 'lib/textus/hooks/registry.rb', line 18

def initialize(dispatcher: nil)
  @rpc        = Hash.new { |h, k| h[k] = {} }   # event => { name => callable }
  @pubsub     = Hash.new { |h, k| h[k] = [] }   # event => [{name:, callable:, keys:}]
  @dispatcher = dispatcher
end

Instance Method Details

#listeners(event, key:) ⇒ Object 



47
48
49
 
# File 'lib/textus/hooks/registry.rb', line 47

def listeners(event, key:)
  @pubsub[event.to_sym].select { |h| h[:keys].nil? || matches_any?(h[:keys], key) }
end

#pubsub_handlers(event) ⇒ Object 



52
 
# File 'lib/textus/hooks/registry.rb', line 52

def pubsub_handlers(event) = @pubsub[event.to_sym]

#register(event, name, keys: nil, &blk) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/textus/hooks/registry.rb', line 24

def register(event, name, keys: nil, &blk)
  spec = EVENTS[event.to_sym] or raise UsageError.new("unknown event: #{event}")
  shape_check!(event, spec, blk)
  name = name.to_sym

  case spec[:mode]
  when :rpc
    raise UsageError.new("#{event} '#{name}' already registered") if @rpc[event.to_sym].key?(name)

    @rpc[event.to_sym][name] = blk
  when :pubsub
    raise UsageError.new("#{event} hook '#{name}' already registered") if @pubsub[event.to_sym].any? { |h| h[:name] == name }

    @pubsub[event.to_sym] << { name: name, callable: blk, keys: keys }
    @dispatcher&.subscribe(event, name, keys: keys, &blk)
  end
end

#rpc_callable(event, name) ⇒ Object 



42
43
44
45
 
# File 'lib/textus/hooks/registry.rb', line 42

def rpc_callable(event, name)
  @rpc[event.to_sym][name.to_sym] or
    raise UsageError.new("unknown #{event}: #{name}")
end

#rpc_names(event) ⇒ Object 



51
 
# File 'lib/textus/hooks/registry.rb', line 51

def rpc_names(event) = @rpc[event.to_sym].keys