diff --git a/lib/paste_to_es.rb b/lib/paste_to_es.rb new file mode 100644 index 0000000..9bf6d07 --- /dev/null +++ b/lib/paste_to_es.rb @@ -0,0 +1,10 @@ +class PasteToEs + include Sidekiq::Worker + def perform(es_object, pb_object) + Logger.new(STDOUT).info("PasteToEs started") + pastes = pb_object.scrape_public_pastes + keys = pb_object.get_unique_paste_keys(pastes) + json_data = pb_object.json_paste(keys) + es_object.json_to_es_bulk(json_data) + end +end