Module: Textus::Dispatcher

Defined in:
lib/textus/dispatcher.rb

Overview

Static verb → use-case map. Canonical lookup as of 0.27.0; replaces the Application::UseCase registry whose entries were populated by file-load side effects in 0.26.x.

Constant Summary collapse

VERBS = 
{
  # Write
  put: Textus::Write::Put,
  propose: Textus::Write::Propose,
  delete: Textus::Write::Delete,
  mv: Textus::Write::Mv,
  accept: Textus::Write::Accept,
  reject: Textus::Write::Reject,
  publish: Textus::Write::Publish,
  fetch: Textus::Write::FetchWorker,
  fetch_all: Textus::Write::FetchAll,
  retention_sweep: Textus::Write::RetentionSweep,

  # Read
  get: Textus::Read::Get,
  get_or_fetch: Textus::Read::GetOrFetch,
  list: Textus::Read::List,
  where: Textus::Read::Where,
  uid: Textus::Read::Uid,
  blame: Textus::Read::Blame,
  audit: Textus::Read::Audit,
  freshness: Textus::Read::Freshness,
  stale: Textus::Read::Stale,
  deps: Textus::Read::Deps,
  rdeps: Textus::Read::Rdeps,
  pulse: Textus::Read::Pulse,
  policy_explain: Textus::Read::PolicyExplain,
  published: Textus::Read::Published,
  schema: Textus::Read::SchemaEnvelope,
  validate_all: Textus::Read::ValidateAll,
  doctor: Textus::Read::Doctor,
  boot: Textus::Read::Boot,
  retainable: Textus::Read::Retainable,
  rules: Textus::Read::Rules,

  # Maintenance
  migrate: Textus::Maintenance::Migrate,
  zone_mv: Textus::Maintenance::ZoneMv,
  key_mv_prefix: Textus::Maintenance::KeyMvPrefix,
  key_delete_prefix: Textus::Maintenance::KeyDeletePrefix,
  rule_lint: Textus::Maintenance::RuleLint,
}.freeze

Class Method Summary collapse

Class Method Details

.fetch(verb) ⇒ Object 



49
50
51
 
# File 'lib/textus/dispatcher.rb', line 49

def self.fetch(verb)
  VERBS.fetch(verb.to_sym) { raise UsageError.new("unknown verb: #{verb.inspect}") }
end

.invoke(verb, container:, call:, args: [], kwargs: {}) ⇒ Object

Single home for the uniform use-case invocation protocol (ADR 0023): look up the verb, construct on (container:, call:), and invoke #call.



55
56
57
 
# File 'lib/textus/dispatcher.rb', line 55

def self.invoke(verb, container:, call:, args: [], kwargs: {})
  fetch(verb).new(container: container, call: call).call(*args, **kwargs)
end