add unit test for some func

db_test.go

@@ -532,6 +532,23 @@ func txPush(t *testing.T, db *DB, bucket string, key, val []byte, isLeft bool, e
 	assertErr(t, err, finalExpectErr)
 }
 
+func txPushRaw(t *testing.T, db *DB, bucket string, key, val []byte, isLeft bool, expectErr error, finalExpectErr error) {
+	err := db.Update(func(tx *Tx) error {
+		var err error
+
+		if isLeft {
+			err = tx.LPushRaw(bucket, key, val)
+		} else {
+			err = tx.RPushRaw(bucket, key, val)
+		}
+
+		assertErr(t, err, expectErr)
+
+		return nil
+	})
+	assertErr(t, err, finalExpectErr)
+}
+
 func txExpireList(t *testing.T, db *DB, bucket string, key []byte, ttl uint32, expectErr error) {
 	err := db.Update(func(tx *Tx) error {
 		err := tx.ExpireList(bucket, key, ttl)

errors_test.go

@@ -2,15 +2,15 @@ package nutsdb
 
 import (
 	"fmt"
-	"github.com/stretchr/testify/require"
 	"testing"
 
+	"github.com/stretchr/testify/require"
+
 	"github.com/pkg/errors"
 	"github.com/stretchr/testify/assert"
 )
 
 func TestIsKeyNotFound(t *testing.T) {
-
 	ts := []struct {
 		err error
 
@@ -220,3 +220,27 @@ func TestIsPrefixSearchScan(t *testing.T) {
 		})
 	})
 }
+
+func TestGetMergeReadEntryError(t *testing.T) {
+	type args struct {
+		err error
+	}
+	tests := []struct {
+		name    string
+		args    args
+		wantErr error
+	}{
+		{
+			name: "test error",
+			args: args{
+				err: errors.New("test error"),
+			},
+			wantErr: fmt.Errorf("when merge operation build hintIndex readAt err: %s", errors.New("test error")),
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			require.Equal(t, tt.wantErr, GetMergeReadEntryError(tt.args.err))
+		})
+	}
+}

tx_list_test.go

@@ -77,6 +77,40 @@ func TestTx_LPush(t *testing.T) {
 	})
 }
 
+func TestTx_LPushRaw(t *testing.T) {
+	bucket := "bucket"
+	runNutsDBTest(t, nil, func(t *testing.T, db *DB) {
+		seq := uint64(100000)
+		for i := 0; i <= 100; i++ {
+			key := encodeListKey([]byte("0"), seq)
+			seq--
+			txPushRaw(t, db, bucket, key, GetTestBytes(i), true, nil, nil)
+		}
+
+		for i := 0; i <= 100; i++ {
+			v := GetTestBytes(100 - i)
+			txPop(t, db, bucket, []byte("0"), v, nil, true)
+		}
+	})
+}
+
+func TestTx_RPushRaw(t *testing.T) {
+	bucket := "bucket"
+	runNutsDBTest(t, nil, func(t *testing.T, db *DB) {
+		seq := uint64(100000)
+		for i := 0; i <= 100; i++ {
+			key := encodeListKey([]byte("0"), seq)
+			seq++
+			txPushRaw(t, db, bucket, key, GetTestBytes(i), false, nil, nil)
+		}
+
+		for i := 0; i <= 100; i++ {
+			v := GetTestBytes(100 - i)
+			txPop(t, db, bucket, []byte("0"), v, nil, false)
+		}
+	})
+}
+
 func TestTx_LPop(t *testing.T) {
 	bucket := "bucket"