Contents

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

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
cfn-bridge-0.0.16	lib/cloud_formation/bridge/executor.rb
cfn-bridge-0.0.15	lib/cloud_formation/bridge/executor.rb
cfn-bridge-0.0.14	lib/cloud_formation/bridge/executor.rb
cfn-bridge-0.0.13	lib/cloud_formation/bridge/executor.rb
cfn-bridge-0.0.11	lib/cloud_formation/bridge/executor.rb