Sha256: 2b61a6e23fbff73a978a3936c6f0e52e20bd4f4b87cf4a7434e7cbae1b8d83c9
Contents?: true
Size: 1.96 KB
Versions: 5
Compression:
Stored size: 1.96 KB
Contents
# frozen_string_literal: true
require 'transproc/all'
require 'transproc/registry'
require 'transproc/transformer'
module ROM
class Changeset
# Transproc Registry useful for pipe
#
# @api private
module PipeRegistry
extend Transproc::Registry
import Transproc::HashTransformations
def self.add_timestamps(data)
now = Time.now
Hash(created_at: now, updated_at: now).merge(data)
end
def self.touch(data)
Hash(updated_at: Time.now).merge(data)
end
end
# Composable data transformation pipe used by default in changesets
#
# @api private
class Pipe < Transproc::Transformer[PipeRegistry]
extend Initializer
param :processor, default: -> { self.class.transproc }
option :use_for_diff, optional: true, default: -> { true }
option :diff_processor, default: -> { use_for_diff ? processor : nil }
def self.[](name)
container[name]
end
def [](name)
self.class[name]
end
def bind(context)
if processor.is_a?(Proc)
self.class.new(Pipe[-> *args { context.instance_exec(*args, &processor) }])
else
self
end
end
def compose(other, for_diff: other.is_a?(Pipe) ? other.use_for_diff : false)
new_proc = processor ? processor >> other : other
if for_diff
diff_proc = diff_processor ? diff_processor >> other : other
new(new_proc, diff_processor: diff_proc)
else
new(new_proc)
end
end
alias_method :>>, :compose
def call(data)
if processor
processor.call(data)
else
data
end
end
def for_diff(data)
if diff_processor
diff_processor.call(data)
else
data
end
end
def new(processor, opts = EMPTY_HASH)
Pipe.new(processor, opts.empty? ? options : options.merge(opts))
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems