Function requireDocumentEvents

rest/audit_test.go:1553–1566

requireDocumentEvents validates that a document CRUD event occurred on the right doc ID with the correct channels.

(rt *RestTester, eventID base.AuditID, output []byte, docID, docVersion string, count int)

// requireDocumentEvents validates that a document CRUD event occurred on the right doc ID with the correct channels.
func requireDocumentEvents(rt *RestTester, eventID base.AuditID, output []byte, docID, docVersion string, count int) {
	events := jsonLines(rt.TB(), output)
	countFound := 0
	for _, event := range events {
		// skip events that are the target eventID
		if base.AuditID(event[base.AuditFieldID].(float64)) != eventID {
			continue
		}
		require.Equal(rt.TB(), docID, event[base.AuditFieldDocID])
		require.Equal(rt.TB(), docVersion, event[base.AuditFieldDocVersion].(string))
		countFound++
	}
	require.Equal(rt.TB(), count, countFound, "expected exactly %d %s events, got %d", count, base.AuditEvents[eventID].Name, countFound)
}

// requireChangesStartEvent validates that there is a changes start event with the specified fields
func requireChangesStartEvent(t testing.TB, output []byte, expectedFields map[string]any) {