Move the snappy compressor into a separate go package

Currently, Snappy is downloaded and included even when users only require LZ4 compression.
To streamline the driver and reduce unnecessary dependency overhead for users who don't utilize Snappy,
move the Snappy compressor into its own separate package.
This will allow users to include only the compression dependencies they need.

Patch by Mykyta Oleksiienko; reviewed by Joao Reis CASSGO-33

Author: OleksiienkoMykyta

CHANGELOG.md

@@ -21,6 +21,8 @@ This release is the first after the donation of gocql to the Apache Software Fou
   driver as an ASF driver.  This should clearly distinguish this release (and future gocql-cassandra-driver
   releases) from prior versions. (#1824)
 - Supported Go versions updated to 1.23 and 1.22 to conform to gocql's sunset model. (#1825)
+- Moved the Snappy compressor into its own separate package. 
+  This allows users to include only the compression dependencies they need. (CASSGO-33)
 
 ## [1.6.0] - 2023-08-28
 

common_test.go

@@ -36,6 +36,7 @@ import (
 	"time"
 
 	"github.com/gocql/gocql/lz4"
+	"github.com/gocql/gocql/snappy"
 )
 
 var (
@@ -112,7 +113,7 @@ func createCluster(opts ...func(*ClusterConfig)) *ClusterConfig {
 
 	switch *flagCompressTest {
 	case "snappy":
-		cluster.Compressor = &SnappyCompressor{}
+		cluster.Compressor = &snappy.SnappyCompressor{}
 	case "lz4":
 		cluster.Compressor = lz4.LZ4Compressor{}
 	case "":

compressor.go

@@ -24,8 +24,6 @@
 
 package gocql
 
-import "github.com/golang/snappy"
-
 type Compressor interface {
 	Name() string
 
@@ -52,23 +50,3 @@ type Compressor interface {
 // compress incoming and outgoing frames. The snappy compression algorithm
 // aims for very high speeds and reasonable compression.
 type SnappyCompressor struct{}
-
-func (s SnappyCompressor) Name() string {
-	return "snappy"
-}
-
-func (s SnappyCompressor) AppendCompressedWithLength(dst, src []byte) ([]byte, error) {
-	return snappy.Encode(dst, src), nil
-}
-
-func (s SnappyCompressor) AppendDecompressedWithLength(dst, src []byte) ([]byte, error) {
-	return snappy.Decode(dst, src)
-}
-
-func (s SnappyCompressor) AppendCompressed(dst, src []byte) ([]byte, error) {
-	panic("SnappyCompressor.AppendCompressed is not supported")
-}
-
-func (s SnappyCompressor) AppendDecompressed(dst, src []byte, decompressedLength uint32) ([]byte, error) {
-	panic("SnappyCompressor.AppendDecompressed is not supported")
-}

compressor_test.go renamed to snappy/compressor_test.go

@@ -22,7 +22,7 @@
  * See the NOTICE file distributed with this work for additional information.
  */
 
-package gocql
+package snappy
 
 import (
 	"bytes"

snappy/snappy_compressor.go

@@ -0,0 +1,28 @@
+package snappy
+
+import "github.com/golang/snappy"
+
+// SnappyCompressor implements the Compressor interface and can be used to
+// compress incoming and outgoing frames. The snappy compression algorithm
+// aims for very high speeds and reasonable compression.
+type SnappyCompressor struct{}
+
+func (s SnappyCompressor) Name() string {
+	return "snappy"
+}
+
+func (s SnappyCompressor) AppendCompressedWithLength(dst, src []byte) ([]byte, error) {
+	return snappy.Encode(dst, src), nil
+}
+
+func (s SnappyCompressor) AppendDecompressedWithLength(dst, src []byte) ([]byte, error) {
+	return snappy.Decode(dst, src)
+}
+
+func (s SnappyCompressor) AppendCompressed(dst, src []byte) ([]byte, error) {
+	panic("SnappyCompressor.AppendCompressed is not supported")
+}
+
+func (s SnappyCompressor) AppendDecompressed(dst, src []byte, decompressedLength uint32) ([]byte, error) {
+	panic("SnappyCompressor.AppendDecompressed is not supported")
+}