lib/esse/backend/index/reset.rb in esse-0.2.0 vs lib/esse/backend/index/reset.rb in esse-0.2.2

@@ -7,21 +7,21 @@
         # Deletes, creates and imports data to the index. Performs zero-downtime index resetting.
         #
         # @option options [String, nil] :suffix The index suffix. Defaults to the index_version.
         #   A uniq index name will be generated if one index already exist with the given alias.
         # @option options [Time] :timeout Explicit operation timeout
-        # @raise [Elasticsearch::Transport::Transport::Errors::BadRequest, Elasticsearch::Transport::Transport::Errors::NotFound]
+        # @raise [Esse::Backend::ServerError]
         #   in case of failure
         # @return [Hash] the elasticsearch response
         #
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/master/indices-open-close.html
-        def reset_index!(suffix: index_version, **options)
+        def reset_index!(suffix: index_version, import: true, **options)
           existing = []
           suffix ||= Esse.timestamp
-          suffix = Esse.timestamp while exist?(suffix: suffix).tap { |exist| existing << suffix if exist }
+          suffix = Esse.timestamp while index_exist?(suffix: suffix).tap { |exist| existing << suffix if exist }
 
           create_index!(**options, suffix: suffix, alias: false)
-          import!(**options, suffix: suffix)
+          import!(**options, suffix: suffix) if import
           update_aliases!(suffix: suffix)
           existing.each { |_s| delete_index!(**options, suffix: suffix) }
           true
         end
       end