package persistence

import (
	"testing"
	"time"
)

func TestMRUCleanupCoalescerCoalescesSameKey(t *testing.T) {
	coalescer := newMRUCleanupCoalescer(time.Minute)
	now := time.Now()

	if !coalescer.shouldQueue("005-user\x00Lead", now) {
		t.Fatal("first cleanup should queue")
	}
	if coalescer.shouldQueue("005-user\x00Lead", now.Add(time.Second)) {
		t.Fatal("same key cleanup queued while in flight")
	}

	coalescer.finish("005-user\x00Lead")
	if coalescer.shouldQueue("005-user\x00Lead", now.Add(30*time.Second)) {
		t.Fatal("same key cleanup queued inside coalesce window")
	}
	if !coalescer.shouldQueue("005-user\x00Contact", now.Add(30*time.Second)) {
		t.Fatal("different key cleanup should queue independently")
	}
}