@@ -49,7 +49,7 @@ class DataFlowSchema
4949
5050 include DataShift ::Logging
5151
52- attr_reader :configuration , :nodes
52+ attr_reader :nodes , :raw_data , :yaml_data
5353
5454 def initialize
5555 @nodes = DataShift ::NodeCollection . new
@@ -59,16 +59,19 @@ def sources
5959 @nodes . collect ( &:method_binding ) . collect ( &:source )
6060 end
6161
62- def prepare_from_klass ( klass )
62+ # Build the node collection from a Class, that is for each operator in scope
63+ # create a method binding and a node context, and add to collection.
64+ #
65+ def prepare_from_klass ( klass , doc_context = nil )
66+
67+ context = doc_context || DocContext . new ( klass )
6368
6469 @nodes = DataShift ::NodeCollection . new
6570
6671 klass_to_model_methods ( klass ) . each_with_index do |mm , i |
67- puts "DataFlowSchema - #{ mm . operator }
68-
6972 binding = MethodBinding . new ( mm . operator , i , mm )
7073
71- @nodes << DataShift ::NodeContext . new ( DocContext . new ( klass ) , binding , i , nil )
74+ @nodes << DataShift ::NodeContext . new ( context , binding , i , nil )
7275 end
7376
7477 @nodes
@@ -97,32 +100,44 @@ def klass_to_model_methods(klass)
97100 end
98101
99102 model_methods
100-
101103 end
102104
103105 def prepare_from_file ( file_name , locale_key = 'data_flow_schema' )
104- yaml = YAML . load ( File . read ( file_name ) )
106+ @raw_data = File . read ( file_name )
107+ yaml = YAML . load ( raw_data )
105108
106109 prepare_from_yaml ( yaml , locale_key )
107110 end
108111
109112 def prepare_from_string ( text , locale_key = 'data_flow_schema' )
113+ @raw_data = text
110114 yaml = YAML . load ( text )
111115
112116 prepare_from_yaml ( yaml , locale_key )
113117 end
114118
115119 def prepare_from_yaml ( yaml , locale_key = 'data_flow_schema' )
116120
121+ @yaml_data = yaml
122+
117123 @nodes = NodeCollection . new
118124
119125 raise RuntimeError . new ( "Bad YAML syntax - No key #{ locale_key } #{ yaml } ) unless yaml [ locale_key ]
120126
121- klass_section = yaml [ locale_key ]
127+ locale_section = yaml [ locale_key ]
122128
123- klass = klass_section . keys . first
129+ klass = locale_section . keys . first
130+
131+ klass_section = locale_section [ klass ]
132+
133+ # The over all doc context
134+ doc = DocContext . new ( MapperUtils . class_from_string_or_raise ( klass ) )
124135
125- yaml_nodes = klass_section [ klass ] [ 'nodes' ]
136+ nodes . doc_context = doc
137+
138+ DataShift ::Transformer . factory { |f | f . configure_from_yaml ( klass , klass_section ) }
139+
140+ yaml_nodes = klass_section [ 'nodes' ]
126141
127142 logger . info ( "Read Data Schema Nodes: #{ yaml_nodes . inspect } )
128143
@@ -131,11 +146,6 @@ def prepare_from_yaml(yaml, locale_key = 'data_flow_schema')
131146 raise 'Bad syntax in flow schema YAML - Nodes should be a sequence'
132147 end
133148
134- nodes = [ ]
135-
136- # The over all doc context
137- doc = DocContext . new ( MapperUtils . class_from_string_or_raise ( klass ) )
138-
139149 yaml_nodes . each_with_index do |keyed_node , i |
140150
141151 unless ( keyed_node . keys . size == 1 )
@@ -149,28 +159,23 @@ def prepare_from_yaml(yaml, locale_key = 'data_flow_schema')
149159 # - project:
150160 # heading:
151161 # source: "title"
152- # destination : "Title"
162+ # presentation : "Title"
153163 # operator: title
154164 # operator_type: has_many
155- #
156- # - project_owner_budget:
157- # heading:
158- # destination: "Budget"
159- # operator: owner.budget
160- #
161165 logger . info ( "Node Data: #{ keyed_node . inspect } )
162166
163167 # type one of ModelMethod.supported_types_enum
164-
165168 section = keyed_node . values . first
166169
167170 operator = Operator . new ( section [ 'operator' ] , :method ) if ( section [ 'operator' ] )
168171
169172 model_method = ModelMethod . new ( klass , operator , section [ 'operator_type' ] ) if ( section [ 'operator_type' ] )
170173
171- method_binding = MethodBinding . new ( section [ 'heading' ] [ 'source' ] , i , model_method )
174+ source = section . fetch ( 'heading' , { } ) . fetch ( 'source' , nil )
172175
173- doc . headers . add ( section [ 'heading' ] [ 'source' ] )
176+ method_binding = MethodBinding . new ( source , i , model_method )
177+
178+ doc . headers . add ( source )
174179
175180 node = DataShift ::NodeContext . new ( doc , method_binding , i , nil )
176181
@@ -180,50 +185,5 @@ def prepare_from_yaml(yaml, locale_key = 'data_flow_schema')
180185 nodes
181186 end
182187
183- private
184-
185- attr_accessor :current_review_object
186-
187- attr_accessor :model_object
188-
189- def row_to_node_collection ( review_object , row )
190- # The section name, can be used as the state, for linking whole section, rather than at field level
191- link_state = row [ :link_state ] || current_section
192- link_title = row [ :link_title ]
193-
194- @current_review_object = review_object
195-
196- # The review partial can support whole objects, or low level data from method call defined in the DSL
197- if ( row [ :method ] . blank? )
198- node_collection . add ( row [ :title ] , review_object , link_state . to_s , link_title )
199- else
200- # rubocop:disable Style/IfInsideElse
201- if ( review_object . respond_to? ( :each ) )
202- review_object . each do |o |
203- @current_review_object = o
204- node_collection . add ( row [ :title ] , send_chain ( row [ :method ] ) , link_state . to_s , link_title )
205- end
206- else
207- node_collection . add ( row [ :title ] , send_chain ( row [ :method ] ) , link_state . to_s , link_title )
208- end
209-
210- end
211- end
212-
213- def find_association ( method_chain )
214- arr = method_chain . to_s . split ( '.' )
215-
216- arr . inject ( model_object ) { |o , a | o . send ( a ) }
217- end
218-
219- def send_chain ( method_chain )
220- arr = method_chain . to_s . split ( '.' )
221- begin
222- arr . inject ( current_review_object ) { |o , a | o . send ( a ) }
223- rescue => e
224- Rails . logger . error ( "Failed to process method chain #{ method_chain } #{ e . message } )
225- return I18n . t ( '.enrollment_review.missing_data' )
226- end
227- end
228188 end
229189end
0 commit comments