Merge pull request #38 from lixingwang/otherwise-link

support otherwise branch

Author: Frank Martinez

definition/definition.go

@@ -260,6 +260,9 @@ const (
 
 	// LtError denotes an error link
 	LtError LinkType = 3
+
+	// LtOtherwise denotes an otherwise link
+	LtOtherwise = 4
 )
 
 // LinkOld is the object that describes the definition of

definition/definition_ser.go

@@ -361,6 +361,8 @@ func createLink(tasks map[string]*Task, linkRep *LinkRep, id int, ef expression.
 			link.linkType = LtLabel
 		case "error", "3":
 			link.linkType = LtError
+		case "otherwise", "4":
+			link.linkType = LtOtherwise
 		default:
 			//todo get the flow logger
 			log.RootLogger().Warnf("Unsupported link type '%s', using default link")

model/simple/taskbehavior.go

@@ -144,6 +144,8 @@ func (tb *TaskBehavior) Done(ctx model.TaskContext) (notifyFlow bool, taskEntrie
 			logger.Debugf("Task '%s' has %d outgoing links", ctx.Task().ID(), numLinks)
 		}
 
+		var linkFollowed bool
+		var otherwiseLinkInst model.LinkInstance
 		for _, linkInst := range linkInsts {
 
 			follow := true
@@ -153,6 +155,11 @@ func (tb *TaskBehavior) Done(ctx model.TaskContext) (notifyFlow bool, taskEntrie
 				continue
 			}
 
+			if linkInst.Link().Type() == definition.LtOtherwise {
+				otherwiseLinkInst = linkInst
+				continue
+			}
+
 			if linkInst.Link().Type() == definition.LtExpression {
 				//todo handle error
 				if logger.DebugEnabled() {
@@ -166,6 +173,7 @@ func (tb *TaskBehavior) Done(ctx model.TaskContext) (notifyFlow bool, taskEntrie
 			}
 
 			if follow {
+				linkFollowed = true
 				linkInst.SetStatus(model.LinkStatusTrue)
 
 				if logger.DebugEnabled() {
@@ -181,6 +189,16 @@ func (tb *TaskBehavior) Done(ctx model.TaskContext) (notifyFlow bool, taskEntrie
 			}
 		}
 
+		//Otherwise branch while no link to follow
+		if !linkFollowed && otherwiseLinkInst != nil {
+			otherwiseLinkInst.SetStatus(model.LinkStatusTrue)
+			if logger.DebugEnabled() {
+				logger.Debugf("Task '%s': Following Link  to task '%s'", ctx.Task().ID(), otherwiseLinkInst.Link().ToTask().ID())
+			}
+			taskEntry := &model.TaskEntry{Task: otherwiseLinkInst.Link().ToTask()}
+			taskEntries = append(taskEntries, taskEntry)
+		}
+
 		//continue on to successor tasks
 		return false, taskEntries, nil
 	}