feat(fxcore): Added core tasks system

fxcore/module.go

@@ -304,16 +304,16 @@ func withHandlers(coreServer *echo.Echo, p FxCoreParam) (*echo.Echo, error) {
 				return echo.NewHTTPError(http.StatusInternalServerError, fmt.Sprintf("cannot close request body: %v", err.Error()))
 			}
 
-			res, err := p.TaskRegistry.Run(ctx, name, input)
-			if err != nil {
+			res := p.TaskRegistry.Run(ctx, name, input)
+			if res.Success == false {
 				logger.Error().Err(err).Str("task", name).Msg("task execution error")
 
-				return echo.NewHTTPError(http.StatusInternalServerError, fmt.Sprintf("task execution error: %v", err.Error()))
+				return c.JSON(http.StatusInternalServerError, res)
 			}
 
 			logger.Info().Str("task", name).Msg("task execution success")
 
-			return c.String(http.StatusOK, string(res))
+			return c.JSON(http.StatusOK, res)
 		})
 
 		coreServer.Logger.Debug("registered tasks handler")

fxcore/task.go

@@ -7,9 +7,15 @@ import (
 	"go.uber.org/fx"
 )
 
+type TaskResult struct {
+	Success  bool           `json:"success"`
+	Message  string         `json:"message"`
+	Metadata map[string]any `json:"metadata,omitempty"`
+}
+
 type Task interface {
 	Name() string
-	Run(ctx context.Context, input []byte) ([]byte, error)
+	Run(ctx context.Context, input []byte) TaskResult
 }
 
 type TaskRegistry struct {
@@ -42,10 +48,13 @@ func (r *TaskRegistry) Names() []string {
 	return names
 }
 
-func (r *TaskRegistry) Run(ctx context.Context, name string, input []byte) ([]byte, error) {
+func (r *TaskRegistry) Run(ctx context.Context, name string, input []byte) TaskResult {
 	task, ok := r.tasks[name]
 	if !ok {
-		return nil, fmt.Errorf("task %s not found in registry", name)
+		return TaskResult{
+			Success: false,
+			Message: fmt.Sprintf("task %s not found", name),
+		}
 	}
 
 	return task.Run(ctx, input)