lib/addy_lambda/common.rb in addy_lambda-0.1.0 vs lib/addy_lambda/common.rb in addy_lambda-0.1.1
- old
+ new
@@ -1,7 +1,6 @@
require 'json'
-require 'aws-sdk-lambda'
module AddyLambda
# Generic methods such as logging, error handling HTTP requests etc.
class Common
def self.generic_log(logger, event, context)
@@ -49,40 +48,14 @@
require 'scout_apm'
ScoutApm::Agent.instance.install
end
- # Lambda client can be obtained by running: lambda_client = Aws::Lambda::Client.new
- def self.post_slack_message(lambda_client, channel, message, emoji = ':tada', unfurl_links: false)
- input_params = {
- 'user' => 'Signature Request',
- 'channel' => channel,
- 'message' => message,
- 'emoji' => emoji,
- 'unfurl_links' => unfurl_links
- }
- response_body = invoke_lambda(lambda_client, 'slack-client', input_params)
- return response_body unless response_body.key?('error')
-
- logger.error(response_body['error'])
- end
-
- def self.invoke_lambda(lambda_client, function_name, payload)
- resp = lambda_client.invoke({
- function_name: function_name,
- invocation_type: 'RequestResponse',
- payload: payload.to_json
- })
- valid_json?(resp.payload.string)
- response_obj = JSON.parse(resp.payload.string)
- valid_json?(resp.payload.string) ? JSON.parse(response_obj['body']) : resp.payload.string
- end
-
def self.get_request(url, params = nil, headers = nil)
uri = URI(url)
uri.query = URI.encode_www_form(params) if params
request = Net::HTTP::Get.new(uri.request_uri)
- response = http_request(request, uri, headers)
+ http_request(request, uri, headers)
end
def self.delete_request(url, headers = nil)
uri = URI(url)
request = Net::HTTP::Delete.new(uri.request_uri)