fix(task): add error to task if the task fails

Signed-off-by: Rodney Osodo <[email protected]>

manager/service.go

@@ -341,6 +341,10 @@ func (svc *service) updateResultsHandler(ctx context.Context, msg map[string]int
 	t.UpdatedAt = time.Now()
 	t.FinishTime = time.Now()
 
+	if errMsg, ok := msg["error"].(string); ok {
+		t.Error = errMsg
+	}
+
 	if err := svc.tasksDB.Update(ctx, t.ID, t); err != nil {
 		return err
 	}

proplet/wasm.go

@@ -146,13 +146,20 @@ func (w *wazeroRuntime) runOnHostRuntime(ctx context.Context, wasmBinary []byte,
 	}
 
 	go func(fileName string) {
+		var payload map[string]interface{}
+
 		if err := cmd.Wait(); err != nil {
 			w.logger.Error("failed to wait for command", slog.String("id", id), slog.String("error", err.Error()))
-		}
-
-		payload := map[string]interface{}{
-			"task_id": id,
-			"results": results.String(),
+			payload = map[string]interface{}{
+				"task_id": id,
+				"error":   err.Error(),
+				"results": results.String(),
+			}
+		} else {
+			payload = map[string]interface{}{
+				"task_id": id,
+				"results": results.String(),
+			}
 		}
 
 		topic := fmt.Sprintf(resultsTopic, w.channelID)

task/task.go

@@ -38,6 +38,7 @@ type Task struct {
 	CLIArgs    []string  `json:"cli_args"`
 	Inputs     []uint64  `json:"inputs,omitempty"`
 	Results    any       `json:"results,omitempty"`
+	Error      string    `json:"error,omitempty"`
 	StartTime  time.Time `json:"start_time"`
 	FinishTime time.Time `json:"finish_time"`
 	CreatedAt  time.Time `json:"created_at"`