wrap inner chunk reader error with %w to preserve errors.Is identity

johnelliott · johnelliott · commit 07b0d6cefa2b · 2026-04-29T11:11:18.000-04:00
diff --git a/pkg/handlers/default.go b/pkg/handlers/default.go
@@ -134,7 +134,7 @@ func (h *defaultHandler) handleNonArchiveContent(
 		dataOrErr := DataOrErr{}
 		if err := chunkResult.Error(); err != nil {
 			h.metrics.incErrors()
-			dataOrErr.Err = fmt.Errorf("%w: error reading chunk: %v", ErrProcessingWarning, err)
+			dataOrErr.Err = fmt.Errorf("%w: error reading chunk: %w", ErrProcessingWarning, err)
 			if writeErr := common.CancellableWrite(ctx, dataOrErrChan, dataOrErr); writeErr != nil {
 				return fmt.Errorf("%w: error writing to data channel: %v", ErrProcessingFatal, writeErr)
 			}

Original file line number	Diff line number	Diff line change
`@@ -134,7 +134,7 @@ func (h *defaultHandler) handleNonArchiveContent(`
`134`	`134`	`dataOrErr := DataOrErr{}`
`135`	`135`	`if err := chunkResult.Error(); err != nil {`
`136`	`136`	`h.metrics.incErrors()`
`137`		`- dataOrErr.Err = fmt.Errorf("%w: error reading chunk: %v", ErrProcessingWarning, err)`
	`137`	`+ dataOrErr.Err = fmt.Errorf("%w: error reading chunk: %w", ErrProcessingWarning, err)`
`138`	`138`	`if writeErr := common.CancellableWrite(ctx, dataOrErrChan, dataOrErr); writeErr != nil {`
`139`	`139`	`return fmt.Errorf("%w: error writing to data channel: %v", ErrProcessingFatal, writeErr)`
`140`	`140`	`}`