✨ Add raw methods for error and activity reporting by addons.

addon/adapter.go

@@ -114,6 +114,7 @@ func (h *Adapter) Run(addon func() error) {
 	}()
 	//
 	// Report addon started.
+	h.Load()
 	h.Started()
 	//
 	// Run addon.

addon/task.go

@@ -6,6 +6,8 @@ import (
 	"github.com/konveyor/tackle2-hub/api"
 	"github.com/konveyor/tackle2-hub/binding"
 	"github.com/konveyor/tackle2-hub/task"
+	"gopkg.in/yaml.v2"
+	"strings"
 )
 
 //
@@ -67,7 +69,6 @@ func (h *Task) Variant() string {
 //
 // Started report addon started.
 func (h *Task) Started() {
-	h.Load()
 	h.deleteReport()
 	h.report.Status = task.Running
 	h.pushReport()
@@ -109,31 +110,69 @@ func (h *Task) Failed(reason string, x ...interface{}) {
 // Error report addon error.
 // The description can be a printf style format.
 func (h *Task) Error(severity, description string, x ...interface{}) {
-	h.report.Status = task.Failed
 	description = fmt.Sprintf(description, x...)
-	h.report.Errors = append(
-		h.report.Errors,
+	h.RawError(
 		api.TaskError{
 			Severity:    severity,
 			Description: description,
 		})
-	h.pushReport()
 	return
 }
 
 //
 // Activity report addon activity.
 // The description can be a printf style format.
-func (h *Task) Activity(entry string, x ...interface{}) {
-	entry = fmt.Sprintf(entry, x...)
-	h.report.Activity = append(
-		h.report.Activity,
-		entry)
+func (h *Task) Activity(entry string, v ...interface{}) {
+	entry = fmt.Sprintf(entry, v...)
+	h.RawActivity(entry)
+	return
+}
+
+//
+// RawError report addon error.
+func (h *Task) RawError(error ...api.TaskError) {
+	h.report.Status = task.Failed
+	for i := range error {
+		h.report.Errors = append(
+			h.report.Errors,
+			error[i])
+		Log.Info(
+			"Addon reported: error.",
+			"error",
+			error[i])
+	}
+	h.pushReport()
+	return
+}
+
+//
+// RawActivity report addon activity.
+func (h *Task) RawActivity(object interface{}) {
+	switch object.(type) {
+	case string:
+		s := object.(string)
+		h.RawActivity(strings.Split(s, "\n"))
+	case []string:
+		prefix := ""
+		list := object.([]string)
+		if len(list) > 1 {
+			prefix = "> "
+		}
+		for i := range list {
+			entry := prefix + list[i]
+			h.report.Activity = append(
+				h.report.Activity,
+				entry)
+			Log.Info(
+				"Addon reported: activity.",
+				"object",
+				entry)
+		}
+	default:
+		b, _ := yaml.Marshal(object)
+		h.RawActivity(string(b))
+	}
 	h.pushReport()
-	Log.Info(
-		"Addon reported: activity.",
-		"activity",
-		h.report.Activity)
 	return
 }
 

hack/cmd/addon/main.go

@@ -38,8 +38,6 @@ type SoftError = hub.SoftError
 // main
 func main() {
 	addon.Run(func() (err error) {
-		_, _ = addon.Identity.List()
-		_, _ = addon.Identity.Get(1)
 		//
 		// Get the addon data associated with the task.
 		d := &Data{}