gabynaiman/eternity

module Eternity
  class Index < Restruct::NestedHash.new(CollectionIndex)

    attr_reader :name

    def initialize(name=nil)
      @name = name ? name.to_s : SecureRandom.uuid
      super connection: Eternity.connection,
            id: Eternity.keyspace[:index][@name]
    end

    def apply(delta)
      delta.each do |collection, elements|
        elements.each do |id, change|
          args = [id, change['data']].compact
          self[collection].send change['action'], *args
        end
      end
    end

    def write_blob
      Blob.write :index, dump
    end

    def self.read_blob(sha1)
      Index.new.tap do |index|
        index.restore Blob.read :index, sha1
      end
    end

    def self.all
      sections_count = Eternity.keyspace[:index].sections.count
      names = Eternity.connection.call('KEYS', Eternity.keyspace[:index]['*']).map do |key|
        Restruct::Id.new(key).sections[sections_count]
      end.uniq
      names.map { |name| new name }
    end

  end
end