require 'rubygems/dependency' require 'semverse' require 'awesome_print' module Aws module Cfn module Compiler module Parse def parse parse_meta(@spec) @dsl ||= Aws::Cfn::Dsl::Template.new(@config[:directory]) @all_sections.each do |section| parse_section(section,@spec) end end def parse_meta(spec) begin reqs = meta(:Require) if reqs reqs.each do |name,args| requirement(name,args) end end rescue Exception => e # pass ... abort! e end end def requirement(name, *args) #options = args.last.is_a?(Hash) ? args.pop.dup : {} constraint = case args.class.name when /Array/ args.shift when /Symbol/ args.to_s when /String/ args else raise "Unsupported class #{args.class.name} for #{args.ai}" end version,constraint = case name when /Compiler/ [Aws::Cfn::Compiler::VERSION,constraint] # when /MinVersion/ # [Aws::Cfn::Compiler::VERSION,">= #{constraint}"] else raise "#{name} constraint not supported" end raise "The constraint failed: #{name} #{constraint}" unless ::Semverse::Constraint.new(constraint).satisfies?(::Semverse::Version.new(version)) end # noinspection RubyGlobalVariableNamingConvention def parse_section(section,spec=nil) logStep "Parsing #{section}..." if spec and spec[section] @items ||= {} @items[section] ||= {} get = {} item = {} spec[section].each do |rsrc| @logger.debug "\tUsing #{section}::#{rsrc}" refp,sub,base,rel = map_resource_reference(rsrc) if refp.nil? path = get_brick_dirname(section, rsrc) else path = get_brick_dirname(sub ? sub : section, rsrc, refp, rel) end abort! "No such directory: #{path} (I am here: #{Dir.pwd})" unless File.directory?(path) unless get[path] get[path] = get_file_set([".*"], path, @config[:precedence]) end set = get[path] if set[base] if item.has_key?(base) @logger.error " !! error: Duplicate item: #{section}/#{base}" abort! end filename = set[base] unless filename =~ /\.(ru?by?|ya?ml|js(|on))\z/i @logger.info "Brick not supported/ relevant: #{filename}" next end begin @logger.debug " reading #{filename}" content = File.read(filename) next if content.size==0 if filename =~ /\.(rb|ruby)\z/i item.merge! parse_rb_file(base, section, filename) elsif filename =~ /\.js(|on)\z/i item.merge! JSON.parse(content) elsif filename =~ /\.ya?ml\z/i item.merge! YAML.load(content) else next end rescue abort! " !! error: #{$!}" end else abort! " !! error: #{section}/#{base} not found!" end end item.keys.each { |key| if @items[section].has_key?(key) abort! " !! error: Duplicate item: #{section}/#{key}" end } @items[section].merge! item unless @items[section].keys.count == spec[section].count abort! " !! error: Suspect that a #{section} item was missed or not properly named (Brick name and file name mismatch?)! \nRequested: #{spec[section]}\n Found: #{@items[section].keys}" end end end def parse_rb_file(base, section, filename) Aws::Cfn::Compiler.binding ||= {} Aws::Cfn::Compiler.binding[section] ||= {} Aws::Cfn::Compiler.binding[section][base] ||= { brick_path: @config[:brick_path], brick_path_list: @config[:brick_path_list], template: @dsl, logger: @logger, compiler: self } source_file = File.expand_path(filename) begin eval 'require source_file', binding rescue Exception => e abort! "Cannot compile #{source_file}\n\n" + e.message + "\n\n" + e.backtrace.to_s end unless @dsl.dict[section.to_sym] abort! "Unable to compile/expand #{filename} for #{section}/#{base}" end sym_to_s(@dsl.dict[section.to_sym]) end def sym_to_s(hash) case hash.class.name when /Hash/ item = {} hash.each { |k,v| item[k.to_s] = sym_to_s(v) } item when /Array/ hash.map{|e| sym_to_s(e) } when /Fixnum|String|TrueClass|FalseClass/ hash when /Symbol/ hash.to_s else abort! "Internal error: #{hash} is a #{hash.class.name} which our Ruby parsing is not prepared for. Fix #{__FILE__}::sym_to_s" end end end end end end