[changeset] port pipe to use dry-transformer

Author: solnic

changeset/lib/rom/changeset/pipe.rb

@@ -1,18 +1,18 @@
 # frozen_string_literal: true
 
-require 'transproc/all'
-require 'transproc/registry'
-require 'transproc/transformer'
+require 'dry/transformer/all'
+require 'dry/transformer/registry'
+require 'dry/transformer'
 
 module ROM
   class Changeset
-    # Transproc Registry useful for pipe
+    # Dry::Transformer function registry used by the pipe
     #
     # @api private
     module PipeRegistry
-      extend Transproc::Registry
+      extend Dry::Transformer::Registry
 
-      import Transproc::HashTransformations
+      import Dry::Transformer::HashTransformations
 
       def self.add_timestamps(data)
         now = Time.now
@@ -27,10 +27,11 @@ def self.touch(data)
     # Composable data transformation pipe used by default in changesets
     #
     # @api private
-    class Pipe < ::Transproc::Transformer[PipeRegistry]
+    class Pipe < Dry::Transformer[PipeRegistry]
       extend Initializer
 
-      param :processor, default: -> { self.class.transproc }
+      param :processor, optional: false, reader: false, default: -> { nil }
+
       option :use_for_diff, optional: true, default: -> { true }
       option :diff_processor, default: -> { use_for_diff ? processor : nil }
 
@@ -42,6 +43,11 @@ def [](name)
         self.class[name]
       end
 
+      # @api private
+      def processor
+        options[:processor] || transproc
+      end
+
       def bind(context)
         if processor.is_a?(::Proc)
           self.class.new(Pipe[-> *args { context.instance_exec(*args, &processor) }])

changeset/lib/rom/changeset/stateful.rb

@@ -52,14 +52,14 @@ class Stateful < Changeset
       #     end
       #   end
       #
-      # @return [Array<Pipe>, Transproc::Function>]
+      # @return [Array<Pipe>, Dry::Transformer::Function>]
       #
-      # @see https://github.com/solnic/transproc Transproc
+      # @see https://github.com/dry-rb/dry-transformer
       #
       # @api public
       def self.map(**options, &block)
         if block.parameters.empty?
-          pipes << Class.new(Pipe, &block).new(**options)
+          pipes << Class.new(Pipe).define!(&block).new(**options)
         else
           pipes << Pipe.new(block, **options)
         end
@@ -70,7 +70,7 @@ def self.map(**options, &block)
       # @see Changeset::Stateful.map
       # @see Changeset::Stateful#extend
       #
-      # @return [Array<Pipe>, Transproc::Function>]
+      # @return [Array<Pipe>, Dry::Transformer::Function>]
       #
       # @api public
       def self.extend(*, &block)

changeset/rom-changeset.gemspec

@@ -19,8 +19,8 @@ Gem::Specification.new do |gem|
   }
 
   gem.add_runtime_dependency 'dry-core', '~> 0.4'
+  gem.add_runtime_dependency 'dry-transformer', '~> 0.1'
   gem.add_runtime_dependency 'rom-core', '~> 5.1', '>= 5.1.2'
-  gem.add_runtime_dependency 'transproc', '~> 1.0', '>= 1.1.0'
 
   gem.add_development_dependency 'rake', '~> 11.2'
   gem.add_development_dependency 'rspec', '~> 3.5'