tidy

examples/rotom/main.go

@@ -1,10 +1,8 @@
 package main
 
 import (
-	"fmt"
 	"net/http"
 	_ "net/http/pprof"
-	"strconv"
 
 	"github.com/xgzlucario/rotom"
 )
@@ -21,20 +19,6 @@ func main() {
 		panic(err)
 	}
 
-	key := "key"
-
-	for j := 0; j < 20; j++ {
-		db.RPush(key, strconv.Itoa(j))
-	}
-	for j := 0; j < 20; j++ {
-		res, err := db.LPop(key)
-		fmt.Println(res, err)
-	}
-
-	// LLen
-	num, err := db.LLen(key)
-	fmt.Println(num, err)
-
 	// run for web server
 	if err := db.Listen("0.0.0.0:7676"); err != nil {
 		panic(err)

rotom.go

@@ -1076,12 +1076,7 @@ func (e *Engine) load() error {
 
 // rewrite write data to the file.
 func (e *Engine) shrink() {
-	if e.SyncPolicy == base.Never {
-		return
-	}
-
 	var _type Type
-	// Marshal any
 	data, err := e.m.MarshalBytesFunc(func(key string, v any, i int64) {
 		switch v := v.(type) {
 		case Map:
@@ -1097,7 +1092,6 @@ func (e *Engine) shrink() {
 		default:
 			panic(fmt.Errorf("%w: %d", base.ErrUnSupportDataType, v))
 		}
-
 		// SetTx
 		if cd, err := NewCodec(OpSetTx).Type(_type).Str(key).Int(i / timeCarry).Any(v); err == nil {
 			e.rwbuf.Write(cd.B)
@@ -1124,10 +1118,8 @@ func (e *Engine) shrink() {
 }
 
 // Shrink forced to shrink db file.
+// Warning: will panic if SyncPolicy is never.
 func (e *Engine) Shrink() error {
-	if e.tickers[2] == nil {
-		return base.ErrUnSupportOperation
-	}
 	return e.tickers[2].ForceFunc()
 }
 

rotom_test.go

@@ -39,7 +39,7 @@ func newDBInstance() (*Engine, *Client, error) {
 
 	// listen
 	go db.Listen(addr)
-	time.Sleep(time.Second / 20)
+	time.Sleep(time.Millisecond)
 
 	cli, err := NewClient(addr)
 	if err != nil {
@@ -385,6 +385,17 @@ func TestList(t *testing.T) {
 	assert.Equal(n, 0)
 	assert.ErrorContains(err, base.ErrWrongType.Error())
 
+	cli.RPush("list", "1")
+	cli.RPop("list")
+	// empty list
+	res, err = cli.LPop("list")
+	assert.Equal(res, "")
+	assert.Equal(err, base.ErrEmptyList)
+
+	res, err = cli.RPop("list")
+	assert.Equal(res, "")
+	assert.Equal(err, base.ErrEmptyList)
+
 	db.Close()
 }