mirror of
https://github.com/luxfi/zapdb.git
synced 2026-10-30 15:12:20 +00:00
zeekay
a6be21b7ea
Removed /v4 suffix from module path and all internal imports. Go module is now github.com/luxfi/zapdb (no major version suffix). Import as: import "github.com/luxfi/zapdb" No code changes — only module path and import rewrite.
57 lines
1.6 KiB
Go
57 lines
1.6 KiB
Go
package y
|
|
|
|
import (
|
|
"hash/crc32"
|
|
"testing"
|
|
|
|
"github.com/cespare/xxhash/v2"
|
|
"github.com/luxfi/zapdb/pb"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestCalculateChecksum_CRC32C(t *testing.T) {
|
|
data := []byte("hello world")
|
|
expected := uint64(crc32.Checksum(data, CastagnoliCrcTable))
|
|
got := CalculateChecksum(data, pb.Checksum_CRC32C)
|
|
require.Equal(t, expected, got)
|
|
|
|
// empty input
|
|
expectedEmpty := uint64(crc32.Checksum([]byte{}, CastagnoliCrcTable))
|
|
gotEmpty := CalculateChecksum([]byte{}, pb.Checksum_CRC32C)
|
|
require.Equal(t, expectedEmpty, gotEmpty)
|
|
}
|
|
|
|
func TestCalculateChecksum_XXHash64(t *testing.T) {
|
|
data := []byte("hello world")
|
|
expected := xxhash.Sum64(data)
|
|
got := CalculateChecksum(data, pb.Checksum_XXHash64)
|
|
require.Equal(t, expected, got)
|
|
}
|
|
|
|
func TestVerifyChecksum_Success(t *testing.T) {
|
|
data := []byte("hello world")
|
|
c1 := &pb.Checksum{Algo: pb.Checksum_CRC32C, Sum: CalculateChecksum(data, pb.Checksum_CRC32C)}
|
|
require.NoError(t, VerifyChecksum(data, c1))
|
|
|
|
c2 := &pb.Checksum{Algo: pb.Checksum_XXHash64, Sum: CalculateChecksum(data, pb.Checksum_XXHash64)}
|
|
require.NoError(t, VerifyChecksum(data, c2))
|
|
}
|
|
|
|
func TestVerifyChecksum_Mismatch(t *testing.T) {
|
|
data := []byte("x")
|
|
c := &pb.Checksum{Algo: pb.Checksum_CRC32C, Sum: 0}
|
|
err := VerifyChecksum(data, c)
|
|
require.Error(t, err)
|
|
require.Contains(t, err.Error(), "checksum mismatch")
|
|
}
|
|
|
|
func TestCalculateChecksum_UnsupportedAlgoPanics(t *testing.T) {
|
|
defer func() {
|
|
if r := recover(); r == nil {
|
|
t.Fatalf("expected panic for unsupported algorithm")
|
|
}
|
|
}()
|
|
|
|
_ = CalculateChecksum([]byte("x"), pb.Checksum_Algorithm(999))
|
|
}
|