diff --git a/tests/aof_test.go b/tests/aof_test.go index d82667c2..9ea140f3 100644 --- a/tests/aof_test.go +++ b/tests/aof_test.go @@ -17,6 +17,7 @@ import ( func subTestAOF(g *testGroup) { g.regSubTest("loading", aof_loading_test) + g.regSubTest("migrate", aof_migrate_test) g.regSubTest("AOF", aof_AOF_test) g.regSubTest("AOFMD5", aof_AOFMD5_test) g.regSubTest("AOFSHRINK", aof_AOFSHRINK_test) @@ -286,3 +287,21 @@ func aof_READONLY_test(mc *mockServer) error { Do("READONLY", "maybe").Err("invalid argument 'maybe'"), ) } + +func aof_migrate_test(mc *mockServer) error { + // var aof string + // aof += "set 1 2 point 10 10\r\n" + // aof += "set 2 3 point 30 30\r\n" + // mc2, err := mockOpenServer(MockServerOptions{ + // AOFFileName: "aof", + // AOFData: []byte(aof), + // Silent: true, + // Metrics: true, + // }) + // if err != nil { + // return err + // } + // defer mc2.Close() + + return nil +} diff --git a/tests/mock_test.go b/tests/mock_test.go index f4354ac8..76b15b24 100644 --- a/tests/mock_test.go +++ b/tests/mock_test.go @@ -53,9 +53,10 @@ func (mc *mockServer) metricsPort() int { } type MockServerOptions struct { - AOFData []byte - Silent bool - Metrics bool + AOFFileName string + AOFData []byte + Silent bool + Metrics bool } var nextPort int32 = 10000 @@ -88,10 +89,13 @@ func mockOpenServer(opts MockServerOptions) (*mockServer, error) { fmt.Printf("Starting test server at port %d\n", port) } if len(opts.AOFData) > 0 { + if opts.AOFFileName == "" { + opts.AOFFileName = "appendonly.aof" + } if err := os.MkdirAll(dir, 0777); err != nil { return nil, err } - err := os.WriteFile(filepath.Join(dir, "appendonly.aof"), + err := os.WriteFile(filepath.Join(dir, opts.AOFFileName), opts.AOFData, 0666) if err != nil { return nil, err