Update from https://github.com/cloudimpl/next-coder/commit/9d0a186ff34c6ead64c725513a418857aa73ae2b

Author: CloudimplBot

polycode/errors.go

@@ -1,7 +1,11 @@
 package polycode
 
 import (
+	"bytes"
+	"compress/gzip"
 	"fmt"
+	"io"
+	"strings"
 )
 
 var ErrBadRequest = DefineError("polycode.client", 2, "bad request")
@@ -24,6 +28,56 @@ type Error struct {
 	CanRetry bool
 }
 
+type Stacktrace struct {
+	Stacktrace   string `json:"stacktrace"`
+	IsAvailable  bool   `json:"isAvailable"`
+	IsCompressed bool   `json:"isCompressed"`
+}
+
+// Compress compresses the stacktrace string using gzip.
+func (s *Stacktrace) Compress() error {
+	if s.IsCompressed || !s.IsAvailable || s.Stacktrace == "" {
+		return nil
+	}
+
+	var buf bytes.Buffer
+	gz := gzip.NewWriter(&buf)
+	_, err := gz.Write([]byte(s.Stacktrace))
+	if err != nil {
+		return err
+	}
+	if err := gz.Close(); err != nil {
+		return err
+	}
+
+	s.Stacktrace = buf.String() // convert []byte to string for JSON compatibility
+	s.IsCompressed = true
+	return nil
+}
+
+// Extract decompresses the stacktrace if it is compressed.
+func (s *Stacktrace) Extract() error {
+	if !s.IsCompressed || s.Stacktrace == "" {
+		return nil
+	}
+
+	buf := strings.NewReader(s.Stacktrace)
+	gz, err := gzip.NewReader(buf)
+	if err != nil {
+		return err
+	}
+	defer gz.Close()
+
+	decoded, err := io.ReadAll(gz)
+	if err != nil {
+		return err
+	}
+
+	s.Stacktrace = string(decoded)
+	s.IsCompressed = false
+	return nil
+}
+
 func (t Error) Wrap(err error) Error {
 	return Error{
 		Module:   t.Module,

polycode/model.go

@@ -42,11 +42,12 @@ type ServiceMeta struct {
 }
 
 type ServiceCompleteEvent struct {
-	IsError bool        `json:"isError"`
-	Output  any         `json:"output"`
-	Error   Error       `json:"error"`
-	Logs    []LogMsg    `json:"logs"`
-	Meta    ServiceMeta `json:"meta"`
+	IsError    bool        `json:"isError"`
+	Output     any         `json:"output"`
+	Error      Error       `json:"error"`
+	Stacktrace Stacktrace  `json:"stacktrace"`
+	Logs       []LogMsg    `json:"logs"`
+	Meta       ServiceMeta `json:"meta"`
 }
 
 type ApiStartEvent struct {

polycode/runtime.go

@@ -156,7 +156,7 @@ func runService(ctx context.Context, taskLogger Logger, event ServiceStartEvent)
 
 					taskLogger.Error().Msg(recovered.Error())
 					err2 := ErrInternal.Wrap(recovered)
-					evt = ErrorToServiceComplete(err2)
+					evt = ErrorToServiceComplete(err2, stackTrace)
 				}
 			} else {
 				stackTrace := string(debug.Stack())
@@ -165,7 +165,7 @@ func runService(ctx context.Context, taskLogger Logger, event ServiceStartEvent)
 				errorStr := fmt.Sprintf("recoverted %v", r)
 				taskLogger.Error().Msg(errorStr)
 				err2 := ErrInternal.Wrap(fmt.Errorf(errorStr))
-				evt = ErrorToServiceComplete(err2)
+				evt = ErrorToServiceComplete(err2, stackTrace)
 			}
 		}
 	}()
@@ -174,7 +174,7 @@ func runService(ctx context.Context, taskLogger Logger, event ServiceStartEvent)
 	if err != nil {
 		err2 := ErrServiceExecError.Wrap(err)
 		taskLogger.Error().Msg(err2.Error())
-		return ErrorToServiceComplete(err2)
+		return ErrorToServiceComplete(err2, "")
 	}
 
 	meta := ServiceMeta{
@@ -185,21 +185,21 @@ func runService(ctx context.Context, taskLogger Logger, event ServiceStartEvent)
 	if err != nil {
 		err2 := ErrServiceExecError.Wrap(err)
 		taskLogger.Error().Msg(err2.Error())
-		return ErrorToServiceComplete(err2)
+		return ErrorToServiceComplete(err2, "")
 	}
 
 	err = ConvertType(event.Input, inputObj)
 	if err != nil {
 		err2 := ErrBadRequest.Wrap(err)
 		taskLogger.Error().Msg(err2.Error())
-		return ErrorToServiceComplete(err2)
+		return ErrorToServiceComplete(err2, "")
 	}
 
 	err = currentValidator.Validate(inputObj)
 	if err != nil {
 		err2 := ErrBadRequest.Wrap(err)
 		taskLogger.Error().Msg(err2.Error())
-		return ErrorToServiceComplete(err2)
+		return ErrorToServiceComplete(err2, "")
 	}
 
 	ctxImpl := &ContextImpl{
@@ -227,7 +227,7 @@ func runService(ctx context.Context, taskLogger Logger, event ServiceStartEvent)
 	if err != nil {
 		err2 := ErrServiceExecError.Wrap(err)
 		taskLogger.Error().Msg(err2.Error())
-		return ErrorToServiceComplete(err2)
+		return ErrorToServiceComplete(err2, "")
 	}
 
 	taskLogger.Info().Msg("service completed")
@@ -330,11 +330,22 @@ func ValueToServiceComplete(output any) ServiceCompleteEvent {
 	}
 }
 
-func ErrorToServiceComplete(err Error) ServiceCompleteEvent {
+func ErrorToServiceComplete(err Error, stacktraceStr string) ServiceCompleteEvent {
+	var stacktrace Stacktrace
+	if stacktraceStr != "" {
+		stacktrace = Stacktrace{
+			Stacktrace:   stacktraceStr,
+			IsAvailable:  true,
+			IsCompressed: false,
+		}
+		_ = stacktrace.Compress()
+	}
+
 	return ServiceCompleteEvent{
-		Output:  nil,
-		IsError: true,
-		Error:   err,
+		Output:     nil,
+		IsError:    true,
+		Error:      err,
+		Stacktrace: stacktrace,
 	}
 }