File size: 1,257 Bytes
6a7089a | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 | package bridge
import (
"testing"
"time"
)
func TestLockManager(t *testing.T) {
m := NewLockManager()
tabID := "tab1"
owner1 := "agent1"
owner2 := "agent2"
ttl := 100 * time.Millisecond
if err := m.TryLock(tabID, owner1, ttl); err != nil {
t.Fatalf("lock failed: %v", err)
}
if err := m.TryLock(tabID, owner1, ttl); err != nil {
t.Fatalf("re-lock same owner failed: %v", err)
}
if err := m.TryLock(tabID, owner2, ttl); err == nil {
t.Error("expected conflict error")
}
if err := m.Unlock(tabID, owner1); err != nil {
t.Fatalf("unlock failed: %v", err)
}
if err := m.TryLock(tabID, owner2, ttl); err != nil {
t.Fatalf("lock after unlock failed: %v", err)
}
time.Sleep(150 * time.Millisecond)
if err := m.TryLock(tabID, owner1, ttl); err != nil {
t.Fatalf("lock after expiration failed: %v", err)
}
}
func TestLockManagerGet(t *testing.T) {
m := NewLockManager()
tabID := "tab1"
owner := "agent1"
ttl := 1 * time.Hour
if info := m.Get(tabID); info != nil {
t.Error("expected nil info for unlocked tab")
}
_ = m.TryLock(tabID, owner, ttl)
info := m.Get(tabID)
if info == nil {
t.Fatal("expected info")
return
}
if info.Owner != owner {
t.Errorf("expected owner %s, got %s", owner, info.Owner)
}
}
|