enhanced logger

Author: adranwit

model/task.go

@@ -3,6 +3,7 @@ package model
 // Task represents a group of action
 type Task struct {
 	*AbstractNode `yaml:",inline"` //abstract node
+	*MetaTag      `yaml:",inline"` //optional template tag propagated to task
 	Actions       []*Action        ` yaml:",omitempty"` //actions
 	*TasksNode    ` yaml:",inline"`
 	Fail          bool      ` yaml:",omitempty"` //controls if return fail status workflow on catch task
@@ -34,6 +35,10 @@ func (t *Task) Clone() *Task {
 	}
 	result.TasksNode = t.TasksNode.Clone()
 	result.AbstractNode = t.AbstractNode.Clone()
+	if t.MetaTag != nil {
+		tag := *t.MetaTag
+		result.MetaTag = &tag
+	}
 	return &result
 }
 

model/task_events.go

@@ -0,0 +1,75 @@
+package model
+
+// TaskStartEvent represents the start of a task within a workflow.
+type TaskStartEvent struct {
+	WorkflowName string   `json:",omitempty"`
+	OwnerURL     string   `json:",omitempty"`
+	TaskName     string   `json:",omitempty"`
+	TaskPath     []string `json:",omitempty"`
+	SessionID    string   `json:",omitempty"`
+	Index        int      `json:",omitempty"`
+	TemplateTag  *MetaTag `json:",omitempty"`
+}
+
+// NewTaskStartEvent creates a new TaskStartEvent.
+func NewTaskStartEvent(workflowName, ownerURL, taskName string, taskPath []string, sessionID string, index int, templateTag *MetaTag) *TaskStartEvent {
+	return &TaskStartEvent{
+		WorkflowName: workflowName,
+		OwnerURL:     ownerURL,
+		TaskName:     taskName,
+		TaskPath:     taskPath,
+		SessionID:    sessionID,
+		Index:        index,
+		TemplateTag:  templateTag,
+	}
+}
+
+// TaskEndEvent represents the end of a task within a workflow.
+type TaskEndEvent struct {
+	WorkflowName string   `json:",omitempty"`
+	OwnerURL     string   `json:",omitempty"`
+	TaskName     string   `json:",omitempty"`
+	TaskPath     []string `json:",omitempty"`
+	SessionID    string   `json:",omitempty"`
+	Index        int      `json:",omitempty"`
+	Status       string   `json:",omitempty"`
+	Error        string   `json:",omitempty"`
+}
+
+// NewTaskEndEvent creates a new TaskEndEvent.
+func NewTaskEndEvent(workflowName, ownerURL, taskName string, taskPath []string, sessionID string, index int, status, errMsg string) *TaskEndEvent {
+	return &TaskEndEvent{
+		WorkflowName: workflowName,
+		OwnerURL:     ownerURL,
+		TaskName:     taskName,
+		TaskPath:     taskPath,
+		SessionID:    sessionID,
+		Index:        index,
+		Status:       status,
+		Error:        errMsg,
+	}
+}
+
+// TaskAsyncStartEvent denotes that a task has launched asynchronous actions.
+type TaskAsyncStartEvent struct {
+	TaskPath  []string `json:",omitempty"`
+	Expected  int      `json:",omitempty"`
+	SessionID string   `json:",omitempty"`
+}
+
+// NewTaskAsyncStartEvent creates a new TaskAsyncStartEvent.
+func NewTaskAsyncStartEvent(taskPath []string, expected int, sessionID string) *TaskAsyncStartEvent {
+	return &TaskAsyncStartEvent{TaskPath: taskPath, Expected: expected, SessionID: sessionID}
+}
+
+// TaskAsyncDoneEvent denotes completion of asynchronous actions within a task.
+type TaskAsyncDoneEvent struct {
+	TaskPath  []string `json:",omitempty"`
+	Completed int      `json:",omitempty"`
+	SessionID string   `json:",omitempty"`
+}
+
+// NewTaskAsyncDoneEvent creates a new TaskAsyncDoneEvent.
+func NewTaskAsyncDoneEvent(taskPath []string, completed int, sessionID string) *TaskAsyncDoneEvent {
+	return &TaskAsyncDoneEvent{TaskPath: taskPath, Completed: completed, SessionID: sessionID}
+}

model/template.go

@@ -288,6 +288,15 @@ func flattenAction(parent *Task, task *Task, tag *Tag, description string) []*Ac
 	if !isRootTask {
 		tag.Group = parent.Name
 	}
+	// propagate template MetaTag to task itself
+	if task.MetaTag == nil {
+		task.MetaTag = &MetaTag{
+			Tag:            tag.Expand(tag.Name),
+			TagIndex:       tag.Iterator.Index(),
+			TagID:          tag.TagID(),
+			TagDescription: description,
+		}
+	}
 	if len(task.Actions) > 0 {
 		result = task.Actions
 		for i := range result {

service/workflow/lifecycle.go

@@ -0,0 +1,49 @@
+package workflow
+
+// WorkflowStartEvent represents the start of a workflow, optionally nested.
+type WorkflowStartEvent struct {
+	Name           string `json:",omitempty"`
+	OwnerURL       string `json:",omitempty"`
+	ParentName     string `json:",omitempty"`
+	ParentOwnerURL string `json:",omitempty"`
+	SessionID      string `json:",omitempty"`
+	SelectedTasks  string `json:",omitempty"`
+	TagIDs         string `json:",omitempty"`
+}
+
+// NewWorkflowStartEvent creates a new WorkflowStartEvent.
+func NewWorkflowStartEvent(name, ownerURL, parentName, parentOwnerURL, sessionID, selectedTasks, tagIDs string) *WorkflowStartEvent {
+	return &WorkflowStartEvent{
+		Name:           name,
+		OwnerURL:       ownerURL,
+		ParentName:     parentName,
+		ParentOwnerURL: parentOwnerURL,
+		SessionID:      sessionID,
+		SelectedTasks:  selectedTasks,
+		TagIDs:         tagIDs,
+	}
+}
+
+// WorkflowEndEvent represents completion of a workflow.
+type WorkflowEndEvent struct {
+	Name           string `json:",omitempty"`
+	OwnerURL       string `json:",omitempty"`
+	ParentName     string `json:",omitempty"`
+	ParentOwnerURL string `json:",omitempty"`
+	SessionID      string `json:",omitempty"`
+	Status         string `json:",omitempty"`
+	Error          string `json:",omitempty"`
+}
+
+// NewWorkflowEndEvent creates a new WorkflowEndEvent.
+func NewWorkflowEndEvent(name, ownerURL, parentName, parentOwnerURL, sessionID, status, errMsg string) *WorkflowEndEvent {
+	return &WorkflowEndEvent{
+		Name:           name,
+		OwnerURL:       ownerURL,
+		ParentName:     parentName,
+		ParentOwnerURL: parentOwnerURL,
+		SessionID:      sessionID,
+		Status:         status,
+		Error:          errMsg,
+	}
+}