flow type structure

.gitignore

@@ -48,6 +48,7 @@
 *.njsproj
 *.sln
 *.sw?
+**/*Zone.Identifier
 
 ################
 ##

Gemfile

@@ -79,7 +79,7 @@ gem 'good_job', '~> 4.0'
 gem 'rotp'
 
 gem 'grpc', '~> 1.67'
-gem 'tucana', '0.0.25'
+gem 'tucana', '0.0.30'
 
 gem 'code0-identities', '~> 0.0.1'
 
@@ -89,3 +89,5 @@ gem 'pry-byebug', '~> 3.10'
 gem 'code0-zero_track', '0.0.4'
 
 gem 'image_processing', '>= 1.2'
+
+gem 'json-schema', '~> 5.1'

Gemfile.lock

@@ -72,6 +72,8 @@ GEM
       securerandom (>= 0.3)
       tzinfo (~> 2.0, >= 2.0.5)
       uri (>= 0.13.1)
+    addressable (2.8.7)
+      public_suffix (>= 2.0.2, < 7.0)
     ast (2.4.3)
     base64 (0.2.0)
     bcrypt (3.1.20)
@@ -154,6 +156,9 @@ GEM
       rdoc (>= 4.0.0)
       reline (>= 0.4.2)
     json (2.12.0)
+    json-schema (5.1.1)
+      addressable (~> 2.8)
+      bigdecimal (~> 3.1)
     language_server-protocol (3.17.0.5)
     lint_roller (1.1.0)
     logger (1.7.0)
@@ -212,6 +217,7 @@ GEM
     psych (5.2.6)
       date
       stringio
+    public_suffix (6.0.2)
     puma (6.6.0)
       nio4r (~> 2.0)
     raabro (1.4.0)
@@ -356,7 +362,7 @@ GEM
     test-prof (1.4.4)
     thor (1.3.2)
     timeout (0.4.3)
-    tucana (0.0.25)
+    tucana (0.0.30)
       grpc (~> 1.64)
     tzinfo (2.0.6)
       concurrent-ruby (~> 1.0)
@@ -389,6 +395,7 @@ DEPENDENCIES
   graphql (~> 2.1)
   grpc (~> 1.67)
   image_processing (>= 1.2)
+  json-schema (~> 5.1)
   lograge (~> 0.14.0)
   pg (~> 1.1)
   pry (~> 0.14.2)
@@ -409,7 +416,7 @@ DEPENDENCIES
   simplecov (~> 0.22.0)
   simplecov-cobertura (~> 2.1)
   test-prof (~> 1.0)
-  tucana (= 0.0.25)
+  tucana (= 0.0.30)
   tzinfo-data
 
 RUBY VERSION

app/graphql/mutations/namespaces/projects/flows/create.rb

@@ -0,0 +1,55 @@
+# frozen_string_literal: true
+
+module Mutations
+  module Namespaces
+    module Projects
+      module Flows
+        class Create < BaseMutation
+          description 'Creates a new flow.'
+
+          field :flow, Types::FlowType, null: true, description: 'The newly created flow.'
+
+          argument :project_id, Types::GlobalIdType[NamespaceProject],
+                   required: true, description: 'The ID of the project to which the flow belongs to'
+
+          argument :flow, Types::Input::FlowInputType, description: 'The flow to create', required: true
+
+          def resolve(project_id:, flow:, **params)
+            project = SagittariusSchema.object_from_id(project_id)
+
+            return error('Invalid project id') if project.nil?
+
+            input_type = SagittariusSchema.object_from_id(flow.input_type)
+
+            return error('Invalid input type id') if input_type.nil?
+
+            return_type = SagittariusSchema.object_from_id(flow.return_type)
+            return error('Invalid return type id') if return_type.nil?
+
+            flow_type = SagittariusSchema.object_from_id(flow.flow_type)
+            return error('Invalid flow type id') if flow_type.nil?
+
+            Namespaces::Projects::Flows::CreateService.new(
+              create_authentication(context[:current_user]),
+              namespace_project: project,
+              params: {
+                return_type: return_type,
+                input_type: input_type,
+                flow_type: flow_type,
+                starting_node: params[:starting_node],
+                settings: params[:settings] || [],
+              }
+            ).execute.to_mutation_response(success_key: :flow)
+          end
+
+          def error(message)
+            {
+              flow: nil,
+              errors: [create_message_error(message)],
+            }
+          end
+        end
+      end
+    end
+  end
+end

app/graphql/mutations/namespaces/projects/flows/delete.rb

@@ -0,0 +1,32 @@
+# frozen_string_literal: true
+
+module Mutations
+  module Namespaces
+    module Projects
+      module Flows
+        class Delete < BaseMutation
+          description 'Deletes a namespace project.'
+
+          field :flow, Types::FlowType, null: true, description: 'The deleted flow.'
+
+          argument :flow_id, Types::GlobalIdType[::Flow],
+                   description: 'The id of the flow which will be deleted'
+
+          def resolve(flow_id:)
+            flow = SagittariusSchema.object_from_id(flow_id)
+
+            if flow.nil?
+              return { flow: nil,
+                       errors: [create_message_error('Invalid flow')] }
+            end
+
+            ::Namespaces::Projects::Flows::DeleteService.new(
+              current_authentication,
+              flow
+            ).execute.to_mutation_response(success_key: :flow)
+          end
+        end
+      end
+    end
+  end
+end

app/graphql/sagittarius_schema.rb

@@ -51,6 +51,7 @@ def self.object_from_id(global_id, query_ctx = nil)
   rescue ActiveRecord::RecordNotFound
     nil
   end
+
   # rubocop:enable Lint/UnusedMethodArgument
 end
 # rubocop:enable GraphQL/MaxDepthSchema

app/graphql/types/base_input_object.rb

@@ -3,5 +3,9 @@
 module Types
   class BaseInputObject < GraphQL::Schema::InputObject
     argument_class Types::BaseArgument
+
+    def self.require_one_of(arguments)
+      validates required: { one_of: arguments, message: "Only one of #{arguments.inspect} should be provided" }
+    end
   end
 end

app/graphql/types/data_type_identifier_type.rb

@@ -0,0 +1,23 @@
+# frozen_string_literal: true
+
+module Types
+  class DataTypeIdentifierType < Types::BaseUnion
+    description 'Represents a data type identifier.'
+
+    possible_types Types::GenericTypeType, Types::DataTypeType, Types::GenericKeyType,
+                   description: 'The identifier can be a generic type, a data type, or a generic key.'
+
+    def self.resolve_type(object, _context)
+      case object
+      when GenericType
+        Types::GenericTypeType
+      when DataType
+        Types::DataTypeType
+      when GenericKey
+        Types::GenericKeyType
+      else
+        raise "Unexpected value type: #{object.class}"
+      end
+    end
+  end
+end

app/graphql/types/data_type_rule_type.rb

@@ -0,0 +1,19 @@
+# frozen_string_literal: true
+
+module Types
+  class DataTypeRuleType < Types::BaseObject
+    description 'Represents a rule that can be applied to a data type.'
+
+    field :variant, Types::DataTypeRules::DataTypeRuleVariantEnum, null: false,
+                                                                   description: 'The type of the rule'
+
+    field :config, Types::DataTypeRules::ConfigType, null: false,
+                                                     description: 'The configuration of the rule'
+
+    timestamps
+
+    def config
+      object.config.merge(variant: object.variant)
+    end
+  end
+end

app/graphql/types/data_type_rules/config_type.rb

@@ -0,0 +1,29 @@
+# frozen_string_literal: true
+
+module Types
+  module DataTypeRules
+    class ConfigType < Types::BaseUnion
+      description 'Represents a rule that can be applied to a data type.'
+
+      possible_types ContainsKeyConfigType, ContainsTypeConfigType, NumberRangeConfigType, ItemOfCollectionConfigType,
+                     RegexConfigType
+
+      def self.resolve_type(object, _context)
+        case object[:variant]
+        when :contains_key
+          Types::DataTypeRuleContainsKeyType
+        when :contains_type
+          Types::DataTypeRuleContainsTypeType
+        when :number_range
+          Types::DataTypeRuleNumberRangeType
+        when :item_of_collection
+          Types::DataTypeRuleItemOfCollectionType
+        when :regex
+          Types::DataTypeRuleRegexType
+        else
+          raise GraphQL::ExecutionError, "Unknown data type rule variant: #{object.variant}"
+        end
+      end
+    end
+  end
+end

app/graphql/types/data_type_rules/contains_key_config_type.rb

@@ -0,0 +1,15 @@
+# frozen_string_literal: true
+
+module Types
+  module DataTypeRules
+    class ContainsKeyConfigType < Types::BaseObject
+      description 'Represents a rule that can be applied to a data type.'
+
+      authorize :read_flow
+
+      field :data_type_identifier, Types::DataTypeIdentifierType,
+            null: false, description: 'The identifier of the data type this rule belongs to'
+      field :key, String, null: false, description: 'The key of the rule'
+    end
+  end
+end

app/graphql/types/data_type_rules/contains_type_config_type.rb

@@ -0,0 +1,14 @@
+# frozen_string_literal: true
+
+module Types
+  module DataTypeRules
+    class ContainsTypeConfigType < Types::BaseObject
+      description 'Represents a rule that can be applied to a data type.'
+
+      authorize :read_flow
+
+      field :data_type_identifier, Types::DataTypeIdentifierType,
+            null: false, description: 'The identifier of the data type this rule belongs to'
+    end
+  end
+end

app/graphql/types/data_type_rules/data_type_rule_variant_enum.rb

@@ -0,0 +1,24 @@
+# frozen_string_literal: true
+
+module Types
+  module DataTypeRules
+    class DataTypeRuleVariantEnum < Types::BaseEnum
+      description 'The type of rule that can be applied to a data type.'
+
+      value :CONTAINS_KEY, 'The rule checks if a key is present in the data type.',
+            value: :contains_key
+      value :CONTAINS_TYPE, 'The rule checks if a specific type is present in the data type.',
+            value: :contains_type
+      value :NUMBER_RANGE, 'The rule checks if a number falls within a specified range.',
+            value: :number_range
+      value :ITEM_OF_COLLECTION, 'The rule checks if an item is part of a collection in the data type.',
+            value: :item_of_collection
+      value :REGEX, 'The rule checks if a string matches a specified regular expression.',
+            value: :regex
+      value :INPUT_TYPE, 'The rule checks if the data type matches a specific input type.',
+            value: :input_type
+      value :RETURN_TYPE, 'The rule checks if the data type matches a specific return type.',
+            value: :return_type
+    end
+  end
+end

app/graphql/types/data_type_rules/input_types_config_type.rb

@@ -0,0 +1,11 @@
+# frozen_string_literal: true
+
+module Types
+  module DataTypeRules
+    class InputTypesConfigType < Types::BaseObject
+      description 'Represents a rule that can be applied to a data type.'
+
+      authorize :read_flow
+    end
+  end
+end

app/graphql/types/data_type_rules/item_of_collection_config_type.rb

@@ -0,0 +1,14 @@
+# frozen_string_literal: true
+
+module Types
+  module DataTypeRules
+    class ItemOfCollectionConfigType < Types::BaseObject
+      description 'Represents a rule that can be applied to a data type.'
+
+      authorize :read_flow
+
+      field :items, [GraphQL::Types::JSON], null: true,
+                                            description: 'The items that can be configured for this rule.'
+    end
+  end
+end

app/graphql/types/data_type_rules/number_range_config_type.rb

@@ -0,0 +1,18 @@
+# frozen_string_literal: true
+
+module Types
+  module DataTypeRules
+    class NumberRangeConfigType < Types::BaseObject
+      description 'Represents a rule that can be applied to a data type.'
+
+      authorize :read_flow
+
+      field :from, Integer, null: false,
+                            description: 'The minimum value of the range'
+      field :steps, Integer, null: true,
+                             description: 'The step value for the range, if applicable'
+      field :to, Integer, null: false,
+                          description: 'The maximum value of the range'
+    end
+  end
+end

app/graphql/types/data_type_rules/regex_config_type.rb

@@ -0,0 +1,14 @@
+# frozen_string_literal: true
+
+module Types
+  module DataTypeRules
+    class RegexConfigType < Types::BaseObject
+      description 'Represents a rule that can be applied to a data type.'
+
+      authorize :read_flow
+
+      field :pattern, String, null: false,
+                              description: 'The regex pattern to match against the data type value.'
+    end
+  end
+end

app/graphql/types/data_type_type.rb

@@ -6,10 +6,18 @@ class DataTypeType < Types::BaseObject
 
     authorize :read_datatype
 
+    field :generic_keys, [String], null: true, description: 'Generic keys of the datatype'
     field :identifier, String, null: false, description: 'The identifier scoped to the namespace'
+    field :name, Types::TranslationType.connection_type, method: :names, null: false,
+                                                         description: 'Names of the flow type setting'
     field :namespace, Types::NamespaceType, null: true,
                                             description: 'The namespace where this datatype belongs to'
-    field :variant, Types::DataTypeVariantEnum, null: false, description: 'The type of the datatype'
+    field :parent, Types::DataTypeIdentifierType,
+          null: true, description: 'The parent datatype'
+    field :rules, Types::DataTypeRuleType.connection_type, null: false,
+                                                           description: 'Rules of the datatype'
+    field :variant, Types::DataTypeVariantEnum, null: false,
+                                                description: 'The type of the datatype'
 
     id_field DataType
     timestamps