dpn-admin/dpn-sync

# This class adapts some state and logic from dpn-server, i.e.
# https://github.com/dpn-admin/dpn-server
# The code in dpn-server is governed by the following copyright notice:
# Copyright (c) 2015 The Regents of the University of Michigan.
# All Rights Reserved.
# Licensed according to the terms of the Revised BSD License
# See LICENSE.md for details.

module DPN
  module Workers
    ##
    # Replicate a bag in the storage path
    class BagStore < BagReplication

      # @return [Boolean] success
      def transfer
        return true if replication.stored
        return false if replication.cancelled
        return false unless replication.store_requested
        store
      end

      private

        def bagit
          @bagit ||= DPN::Bagit::Bag.new(storage_path)
        end

        # @return [Boolean] success of preservation
        def store
          # TODO: consider whether to mark a replication as
          #       cancelled when this fails.  Or try again?
          preserve_rsync &&
            preserve_validate &&
            update_replication &&
            staging_cleanup
        end

        # @return [Boolean] success of rsync transfer
        def preserve_rsync
          src_path = File.join(staging_path, replication.bag, File::SEPARATOR)
          DPN::Workers::BagRsync.new(src_path, storage_path, 'store').rsync
        end

        # @return [Boolean] validity of preserved bag
        def preserve_validate
          bagit.valid? || raise("Bag invalid: #{bagit.errors}")
        end

        def staging_cleanup
          if bagit.valid?
            FileUtils.rm_r(staging_path, secure: true) && true
          else
            false
          end
        end

        # Update the replication transfer resource on the remote node
        # @return [Boolean]
        def update_replication
          replication.stored = true
          replication.update_admin
          replication.update_local
        end
    end
  end
end