Merge pull request #752 from code0-tech/flow-to-grpc-is-failing

Fix flow errors and add logs

Author: Taucher2003

app/grpc/data_type_handler.rb

@@ -2,12 +2,15 @@
 
 class DataTypeHandler < Tucana::Sagittarius::DataTypeService::Service
   include GrpcHandler
+  include Code0::ZeroTrack::Loggable
 
   def update(request, _call)
     current_runtime = Runtime.find(Code0::ZeroTrack::Context.current[:runtime][:id])
 
     response = Runtimes::Grpc::DataTypes::UpdateService.new(current_runtime, request.data_types).execute
 
+    logger.debug("DataTypeHandler#update response: #{response.inspect}")
+
     Tucana::Sagittarius::DataTypeUpdateResponse.new(success: response.success?)
   end
 end

app/grpc/flow_handler.rb

@@ -10,7 +10,7 @@ class FlowHandler < Tucana::Sagittarius::FlowService::Service
   def self.update_runtime(runtime)
     flows = []
     runtime.project_assignments.compatible.each do |assignment|
-      assignment.project.flows.each do |flow|
+      assignment.namespace_project.flows.each do |flow|
         flows << flow.to_grpc
       end
     end

app/grpc/flow_type_handler.rb

@@ -2,12 +2,15 @@
 
 class FlowTypeHandler < Tucana::Sagittarius::FlowTypeService::Service
   include GrpcHandler
+  include Code0::ZeroTrack::Loggable
 
   def update(request, _call)
     current_runtime = Runtime.find(Code0::ZeroTrack::Context.current[:runtime][:id])
 
     response = Runtimes::Grpc::FlowTypes::UpdateService.new(current_runtime, request.flow_types).execute
 
+    logger.debug("FlowTypeHandler#update response: #{response.inspect}")
+
     Tucana::Sagittarius::FlowTypeUpdateResponse.new(success: response.success?)
   end
 end

app/grpc/runtime_function_handler.rb

@@ -2,6 +2,7 @@
 
 class RuntimeFunctionHandler < Tucana::Sagittarius::RuntimeFunctionDefinitionService::Service
   include GrpcHandler
+  include Code0::ZeroTrack::Loggable
 
   def update(request, _call)
     current_runtime = Runtime.find(Code0::ZeroTrack::Context.current[:runtime][:id])
@@ -11,6 +12,8 @@ def update(request, _call)
       request.runtime_functions
     ).execute
 
+    logger.debug("RuntimeFunctionHandler#update response: #{response.inspect}")
+
     Tucana::Sagittarius::RuntimeFunctionDefinitionUpdateResponse.new(success: response.success?)
   end
 end

app/models/node_parameter.rb

@@ -21,7 +21,7 @@ def to_grpc
     elsif reference_value.present?
       param.value.reference_value = reference_value.to_grpc
     elsif function_value.present?
-      param.value.function_value = function_value.to_grpc
+      param.value.node_function_id = function_value.id
     end
 
     param

app/policies/namespace_project_policy.rb

@@ -13,6 +13,10 @@ class NamespaceProjectPolicy < BasePolicy
     enable :read_flow
   end
 
+  rule { admin }.policy do
+    enable :namespace_administrator
+  end
+
   customizable_permission :assign_project_runtimes
   customizable_permission :read_namespace_project
   customizable_permission :update_namespace_project

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

@@ -121,9 +121,13 @@ def create_node_function(node_function_id, input_nodes, t)
               next
             end
             if parameter.value.function_value.present?
+              # A little bit hacky but okay
               params << NodeParameter.create(
                 runtime_parameter: runtime_parameter,
-                function_value: create_node_function(parameter.value.function_value, input_nodes, t)
+                function_value: create_node_function(
+                  parameter.value.function_value.id,
+                  [parameter.value.function_value], t
+                )
               )
               next
             end

bin/docker-entrypoint

@@ -5,8 +5,7 @@ if [ "${1}" == "./bin/rails" ] && [ "${2}" == "server" ]; then
 fi
 
 if [ "${SAGITTARIUS_PREPARE_DATABASE}" == "true" ]; then
-  bundle exec rake db:prepare
-  FILTER=01_application_settings bundle exec rake db:seed_fu
+  bundle exec rake db:prepare db:seed_fu
 fi
 
 exec "${@}"

db/fixtures/development/01_users.rb

@@ -27,3 +27,10 @@
   u.password = 'password'
   u.admin = false
 end
+
+%w[Admin Maintainer Owner User].each do |username|
+  UserSession.seed_once :token do |session|
+    session.user = User.find_by(username: username)
+    session.token = username
+  end
+end