diff --git a/internal/blobgen/compress.go b/internal/blobgen/compress.go index 20f8571..576b054 100644 --- a/internal/blobgen/compress.go +++ b/internal/blobgen/compress.go @@ -26,14 +26,16 @@ func CompressData(data []byte, compressionLevel int, recipients []string) (*Comp } // Write data - if _, err := w.Write(data); err != nil { + _, err = w.Write(data) + if err != nil { _ = w.Close() return nil, fmt.Errorf("writing data: %w", err) } // Close to flush - if err := w.Close(); err != nil { + err = w.Close() + if err != nil { return nil, fmt.Errorf("closing writer: %w", err) } @@ -61,12 +63,14 @@ func CompressStream(dst io.Writer, src io.Reader, compressionLevel int, recipien }() // Copy data - if _, err := io.Copy(w, src); err != nil { + _, err = io.Copy(w, src) + if err != nil { return 0, "", fmt.Errorf("copying data: %w", err) } // Close to flush - if err := w.Close(); err != nil { + err = w.Close() + if err != nil { return 0, "", fmt.Errorf("closing writer: %w", err) } diff --git a/internal/blobgen/writer.go b/internal/blobgen/writer.go index a14574c..08a13fb 100644 --- a/internal/blobgen/writer.go +++ b/internal/blobgen/writer.go @@ -27,7 +27,8 @@ type Writer struct { // The hash is computed on the uncompressed input for deterministic content-addressing. func NewWriter(w io.Writer, compressionLevel int, recipients []string) (*Writer, error) { // Validate compression level - if err := validateCompressionLevel(compressionLevel); err != nil { + err := validateCompressionLevel(compressionLevel) + if err != nil { return nil, err }