| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749 |
- package toc
- import (
- "math"
- "testing"
- "github.com/mk6i/open-oscar-server/wire"
- "github.com/stretchr/testify/assert"
- )
- func TestFeedbagList_upsertItem(t *testing.T) {
- t.Run("generates unique ItemID", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }, func(n int) int { return 42 })
- result, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "alice",
- ClassID: wire.FeedbagClassIdBuddy,
- GroupID: 1,
- })
- assert.True(t, inserted)
- assert.Equal(t, uint16(42), result.ItemID)
- assert.Equal(t, "alice", result.Name)
- assert.Equal(t, wire.FeedbagClassIdBuddy, result.ClassID)
- assert.Equal(t, uint16(1), result.GroupID)
- })
- t.Run("subsequent insert avoids collision", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }, func(n int) int { return 42 })
- fl.upsertItem(wire.FeedbagItem{
- Name: "alice",
- ClassID: wire.FeedbagClassIdBuddy,
- GroupID: 1,
- })
- result, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "bob",
- ClassID: wire.FeedbagClassIdBuddy,
- GroupID: 1,
- })
- assert.True(t, inserted)
- assert.Equal(t, uint16(43), result.ItemID)
- })
- t.Run("non-buddy item does not update group order", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 5 })
- fl.upsertItem(wire.FeedbagItem{
- Name: "alice",
- ClassID: wire.FeedbagClassIDPermit,
- })
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 1)
- assert.Equal(t, wire.FeedbagClassIDPermit, upserts[0].ClassID)
- })
- t.Run("updates existing non-buddy item in place", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {
- Name: "alice",
- ClassID: wire.FeedbagClassIDPermit,
- ItemID: 7,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(0x01, uint16(100)),
- },
- },
- },
- }, nil)
- _, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "alice",
- ClassID: wire.FeedbagClassIDPermit,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(0x01, uint16(200)),
- },
- },
- })
- assert.False(t, inserted)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 1)
- assert.Equal(t, uint16(7), upserts[0].ItemID)
- val, ok := upserts[0].Uint16BE(0x01)
- assert.True(t, ok)
- assert.Equal(t, uint16(200), val)
- })
- t.Run("updates existing buddy item matched by group", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Group1", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- {Name: "Group2", ClassID: wire.FeedbagClassIdGroup, GroupID: 2},
- {Name: "alice", ClassID: wire.FeedbagClassIdBuddy, GroupID: 1, ItemID: 10},
- {Name: "alice", ClassID: wire.FeedbagClassIdBuddy, GroupID: 2, ItemID: 20},
- }, nil)
- _, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "alice",
- ClassID: wire.FeedbagClassIdBuddy,
- GroupID: 2,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(0x01, uint16(999)),
- },
- },
- })
- assert.False(t, inserted)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 1)
- assert.Equal(t, uint16(2), upserts[0].GroupID)
- assert.Equal(t, "alice", upserts[0].Name)
- assert.Equal(t, uint16(20), upserts[0].ItemID)
- val, ok := upserts[0].Uint16BE(0x01)
- assert.True(t, ok)
- assert.Equal(t, uint16(999), val)
- })
- t.Run("skips update when existing item is identical", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {
- Name: "alice",
- ClassID: wire.FeedbagClassIDPermit,
- ItemID: 7,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(0x01, uint16(100)),
- },
- },
- },
- }, nil)
- _, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "alice",
- ClassID: wire.FeedbagClassIDPermit,
- ItemID: 7,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(0x01, uint16(100)),
- },
- },
- })
- assert.False(t, inserted)
- assert.Nil(t, fl.PendingUpdates())
- })
- t.Run("normalized screen name: buddy stored with lowercase name", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }, func(n int) int { return 10 })
- result, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "Alice",
- ClassID: wire.FeedbagClassIdBuddy,
- GroupID: 1,
- })
- assert.True(t, inserted)
- assert.Equal(t, "alice", result.Name)
- })
- t.Run("normalized screen name: buddy upsert with different case matches existing", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- {Name: "alice", ClassID: wire.FeedbagClassIdBuddy, GroupID: 1, ItemID: 99},
- }, nil)
- result, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "ALICE",
- ClassID: wire.FeedbagClassIdBuddy,
- GroupID: 1,
- })
- assert.False(t, inserted)
- assert.Equal(t, uint16(99), result.ItemID)
- assert.Equal(t, "alice", result.Name)
- })
- t.Run("normalized screen name: permit stored with lowercase name and spaces stripped", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 1 })
- result, _ := fl.upsertItem(wire.FeedbagItem{
- Name: " Bob Smith ",
- ClassID: wire.FeedbagClassIDPermit,
- })
- assert.Equal(t, "bobsmith", result.Name)
- })
- t.Run("normalized screen name: permit upsert with different case matches existing", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "bob", ClassID: wire.FeedbagClassIDPermit, ItemID: 5},
- }, nil)
- result, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "BOB",
- ClassID: wire.FeedbagClassIDPermit,
- })
- assert.False(t, inserted)
- assert.Equal(t, "bob", result.Name)
- assert.Equal(t, uint16(5), result.ItemID)
- })
- t.Run("normalized screen name: deny upsert with different case matches existing", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "charlie", ClassID: wire.FeedbagClassIDDeny, ItemID: 3},
- }, nil)
- result, inserted := fl.upsertItem(wire.FeedbagItem{
- Name: "Charlie",
- ClassID: wire.FeedbagClassIDDeny,
- })
- assert.False(t, inserted)
- assert.Equal(t, "charlie", result.Name)
- assert.Equal(t, uint16(3), result.ItemID)
- })
- }
- func TestFeedbagList_deleteItem(t *testing.T) {
- t.Run("non-buddy item does not update group order", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "alice", ClassID: wire.FeedbagClassIDPermit, ItemID: 5},
- }, nil)
- fl.deleteItem(wire.FeedbagItem{Name: "alice", ClassID: wire.FeedbagClassIDPermit, ItemID: 5})
- deletes := fl.PendingDeletes()
- assert.Len(t, deletes, 1)
- assert.Nil(t, fl.PendingUpdates())
- })
- t.Run("removes item from items list", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "alice", ClassID: wire.FeedbagClassIDPermit, ItemID: 1},
- {Name: "bob", ClassID: wire.FeedbagClassIDPermit, ItemID: 2},
- {Name: "charlie", ClassID: wire.FeedbagClassIDPermit, ItemID: 3},
- }, nil)
- fl.deleteItem(wire.FeedbagItem{Name: "bob", ClassID: wire.FeedbagClassIDPermit, ItemID: 2})
- deletes := fl.PendingDeletes()
- assert.Len(t, deletes, 1)
- assert.Equal(t, "bob", deletes[0].Name)
- assert.Equal(t, wire.FeedbagClassIDPermit, deletes[0].ClassID)
- })
- t.Run("multiple deletes accumulate", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "alice", ClassID: wire.FeedbagClassIDDeny, ItemID: 1},
- {Name: "bob", ClassID: wire.FeedbagClassIDDeny, ItemID: 2},
- }, nil)
- fl.deleteItem(wire.FeedbagItem{Name: "alice", ClassID: wire.FeedbagClassIDDeny, ItemID: 1})
- fl.deleteItem(wire.FeedbagItem{Name: "bob", ClassID: wire.FeedbagClassIDDeny, ItemID: 2})
- deletes := fl.PendingDeletes()
- assert.Len(t, deletes, 2)
- })
- t.Run("normalized screen name: delete buddy by different case", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- {Name: "alice", ClassID: wire.FeedbagClassIdBuddy, GroupID: 1, ItemID: 50},
- }, nil)
- deleted, found := fl.deleteItem(wire.FeedbagItem{
- Name: "ALICE",
- ClassID: wire.FeedbagClassIdBuddy,
- GroupID: 1,
- })
- assert.True(t, found)
- assert.Equal(t, "alice", deleted.Name)
- assert.Equal(t, uint16(50), deleted.ItemID)
- })
- t.Run("normalized screen name: delete permit by different case", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "bob", ClassID: wire.FeedbagClassIDPermit, ItemID: 7},
- }, nil)
- deleted, found := fl.deleteItem(wire.FeedbagItem{Name: "Bob", ClassID: wire.FeedbagClassIDPermit})
- assert.True(t, found)
- assert.Equal(t, "bob", deleted.Name)
- })
- t.Run("normalized screen name: delete deny by different case", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "charlie", ClassID: wire.FeedbagClassIDDeny, ItemID: 8},
- }, nil)
- deleted, found := fl.deleteItem(wire.FeedbagItem{Name: "CHARLIE", ClassID: wire.FeedbagClassIDDeny})
- assert.True(t, found)
- assert.Equal(t, "charlie", deleted.Name)
- })
- }
- func TestFeedbagList_genID(t *testing.T) {
- tt := []struct {
- name string
- randInt func(n int) int
- items []wire.FeedbagItem
- want uint16
- }{
- {
- name: "empty items list returns random ID",
- randInt: func(n int) int { return 1000 },
- items: []wire.FeedbagItem{},
- want: 1000,
- },
- {
- name: "finds next available ID when starting ID conflicts with ItemID",
- randInt: func(n int) int { return 100 },
- items: []wire.FeedbagItem{
- {ItemID: 100, GroupID: 1},
- {ItemID: 101, GroupID: 1},
- },
- want: 102,
- },
- {
- name: "finds next available ID when starting ID conflicts with GroupID",
- randInt: func(n int) int { return 50 },
- items: []wire.FeedbagItem{
- {ItemID: 1, GroupID: 50},
- {ItemID: 2, GroupID: 51},
- },
- want: 52,
- },
- {
- name: "wraps around and skips 0 to find next available ID",
- randInt: func(n int) int { return math.MaxUint16 - 2 },
- items: []wire.FeedbagItem{
- {ItemID: math.MaxUint16 - 2, GroupID: 1},
- {ItemID: math.MaxUint16 - 1, GroupID: 1},
- {ItemID: math.MaxUint16, GroupID: 1},
- },
- want: 2,
- },
- {
- name: "skips 0 when starting from 0 and finds next available",
- randInt: func(n int) int { return 0 },
- items: []wire.FeedbagItem{},
- want: 1,
- },
- {
- name: "returns 0 when all IDs are taken",
- randInt: func(n int) int { return 100 },
- items: func() []wire.FeedbagItem {
- items := make([]wire.FeedbagItem, 0, math.MaxUint16+1)
- for i := 0; i <= math.MaxUint16; i++ {
- items = append(items, wire.FeedbagItem{
- ItemID: uint16(i),
- GroupID: uint16(i),
- })
- }
- return items
- }(),
- want: 0,
- },
- {
- name: "finds ID that conflicts with both ItemID and GroupID",
- randInt: func(n int) int { return 200 },
- items: []wire.FeedbagItem{
- {ItemID: 200, GroupID: 201},
- {ItemID: 201, GroupID: 200},
- },
- want: 202,
- },
- {
- name: "finds available ID immediately when no conflicts",
- randInt: func(n int) int { return 500 },
- items: []wire.FeedbagItem{
- {ItemID: 100, GroupID: 1},
- {ItemID: 200, GroupID: 2},
- {ItemID: 300, GroupID: 3},
- },
- want: 500,
- },
- {
- name: "handles single conflict and finds next",
- randInt: func(n int) int { return 42 },
- items: []wire.FeedbagItem{
- {ItemID: 42, GroupID: 1},
- },
- want: 43,
- },
- {
- name: "finds ID before starting point when wrapping",
- randInt: func(n int) int { return 5 },
- items: []wire.FeedbagItem{
- {ItemID: 5, GroupID: 1},
- {ItemID: 6, GroupID: 1},
- {ItemID: 7, GroupID: 1},
- },
- want: 8,
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- fl := newFeedbagList(tc.items, tc.randInt)
- got := fl.genID()
- assert.Equal(t, tc.want, got)
- })
- }
- }
- func TestFeedbagList_AddGroup(t *testing.T) {
- t.Run("creates group and root group when none exists", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 5 })
- group := fl.AddGroup("Buddies")
- assert.Equal(t, uint16(5), group.GroupID)
- assert.Equal(t, "Buddies", group.Name)
- assert.Equal(t, wire.FeedbagClassIdGroup, group.ClassID)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 2)
- root := upserts[0]
- assert.Equal(t, wire.FeedbagClassIdGroup, root.ClassID)
- assert.Equal(t, uint16(0), root.GroupID)
- order, ok := root.Uint16SliceBE(wire.FeedbagAttributesOrder)
- assert.True(t, ok)
- assert.Equal(t, []uint16{5}, order)
- })
- t.Run("updates existing root group order", func(t *testing.T) {
- existing := []wire.FeedbagItem{
- {
- ClassID: wire.FeedbagClassIdGroup,
- GroupID: 0,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesOrder, []uint16{1}),
- },
- },
- },
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }
- callCount := 0
- fl := newFeedbagList(existing, func(n int) int {
- callCount++
- return callCount + 1
- })
- group := fl.AddGroup("Coworkers")
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 2)
- order, ok := upserts[0].Uint16SliceBE(wire.FeedbagAttributesOrder)
- assert.True(t, ok)
- assert.Equal(t, []uint16{1, group.GroupID}, order)
- })
- t.Run("multiple AddGroup calls accumulate in root order", func(t *testing.T) {
- callCount := 0
- fl := newFeedbagList(nil, func(n int) int {
- callCount++
- return callCount * 10
- })
- g1 := fl.AddGroup("Group1")
- g2 := fl.AddGroup("Group2")
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 3)
- order, ok := upserts[0].Uint16SliceBE(wire.FeedbagAttributesOrder)
- assert.True(t, ok)
- assert.Equal(t, []uint16{g1.GroupID, g2.GroupID}, order)
- })
- }
- func TestFeedbagList_DeleteGroup(t *testing.T) {
- t.Run("updates root group order", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {
- Name: "",
- ClassID: wire.FeedbagClassIdGroup,
- GroupID: 0,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesOrder, []uint16{1, 2, 3}),
- },
- },
- },
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- {Name: "Coworkers", ClassID: wire.FeedbagClassIdGroup, GroupID: 2},
- {Name: "Family", ClassID: wire.FeedbagClassIdGroup, GroupID: 3},
- }, nil)
- fl.DeleteGroup("Coworkers")
- deletes := fl.PendingDeletes()
- assert.Len(t, deletes, 1)
- assert.Equal(t, "Coworkers", deletes[0].Name)
- assert.Equal(t, uint16(2), deletes[0].GroupID)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 1)
- assert.Equal(t, uint16(0), upserts[0].GroupID)
- order, ok := upserts[0].Uint16SliceBE(wire.FeedbagAttributesOrder)
- assert.True(t, ok)
- assert.Equal(t, []uint16{1, 3}, order)
- })
- }
- func TestFeedbagList_AddBuddy(t *testing.T) {
- t.Run("updates parent group order", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }, func(n int) int { return 50 })
- inserted, err := fl.AddBuddy("Buddies", "alice", "", "")
- assert.NoError(t, err)
- assert.True(t, inserted)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 2)
- assert.Equal(t, uint16(1), upserts[1].GroupID)
- order, ok := upserts[1].Uint16SliceBE(wire.FeedbagAttributesOrder)
- assert.True(t, ok)
- assert.Equal(t, []uint16{upserts[0].ItemID}, order)
- })
- t.Run("multiple buddies accumulate in parent group order", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {
- Name: "Buddies",
- ClassID: wire.FeedbagClassIdGroup,
- GroupID: 1,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesOrder, []uint16{10}),
- },
- },
- },
- }, func(n int) int { return 50 })
- _, err := fl.AddBuddy("Buddies", "alice", "", "")
- assert.NoError(t, err)
- _, err = fl.AddBuddy("Buddies", "bob", "", "")
- assert.NoError(t, err)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 3)
- order, ok := upserts[1].Uint16SliceBE(wire.FeedbagAttributesOrder)
- assert.True(t, ok)
- assert.Equal(t, []uint16{10, upserts[0].ItemID, upserts[2].ItemID}, order)
- })
- t.Run("returns error when parent group does not exist", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 5 })
- _, err := fl.AddBuddy("Nonexistent", "alice", "", "")
- assert.ErrorContains(t, err, "group \"Nonexistent\" not found")
- })
- t.Run("normalized screen name: stores buddy with lowercase name", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }, func(n int) int { return 1 })
- inserted, err := fl.AddBuddy("Buddies", "Alice", "", "")
- assert.NoError(t, err)
- assert.True(t, inserted)
- upserts := fl.PendingUpdates()
- var buddy *wire.FeedbagItem
- for i := range upserts {
- if upserts[i].ClassID == wire.FeedbagClassIdBuddy {
- buddy = &upserts[i]
- break
- }
- }
- assert.NotNil(t, buddy)
- assert.Equal(t, "alice", buddy.Name)
- })
- t.Run("normalized screen name: second AddBuddy with different case does not insert duplicate", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }, func(n int) int { return 1 })
- inserted1, err := fl.AddBuddy("Buddies", "alice", "", "")
- assert.NoError(t, err)
- assert.True(t, inserted1)
- inserted2, err := fl.AddBuddy("Buddies", "ALICE", "", "")
- assert.NoError(t, err)
- assert.False(t, inserted2)
- })
- t.Run("normalized screen name: DeleteBuddy finds buddy by different case", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }, func(n int) int { return 1 })
- _, err := fl.AddBuddy("Buddies", "alice", "", "")
- assert.NoError(t, err)
- _ = fl.PendingUpdates()
- err = fl.DeleteBuddy("Buddies", "Alice")
- assert.NoError(t, err)
- deletes := fl.PendingDeletes()
- assert.Len(t, deletes, 1)
- assert.Equal(t, "alice", deletes[0].Name)
- })
- }
- func TestFeedbagList_DeleteBuddy(t *testing.T) {
- t.Run("updates parent group order", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {
- Name: "Buddies",
- ClassID: wire.FeedbagClassIdGroup,
- GroupID: 1,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesOrder, []uint16{10, 20, 30}),
- },
- },
- },
- {Name: "alice", ClassID: wire.FeedbagClassIdBuddy, GroupID: 1, ItemID: 10},
- {Name: "bob", ClassID: wire.FeedbagClassIdBuddy, GroupID: 1, ItemID: 20},
- {Name: "charlie", ClassID: wire.FeedbagClassIdBuddy, GroupID: 1, ItemID: 30},
- }, nil)
- err := fl.DeleteBuddy("Buddies", "bob")
- assert.NoError(t, err)
- deletes := fl.PendingDeletes()
- assert.Len(t, deletes, 1)
- assert.Equal(t, "bob", deletes[0].Name)
- assert.Equal(t, uint16(20), deletes[0].ItemID)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 1)
- order, ok := upserts[0].Uint16SliceBE(wire.FeedbagAttributesOrder)
- assert.True(t, ok)
- assert.Equal(t, []uint16{10, 30}, order)
- })
- t.Run("removes only buddy in specified group when same screen name in two groups", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {
- Name: "Buddies",
- ClassID: wire.FeedbagClassIdGroup,
- GroupID: 1,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesOrder, []uint16{10, 20}),
- },
- },
- },
- {
- Name: "Coworkers",
- ClassID: wire.FeedbagClassIdGroup,
- GroupID: 2,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesOrder, []uint16{20}),
- },
- },
- },
- {Name: "alice", ClassID: wire.FeedbagClassIdBuddy, GroupID: 2, ItemID: 20},
- {Name: "alice", ClassID: wire.FeedbagClassIdBuddy, GroupID: 1, ItemID: 10},
- }, nil)
- err := fl.DeleteBuddy("Buddies", "alice")
- assert.NoError(t, err)
- deletes := fl.PendingDeletes()
- assert.Len(t, deletes, 1)
- assert.Equal(t, "alice", deletes[0].Name)
- assert.Equal(t, uint16(1), deletes[0].GroupID, "should delete from Buddies (group 1), not Coworkers (group 2)")
- assert.Equal(t, uint16(10), deletes[0].ItemID)
- })
- }
- func TestFeedbagList_PendingUpdates(t *testing.T) {
- t.Run("empty when nothing inserted", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 1 })
- assert.Nil(t, fl.PendingUpdates())
- })
- t.Run("includes inserts and updates", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "Buddies", ClassID: wire.FeedbagClassIdGroup, GroupID: 1},
- }, func(n int) int { return 50 })
- _, err := fl.AddBuddy("Buddies", "alice", "", "")
- assert.NoError(t, err)
- _, err = fl.AddBuddy("Buddies", "bob", "", "")
- assert.NoError(t, err)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 3)
- assert.Equal(t, wire.FeedbagClassIdBuddy, upserts[0].ClassID)
- assert.Equal(t, wire.FeedbagClassIdGroup, upserts[1].ClassID)
- assert.Equal(t, wire.FeedbagClassIdBuddy, upserts[2].ClassID)
- })
- t.Run("clears after retrieval", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 5 })
- fl.AddGroup("Buddies")
- assert.Len(t, fl.PendingUpdates(), 2)
- assert.Nil(t, fl.PendingUpdates())
- })
- }
- func TestFeedbagList_PendingDeletes(t *testing.T) {
- t.Run("empty when nothing deleted", func(t *testing.T) {
- fl := newFeedbagList(nil, nil)
- assert.Nil(t, fl.PendingDeletes())
- })
- t.Run("clears after retrieval", func(t *testing.T) {
- fl := newFeedbagList([]wire.FeedbagItem{
- {Name: "alice", ClassID: wire.FeedbagClassIDPermit, ItemID: 1},
- }, nil)
- fl.deleteItem(wire.FeedbagItem{Name: "alice", ClassID: wire.FeedbagClassIDPermit, ItemID: 1})
- assert.Len(t, fl.PendingDeletes(), 1)
- assert.Nil(t, fl.PendingDeletes())
- })
- }
- func TestFeedbagList_PendingUpdates_upsertsOnly(t *testing.T) {
- t.Run("tracks upserted items", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 5 })
- result, inserted := fl.upsertItem(wire.FeedbagItem{ClassID: wire.FeedbagClassIDPermit, Name: "alice"})
- assert.True(t, inserted)
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 1)
- assert.Equal(t, "alice", upserts[0].Name)
- assert.Equal(t, uint16(5), result.ItemID)
- })
- t.Run("clears after retrieval", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 5 })
- fl.upsertItem(wire.FeedbagItem{ClassID: wire.FeedbagClassIDPermit})
- assert.Len(t, fl.PendingUpdates(), 1)
- assert.Nil(t, fl.PendingUpdates())
- })
- t.Run("multiple inserts accumulate", func(t *testing.T) {
- fl := newFeedbagList(nil, func(n int) int { return 10 })
- fl.upsertItem(wire.FeedbagItem{ClassID: wire.FeedbagClassIDPermit, Name: "alice"})
- fl.upsertItem(wire.FeedbagItem{ClassID: wire.FeedbagClassIDPermit, Name: "bob"})
- upserts := fl.PendingUpdates()
- assert.Len(t, upserts, 2)
- })
- }
|