lib/esse/backend/index/update.rb in esse-0.0.2 vs lib/esse/backend/index/update.rb in esse-0.0.3

@@ -2,15 +2,117 @@
 
 module Esse
   module Backend
     class Index
       module InstanceMethods
-        def update_mapping!(**options)
-          # @TODO
+        # Create or update a mapping
+        #
+        # @option options [String] :type The name of the document type. This field is required for some elasticsearch versions
+        # @option options [Boolean] :ignore_conflicts Specify whether to ignore conflicts while updating the mapping
+        #   (default: false)
+        # @option options [Boolean] :allow_no_indices Whether to ignore if a wildcard indices expression resolves into
+        #   no concrete indices. (This includes `_all` string or when no indices have been specified)
+        # @option options [String] :expand_wildcards Whether to expand wildcard expression to concrete indices that
+        #   are open, closed or both. (options: open, closed)
+        # @option options [String] :ignore_indices When performed on multiple indices, allows to ignore
+        #   `missing` ones (options: none, missing) @until 1.0
+        # @option options [Boolean] :ignore_unavailable Whether specified concrete indices should be ignored when
+        #   unavailable (missing, closed, etc)
+        # @option options [Boolean] :update_all_types Whether to update the mapping for all fields
+        #   with the same name across all types
+        # @option options [Time] :timeout Explicit operation timeout
+        # @option options [Boolean] :master_timeout Timeout for connection to master
+        # @raise [Elasticsearch::Transport::Transport::Errors::BadRequest, Elasticsearch::Transport::Transport::Errors::NotFound]
+        #   in case of failure
+        # @return [Hash] the elasticsearch response
+        #
+        # @see http://www.elasticsearch.org/guide/reference/api/admin-indices-put-mapping/
+        def update_mapping!(suffix: index_version, **options)
+          name = suffix ? real_index_name(suffix) : index_name
+
+          client.indices.put_mapping(options.merge(index: name, body: mappings_hash.fetch(Esse::MAPPING_ROOT_KEY)))
         end
 
-        def update_settings!(**options)
-          # @TODO
+        # Create or update a mapping
+        #
+        # @option options [String] :type The name of the document type. This field is required for some elasticsearch versions
+        # @option options [Boolean] :ignore_conflicts Specify whether to ignore conflicts while updating the mapping
+        #   (default: false)
+        # @option options [Boolean] :allow_no_indices Whether to ignore if a wildcard indices expression resolves into
+        #   no concrete indices. (This includes `_all` string or when no indices have been specified)
+        # @option options [String] :expand_wildcards Whether to expand wildcard expression to concrete indices that
+        #   are open, closed or both. (options: open, closed)
+        # @option options [String] :ignore_indices When performed on multiple indices, allows to ignore
+        #   `missing` ones (options: none, missing) @until 1.0
+        # @option options [Boolean] :ignore_unavailable Whether specified concrete indices should be ignored when
+        #   unavailable (missing, closed, etc)
+        # @option options [Boolean] :update_all_types Whether to update the mapping for all fields
+        #   with the same name across all types
+        # @option options [Time] :timeout Explicit operation timeout
+        # @option options [Boolean] :master_timeout Timeout for connection to master
+        # @return [Hash, false] the elasticsearch response, or false in case of failure
+        #
+        # @see http://www.elasticsearch.org/guide/reference/api/admin-indices-put-mapping/
+        def update_mapping(suffix: index_version, **options)
+          update_mapping!(suffix: suffix, **options)
+        rescue Elasticsearch::Transport::Transport::ServerError
+          false
+        end
+
+
+        # Closes the index for read/write operations, updates the index settings, and open it again
+        #
+        # @option options [String] :expand_wildcards Whether to expand wildcard expression to concrete indices that
+        #   are open, closed or both. (options: open, closed)
+        # @option options [String] :ignore_indices When performed on multiple indices, allows to ignore
+        #   `missing` ones (options: none, missing) @until 1.0
+        # @option options [Boolean] :ignore_unavailable Whether specified concrete indices should be ignored when
+        #   unavailable (missing, closed, etc)
+        # @option options [Boolean] :include_defaults Whether to return all default clusters setting
+        # @option options [Boolean] :preserve_existing Whether to update existing settings.
+        #   If set to `true` existing settings on an index remain unchanged, the default is `false`
+        # @option options [Time] :master_timeout Specify timeout for connection to master
+        # @option options [Boolean] :flat_settings Return settings in flat format (default: false)
+        # @raise [Elasticsearch::Transport::Transport::Errors::BadRequest, Elasticsearch::Transport::Transport::Errors::NotFound]
+        #   in case of failure
+        # @return [Hash] the elasticsearch response
+        #
+        # @see http://www.elasticsearch.org/guide/reference/api/admin-indices-update-settings/
+        def update_settings!(suffix: index_version, **options)
+          name = suffix ? real_index_name(suffix) : index_name
+          response = nil
+
+          close!(suffix: suffix)
+          begin
+            body = settings_hash(cluster_settings: false).fetch(Esse::SETTING_ROOT_KEY)
+            response = client.indices.put_settings(options.merge(index: name, body: body))
+          ensure
+            open!(suffix: suffix)
+          end
+
+          response
+        end
+
+        # Closes the index for read/write operations, updates the index settings, and open it again
+        #
+        # @option options [String] :expand_wildcards Whether to expand wildcard expression to concrete indices that
+        #   are open, closed or both. (options: open, closed)
+        # @option options [String] :ignore_indices When performed on multiple indices, allows to ignore
+        #   `missing` ones (options: none, missing) @until 1.0
+        # @option options [Boolean] :ignore_unavailable Whether specified concrete indices should be ignored when
+        #   unavailable (missing, closed, etc)
+        # @option options [Boolean] :include_defaults Whether to return all default clusters setting
+        # @option options [Boolean] :preserve_existing Whether to update existing settings.
+        #   If set to `true` existing settings on an index remain unchanged, the default is `false`
+        # @option options [Time] :master_timeout Specify timeout for connection to master
+        # @option options [Boolean] :flat_settings Return settings in flat format (default: false)
+        # @return [Hash, false] the elasticsearch response, false in case of failure
+        #
+        # @see http://www.elasticsearch.org/guide/reference/api/admin-indices-update-settings/
+        def update_settings(suffix: index_version, **options)
+          update_settings!(suffix: suffix, **options)
+        rescue Elasticsearch::Transport::Transport::ServerError
+          false
         end
       end
 
       include InstanceMethods
     end