Module: WolfCore::LambdaFunctionOperations
- Included in:
- ApplicationService, Barton::Routing
- Defined in:
- lib/wolf_core/infrastructure/lambda_function_operations.rb
Instance Method Summary collapse
- #deep_parse_json(input) ⇒ Object
- #get_event_params(event) ⇒ Object
- #invoke_lambda(function_name:, payload:) ⇒ Object
- #result_to_response(result) ⇒ Object
Instance Method Details
#deep_parse_json(input) ⇒ Object
13 14 15 16 17 18 19 20 21 22 23 |
# File 'lib/wolf_core/infrastructure/lambda_function_operations.rb', line 13 def deep_parse_json(input) while input.is_a?(String) begin input = JSON.parse(input) rescue JSON::ParserError break end end input&.with_indifferent_access || {} end |
#get_event_params(event) ⇒ Object
7 8 9 10 11 |
# File 'lib/wolf_core/infrastructure/lambda_function_operations.rb', line 7 def get_event_params(event) event_body = event['body'] return deep_parse_json(event_body) if event_body.present? event.with_indifferent_access end |
#invoke_lambda(function_name:, payload:) ⇒ Object
3 4 5 |
# File 'lib/wolf_core/infrastructure/lambda_function_operations.rb', line 3 def invoke_lambda(function_name:, payload:) WolfCore::LambdaFunctionDataSource.invoke(function_name: function_name, payload: payload) end |
#result_to_response(result) ⇒ Object
25 26 27 28 29 30 31 |
# File 'lib/wolf_core/infrastructure/lambda_function_operations.rb', line 25 def result_to_response(result) if result.success? { statusCode: 200, body: result.data.to_h.to_json } else { statusCode: result.error.status || 422, body: result.error.to_h.to_json } end end |