cubicweb: comparison entities/wfobjs.py

equal deleted inserted replaced

-:70dbba754c11
+:440931181322
 'WHERE S eid %(s)s, T eid %(t)s',
 {'s': state, 't': tr.eid}, ('s', 't'))
 tr.set_transition_permissions(requiredgroups, conditions, reset=False)
 return tr
-def add_transition(self, name, fromstates, tostate,
+def add_transition(self, name, fromstates, tostate=None,
 requiredgroups=(), conditions=(), **kwargs):
 """add a transition to this workflow from some state(s) to another"""
 tr = self._add_transition('Transition', name, fromstates,
 requiredgroups, conditions, **kwargs)
-if hasattr(tostate, 'eid'):
+if tostate is not None:
-tostate = tostate.eid
+if hasattr(tostate, 'eid'):
-self.req.execute('SET T destination_state S '
+tostate = tostate.eid
-'WHERE S eid %(s)s, T eid %(t)s',
+self.req.execute('SET T destination_state S '
-{'t': tr.eid, 's': tostate}, ('s', 't'))
+'WHERE S eid %(s)s, T eid %(t)s',
+{'t': tr.eid, 's': tostate}, ('s', 't'))
 return tr
-def add_wftransition(self, name, subworkflow, fromstates, exitpoints,
+def add_wftransition(self, name, subworkflow, fromstates, exitpoints=(),
 requiredgroups=(), conditions=(), **kwargs):
 """add a workflow transition to this workflow"""
 tr = self._add_transition('WorkflowTransition', name, fromstates,
 requiredgroups, conditions, **kwargs)
 if hasattr(subworkflow, 'eid'):
 return self.subwf.initial
 def add_exit_point(self, fromstate, tostate):
 if hasattr(fromstate, 'eid'):
 fromstate = fromstate.eid
-if hasattr(tostate, 'eid'):
+if tostate is None:
-tostate = tostate.eid
+self.req.execute('INSERT SubWorkflowExitPoint X: T subworkflow_exit X, '
-self.req.execute('INSERT SubWorkflowExitPoint X: T subworkflow_exit X, '
+'X subworkflow_state FS WHERE T eid %(t)s, FS eid %(fs)s',
-'X subworkflow_state FS, X destination_state TS '
+{'t': self.eid, 'fs': fromstate}, ('t', 'fs'))
-'WHERE T eid %(t)s, FS eid %(fs)s, TS eid %(ts)s',
+else:
-{'t': self.eid, 'fs': fromstate, 'ts': tostate},
+if hasattr(tostate, 'eid'):
-('t', 'fs', 'ts'))
+tostate = tostate.eid
+self.req.execute('INSERT SubWorkflowExitPoint X: T subworkflow_exit X, '
-def get_exit_point(self, state):
+'X subworkflow_state FS, X destination_state TS '
+'WHERE T eid %(t)s, FS eid %(fs)s, TS eid %(ts)s',
+{'t': self.eid, 'fs': fromstate, 'ts': tostate},
+('t', 'fs', 'ts'))
+def get_exit_point(self, entity, stateeid):
 """if state is an exit point, return its associated destination state"""
-if hasattr(state, 'eid'):
+if hasattr(stateeid, 'eid'):
-state = state.eid
+stateeid = stateeid.eid
-stateeid = self.exit_points().get(state)
+try:
-if stateeid is not None:
+tostateeid = self.exit_points()[stateeid]
-return self.req.entity_from_eid(stateeid)
+except KeyError:
 return None
+if tostateeid is None:
+# go back to state from which we've entered the subworkflow
+return entity.subworkflow_input_trinfo().previous_state
+return self.req.entity_from_eid(tostateeid)
 @cached
 def exit_points(self):
 result = {}
 for ep in self.subworkflow_exit:
-result[ep.subwf_state.eid] = ep.destination.eid
+result[ep.subwf_state.eid] = ep.destination and ep.destination.eid
 return result
 def clear_all_caches(self):
 super(WorkflowableMixIn, self).clear_all_caches()
 clear_cache(self, 'exit_points')
 def subwf_state(self):
 return self.subworkflow_state[0]
 @property
 def destination(self):
-return self.destination_state[0]
+return self.destination_state and self.destination_state[0] or None
 class State(AnyEntity):
 """customized class for State entities"""
 id = 'State'
 """change the entity's state by firing transition of the given name in
 entity's workflow
 """
 assert self.current_workflow
 if isinstance(tr, basestring):
-tr = self.current_workflow.transition_by_name(tr)
+_tr = self.current_workflow.transition_by_name(tr)
-assert tr is not None, 'not a %s transition: %s' % (self.id, tr)
+assert _tr is not None, 'not a %s transition: %s' % (self.id, tr)
+tr = _tr
 return self._add_trinfo(comment, commentformat, tr.eid)
 def change_state(self, statename, comment=None, commentformat=None, tr=None):
 """change the entity's state to the given state (name or entity) in
 entity's workflow. This method should only by used by manager to fix an
 statename))
 stateeid = state.eid
 # XXX try to find matching transition?
 return self._add_trinfo(comment, commentformat, tr and tr.eid, stateeid)
-def subworkflow_input_transition(self):
+def subworkflow_input_trinfo(self):
-"""return the transition which has went through the current sub-workflow
+"""return the TrInfo which has be recorded when this entity went into
+the current sub-workflow
 """
 if self.main_workflow.eid == self.current_workflow.eid:
 return # doesn't make sense
 subwfentries = []
 for trinfo in self.workflow_history:
 else:
 # enter
 subwfentries.append(trinfo)
 if not subwfentries:
 return None
-return subwfentries[-1].transition
+return subwfentries[-1]
+def subworkflow_input_transition(self):
+"""return the transition which has went through the current sub-workflow
+"""
+return getattr(self.subworkflow_input_trinfo(), 'transition', None)
 def clear_all_caches(self):
 super(WorkflowableMixIn, self).clear_all_caches()
 clear_cache(self, 'cwetype_workflow')

branch	stable
changeset 3628	440931181322
parent 3621	1ec4452aa36f
child 3629	559cad62c786
child 3663	c74d8ec4cdb2