Migrate flow to tucana 0.0.36

Author: Taucher2003

app/models/flow.rb

@@ -18,7 +18,20 @@ def to_grpc
       input_type_identifier: input_type&.identifier,
       return_type_identifier: return_type&.identifier,
       settings: flow_settings.map(&:to_grpc),
-      starting_node: starting_node.to_grpc
+      starting_node_id: starting_node.id,
+      node_functions: collect_node_functions
     )
   end
+
+  private
+
+  def collect_node_functions
+    current_node = starting_node
+    nodes = []
+    until current_node.nil?
+      nodes << current_node.to_grpc
+      current_node = current_node.next_node
+    end
+    nodes
+  end
 end

app/models/node_function.rb

@@ -45,7 +45,7 @@ def to_grpc
       database_id: id,
       runtime_function_id: runtime_function.runtime_name,
       parameters: node_parameters.map(&:to_grpc),
-      next_node: next_node&.to_grpc
+      next_node_id: next_node&.id
     )
   end
 end

spec/models/flow_spec.rb

@@ -17,56 +17,73 @@
 
   describe '#to_grpc' do
     let(:flow) do
-      create(:flow,
-             flow_settings: [
-               create(:flow_setting,
-                      flow_setting_id: 'example_key',
-                      object: { some_key: 'some_value' })
-             ],
-             starting_node: create(:node_function,
-                                   node_parameters: [
-                                     create(:node_parameter,
-                                            runtime_parameter: create(:runtime_parameter_definition,
-                                                                      data_type: create(:data_type_identifier,
-                                                                                        generic_key: 'T')))
-                                   ]))
+      create(
+        :flow,
+        flow_settings: [
+          create(
+            :flow_setting,
+            flow_setting_id: 'example_key',
+            object: { some_key: 'some_value' }
+          )
+        ],
+        starting_node: create(
+          :node_function,
+          node_parameters: [
+            create(
+              :node_parameter,
+              runtime_parameter: create(
+                :runtime_parameter_definition,
+                data_type: create(
+                  :data_type_identifier,
+                  generic_key: 'T'
+                )
+              )
+            )
+          ]
+        )
+      )
     end
 
     it 'matches the model' do
       grpc_object = flow.to_grpc
 
-      expect(grpc_object.to_h).to eq({
-                                       flow_id: flow.id,
-                                       project_id: flow.project.id,
-                                       type: flow.flow_type.identifier,
-                                       starting_node: {
-                                         database_id: flow.starting_node.id,
-                                         runtime_function_id: flow.starting_node.runtime_function.runtime_name,
-                                         parameters: [
-                                           {
-                                             database_id: flow.starting_node.node_parameters.first.id,
-                                             runtime_parameter_id:
-                                               flow.starting_node.node_parameters.first.runtime_parameter.runtime_name,
-                                             value: {
-                                               literal_value: {
-                                                 string_value: flow.starting_node.node_parameters.first.literal_value,
-                                               },
-                                             },
-                                           }
-                                         ],
-                                       },
-                                       settings: [
-                                         database_id: flow.flow_settings.first.id,
-                                         flow_setting_id: flow.flow_settings.first.flow_setting_id,
-                                         object: {
-                                           fields: {
-                                             'some_key' => {
-                                               string_value: flow.flow_settings.first.object['some_key'],
-                                             },
-                                           },
-                                         }
-                                       ],
-                                     })
+      expect(grpc_object.to_h).to eq(
+        {
+          flow_id: flow.id,
+          project_id: flow.project.id,
+          type: flow.flow_type.identifier,
+          node_functions: [
+            {
+              database_id: flow.starting_node.id,
+              runtime_function_id: flow.starting_node.runtime_function.runtime_name,
+              parameters: [
+                {
+                  database_id: flow.starting_node.node_parameters.first.id,
+                  runtime_parameter_id:
+                    flow.starting_node.node_parameters.first.runtime_parameter.runtime_name,
+                  value: {
+                    literal_value: {
+                      string_value: flow.starting_node.node_parameters.first.literal_value,
+                    },
+                  },
+                }
+              ],
+            }
+          ],
+          starting_node_id: flow.starting_node.id,
+          settings: [
+            database_id: flow.flow_settings.first.id,
+            flow_setting_id: flow.flow_settings.first.flow_setting_id,
+            object: {
+              fields: {
+                'some_key' => {
+                  string_value: flow.flow_settings.first.object['some_key'],
+                },
+              },
+            }
+          ],
+        }
+      )
     end
   end
 end