Method getChanges

rest/revocation_test.go:136–148

(sinceSeq interface{}, expectedLength int)

}

func (tester *ChannelRevocationTester) getChanges(sinceSeq interface{}, expectedLength int) ChangesResults {
	var changes ChangesResults

	// Ensure any previous mutations have caught up before issuing changes request
	tester.restTester.WaitForPendingChanges()

	err := tester.restTester.WaitForCondition(func() bool {
		changes = tester.restTester.GetChanges(fmt.Sprintf("/{{.keyspace}}/_changes?since=%v&revocations=true", sinceSeq), "user")
		return len(changes.Results) == expectedLength
	})
	require.NoError(tester.test, err, fmt.Sprintf("Unexpected: %d. Expected %d", len(changes.Results), expectedLength))
	return changes
}

func InitScenario(t testing.TB, rtConfig *RestTesterConfig) (ChannelRevocationTester, *RestTester) {