Add depth node scope

Author: Knerio

app/graphql/types/input/reference_value_input_type.rb

@@ -9,6 +9,13 @@ class ReferenceValueInputType < Types::BaseInputObject
                required: true, description: 'The paths associated with this reference value'
 
       argument :node_function, GlobalIdType[::NodeFunction], required: true, description: 'The referenced value'
+
+      argument :data_type_identifier, Types::Input::DataTypeIdentifierInputType,
+               required: true, description: 'The identifier of the data type this reference value belongs to'
+
+      argument :depth, Int, required: true, description: 'The depth of the reference value'
+      argument :node, Int, required: true, description: 'The node of the reference'
+      argument :scope, [Int], required: true, description: 'The scope of the reference value'
     end
   end
 end

app/graphql/types/reference_value_type.rb

@@ -8,6 +8,13 @@ class ReferenceValueType < Types::BaseObject
 
     field :node_function, Types::NodeFunctionType, null: false, description: 'The referenced value.'
 
+    field :data_type_identifier, Types::DataTypeIdentifierType,
+          null: false, description: 'The identifier of the data type this reference value belongs to.'
+
+    field :depth, Int, null: false, description: 'The depth of the reference value.'
+    field :node, Int, null: false, description: 'The node of the reference value.'
+    field :scope, [Int], null: false, description: 'The scope of the reference value.'
+
     field :reference_path, [Types::ReferencePathType], null: false,
                                                        description: 'The paths associated with this reference value.'
 

app/models/reference_value.rb

@@ -2,6 +2,7 @@
 
 class ReferenceValue < ApplicationRecord
   belongs_to :node_function # real value association
+  belongs_to :data_type_identifier
   has_many :reference_paths, inverse_of: :reference_value
   has_many :node_parameters, inverse_of: :reference_value
 

app/services/namespaces/projects/flows/create_service.rb

@@ -124,6 +124,10 @@ def create_node_function(node_function, t)
               runtime_parameter: runtime_parameter,
               reference_value: ReferenceValue.create(
                 node_function: reference_value,
+                data_type_identifier: get_data_type_identifier(parameter.value.reference_value.data_type_identifier),
+                depth: parameter.value.reference_value.depth,
+                node: parameter.value.reference_value.node,
+                scope: parameter.value.reference_value.scope,
                 reference_paths: parameter.value.reference_value.reference_paths.map do |path|
                   ReferencePath.create(
                     path: path.path,
@@ -143,6 +147,28 @@ def create_node_function(node_function, t)
             node_parameters: params
           )
         end
+
+        private
+
+        def get_data_type_identifier(identifier)
+          return DataTypeIdentifier.create(generic_key: identifier.generic_key) if identifier.generic_key.present?
+
+          if identifier.generic_type.present?
+            data_type = SagittariusSchema.object_from_id(identifier.generic_type.data_type_id)
+            mappers = identifier.generic_type.mappers.map do |mapper|
+              GenericMapper.create(
+                generic_mapper_id: mapper.generic_mapper_id,
+                source: mapper.source,
+                target: mapper.target
+              )
+            end
+            return DataTypeIdentifier.create(generic_type: GenericType.create(data_type: data_type, mappers: mappers))
+          end
+
+          return if identifier.data_type_id.blank?
+
+          DataTypeIdentifier.create(data_type: SagittariusSchema.object_from_id(identifier.data_type_id))
+        end
       end
     end
   end

db/migrate/20251115163257_add_depth_node_scope_to_ref_values.rb

@@ -0,0 +1,15 @@
+# frozen_string_literal: true
+
+class AddDepthNodeScopeToRefValues < Code0::ZeroTrack::Database::Migration[1.0]
+  def change
+    add_column :reference_values, :depth, :integer, null: false, default: 0
+    add_column :reference_values, :node, :integer, null: false, default: 0
+    add_column :reference_values, :scope, :integer, array: true, null: false, default: []
+
+    # rubocop:disable Rails/NotNullColumn -- backwards compatibility intentionally ignored
+    add_reference :reference_values, :data_type_identifier, null: false, foreign_key: {
+      to_table: :data_type_identifiers, on_delete: :restrict
+    }
+    # rubocop:enable Rails/NotNullColumn
+  end
+end

db/schema_migrations/20251115163257

@@ -0,0 +1 @@
+862fdbc0a63df92424319894f331d68ee7d36cdd6f0e83996f83bdb4dfc3e371

db/structure.sql

@@ -662,7 +662,11 @@ CREATE TABLE reference_values (
     id bigint NOT NULL,
     created_at timestamp with time zone NOT NULL,
     updated_at timestamp with time zone NOT NULL,
-    node_function_id bigint NOT NULL
+    node_function_id bigint NOT NULL,
+    depth integer DEFAULT 0 NOT NULL,
+    node integer DEFAULT 0 NOT NULL,
+    scope integer[] DEFAULT '{}'::integer[] NOT NULL,
+    data_type_identifier_id bigint NOT NULL
 );
 
 CREATE SEQUENCE reference_values_id_seq
@@ -1197,6 +1201,8 @@ CREATE INDEX index_parameter_definitions_on_runtime_parameter_definition_id ON p
 
 CREATE INDEX index_reference_paths_on_reference_value_id ON reference_paths USING btree (reference_value_id);
 
+CREATE INDEX index_reference_values_on_data_type_identifier_id ON reference_values USING btree (data_type_identifier_id);
+
 CREATE INDEX index_reference_values_on_node_function_id ON reference_values USING btree (node_function_id);
 
 CREATE INDEX index_runtime_function_definitions_on_return_type_id ON runtime_function_definitions USING btree (return_type_id);
@@ -1354,6 +1360,9 @@ ALTER TABLE ONLY flow_type_settings
 ALTER TABLE ONLY flows
     ADD CONSTRAINT fk_rails_ab927e0ecb FOREIGN KEY (project_id) REFERENCES namespace_projects(id) ON DELETE CASCADE;
 
+ALTER TABLE ONLY reference_values
+    ADD CONSTRAINT fk_rails_bb34a5d62c FOREIGN KEY (data_type_identifier_id) REFERENCES data_type_identifiers(id) ON DELETE RESTRICT;
+
 ALTER TABLE ONLY flows
     ADD CONSTRAINT fk_rails_bb587eff6a FOREIGN KEY (input_type_id) REFERENCES data_types(id) ON DELETE RESTRICT;
 

docs/graphql/input_object/datatypeidentifierinput.md

@@ -0,0 +1,13 @@
+---
+title: DataTypeIdentifierInput
+---
+
+Input type for data type identifier
+
+## Fields
+
+| Name | Type | Description |
+|------|------|-------------|
+| `dataTypeId` | [`DataTypeID`](../scalar/datatypeid.md) | Data type ID |
+| `genericKey` | [`String`](../scalar/string.md) | Generic key value |
+| `genericType` | [`GenericTypeInput`](../input_object/generictypeinput.md) | Generic type information |

docs/graphql/input_object/genericmapperinput.md

@@ -0,0 +1,12 @@
+---
+title: GenericMapperInput
+---
+
+Input type for generic mappers
+
+## Fields
+
+| Name | Type | Description |
+|------|------|-------------|
+| `sources` | [`[DataTypeIdentifierInput!]!`](../input_object/datatypeidentifierinput.md) | The source data type identifier for the mapper |
+| `target` | [`String!`](../scalar/string.md) | The target data type identifier for the mapper |

docs/graphql/input_object/generictypeinput.md

@@ -0,0 +1,12 @@
+---
+title: GenericTypeInput
+---
+
+Input type for generic type operations.
+
+## Fields
+
+| Name | Type | Description |
+|------|------|-------------|
+| `dataTypeId` | [`DataTypeID!`](../scalar/datatypeid.md) | The data type associated with this generic type. |
+| `genericMappers` | [`[GenericMapperInput!]!`](../input_object/genericmapperinput.md) | The mappers associated with this generic type. |