Function TestRequestPlusSkippedSequence

rest/changes_request_plus_test.go:23–63

TestRequirePlusSkippedSequence makes sure that a final skipped sequence in a request_plus request will not hang the request

(t *testing.T)

// TestRequirePlusSkippedSequence makes sure that a final skipped sequence in a request_plus request will not hang the request
func TestRequestPlusSkippedSequence(t *testing.T) {

	defer db.SuspendSequenceBatching()()
	restTesterConfig := RestTesterConfig{SyncFn: channels.DocChannelsSyncFunction}

	// JWT claim based grants do not support named collections
	rt := NewRestTester(t, &restTesterConfig)
	defer rt.Close()

	const (
		username = "alice"
		channel  = "foo"
	)
	rt.CreateUser(username, []string{channel})

	// add a single document for the user
	resp := rt.SendAdminRequest(http.MethodPut, "/{{.keyspace}}/doc1", fmt.Sprintf(`{"channels":"%s"}`, channel))
	RequireStatus(t, resp, http.StatusCreated)
	docSeq := rt.GetDocumentSequence("doc1")

	rt.WaitForPendingChanges()

	// add an unused sequence
	unusedSeq, err := db.AllocateTestSequence(rt.GetDatabase())
	require.NoError(t, err)

	caughtUpCount := rt.GetDatabase().DbStats.CBLReplicationPull().NumPullReplCaughtUp.Value()

	requestFinished := make(chan struct{})
	// make sure this request doesn't hang
	go func() {
		defer close(requestFinished)
		changes := rt.GetChanges(fmt.Sprintf("/{{.keyspace}}/_changes?since=%d&request_plus=true", docSeq), username)
		require.Len(t, changes.Results, 0)
	}()
	require.NoError(t, rt.GetDatabase().WaitForCaughtUp(caughtUpCount+1))
	// the request should finish once the sequence is released
	err = db.ReleaseTestSequence(base.TestCtx(t), rt.GetDatabase(), unusedSeq)
	require.NoError(t, err)
	<-requestFinished
}