wip - initial work on attaching plugins to configuration notifications

lib/rom/components/core.rb

@@ -72,7 +72,14 @@ def adapter
         )
       end
 
-      # @api public
+      # @api private
+      def attach_plugins
+        plugins
+          .select { |plugin| plugin.attachable? }
+          .each { |plugin| plugin.attach_to(configuration) }
+      end
+
+      # @api private
       def apply_plugins
         plugins.each do |plugin|
           plugin.apply_to(constant)

lib/rom/components/relation.rb

@@ -30,6 +30,8 @@ def key
       #
       # @api public
       def build
+        attach_plugins
+
         # TODO: this should become a built-in feature, no neeed to use a plugin
         constant.use(:registry_reader, relations: components.relations.map(&:id).uniq)
 

lib/rom/plugin.rb

@@ -27,6 +27,16 @@ class Plugin
     # @api private
     option :type
 
+    # @api private
+    def attach_to(configuration)
+      # TODO: this is a noop for now
+    end
+
+    # @api private
+    def attachable?
+      mod.respond_to?(:subscribe)
+    end
+
     # Apply this plugin to the target
     #
     # @param [Class,Object] target

spec/shared/changeset/database.rb

@@ -15,7 +15,11 @@
 RSpec.shared_context "changeset / database setup" do
   include_context "changeset / db_uri"
 
-  let(:configuration) { ROM::Configuration.new(:sql, db_uri) }
+  let(:configuration) do
+    ROM::Configuration.new(:sql, db_uri) do |config|
+      config.plugin(:sql, relation: :auto_restrictions)
+    end
+  end
 
   let(:conn) { configuration.gateways[:default].connection }
 

spec/shared/repository/database.rb

@@ -1,5 +1,6 @@
 # frozen_string_literal: true
 
+require "rom/sql"
 RSpec.shared_context "repository / db_uri" do
   let(:base_db_uri) do
     ENV.fetch("BASE_DB_URI", "postgres@localhost/rom")
@@ -14,7 +15,9 @@
   include_context "repository / db_uri"
 
   let(:configuration) do
-    ROM::Configuration.new(:sql, db_uri)
+    ROM::Configuration.new(:sql, db_uri) do |config|
+      config.plugin(:sql, relation: :auto_restrictions)
+    end
   end
 
   let(:conn) do