# Get the first es node in the list
es_node =  node['Nodes']['ES'].first

ruby_block "check_ElasticSearch_Cluster_Health" do
    block do
      #tricky way to load this Chef::Mixin::ShellOut utilities
      Chef::Resource::RubyBlock.send(:include, Chef::Mixin::ShellOut)
      curl_command = "http://#{es_node}:9200/_cluster/health?pretty=true"
      resp = Net::HTTP.get_response URI.parse(curl_command)
      stat = JSON.parse(resp.read_body)['status']

      case stat
         when "green"
            printf("\033[32m%s\n\033[0m", "  ElasticSearch Cluster status is green.")
         when "yellow"
            printf("\033[33m%s\n\033[0m", "  ElasticSearch Cluster status is yellow...")
         when "red"
            printf("\033[31m%s\n\033[0m", "  ElasticSearch Cluster status is red!")
            break;
      end
   end
   retries 10
   retry_delay 2
end

bash "create resources mapping" do
	code <<-EOH	
		curl -i -X PUT -d '{ "order": 1, "template": "resources", "settings": {}, "mappings":
			{
				"esartifactdata": {
					"properties": {
						"id": { "include_in_all": true, "index": "not_analyzed", "type": "string" },
						"data": { "include_in_all": false, "type": "string" }
					},
					"_all": { "enabled": true } 
				}
			}
		}' http://#{es_node}:9200/_template/resources_template
	EOH
end