mirror of
https://github.com/fog/fog-aws.git
synced 2022-11-09 13:50:52 -05:00
461 lines
18 KiB
Ruby
461 lines
18 KiB
Ruby
|
Shindo.tests('AWS::Lambda | function requests', ['aws', 'lambda']) do
|
||
|
|
|
||
|
|
_lambda = Fog::AWS[:lambda]
|
||
|
|
account_id = _lambda.account_id
|
||
|
|
region = _lambda.region
|
||
|
|
|
||
|
|
function1 = IO.read(AWS::Lambda::Samples::FUNCTION_1)
|
||
|
|
function2 = IO.read(AWS::Lambda::Samples::FUNCTION_2)
|
||
|
|
zipped_function1 = Base64::encode64(AWS::Lambda::Formats.zip(function1))
|
||
|
|
zipped_function2 = Base64::encode64(AWS::Lambda::Formats.zip(function2))
|
||
|
|
|
||
|
|
function1_arn = nil
|
||
|
|
function1_name = 'function1'
|
||
|
|
function2_name = 'function2'
|
||
|
|
function1_handler = 'index.handler'
|
||
|
|
|
||
|
|
function_role = 'arn:aws:iam::647975416665:role/lambda_basic_execution'
|
||
|
|
|
||
|
|
sns_principal = 'sns.amazonaws.com'
|
||
|
|
sns_topic_sid = Fog::Mock.random_letters_and_numbers(32)
|
||
|
|
sns_allowed_action = 'lambda:invoke'
|
||
|
|
sns_topic_arn = Fog::AWS::Mock.arn('sns', account_id, 'mock_topic', region)
|
||
|
|
|
||
|
|
kinesis_stream_arn = Fog::AWS::Mock.arn('kinesis', account_id, 'mock_stream', region)
|
||
|
|
event_source_mapping1_id = nil
|
||
|
|
|
||
|
|
tests('success') do
|
||
|
|
|
||
|
|
tests('#list_functions').formats(AWS::Lambda::Formats::LIST_FUNCTIONS) do
|
||
|
|
result = _lambda.list_functions.body
|
||
|
|
functions = result['Functions']
|
||
|
|
returns(true) { functions.empty? }
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#create_function').formats(AWS::Lambda::Formats::CREATE_FUNCTION) do
|
||
|
|
description = 'a copy of my first function'
|
||
|
|
|
||
|
|
result = _lambda.create_function(
|
||
|
|
'FunctionName' => function1_name,
|
||
|
|
'Handler' => function1_handler,
|
||
|
|
'Role' => function_role,
|
||
|
|
'Description' => description,
|
||
|
|
'Code' => { 'ZipFile' => zipped_function1 }
|
||
|
|
).body
|
||
|
|
|
||
|
|
returns(true) { result.has_key?('FunctionArn') }
|
||
|
|
returns(true) { result['CodeSize'] > 0 }
|
||
|
|
returns(true) { result['MemorySize'] >= 128 }
|
||
|
|
returns(true) { result['FunctionName'].eql?(function1_name) }
|
||
|
|
returns(true) { result['Handler'].eql?(function1_handler) }
|
||
|
|
|
||
|
|
function1_arn = result['FunctionArn']
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#invoke') do
|
||
|
|
payload = { 'value1' => 2, 'value2' => 42 }
|
||
|
|
|
||
|
|
result = _lambda.invoke(
|
||
|
|
'FunctionName' => function1_name,
|
||
|
|
'Payload' => payload
|
||
|
|
).body
|
||
|
|
|
||
|
|
returns(false) { result.length.zero? }
|
||
|
|
returns(false) { result.match(/function:#{function1_name} was invoked/).nil? }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_function').formats(AWS::Lambda::Formats::GET_FUNCTION) do
|
||
|
|
result = _lambda.get_function('FunctionName' => function1_name).body
|
||
|
|
func_config = result['Configuration']
|
||
|
|
|
||
|
|
returns(false) { result['Code']['Location'].match(/^https:\/\/awslambda-/).nil? }
|
||
|
|
returns(true) { func_config.has_key?('FunctionArn') }
|
||
|
|
returns(true) { func_config['CodeSize'] > 0 }
|
||
|
|
returns(true) { func_config['MemorySize'] >= 128 }
|
||
|
|
returns(true) { func_config['FunctionName'].eql?(function1_name) }
|
||
|
|
returns(true) { func_config['Handler'].eql?(function1_handler) }
|
||
|
|
returns(true) { func_config['FunctionArn'].eql?(function1_arn) }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_function_configuration').formats(AWS::Lambda::Formats::GET_FUNCTION_CONFIGURATION) do
|
||
|
|
result = _lambda.get_function_configuration(
|
||
|
|
'FunctionName' => function1_name).body
|
||
|
|
|
||
|
|
returns(true) { result.has_key?('FunctionArn') }
|
||
|
|
returns(true) { result['CodeSize'] > 0 }
|
||
|
|
returns(true) { result['MemorySize'] >= 128 }
|
||
|
|
returns(true) { result['FunctionName'].eql?(function1_name) }
|
||
|
|
returns(true) { result['Handler'].eql?(function1_handler) }
|
||
|
|
returns(true) { result['FunctionArn'].eql?(function1_arn) }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#update_function_configuration').formats(AWS::Lambda::Formats::UPDATE_FUNCTION_CONFIGURATION) do
|
||
|
|
new_memory_size = 256
|
||
|
|
new_description = "this function does nothing, just let's call it foobar"
|
||
|
|
new_timeout = 10
|
||
|
|
|
||
|
|
result = _lambda.update_function_configuration(
|
||
|
|
'FunctionName' => function1_name,
|
||
|
|
'MemorySize' => new_memory_size,
|
||
|
|
'Description' => new_description,
|
||
|
|
'Timeout' => new_timeout
|
||
|
|
).body
|
||
|
|
|
||
|
|
returns(true) { result['CodeSize'] > 0 }
|
||
|
|
returns(true) { result['MemorySize'].eql?(new_memory_size) }
|
||
|
|
returns(true) { result['FunctionArn'].eql?(function1_arn) }
|
||
|
|
returns(true) { result['Description'].eql?(new_description) }
|
||
|
|
returns(true) { result['Timeout'].eql?(new_timeout) }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#update_function_code').formats(AWS::Lambda::Formats::UPDATE_FUNCTION_CODE) do
|
||
|
|
result = _lambda.update_function_code(
|
||
|
|
'FunctionName' => function1_name,
|
||
|
|
'ZipFile' => zipped_function2
|
||
|
|
).body
|
||
|
|
|
||
|
|
returns(true) { result.has_key?('FunctionArn') }
|
||
|
|
returns(true) { result['CodeSize'] > 0 }
|
||
|
|
returns(true) { result['MemorySize'] >= 128 }
|
||
|
|
returns(true) { result['FunctionName'].eql?(function1_name) }
|
||
|
|
returns(true) { result['Handler'].eql?(function1_handler) }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#add_permission').formats(AWS::Lambda::Formats::ADD_PERMISSION) do
|
||
|
|
params = {
|
||
|
|
'FunctionName' => function1_name,
|
||
|
|
'Principal' => sns_principal,
|
||
|
|
'StatementId' => sns_topic_sid,
|
||
|
|
'Action' => sns_allowed_action,
|
||
|
|
'SourceArn' => sns_topic_arn
|
||
|
|
}
|
||
|
|
result = _lambda.add_permission(params).body
|
||
|
|
statement = result['Statement']
|
||
|
|
|
||
|
|
returns(true) { statement['Action'].include?(sns_allowed_action) }
|
||
|
|
returns(true) { statement['Principal']['Service'].eql?(sns_principal) }
|
||
|
|
returns(true) { statement['Sid'].eql?(sns_topic_sid) }
|
||
|
|
returns(true) { statement['Resource'].eql?(function1_arn) }
|
||
|
|
returns(true) { statement['Effect'].eql?('Allow') }
|
||
|
|
returns(false) { statement['Condition'].empty? }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_policy').formats(AWS::Lambda::Formats::GET_POLICY) do
|
||
|
|
result = _lambda.get_policy('FunctionName' => function1_name).body
|
||
|
|
policy = result['Policy']
|
||
|
|
|
||
|
|
returns(false) { policy['Statement'].empty? }
|
||
|
|
|
||
|
|
statement = policy['Statement'].first
|
||
|
|
|
||
|
|
returns(true) { statement['Action'].include?(sns_allowed_action) }
|
||
|
|
returns(true) { statement['Principal']['Service'].eql?(sns_principal) }
|
||
|
|
returns(true) { statement['Sid'].eql?(sns_topic_sid) }
|
||
|
|
returns(true) { statement['Resource'].eql?(function1_arn) }
|
||
|
|
returns(true) { statement['Effect'].eql?('Allow') }
|
||
|
|
returns(false) { statement['Condition'].empty? }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#remove_permission') do
|
||
|
|
params = {
|
||
|
|
'FunctionName' => function1_name,
|
||
|
|
'StatementId' => sns_topic_sid
|
||
|
|
}
|
||
|
|
result = _lambda.remove_permission(params).body
|
||
|
|
|
||
|
|
returns(true) { result.empty? }
|
||
|
|
|
||
|
|
raises(Fog::AWS::Lambda::Error) do
|
||
|
|
_lambda.get_policy('FunctionName' => function1_name)
|
||
|
|
end
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#create_event_source_mapping').formats(AWS::Lambda::Formats::CREATE_EVENT_SOURCE_MAPPING) do
|
||
|
|
params = {
|
||
|
|
'FunctionName' => function1_name,
|
||
|
|
'EventSourceArn' => kinesis_stream_arn,
|
||
|
|
'Enabled' => true,
|
||
|
|
'StartingPosition' => 'TRIM_HORIZON'
|
||
|
|
}
|
||
|
|
result = _lambda.create_event_source_mapping(params).body
|
||
|
|
|
||
|
|
returns(true) { result['BatchSize'] > 0 }
|
||
|
|
returns(true) { result['EventSourceArn'].eql?(kinesis_stream_arn) }
|
||
|
|
returns(true) { result['FunctionArn'].eql?(function1_arn) }
|
||
|
|
returns(true) { result['LastProcessingResult'].eql?('No records processed') }
|
||
|
|
returns(true) { result['State'].eql?('Creating') }
|
||
|
|
returns(true) { result['StateTransitionReason'].eql?('User action') }
|
||
|
|
|
||
|
|
event_source_mapping1_id = result['UUID']
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#list_event_source_mappings').formats(AWS::Lambda::Formats::LIST_EVENT_SOURCE_MAPPINGS) do
|
||
|
|
params = { 'FunctionName' => function1_name }
|
||
|
|
result = _lambda.list_event_source_mappings(params).body
|
||
|
|
event_source_mappings = result['EventSourceMappings']
|
||
|
|
returns(false) { event_source_mappings.empty? }
|
||
|
|
mapping = event_source_mappings.first
|
||
|
|
returns(true) { mapping['UUID'].eql?(event_source_mapping1_id) }
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_event_source_mapping').formats(AWS::Lambda::Formats::GET_EVENT_SOURCE_MAPPING) do
|
||
|
|
params = { 'UUID' => event_source_mapping1_id }
|
||
|
|
result = _lambda.get_event_source_mapping(params).body
|
||
|
|
|
||
|
|
returns(true) { result['BatchSize'] > 0 }
|
||
|
|
returns(true) { result['EventSourceArn'].eql?(kinesis_stream_arn) }
|
||
|
|
returns(true) { result['FunctionArn'].eql?(function1_arn) }
|
||
|
|
returns(true) { result['LastProcessingResult'].eql?('OK') }
|
||
|
|
returns(true) { result['State'].eql?('Enabled') }
|
||
|
|
returns(true) { result['StateTransitionReason'].eql?('User action') }
|
||
|
|
returns(true) { result['UUID'].eql?(event_source_mapping1_id) }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#update_event_source_mapping').formats(AWS::Lambda::Formats::UPDATE_EVENT_SOURCE_MAPPING) do
|
||
|
|
new_batch_size = 500
|
||
|
|
enabled_mapping = false
|
||
|
|
params = {
|
||
|
|
'UUID' => event_source_mapping1_id,
|
||
|
|
'BatchSize' => new_batch_size,
|
||
|
|
'Enabled' => enabled_mapping
|
||
|
|
}
|
||
|
|
result = _lambda.update_event_source_mapping(params).body
|
||
|
|
|
||
|
|
returns(true) { result['BatchSize'].eql?(new_batch_size) }
|
||
|
|
returns(true) { result['EventSourceArn'].eql?(kinesis_stream_arn) }
|
||
|
|
returns(true) { result['FunctionArn'].eql?(function1_arn) }
|
||
|
|
returns(true) { result['LastProcessingResult'].eql?('OK') }
|
||
|
|
returns(true) { result['State'].eql?('Disabling') }
|
||
|
|
returns(true) { result['StateTransitionReason'].eql?('User action') }
|
||
|
|
returns(true) { result['UUID'].eql?(event_source_mapping1_id) }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#delete_event_source_mapping').formats(AWS::Lambda::Formats::DELETE_EVENT_SOURCE_MAPPING) do
|
||
|
|
params = { 'UUID' => event_source_mapping1_id }
|
||
|
|
result = _lambda.delete_event_source_mapping(params).body
|
||
|
|
returns(true) { result['BatchSize'] > 0 }
|
||
|
|
returns(true) { result['EventSourceArn'].eql?(kinesis_stream_arn) }
|
||
|
|
returns(true) { result['FunctionArn'].eql?(function1_arn) }
|
||
|
|
returns(false) { result['LastProcessingResult'].empty? }
|
||
|
|
returns(true) { result['State'].eql?('Deleting') }
|
||
|
|
returns(true) { result['StateTransitionReason'].eql?('User action') }
|
||
|
|
returns(true) { result['UUID'].eql?(event_source_mapping1_id) }
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#list_event_source_mappings again').formats(AWS::Lambda::Formats::LIST_EVENT_SOURCE_MAPPINGS) do
|
||
|
|
params = { 'FunctionName' => function1_name }
|
||
|
|
result = _lambda.list_event_source_mappings(params).body
|
||
|
|
event_source_mappings = result['EventSourceMappings']
|
||
|
|
returns(true) { event_source_mappings.empty? }
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#delete_function') do
|
||
|
|
result = _lambda.delete_function('FunctionName' => function1_name).body
|
||
|
|
|
||
|
|
returns(true) { result.empty? }
|
||
|
|
|
||
|
|
raises(Fog::AWS::Lambda::Error) do
|
||
|
|
_lambda.get_function('FunctionName' => function1_name)
|
||
|
|
end
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#list_functions again').formats(AWS::Lambda::Formats::LIST_FUNCTIONS) do
|
||
|
|
result = _lambda.list_functions.body
|
||
|
|
functions = result['Functions']
|
||
|
|
returns(true) { functions.empty? }
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#create_function for failures tests').formats(AWS::Lambda::Formats::CREATE_FUNCTION) do
|
||
|
|
description = 'failure tests function'
|
||
|
|
|
||
|
|
result = _lambda.create_function(
|
||
|
|
'FunctionName' => function2_name,
|
||
|
|
'Handler' => function1_handler,
|
||
|
|
'Role' => function_role,
|
||
|
|
'Description' => description,
|
||
|
|
'Code' => { 'ZipFile' => zipped_function1 }
|
||
|
|
).body
|
||
|
|
|
||
|
|
returns(true) { result.has_key?('FunctionArn') }
|
||
|
|
returns(true) { result['CodeSize'] > 0 }
|
||
|
|
returns(true) { result['MemorySize'] >= 128 }
|
||
|
|
returns(true) { result['FunctionName'].eql?(function2_name) }
|
||
|
|
returns(true) { result['Handler'].eql?(function1_handler) }
|
||
|
|
|
||
|
|
result
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('failures') do
|
||
|
|
|
||
|
|
tests("#invoke without function name").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.invoke.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#invoke nonexistent function").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = Fog::AWS[:lambda].invoke('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#get_function without function name").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_function.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#get_function on nonexistent function").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_function('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#get_function_configuration without function name").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_function_configuration.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#get_function_configuration on nonexistent function").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_function_configuration('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("update_function_configuration without function name").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.update_function_configuration.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#update_function_configuration on nonexistent function").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.update_function_configuration('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("update_function_code without function name").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.update_function_code.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#update_function_code on nonexistent function").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.update_function_code(
|
||
|
|
'FunctionName' => 'nonexistent',
|
||
|
|
'ZipFile' => zipped_function2
|
||
|
|
).body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#update_function_code on valid function without source").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.update_function_code('FunctionName' => 'foobar').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#delete_function without params").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.delete_function.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests("#delete_function on nonexistent function").raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.delete_function('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_policy without params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_policy.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_policy on nonexistent function').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_policy('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_policy on function without permissions').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_policy('FunctionName' => function2_name).body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#add_permission without params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.add_permission.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#add_permission on nonexistent function').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.add_permission('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#add_permission with missing params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.add_permission('FunctionName' => function2_name).body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#remove_permission without params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.remove_permission.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#remove_permission on nonexistent function').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.remove_permission('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#remove_permission on function with missing sid param').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_policy('FunctionName' => function2_name).body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#remove_permission on function with missing sid param').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_policy(
|
||
|
|
'FunctionName' => function2_name,
|
||
|
|
'StatementId' => 'nonexistent_statement_id'
|
||
|
|
).body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#create_event_source_mapping without params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.create_event_source_mapping.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#create_event_source_mapping on nonexistent function').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.create_event_source_mapping('FunctionName' => 'nonexistent').body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#create_event_source_mapping with missing params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.create_event_source_mapping('FunctionName' => function2_name).body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_event_source_mapping without params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.get_event_source_mapping.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#get_event_source_mapping nonexistent').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
mapping_id = "deadbeef-caca-cafe-cafa-ffffdeadbeef"
|
||
|
|
response = _lambda.get_event_source_mapping('UUID' => mapping_id).body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#update_event_source_mapping without params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.update_event_source_mapping.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#update_event_source_mapping nonexistent').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
mapping_id = "deadbeef-caca-cafe-cafa-ffffdeadbeef"
|
||
|
|
response = _lambda.update_event_source_mapping('UUID' => mapping_id).body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#delete_event_source_mapping without params').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
response = _lambda.delete_event_source_mapping.body
|
||
|
|
end
|
||
|
|
|
||
|
|
tests('#delete_event_source_mapping nonexistent').raises(Fog::AWS::Lambda::Error) do
|
||
|
|
mapping_id = "deadbeef-caca-cafe-cafa-ffffdeadbeef"
|
||
|
|
response = _lambda.create_event_source_mapping('UUID' => mapping_id).body
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|