12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
# File 'app/services/jumbotron/services/adapters/execute_endpoint.rb', line 12
def call
operation = adapter.operation(endpoint)
provider_result = operation.acquire(**(acquisition || {}))
unless provider_result.success?
fail_acquisition!(provider_result)
return
end
begin
context.sync_input = operation.transform(provider_result.output, observed_at: observed_at)
rescue Jumbotron::Adapters::TransformError => e
context.fail!(
application_error: Jumbotron::Errors::Adapters::NormalizationFailedError.new(
details: { message: e.message }
)
)
end
end
|