Module: Textus::Produce::Acquire::Handler

Defined in:
lib/textus/produce/acquire/handler.rb

Overview

Invokes a :resolve_handler hook handler by name under a timeout — the single home for “call the intake handler under a deadline” (ADR 0048 D1). Shared by Produce::Acquire::Intake (the internal ingest mechanism — no public verb since ADR 0079) as driven by the ‘reconcile` sweep and `textus hook run` (ADR 0089 made ingest system-pushed; there is no read or put trigger). Always passes a Container as `caps:` so the hook contract (ADR 0027) is uniform across every entry point. Maps Timeout::Error to a UsageError; leaves any other error to the caller (call sites differ in how they wrap).

Constant Summary collapse

FETCH_TIMEOUT_SECONDS = 
30

Class Method Summary collapse

Class Method Details

.invoke(caps:, handler:, config:, args:, label:, timeout: FETCH_TIMEOUT_SECONDS) ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/textus/produce/acquire/handler.rb', line 19

def invoke(caps:, handler:, config:, args:, label:, timeout: FETCH_TIMEOUT_SECONDS)
  Timeout.timeout(timeout) do
    caps.rpc.invoke(:resolve_handler, handler, caps: caps, config: config, args: args)
  end
rescue Timeout::Error
  raise Textus::UsageError.new("#{label} '#{handler}' exceeded #{timeout}s timeout")
end