/
executor.rb
61 lines (51 loc) · 1.99 KB
/
executor.rb
1
2
3
4
5
6
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
54
55
56
57
58
59
60
61
require 'cloud_formation/bridge/exception_notifier'
require 'cloud_formation/bridge/names'
require 'cloud_formation/bridge/resources/subscribe_queue_to_topic'
require 'cloud_formation/bridge/resources/cloud_formation_outputs'
require 'cloud_formation/bridge/resources/elasti_cache_replication_group'
require 'cloud_formation/bridge/resources/elasti_cache_replica_cluster'
require 'cloud_formation/bridge/resources/elasti_cache_node_urls'
module CloudFormation
module Bridge
class Executor
include CloudFormation::Bridge::Names
DEFAULT_REGISTRY = {
"Custom::SubscribeSQSQueueToSNSTopic" =>
CloudFormation::Bridge::Resources::SubscribeQueueToTopic.new,
"Custom::CloudFormationOutputs" =>
CloudFormation::Bridge::Resources::CloudFormationOutputs.new,
"Custom::ElastiCacheReplicationGroup" =>
CloudFormation::Bridge::Resources::ElastiCacheReplicationGroup.new,
"Custom::ElastiCacheReplicaCluster" =>
CloudFormation::Bridge::Resources::ElastiCacheReplicaCluster.new,
"Custom::ElastiCacheNodeURLs" =>
CloudFormation::Bridge::Resources::ElastiCacheNodeUrls.new,
}
attr_reader :registry
def initialize(registry = DEFAULT_REGISTRY)
@registry = registry
end
def execute(request)
begin
if resource = registry[request.resource_type]
response = if request.create?
resource.create(request)
elsif request.update?
resource.update(request)
else
resource.delete(request)
end
request.succeed!(response)
elsif request.delete?
request.succeed!
else
request.fail!("Don't know what to do with resource #{request.resource_type}")
end
rescue Exception => ex
ExceptionNotifier.report_exception(ex, request.request)
request.fail!("#{ex.class.name} - #{ex.message}")
end
end
end
end
end