Add primary runtime conflicts

Author: Knerio

app/grpc/flow_handler.rb

@@ -9,14 +9,12 @@ class FlowHandler < Tucana::Sagittarius::FlowService::Service
 
   def self.update_runtime(runtime)
     flows = []
-    runtime.projects.each do |project|
-      project.flows.each do |flow|
+    runtime.project_assignments.compatible.each do |assignment|
+      assignment.project.flows.each do |flow|
         flows << flow.to_grpc
       end
     end
 
-    # TODO: Add check to check for primary runtime conflicts
-
     send_update(
       Tucana::Sagittarius::FlowResponse.new(
         flows: Tucana::Shared::Flows.new(

app/jobs/update_runtime_compatibility_job.rb

@@ -0,0 +1,14 @@
+# frozen_string_literal: true
+
+class UpdateRuntimeCompatibilityJob < ApplicationJob
+  def perform(conditions)
+    assignments = NamespaceProjectRuntimeAssignment.where(conditions)
+
+    assignments.each do |assignment|
+      res = Runtimes::CheckRuntimeCompatibilityService.new(assignment.runtime, assignment.namespace_project).execute
+
+      assignment.compatible = res.success?
+      assignment.save!
+    end
+  end
+end

app/models/namespace_project_runtime_assignment.rb

@@ -9,6 +9,8 @@ class NamespaceProjectRuntimeAssignment < ApplicationRecord
   validate :validate_namespaces, if: :runtime_changed?
   validate :validate_namespaces, if: :namespace_project_changed?
 
+  scope :compatible, -> { where(compatible: true) }
+
   private
 
   def validate_namespaces

app/services/error_code.rb

@@ -40,6 +40,10 @@ def self.error_codes
       primary_level_not_found: { description: '', deprecation_reason: 'Outdated concept' },
       secondary_level_not_found: { description: '', deprecation_reason: 'Outdated concept' },
       tertiary_level_exceeds_parameters: { description: '', deprecation_reason: 'Outdated concept' },
+
+      missing_primary_runtime: { description: 'The project is missing a primary runtime' },
+      missing_definition: { description: 'The primary runtime has more definitions than this one' },
+      outdated_definition: { description: 'The primary runtime has a newer definition than this one' },
     }
   end
 end

app/services/namespaces/projects/assign_runtimes_service.rb

@@ -31,6 +31,8 @@ def execute
             )
           end
 
+          UpdateRuntimeCompatibilityJob.perform_later(namespace_project_id: namespace_project.id)
+
           AuditService.audit(
             :project_runtimes_assigned,
             author_id: current_authentication.user.id,

app/services/runtimes/check_runtime_compatibility_service.rb

@@ -0,0 +1,61 @@
+# frozen_string_literal: true
+
+module Runtimes
+  class CheckRuntimeCompatibilityService
+    attr_reader :runtime, :namespace_project
+
+    def initialize(runtime, namespace_project)
+      @runtime = runtime
+      @namespace_project = namespace_project
+    end
+
+    def execute
+      primary_runtime = namespace_project.primary_runtime
+
+      if primary_runtime.nil?
+        return ServiceResponse.error(message: 'No primary runtime given',
+                                     payload: :missing_primary_runtime)
+      end
+
+      { DataType => :identifier, FlowType => :identifier,
+        RuntimeFunctionDefinition => :runtime_name }.each do |model, identifier_field|
+        res = check_versions(model, identifier_field)
+        return res if res.error?
+      end
+      ServiceResponse.success(message: 'Runtime is compatible', payload: runtime)
+    end
+
+    def check_versions(model, identifier_field = :identifier)
+      to_check_types = model.where(runtime: runtime)
+      primary_types = model.where(runtime: namespace_project.primary_runtime)
+
+      if to_check_types.size < primary_types.size
+        return ServiceResponse.error(message: "#{model} amount dont match",
+                                     payload: :missing_definition)
+      end
+
+      primary_types.each do |curr_type|
+        to_check = model.find_by(runtime: runtime, identifier_field => curr_type.send(identifier_field))
+        if to_check.nil?
+          return ServiceResponse.error(message: "#{model} is not present in new runtime",
+                                       payload: :missing_definition)
+        end
+
+        result = compare_version(curr_type.parsed_version, to_check.parsed_version)
+
+        unless result
+          return ServiceResponse.error(message: "#{model} is outdated",
+                                       payload: :outdated_definition)
+        end
+      end
+      ServiceResponse.success
+    end
+
+    def compare_version(primary_version, to_check_version)
+      return false if primary_version.segments[0] != to_check_version.segments[0]
+      return false if primary_version.segments[1] < to_check_version.segments[1]
+
+      true
+    end
+  end
+end

app/services/runtimes/data_types/update_service.rb

@@ -24,6 +24,8 @@ def execute
             end
           end
 
+          UpdateRuntimeCompatibilityJob.perform_later({ runtime_id: current_runtime.id })
+
           ServiceResponse.success(message: 'Updated data types', payload: data_types)
         end
       end

app/services/runtimes/flow_types/update_service.rb

@@ -24,6 +24,8 @@ def execute
             end
           end
 
+          UpdateRuntimeCompatibilityJob.perform_later({ runtime_id: current_runtime.id })
+
           ServiceResponse.success(message: 'Updated data types', payload: flow_types)
         end
       end

app/services/runtimes/runtime_function_definitions/update_service.rb

@@ -25,6 +25,8 @@ def execute
             end
           end
 
+          UpdateRuntimeCompatibilityJob.perform_later({ runtime_id: current_runtime.id })
+
           ServiceResponse.success(message: 'Updated runtime function definition', payload: runtime_function_definitions)
         end
       end

db/migrate/20251109141754_add_is_compatible_to_primary_runtime.rb

@@ -0,0 +1,7 @@
+# frozen_string_literal: true
+
+class AddIsCompatibleToPrimaryRuntime < Code0::ZeroTrack::Database::Migration[1.0]
+  def change
+    add_column :namespace_project_runtime_assignments, :compatible, :boolean, null: false, default: false
+  end
+end