test for reversed redis history with no existing meta

centrifugal · Oct 30, 2023 · 0dfffe1 · 0dfffe1
1 parent 816d5db
commit 0dfffe1
Showing 1 changed file with 32 additions and 0 deletions.
diff --git a/broker_redis_test.go b/broker_redis_test.go
@@ -1522,6 +1522,38 @@ func TestRedisHistoryIteration(t *testing.T) {
 	}
 }
 
+func TestRedisHistoryReversedNoMetaYet(t *testing.T) {
+	for _, tt := range redisTests {
+		t.Run(tt.Name, func(t *testing.T) {
+			node := testNode(t)
+			broker := newTestRedisBroker(t, node, tt.UseStreams, tt.UseCluster)
+			defer func() { _ = node.Shutdown(context.Background()) }()
+			defer stopRedisBroker(broker)
+			pubs, sp, err := broker.History(
+				randString(10),
+				HistoryOptions{
+					Filter:  HistoryFilter{Limit: 10, Reverse: true},
+					MetaTTL: 24 * time.Hour,
+				},
+			)
+			require.NoError(t, err)
+			require.Equal(t, uint64(0), sp.Offset)
+			require.Len(t, pubs, 0)
+
+			pubs, sp, err = broker.History(
+				randString(10),
+				HistoryOptions{
+					Filter:  HistoryFilter{Limit: -1, Reverse: true},
+					MetaTTL: 24 * time.Hour,
+				},
+			)
+			require.NoError(t, err)
+			require.Equal(t, uint64(0), sp.Offset)
+			require.Len(t, pubs, 0)
+		})
+	}
+}
+
 func TestRedisHistoryIterationReverse(t *testing.T) {
 	for _, tt := range redisTests {
 		t.Run(tt.Name, func(t *testing.T) {