Sha256: ce5c29b7d3e724131080b2a194de7805a5a4da214c8df044479855fe63c3c9b5
Contents?: true
Size: 1.27 KB
Versions: 11
Compression:
Stored size: 1.27 KB
Contents
module Ddr module Events class FixityCheckEvent < Event include PreservationEventBehavior include ReindexObjectAfterSave self.preservation_event_type = :fix self.description = "Validation of datastream checksums" DETAIL_PREAMBLE = "Datastream checksum validation results:" DETAIL_TEMPLATE = "%{dsid} ... %{validation}" # Message sent by ActiveSupport::Notifications def self.call(*args) notification = ActiveSupport::Notifications::Event.new(*args) result = notification.payload[:result] # FixityCheck::Result instance detail = [DETAIL_PREAMBLE] result.results.each do |dsid, dsProfile| # validation = dsProfile["dsChecksumValid"] ? VALID : INVALID validation = dsProfile["checksum_valid"] ? VALID : INVALID detail << DETAIL_TEMPLATE % {dsid: dsid, validation: validation} end create(pid: result.id, event_date_time: notification.time, outcome: result.success ? SUCCESS : FAILURE, detail: detail.join("\n") ) end def to_solr { Ddr::Index::Fields::LAST_FIXITY_CHECK_ON => event_date_time_s, Ddr::Index::Fields::LAST_FIXITY_CHECK_OUTCOME => outcome } end end end end
Version data entries
11 entries across 11 versions & 1 rubygems