Sha256: f440280894238e3fed6ce191b9e24943e5e9d0d4b3332b9179ab04de895aed60
Contents?: true
Size: 1006 Bytes
Versions: 12
Compression:
Stored size: 1006 Bytes
Contents
module Eternity
class ObjectTracker
extend Forwardable
def_delegators :changes, :to_a, :to_primitive, :count, :each, :destroy
def initialize(options)
@changes = Restruct::MarshalArray.new options
end
def insert(data)
track INSERT, data
end
def update(data)
track UPDATE, data
end
def delete
track DELETE
end
def revert
locker.lock! :revert do
changes.destroy
end
end
def flatten
TrackFlatter.flatten changes
end
private
attr_reader :changes
def track(action, data=nil)
locker.lock :track do
change = {'action' => action}
change['blob'] = Blob.write(:data, data) if data
Eternity.logger.debug(self.class) { "#{changes.id} - #{change} - #{data}" }
changes << change
end
end
def locker
Eternity.locker_for repository_name
end
def repository_name
changes.id.sections.reverse[3]
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems