diff --git a/app/workers/reindex_touched_dois_worker.rb b/app/workers/reindex_touched_dois_worker.rb index 0165475..629cf9f 100644 --- a/app/workers/reindex_touched_dois_worker.rb +++ b/app/workers/reindex_touched_dois_worker.rb @@ -2,16 +2,16 @@ class ReindexTouchedDoisWorker include Shoryuken::Worker shoryuken_options queue: -> { "#{ENV["RAILS_ENV"]}_events_reindex_daily" }, auto_delete: true + log_prefix = "[Events:ReindexTouchedDoisWorker]" def perform(sqs_message = nil, data = nil) - log_prefix = "[Events:ReindexTouchedDoisWorker]" - Rails.logger.error("#{log_prefix} Received message body: #{sqs_message.body}") - Rails.logger.error("#{log_prefix} Received message data: #{data}") - - date = get_date(data) - Rails.logger.info("#{log_prefix} Starting reindex of DOIs touched on #{date}") + date = JSON.parse(data).dig("date") + Rails.logger.error("#{log_prefix} data date: #{date}") + date = Date.parse(date) + Rails.logger.error("#{log_prefix} parsed date: #{date}") + if date.nil? Rails.logger.error("#{log_prefix} Date was not provided") return @@ -22,20 +22,4 @@ def perform(sqs_message = nil, data = nil) Rails.logger.info("#{log_prefix} Sent #{count} unique DOIs for re-indexing on #{date}") end - - private - - # Will return nil if either data or date field is missing. - def get_date(data) - return if data.blank? - - data_hash = JSON.parse(data) - data_hash.dig("date") - - begin - Date.parse(date) - rescue - nil - end - end end