Merge pull request #1668 from nats-io/dedupe

Purge clears dedupe window as well

server/stream.go

@@ -520,6 +520,8 @@ func (mset *Stream) Purge() uint64 {
 		return 0
 	}
 	purged := mset.store.Purge()
+	// Purge dedupe.
+	mset.ddmap = nil
 	stats := mset.store.State()
 	var obs []*Consumer
 	for _, o := range mset.consumers {

test/jetstream_test.go

@@ -2896,6 +2896,10 @@ func TestJetStreamPublishDeDupe(t *testing.T) {
 	if !pa.Duplicate {
 		t.Fatalf("Expected duplicate to be set")
 	}
+
+	// Purge should wipe the msgIds as well.
+	mset.Purge()
+	nmids(0)
 }
 
 func TestJetStreamPullConsumerRemoveInterest(t *testing.T) {