davidesantangelo/feedi

View on GitHub
app/models/importer.rb

Summary

Maintainability
A
0 mins
Test Coverage
# frozen_string_literal: true

class Importer
  def self.run(limit: 1000)
    Feed.unscoped.all.order('last_import_at ASC NULLS FIRST').limit(limit).find_each(&:async_update)
  end

  def self.reload(feed:)
    feed.entries.delete_all
    feed.logs.delete_all
    feed.async_import
  end

  module ElasticSearch
    def self.reset_index(model:)
      model.__elasticsearch__.create_index!(force: true)
      model.__elasticsearch__.refresh_index!
    end
  end
end