@@ -95,6 +95,7 @@ def solve(self, ntuple):
9595 else :
9696 self .ntuple = ntuple
9797 predicate_type = ntuple ['predicate_type' ]
98+ #print(predicate_type)
9899 try :
99100 dispatch = getattr (self , "solve_%s" % predicate_type )
100101 dispatch (ntuple )
@@ -114,7 +115,7 @@ def update_world(self, discovered=[]):
114115 self .world .append (item )
115116
116117 def solve_command (self , ntuple ):
117- self .route_event (ntuple ['eventDescriptor' ], "query " )
118+ self .route_event (ntuple ['eventDescriptor' ], "command " )
118119 #self.decoder.pprint_ntuple(ntuple)
119120
120121 def solve_query (self , ntuple ):
@@ -171,7 +172,9 @@ def route_action(self, parameters, predicate):
171172 if parameters ['p_features' ]:
172173 self .p_features = parameters ['p_features' ]['processFeatures' ]
173174 dispatch = getattr (self , "{}_{}" .format (predicate , action ))
174- return_value = dispatch (parameters )
175+
176+ #return_value = dispatch(parameters)
177+ return_value = self .route_dispatch (dispatch , parameters )
175178 self .history .insert (0 , (parameters , True ))
176179 self .p_features = None
177180 return return_value
@@ -182,15 +185,13 @@ def route_action(self, parameters, predicate):
182185 self .history .insert (0 , (parameters , False ))
183186 self .identification_failure (message )
184187
188+ def route_dispatch (self , dispatch_function , parameters ):
189+ """ Simply runs dispatch_function on PARAMETERS. """
190+ return dispatch_function (parameters )
191+
185192 def close (self ):
186193 return
187194
188- def solve_serial (self , parameters , predicate ):
189- print (parameters )
190-
191- def solve_serial (self , parameters , predicate ):
192- print (parameters )
193-
194195 def check_for_clarification (self , ntuple ):
195196 """ Will need to be replaced by a process that checks whether ntuple needs clarification.
196197 Requires some sort of context/world model. """
0 commit comments