dpn-admin/dpn-sync

module DPN
  module Workers
    ##
    # Fetch the latest digests from a remote node
    class SyncDigests < Sync

      # @return [Boolean] success of sync operations
      def sync
        sync_digests
      end

      private

        # @return [Boolean] success of digest sync operations
        def sync_digests
          success = []
          remote_node_bags.each do |bag|
            success << remote_node_bag_digests(bag)
          end
          success.all? ? last_success_update : false
        end

        # @return [Boolean] success of remote node digests for a bag
        def remote_node_bag_digests(bag)
          success = []
          remote_client.bag_digests(bag[:uuid]) do |response|
            # the paginated response should contain only one digest
            success << create_or_update_digest(response)
          end
          success.all?
        end

        # @param [DPN::Client::Response] remote_response
        # @return [Boolean] success of digest create or update operation
        def create_or_update_digest(remote_response)
          json_data = remote_response.body
          if remote_response.success?
            local_digest = DPN::Workers::SyncDigest.new(json_data, local_client, logger)
            local_digest.create_or_update
          else
            logger.error json_data
            false
          end
        end
    end
  end
end