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.
  intake: { 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] },
  deleted: { mode: :pubsub, args: %i[store key] },
  refreshed: { mode: :pubsub, args: %i[store key envelope change] },
  built: { mode: :pubsub, args: %i[store key envelope sources] },
  accepted: { mode: :pubsub, args: %i[store key target_key] },
  published: { mode: :pubsub, args: %i[store key envelope source target] },
  mv: { mode: :pubsub, args: %i[store key from_key to_key envelope] },
  reject: { mode: :pubsub, args: %i[store key target_key] },
  loaded: { mode: :pubsub, args: %i[store] },
  refresh_began: { mode: :pubsub, args: %i[store key mode] },
  refresh_failed: { mode: :pubsub, args: %i[store key error_class error_message] },
  refresh_detached: { mode: :pubsub, args: %i[store key started_at budget_ms] },
}.freeze

Instance Method Summary collapse

Constructor Details

#initialize(dispatcher: nil) ⇒ Registry

Returns a new instance of Registry.



25
26
27
28
29
 
# File 'lib/textus/hooks/registry.rb', line 25

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 



54
55
56
 
# File 'lib/textus/hooks/registry.rb', line 54

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

#pubsub_handlers(event) ⇒ Object 



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

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

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



31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/textus/hooks/registry.rb', line 31

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 



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

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

#rpc_names(event) ⇒ Object 



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

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