7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
# File 'lib/legion/api/absorbers.rb', line 7
def self.registered(app)
app.get '/api/absorbers' do
patterns = Legion::Extensions::Absorbers::PatternMatcher.list
items = patterns.map do |p|
{
type: p[:type],
value: p[:value],
priority: p[:priority],
description: p[:description],
absorber_class: p[:absorber_class]&.name
}
end
json_response(items)
end
app.post '/api/absorbers/dispatch' do
body = parse_request_body
input = body[:url] || body[:input]
halt 400, json_error('missing_param', 'url parameter is required') unless input
require 'legion/extensions/actors/absorber_dispatch'
context = body[:context] || {}
job_id = SecureRandom.hex(8)
Thread.new do
Legion::Extensions::Actors::AbsorberDispatch.dispatch(
input: input, job_id: job_id, context: context
)
rescue StandardError => e
Legion::Logging.error("Async absorb #{job_id} failed: #{e.message}") if defined?(Legion::Logging)
end
json_response({ success: true, job_id: job_id, absorber: PatternMatcher.resolve(input)&.name, status: :accepted })
end
app.get '/api/absorbers/resolve' do
input = params[:url] || params[:input]
halt 400, json_error('missing_param', 'url parameter is required') unless input
absorber = Legion::Extensions::Absorbers::PatternMatcher.resolve(input)
json_response({
input: input,
match: !absorber.nil?,
absorber: absorber&.name
})
end
end
|