fix: add econciliate plugin

Author: arnaud-moncel

packages/forest_admin_datasource_rpc/lib/forest_admin_datasource_rpc/reconciliate_rpc.rb

@@ -0,0 +1,76 @@
+module ForestAdminDatasourceRpc
+  class ReconciliateRpc < ForestAdminDatasourceCustomizer::Plugins::Plugin
+    def run(datasource_customizer, _collection_customizer = nil, _options = {})
+      datasource_customizer.datasources.each do |datasource|
+        next unless datasource.is_a?(ForestAdminDatasourceRpc::Datasource)
+
+        # Disable search for non-searchable collections
+        datasource.collections.each do |_name, collection|
+          unless collection.schema[:searchable]
+            cz = datasource_customizer.get_collection(collection.name)
+            cz.disable_search
+          end
+        end
+
+        # Add relations from rpc_relations
+        (datasource.rpc_relations || {}).each do |collection_name, relations|
+          cz = datasource_customizer.get_collection(collection_name)
+
+          relations.each do |relation_name, relation_definition|
+            add_relation(cz, relation_name, relation_definition)
+          end
+        end
+      end
+    end
+
+    private
+
+    def add_relation(collection_customizer, relation_name, relation_definition)
+      type = relation_definition[:type] || relation_definition['type']
+      foreign_collection = relation_definition[:foreign_collection] || relation_definition['foreign_collection']
+
+      case type
+      when 'ManyToMany'
+        through_collection = relation_definition[:through_collection] || relation_definition['through_collection']
+        collection_customizer.add_many_to_many_relation(
+          relation_name,
+          foreign_collection,
+          through_collection,
+          {
+            foreign_key: relation_definition[:foreign_key] || relation_definition['foreign_key'],
+            foreign_key_target: relation_definition[:foreign_key_target] || relation_definition['foreign_key_target'],
+            origin_key: relation_definition[:origin_key] || relation_definition['origin_key'],
+            origin_key_target: relation_definition[:origin_key_target] || relation_definition['origin_key_target']
+          }
+        )
+      when 'OneToMany'
+        collection_customizer.add_one_to_many_relation(
+          relation_name,
+          foreign_collection,
+          {
+            origin_key: relation_definition[:origin_key] || relation_definition['origin_key'],
+            origin_key_target: relation_definition[:origin_key_target] || relation_definition['origin_key_target']
+          }
+        )
+      when 'OneToOne'
+        collection_customizer.add_one_to_one_relation(
+          relation_name,
+          foreign_collection,
+          {
+            origin_key: relation_definition[:origin_key] || relation_definition['origin_key'],
+            origin_key_target: relation_definition[:origin_key_target] || relation_definition['origin_key_target']
+          }
+        )
+      else # ManyToOne
+        collection_customizer.add_many_to_one_relation(
+          relation_name,
+          foreign_collection,
+          {
+            foreign_key: relation_definition[:foreign_key] || relation_definition['foreign_key'],
+            foreign_key_target: relation_definition[:foreign_key_target] || relation_definition['foreign_key_target']
+          }
+        )
+      end
+    end
+  end
+end

packages/forest_admin_rpc_agent/lib/forest_admin_rpc_agent/agent.rb

@@ -94,19 +94,16 @@ def build_and_cache_rpc_schema_from_datasource
     def build_rpc_schema_from_datasource(datasource)
       schema = customizer.schema
 
-      schema = agent.customizer.schema
-      rpc_collections = agent.rpc_collections || []
-
       rpc_relations = {}
       collections = []
 
       datasource.collections.each do |_name, collection|
-        if rpc_collections.include?(collection.name)
+        if @rpc_collections.include?(collection.name)
           # RPC collection → extract relations to non-RPC collections
           relations = {}
           collection.schema[:fields].each do |field_name, field|
             next if field.type == 'Column'
-            next if rpc_collections.include?(field.foreign_collection)
+            next if @rpc_collections.include?(field.foreign_collection)
 
             relations[field_name] = field
           end