Function spoolDownloadResponse

internal/registry/github/client.go:955–996

(body io.Reader, slug string, maxBytes int64)

}

func spoolDownloadResponse(body io.Reader, slug string, maxBytes int64) (_ io.ReadCloser, size int64, err error) {
	file, err := os.CreateTemp("", "agh-github-download-*")
	if err != nil {
		return nil, 0, fmt.Errorf("create temp download file for %q: %w", slug, err)
	}
	defer func() {
		if err != nil {
			_ = os.Remove(file.Name())
		}
	}()

	limit := normalizeArchiveSizeLimit(maxBytes)
	written, err := io.Copy(file, io.LimitReader(body, limit+1))
	if err != nil {
		closeErr := file.Close()
		return nil, 0, joinErrors(
			fmt.Errorf("write temp download file for %q: %w", slug, err),
			closeErr,
		)
	}
	if written > limit {
		closeErr := file.Close()
		return nil, written, joinErrors(
			fmt.Errorf(
				"%w: github download for %q exceeds compressed archive limit %d",
				registry.ErrArchiveTooLargeCompressed,
				slug,
				limit,
			),
			closeErr,
		)
	}
	if _, err := file.Seek(0, io.SeekStart); err != nil {
		closeErr := file.Close()
		return nil, 0, joinErrors(
			fmt.Errorf("rewind temp download file for %q: %w", slug, err),
			closeErr,
		)
	}

	return &tempFileReadCloser{File: file, path: file.Name()}, written, nil
}

func normalizeArchiveSizeLimit(limit int64) int64 {
	if limit > 0 {