Sha256: 3650f27db8f4c60e51436cc21769ba461df82e98142da5871b1e093704a281f6

Contents?: true

Size: 1.68 KB

Versions: 1

Compression:

Stored size: 1.68 KB

Contents

module SnapshotArchive
  module Archives
    class Builder
      def self.call(dir:, stores:, id:)
        new(dir, stores, id).call
      end

      attr_reader :dir, :stores, :id
      def initialize(dir, stores, id)
        @dir = dir
        @stores = stores
        @id = id
      end

      def call
        stores_metadata = (
          stores
            .map { |name, store|
              File
                .join(dir, name)
                .tap { FileUtils.mkdir(_1) }
                .then { store.backup(_1, id)&.merge(type: name) }
            }
            .compact
        )

        {
          stores: stores_metadata
        }
      end
    end

    class Restore
      def self.call(metadata)
        new(metadata).call
      end

      attr_reader :metadata
      def initialize(metadata)
        @metadata = metadata
      end

      def call
        metadata.fetch("stores").reverse.each do |store_metadata|
          store = Cfg.instance.store(store_metadata.fetch("type"))
          store.restore(store_metadata)
        end
      end
    end

    class Delete
      def self.call(metadata)
        new(metadata).call
      end

      attr_reader :metadata
      def initialize(metadata)
        @metadata = metadata
      end

      def call
        metadata.fetch("stores").each do |store_metadata|
          store = Cfg.instance.store(store_metadata.fetch("type"))
          if store.respond_to?(:delete)
            store.delete(store_metadata)
          end
        end
      end
    end


    class Presenter
      def self.call(metadata)
        new(metadata).call
      end

      attr_reader :metadata
      def initialize(metadata)
        @metadata = metadata
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
snapshot_archive-0.13.0 lib/snapshot_archive/archives.rb