Function TestResyncUsingDCPStreamReset

rest/adminapitest/admin_api_test.go:754–815

(t *testing.T)

}

func TestResyncUsingDCPStreamReset(t *testing.T) {
	base.TestRequiresDCPResync(t)
	base.LongRunningTest(t)

	syncFn := `
	function(doc) {
		channel("x")
	}`

	rt := rest.NewRestTester(t,
		&rest.RestTesterConfig{
			SyncFn: syncFn,
		},
	)
	defer rt.Close()

	const numDocs = 1000

	// create some docs
	for i := 0; i < numDocs; i++ {
		rt.CreateTestDoc(fmt.Sprintf("doc%d", i))
	}

	rt.TakeDbOffline()

	// start a resync run
	response := rt.SendAdminRequest("POST", "/db/_resync?action=start", "")
	rest.RequireStatus(t, response, http.StatusOK)

	resyncManagerStatus := rt.WaitForResyncDCPStatus(db.BackgroundProcessStateRunning)
	resyncID := resyncManagerStatus.ResyncID

	// stop resync before it completes, assert it has been aborted
	response = rt.SendAdminRequest("POST", "/db/_resync?action=stop", "")
	rest.RequireStatus(t, response, http.StatusOK)

	_ = rt.WaitForResyncDCPStatus(db.BackgroundProcessStateStopped)

	// reset the resync process through the endpoint
	response = rt.SendAdminRequest("POST", "/db/_resync?reset=true", "")
	rest.RequireStatus(t, response, http.StatusOK)

	// grab new resync status from rest run, assert the resync if is not the same as the first
	// run and that the docs processed is equal to number of docs we have created
	resyncManagerStatus = rt.WaitForResyncDCPStatus(db.BackgroundProcessStateRunning)
	assert.NotEqual(t, resyncID, resyncManagerStatus.ResyncID)

	resyncManagerStatus = rt.WaitForResyncDCPStatus(db.BackgroundProcessStateCompleted)
	if !base.UnitTestUrlIsWalrus() && !base.TestsDisableGSI() {
		// It is possible for Couchbase Server GSI runs which use DCP purge to two DCP events from a previous
		// test.
		// 1. doc1 mutation
		// 2. doc1 deletion
		//
		// In a test, these will not be resynced but docsProcessed is incremented. Relax
		// the assertion to greater than the number of documents.
		assert.GreaterOrEqual(t, int(resyncManagerStatus.DocsProcessed), numDocs)
	} else {