jwetzell/showbridge-go
1
0
Fork 0
mirror of https://github.com/jwetzell/showbridge-go.git synced 2026-07-26 09:58:40 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

include processor index in processpayload error

Browse Source
This commit is contained in:
Joel Wetzell
2026-05-26 17:53:34 -05:00
parent f175bed084
commit 438c396aeb
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/route/route.go
+3 -3
View File
@@ -40,12 +40,12 @@ func (r *Route) Input() string {
}
func (r *Route) ProcessPayload(ctx context.Context, wrappedPayload common.WrappedPayload) (any, error) {
for _, processor := range r.processors {
for processorIndex, processor := range r.processors {
processedPayload, err := processor.Process(ctx, wrappedPayload)
if err != nil {
return nil, err
return nil, fmt.Errorf("processor[%d] error: %w", processorIndex, err)
}
//NOTE(jwetzell) payload has been marked as an end
//NOTE(jwetzell) payload has been marked as an end without error
if processedPayload.End {
return processedPayload.Payload, nil
}