Consolidate pager tests while adding more coverage (#4622)
Rewrite the pager tests to more uniformly test the different outcomes when various pagers/configurations are used This PR splits tests into two main categories: those that deal with getting results from a single pager with no resets etc and those that deal with resets, fallbacks, and other similar things All tests now check for correctness when the pager does and doesn't support returning mod times --- #### Does this PR need a docs update or release note? - [ ] ✅ Yes, it's included - [ ] 🕐 Yes, but in a later PR - [x] ⛔ No #### Type of change - [ ] 🌻 Feature - [ ] 🐛 Bugfix - [ ] 🗺️ Documentation - [x] 🤖 Supportability/Tests - [ ] 💻 CI/Deployment - [ ] 🧹 Tech Debt/Cleanup #### Test Plan - [x] 💪 Manual - [ ] ⚡ Unit test - [ ] 💚 E2E
This commit is contained in:
ashmrtn
GitHub
parent
16782d90d6
commit
7662cfca68
@ -305,296 +305,588 @@ func (suite *PagerUnitSuite) TestBatchEnumerateItems() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (suite *PagerUnitSuite) TestGetAddedAndRemovedItemIDs() {
|
func assertSliceEmptyOr[S ~[]E, E any](
|
||||||
type expected struct {
|
t *testing.T,
|
||||||
added []testItem
|
expect S,
|
||||||
removed []string
|
got S,
|
||||||
deltaUpdate DeltaUpdate
|
assertionFunc assert.ComparisonAssertionFunc,
|
||||||
validModTimes bool
|
msgAndArgs ...any,
|
||||||
|
) {
|
||||||
|
if len(expect) == 0 {
|
||||||
|
assert.Empty(t, got, msgAndArgs)
|
||||||
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
nilPager := func(t *testing.T) NonDeltaHandler[testItem] {
|
assertionFunc(t, expect, got, msgAndArgs)
|
||||||
|
}
|
||||||
|
|
||||||
|
func assertMapEmptyOr[M ~map[K]V, K comparable, V any](
|
||||||
|
t *testing.T,
|
||||||
|
expect M,
|
||||||
|
got M,
|
||||||
|
assertionFunc assert.ComparisonAssertionFunc,
|
||||||
|
msgAndArgs ...any,
|
||||||
|
) {
|
||||||
|
if len(expect) == 0 {
|
||||||
|
assert.Empty(t, got, msgAndArgs)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
assertionFunc(t, expect, got, msgAndArgs)
|
||||||
|
}
|
||||||
|
|
||||||
|
func assertAddedAndRemoved(
|
||||||
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
|
wantAdded []testItem,
|
||||||
|
gotAdded map[string]time.Time,
|
||||||
|
wantRemoved []testItem,
|
||||||
|
gotRemoved []string,
|
||||||
|
) {
|
||||||
|
epoch, err := time.Parse(time.DateOnly, "1970-01-01")
|
||||||
|
require.NoError(t, err, clues.ToCore(err))
|
||||||
|
|
||||||
|
expectAdded := map[string]time.Time{}
|
||||||
|
for _, item := range wantAdded {
|
||||||
|
expectAdded[item.id] = item.modTime
|
||||||
|
}
|
||||||
|
|
||||||
|
if validModTimes {
|
||||||
|
assertMapEmptyOr(
|
||||||
|
t,
|
||||||
|
expectAdded,
|
||||||
|
gotAdded,
|
||||||
|
assert.Equal,
|
||||||
|
"added item IDs and mod times")
|
||||||
|
} else {
|
||||||
|
assertSliceEmptyOr(
|
||||||
|
t,
|
||||||
|
maps.Keys(expectAdded),
|
||||||
|
maps.Keys(gotAdded),
|
||||||
|
assert.ElementsMatch,
|
||||||
|
"added item IDs")
|
||||||
|
|
||||||
|
for _, modtime := range gotAdded {
|
||||||
|
assert.True(t, modtime.After(epoch), "mod time after epoch")
|
||||||
|
assert.False(t, modtime.IsZero(), "non-zero mod time")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
expectRemoved := []string{}
|
||||||
|
for _, item := range wantRemoved {
|
||||||
|
expectRemoved = append(expectRemoved, item.id)
|
||||||
|
}
|
||||||
|
|
||||||
|
assertSliceEmptyOr(
|
||||||
|
t,
|
||||||
|
expectRemoved,
|
||||||
|
gotRemoved,
|
||||||
|
assert.ElementsMatch,
|
||||||
|
"removed item IDs")
|
||||||
|
}
|
||||||
|
|
||||||
|
type modTimeTest struct {
|
||||||
|
name string
|
||||||
|
validModTimes bool
|
||||||
|
}
|
||||||
|
|
||||||
|
var (
|
||||||
|
addedItem1 = addedItem("a_uno", time.Now())
|
||||||
|
addedItem2 = addedItem("a_dos", time.Now())
|
||||||
|
|
||||||
|
removedItem1 = removedItem("r_uno")
|
||||||
|
removedItem2 = removedItem("r_dos")
|
||||||
|
|
||||||
|
modTimeTests = []modTimeTest{
|
||||||
|
{
|
||||||
|
name: "ValidModTimes",
|
||||||
|
validModTimes: true,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "InvalidModTimes",
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
nilPager = func(*testing.T, bool) NonDeltaHandler[testItem] {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
)
|
||||||
|
|
||||||
epoch, err := time.Parse(time.DateOnly, "1970-01-01")
|
func (suite *PagerUnitSuite) TestGetAddedAndRemovedItemIDs() {
|
||||||
require.NoError(suite.T(), err, clues.ToCore(err))
|
pagerTypeTests := []struct {
|
||||||
|
name string
|
||||||
|
prevDelta string
|
||||||
|
canUseDelta bool
|
||||||
|
pagersFunc func(
|
||||||
|
p *testIDsNonDeltaMultiPager,
|
||||||
|
) (NonDeltaHandler[testItem], DeltaHandler[testItem])
|
||||||
|
expectDeltaReset bool
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "NoPrevDelta",
|
||||||
|
canUseDelta: true,
|
||||||
|
pagersFunc: func(
|
||||||
|
p *testIDsNonDeltaMultiPager,
|
||||||
|
) (NonDeltaHandler[testItem], DeltaHandler[testItem]) {
|
||||||
|
return nil, newDeltaPager(p)
|
||||||
|
},
|
||||||
|
expectDeltaReset: true,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "PrevDelta",
|
||||||
|
prevDelta: "a",
|
||||||
|
canUseDelta: true,
|
||||||
|
pagersFunc: func(
|
||||||
|
p *testIDsNonDeltaMultiPager,
|
||||||
|
) (NonDeltaHandler[testItem], DeltaHandler[testItem]) {
|
||||||
|
return nil, newDeltaPager(p)
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "DeltaNotAllowed",
|
||||||
|
prevDelta: "a",
|
||||||
|
pagersFunc: func(
|
||||||
|
p *testIDsNonDeltaMultiPager,
|
||||||
|
) (NonDeltaHandler[testItem], DeltaHandler[testItem]) {
|
||||||
|
return p, nil
|
||||||
|
},
|
||||||
|
expectDeltaReset: true,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
item1 := addedItem("uno", time.Now())
|
type expected struct {
|
||||||
item2 := addedItem("dos", time.Now())
|
errCheck assert.ErrorAssertionFunc
|
||||||
|
added []testItem
|
||||||
|
removed []testItem
|
||||||
|
}
|
||||||
|
|
||||||
|
table := []struct {
|
||||||
|
name string
|
||||||
|
pagerGetter func(
|
||||||
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
|
) *testIDsNonDeltaMultiPager
|
||||||
|
filter func(a testItem) bool
|
||||||
|
expect expected
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "OnePage",
|
||||||
|
pagerGetter: func(t *testing.T, validModTime bool) *testIDsNonDeltaMultiPager {
|
||||||
|
return &testIDsNonDeltaMultiPager{
|
||||||
|
t: t,
|
||||||
|
pages: []pageResult{
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
addedItem1,
|
||||||
|
addedItem2,
|
||||||
|
removedItem1,
|
||||||
|
removedItem2,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
validModTimes: validModTime,
|
||||||
|
}
|
||||||
|
},
|
||||||
|
expect: expected{
|
||||||
|
errCheck: assert.NoError,
|
||||||
|
added: []testItem{
|
||||||
|
addedItem1,
|
||||||
|
addedItem2,
|
||||||
|
},
|
||||||
|
removed: []testItem{removedItem1, removedItem2},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "TwoPages",
|
||||||
|
pagerGetter: func(t *testing.T, validModTime bool) *testIDsNonDeltaMultiPager {
|
||||||
|
return &testIDsNonDeltaMultiPager{
|
||||||
|
t: t,
|
||||||
|
pages: []pageResult{
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
addedItem1,
|
||||||
|
removedItem1,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
addedItem2,
|
||||||
|
removedItem2,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
validModTimes: validModTime,
|
||||||
|
}
|
||||||
|
},
|
||||||
|
expect: expected{
|
||||||
|
errCheck: assert.NoError,
|
||||||
|
added: []testItem{
|
||||||
|
addedItem1,
|
||||||
|
addedItem2,
|
||||||
|
},
|
||||||
|
removed: []testItem{removedItem1, removedItem2},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "OnePage FilterFailsAll",
|
||||||
|
pagerGetter: func(t *testing.T, validModTimes bool) *testIDsNonDeltaMultiPager {
|
||||||
|
return &testIDsNonDeltaMultiPager{
|
||||||
|
t: t,
|
||||||
|
pages: []pageResult{
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
addedItem1,
|
||||||
|
addedItem2,
|
||||||
|
removedItem1,
|
||||||
|
removedItem2,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
validModTimes: validModTimes,
|
||||||
|
}
|
||||||
|
},
|
||||||
|
filter: func(testItem) bool { return false },
|
||||||
|
expect: expected{
|
||||||
|
errCheck: assert.NoError,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "TwoPages FilterFailsAll",
|
||||||
|
pagerGetter: func(t *testing.T, validModTimes bool) *testIDsNonDeltaMultiPager {
|
||||||
|
return &testIDsNonDeltaMultiPager{
|
||||||
|
t: t,
|
||||||
|
pages: []pageResult{
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
addedItem1,
|
||||||
|
removedItem1,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
addedItem2,
|
||||||
|
removedItem2,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
validModTimes: validModTimes,
|
||||||
|
}
|
||||||
|
},
|
||||||
|
filter: func(testItem) bool { return false },
|
||||||
|
expect: expected{
|
||||||
|
errCheck: assert.NoError,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "Error",
|
||||||
|
pagerGetter: func(t *testing.T, validModTimes bool) *testIDsNonDeltaMultiPager {
|
||||||
|
return &testIDsNonDeltaMultiPager{
|
||||||
|
t: t,
|
||||||
|
pages: []pageResult{
|
||||||
|
{
|
||||||
|
err: assert.AnError,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
validModTimes: validModTimes,
|
||||||
|
}
|
||||||
|
},
|
||||||
|
expect: expected{
|
||||||
|
errCheck: assert.Error,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, modTimeTest := range modTimeTests {
|
||||||
|
suite.Run(modTimeTest.name, func() {
|
||||||
|
for _, pagerTypeTest := range pagerTypeTests {
|
||||||
|
suite.Run(pagerTypeTest.name, func() {
|
||||||
|
for _, test := range table {
|
||||||
|
suite.Run(test.name, func() {
|
||||||
|
t := suite.T()
|
||||||
|
|
||||||
|
ctx, flush := tester.NewContext(t)
|
||||||
|
defer flush()
|
||||||
|
|
||||||
|
filters := []func(testItem) bool{}
|
||||||
|
if test.filter != nil {
|
||||||
|
filters = append(filters, test.filter)
|
||||||
|
}
|
||||||
|
|
||||||
|
basePager := test.pagerGetter(t, modTimeTest.validModTimes)
|
||||||
|
getter, deltaGetter := pagerTypeTest.pagersFunc(basePager)
|
||||||
|
|
||||||
|
addRemoved, err := GetAddedAndRemovedItemIDs[testItem](
|
||||||
|
ctx,
|
||||||
|
getter,
|
||||||
|
deltaGetter,
|
||||||
|
pagerTypeTest.prevDelta,
|
||||||
|
pagerTypeTest.canUseDelta,
|
||||||
|
AddedAndRemovedByAddtlData[testItem],
|
||||||
|
filters...)
|
||||||
|
test.expect.errCheck(t, err, "getting added and removed item IDs: %+v", clues.ToCore(err))
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
assert.Equal(t, modTimeTest.validModTimes, addRemoved.ValidModTimes, "valid mod times")
|
||||||
|
assert.Equal(t, pagerTypeTest.expectDeltaReset, addRemoved.DU.Reset, "delta update")
|
||||||
|
|
||||||
|
assertAddedAndRemoved(
|
||||||
|
t,
|
||||||
|
modTimeTest.validModTimes,
|
||||||
|
test.expect.added,
|
||||||
|
addRemoved.Added,
|
||||||
|
test.expect.removed,
|
||||||
|
addRemoved.Removed)
|
||||||
|
})
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// TestGetAddedAndRemovedItemIDs_FallbackPagers tests that when pagers get reset
|
||||||
|
// or need to fallback to other pager types things work as expected. This only
|
||||||
|
// tests for basic cases where we enumerate everything with the fallback pager.
|
||||||
|
// These are here mostly to ensure we clear the results from the invalid pager
|
||||||
|
// properly. If we can ensure that then other tests will ensure the fallback
|
||||||
|
// pager properly handles all the other things like item filtering, item limits,
|
||||||
|
// cancellation, etc.
|
||||||
|
func (suite *PagerUnitSuite) TestGetAddedAndRemovedItemIDs_FallbackPagers() {
|
||||||
|
type expected struct {
|
||||||
|
errCheck assert.ErrorAssertionFunc
|
||||||
|
added []testItem
|
||||||
|
removed []testItem
|
||||||
|
}
|
||||||
|
|
||||||
tests := []struct {
|
tests := []struct {
|
||||||
name string
|
name string
|
||||||
pagerGetter func(
|
pagerGetter func(
|
||||||
*testing.T,
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
) NonDeltaHandler[testItem]
|
) NonDeltaHandler[testItem]
|
||||||
deltaPagerGetter func(
|
deltaPagerGetter func(
|
||||||
*testing.T,
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
) DeltaHandler[testItem]
|
) DeltaHandler[testItem]
|
||||||
prevDelta string
|
expect expected
|
||||||
filter func(a testItem) bool
|
|
||||||
expect expected
|
|
||||||
canDelta bool
|
|
||||||
validModTimes bool
|
|
||||||
}{
|
}{
|
||||||
{
|
{
|
||||||
name: "no prev delta",
|
name: "TwoValidPages DeltaReset",
|
||||||
pagerGetter: nilPager,
|
pagerGetter: nilPager,
|
||||||
deltaPagerGetter: func(t *testing.T) DeltaHandler[testItem] {
|
deltaPagerGetter: func(
|
||||||
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
|
) DeltaHandler[testItem] {
|
||||||
return newDeltaPager(
|
return newDeltaPager(
|
||||||
&testIDsNonDeltaMultiPager{
|
&testIDsNonDeltaMultiPager{
|
||||||
t: t,
|
t: t,
|
||||||
pages: []pageResult{
|
pages: []pageResult{
|
||||||
{
|
{
|
||||||
items: []testItem{
|
items: []testItem{
|
||||||
item1,
|
addedItem1,
|
||||||
item2,
|
removedItem1,
|
||||||
removedItem("tres"),
|
|
||||||
removedItem("quatro"),
|
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
|
||||||
validModTimes: true,
|
|
||||||
})
|
|
||||||
},
|
|
||||||
expect: expected{
|
|
||||||
added: []testItem{
|
|
||||||
item1,
|
|
||||||
item2,
|
|
||||||
},
|
|
||||||
removed: []string{"tres", "quatro"},
|
|
||||||
deltaUpdate: DeltaUpdate{Reset: true},
|
|
||||||
validModTimes: true,
|
|
||||||
},
|
|
||||||
canDelta: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "no prev delta invalid mod times",
|
|
||||||
pagerGetter: nilPager,
|
|
||||||
deltaPagerGetter: func(t *testing.T) DeltaHandler[testItem] {
|
|
||||||
return newDeltaPager(
|
|
||||||
&testIDsNonDeltaMultiPager{
|
|
||||||
t: t,
|
|
||||||
pages: []pageResult{
|
|
||||||
{
|
|
||||||
items: []testItem{
|
|
||||||
addedItem("uno", time.Time{}),
|
|
||||||
addedItem("dos", time.Time{}),
|
|
||||||
removedItem("tres"),
|
|
||||||
removedItem("quatro"),
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
})
|
|
||||||
},
|
|
||||||
expect: expected{
|
|
||||||
added: []testItem{
|
|
||||||
item1,
|
|
||||||
item2,
|
|
||||||
},
|
|
||||||
removed: []string{"tres", "quatro"},
|
|
||||||
deltaUpdate: DeltaUpdate{Reset: true},
|
|
||||||
},
|
|
||||||
canDelta: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "with prev delta",
|
|
||||||
pagerGetter: nilPager,
|
|
||||||
deltaPagerGetter: func(t *testing.T) DeltaHandler[testItem] {
|
|
||||||
return newDeltaPager(
|
|
||||||
&testIDsNonDeltaMultiPager{
|
|
||||||
t: t,
|
|
||||||
pages: []pageResult{
|
|
||||||
{
|
|
||||||
items: []testItem{
|
|
||||||
item1,
|
|
||||||
item2,
|
|
||||||
removedItem("tres"),
|
|
||||||
removedItem("quatro"),
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
validModTimes: true,
|
|
||||||
})
|
|
||||||
},
|
|
||||||
prevDelta: "delta",
|
|
||||||
expect: expected{
|
|
||||||
added: []testItem{
|
|
||||||
item1,
|
|
||||||
item2,
|
|
||||||
},
|
|
||||||
removed: []string{"tres", "quatro"},
|
|
||||||
deltaUpdate: DeltaUpdate{Reset: false},
|
|
||||||
validModTimes: true,
|
|
||||||
},
|
|
||||||
canDelta: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "delta expired",
|
|
||||||
pagerGetter: nilPager,
|
|
||||||
deltaPagerGetter: func(t *testing.T) DeltaHandler[testItem] {
|
|
||||||
return newDeltaPager(
|
|
||||||
&testIDsNonDeltaMultiPager{
|
|
||||||
t: t,
|
|
||||||
pages: []pageResult{
|
|
||||||
{
|
{
|
||||||
errCode: "SyncStateNotFound",
|
errCode: "SyncStateNotFound",
|
||||||
needsReset: true,
|
needsReset: true,
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
items: []testItem{
|
items: []testItem{
|
||||||
item1,
|
removedItem2,
|
||||||
item2,
|
addedItem2,
|
||||||
removedItem("tres"),
|
|
||||||
removedItem("quatro"),
|
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
validModTimes: true,
|
validModTimes: validModTimes,
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
prevDelta: "delta",
|
|
||||||
expect: expected{
|
expect: expected{
|
||||||
|
errCheck: assert.NoError,
|
||||||
added: []testItem{
|
added: []testItem{
|
||||||
item1,
|
addedItem2,
|
||||||
item2,
|
},
|
||||||
|
removed: []testItem{
|
||||||
|
removedItem2,
|
||||||
},
|
},
|
||||||
removed: []string{"tres", "quatro"},
|
|
||||||
deltaUpdate: DeltaUpdate{Reset: true},
|
|
||||||
validModTimes: true,
|
|
||||||
},
|
},
|
||||||
canDelta: true,
|
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
name: "delta not allowed",
|
name: "TwoPages DeltaResetAtEnd",
|
||||||
pagerGetter: func(t *testing.T) NonDeltaHandler[testItem] {
|
pagerGetter: nilPager,
|
||||||
|
deltaPagerGetter: func(
|
||||||
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
|
) DeltaHandler[testItem] {
|
||||||
|
return newDeltaPager(
|
||||||
|
&testIDsNonDeltaMultiPager{
|
||||||
|
t: t,
|
||||||
|
pages: []pageResult{
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
addedItem("uno", time.Now()),
|
||||||
|
removedItem("tres"),
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
removedItem("quatro"),
|
||||||
|
addedItem("dos", time.Now()),
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
errCode: "SyncStateNotFound",
|
||||||
|
needsReset: true,
|
||||||
|
},
|
||||||
|
// Return an empty page to show no new results after reset.
|
||||||
|
{},
|
||||||
|
},
|
||||||
|
validModTimes: validModTimes,
|
||||||
|
})
|
||||||
|
},
|
||||||
|
expect: expected{
|
||||||
|
errCheck: assert.NoError,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "TwoValidPages DeltaNotSupported",
|
||||||
|
pagerGetter: func(
|
||||||
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
|
) NonDeltaHandler[testItem] {
|
||||||
return &testIDsNonDeltaMultiPager{
|
return &testIDsNonDeltaMultiPager{
|
||||||
t: t,
|
t: t,
|
||||||
pages: []pageResult{
|
pages: []pageResult{
|
||||||
{
|
{
|
||||||
items: []testItem{
|
items: []testItem{
|
||||||
item1,
|
addedItem1,
|
||||||
item2,
|
removedItem1,
|
||||||
removedItem("tres"),
|
},
|
||||||
removedItem("quatro"),
|
},
|
||||||
|
{
|
||||||
|
items: []testItem{
|
||||||
|
removedItem2,
|
||||||
|
addedItem2,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
validModTimes: true,
|
validModTimes: validModTimes,
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
deltaPagerGetter: func(t *testing.T) DeltaHandler[testItem] {
|
deltaPagerGetter: func(
|
||||||
return nil
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
|
) DeltaHandler[testItem] {
|
||||||
|
return newDeltaPager(
|
||||||
|
&testIDsNonDeltaMultiPager{
|
||||||
|
t: t,
|
||||||
|
pages: []pageResult{
|
||||||
|
{
|
||||||
|
err: graph.ErrDeltaNotSupported,
|
||||||
|
needsReset: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
validModTimes: validModTimes,
|
||||||
|
})
|
||||||
},
|
},
|
||||||
expect: expected{
|
expect: expected{
|
||||||
|
errCheck: assert.NoError,
|
||||||
added: []testItem{
|
added: []testItem{
|
||||||
item1,
|
addedItem1,
|
||||||
item2,
|
addedItem2,
|
||||||
|
},
|
||||||
|
removed: []testItem{
|
||||||
|
removedItem1,
|
||||||
|
removedItem2,
|
||||||
},
|
},
|
||||||
removed: []string{"tres", "quatro"},
|
|
||||||
deltaUpdate: DeltaUpdate{Reset: true},
|
|
||||||
validModTimes: true,
|
|
||||||
},
|
},
|
||||||
canDelta: false,
|
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
name: "no prev delta and fail all filter",
|
name: "TwoPages DeltaNotSupportedAtEnd",
|
||||||
pagerGetter: nilPager,
|
pagerGetter: func(
|
||||||
deltaPagerGetter: func(t *testing.T) DeltaHandler[testItem] {
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
|
) NonDeltaHandler[testItem] {
|
||||||
|
return &testIDsNonDeltaMultiPager{
|
||||||
|
t: t,
|
||||||
|
pages: []pageResult{
|
||||||
|
// Return an empty page.
|
||||||
|
{},
|
||||||
|
},
|
||||||
|
validModTimes: validModTimes,
|
||||||
|
}
|
||||||
|
},
|
||||||
|
deltaPagerGetter: func(
|
||||||
|
t *testing.T,
|
||||||
|
validModTimes bool,
|
||||||
|
) DeltaHandler[testItem] {
|
||||||
return newDeltaPager(
|
return newDeltaPager(
|
||||||
&testIDsNonDeltaMultiPager{
|
&testIDsNonDeltaMultiPager{
|
||||||
t: t,
|
t: t,
|
||||||
pages: []pageResult{
|
pages: []pageResult{
|
||||||
{
|
{
|
||||||
items: []testItem{
|
items: []testItem{
|
||||||
item1,
|
addedItem1,
|
||||||
item2,
|
removedItem1,
|
||||||
removedItem("tres"),
|
|
||||||
removedItem("quatro"),
|
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
|
||||||
validModTimes: true,
|
|
||||||
})
|
|
||||||
},
|
|
||||||
filter: func(testItem) bool { return false },
|
|
||||||
expect: expected{
|
|
||||||
removed: []string{},
|
|
||||||
deltaUpdate: DeltaUpdate{Reset: true},
|
|
||||||
validModTimes: true,
|
|
||||||
},
|
|
||||||
canDelta: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "with prev delta and fail all filter",
|
|
||||||
pagerGetter: nilPager,
|
|
||||||
deltaPagerGetter: func(t *testing.T) DeltaHandler[testItem] {
|
|
||||||
return newDeltaPager(
|
|
||||||
&testIDsNonDeltaMultiPager{
|
|
||||||
t: t,
|
|
||||||
pages: []pageResult{
|
|
||||||
{
|
{
|
||||||
items: []testItem{
|
items: []testItem{
|
||||||
item1,
|
removedItem2,
|
||||||
item2,
|
addedItem2,
|
||||||
removedItem("tres"),
|
|
||||||
removedItem("quatro"),
|
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
err: graph.ErrDeltaNotSupported,
|
||||||
|
needsReset: true,
|
||||||
|
},
|
||||||
},
|
},
|
||||||
validModTimes: true,
|
validModTimes: validModTimes,
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
filter: func(testItem) bool { return false },
|
|
||||||
prevDelta: "delta",
|
|
||||||
expect: expected{
|
expect: expected{
|
||||||
removed: []string{},
|
errCheck: assert.NoError,
|
||||||
deltaUpdate: DeltaUpdate{Reset: false},
|
|
||||||
validModTimes: true,
|
|
||||||
},
|
},
|
||||||
canDelta: true,
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, test := range tests {
|
for _, modTimeTest := range modTimeTests {
|
||||||
suite.Run(test.name, func() {
|
suite.Run(modTimeTest.name, func() {
|
||||||
t := suite.T()
|
for _, test := range tests {
|
||||||
|
suite.Run(test.name, func() {
|
||||||
|
t := suite.T()
|
||||||
|
|
||||||
ctx, flush := tester.NewContext(t)
|
ctx, flush := tester.NewContext(t)
|
||||||
defer flush()
|
defer flush()
|
||||||
|
|
||||||
filters := []func(testItem) bool{}
|
addRemoved, err := GetAddedAndRemovedItemIDs[testItem](
|
||||||
if test.filter != nil {
|
ctx,
|
||||||
filters = append(filters, test.filter)
|
test.pagerGetter(t, modTimeTest.validModTimes),
|
||||||
|
test.deltaPagerGetter(t, modTimeTest.validModTimes),
|
||||||
|
"a",
|
||||||
|
true,
|
||||||
|
AddedAndRemovedByAddtlData[testItem])
|
||||||
|
require.NoError(
|
||||||
|
t,
|
||||||
|
err,
|
||||||
|
"getting added and removed item IDs: %+v",
|
||||||
|
clues.ToCore(err))
|
||||||
|
|
||||||
|
assert.Equal(t, modTimeTest.validModTimes, addRemoved.ValidModTimes, "valid mod times")
|
||||||
|
assert.True(t, addRemoved.DU.Reset, "delta update")
|
||||||
|
|
||||||
|
assertAddedAndRemoved(
|
||||||
|
t,
|
||||||
|
modTimeTest.validModTimes,
|
||||||
|
test.expect.added,
|
||||||
|
addRemoved.Added,
|
||||||
|
test.expect.removed,
|
||||||
|
addRemoved.Removed)
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
aar, err := GetAddedAndRemovedItemIDs[testItem](
|
|
||||||
ctx,
|
|
||||||
test.pagerGetter(t),
|
|
||||||
test.deltaPagerGetter(t),
|
|
||||||
test.prevDelta,
|
|
||||||
test.canDelta,
|
|
||||||
AddedAndRemovedByAddtlData[testItem],
|
|
||||||
filters...)
|
|
||||||
|
|
||||||
expectAddedMap := map[string]time.Time{}
|
|
||||||
for _, item := range test.expect.added {
|
|
||||||
expectAddedMap[item.id] = item.modTime
|
|
||||||
}
|
|
||||||
|
|
||||||
require.NoErrorf(t, err, "getting added and removed item IDs: %+v", clues.ToCore(err))
|
|
||||||
if aar.ValidModTimes {
|
|
||||||
assert.Equal(t, expectAddedMap, aar.Added, "added item IDs and mod times")
|
|
||||||
} else {
|
|
||||||
assert.ElementsMatch(t, maps.Keys(expectAddedMap), maps.Keys(aar.Added), "added item IDs")
|
|
||||||
for _, modtime := range aar.Added {
|
|
||||||
assert.True(t, modtime.After(epoch), "mod time after epoch")
|
|
||||||
assert.False(t, modtime.Equal(time.Time{}), "non-zero mod time")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
assert.Equal(t, test.expect.validModTimes, aar.ValidModTimes, "valid mod times")
|
|
||||||
assert.EqualValues(t, test.expect.removed, aar.Removed, "removed item IDs")
|
|
||||||
assert.Equal(t, test.expect.deltaUpdate, aar.DU, "delta update")
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user