Function TestOfflineDatabaseStartup

rest/server_context_test.go:818–863

TestOfflineDatabaseStartup ensures that background processes are not actually running when starting up a database in offline mode.

(t *testing.T)

// TestOfflineDatabaseStartup ensures that background processes are not actually running when starting up a database in offline mode.
func TestOfflineDatabaseStartup(t *testing.T) {
	if !base.TestUseXattrs() {
		t.Skip("TestOfflineDatabaseStartup requires xattrs for document import")
	}

	base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll)

	rt := NewRestTester(t, &RestTesterConfig{
		DatabaseConfig: &DatabaseConfig{
			DbConfig: DbConfig{
				StartOffline: base.Ptr(true),
				AutoImport:   true,
				EnableXattrs: base.Ptr(true),
			},
		},
	})
	defer rt.Close()

	ds := rt.GetSingleDataStore()
	_, err := ds.AddRaw("doc1", 0, []byte(`{"type":"doc1"}`))
	require.NoError(t, err)

	// make sure we actually started offline (try to put a doc through the REST API)
	resp := rt.SendAdminRequest(http.MethodPut, "/{{.keyspace}}/doc2", `{"type":"doc2"}`)
	RequireStatus(t, resp, http.StatusServiceUnavailable)

	// put doc2 bypassing offline checks (this step will begin to fail with Elixir - since we're making offline more comprehensive)
	collection, ctx := rt.GetSingleTestDatabaseCollectionWithUser()
	_, _, err = collection.Put(ctx, "doc2", db.Body{"type": "doc2"})
	require.NoError(t, err)

	require.Nil(t, rt.GetDatabase().ImportListener)

	// ensure doc1 is not imported - since we started the database offline
	assert.Equal(t, int64(0), rt.GetDatabase().DbStats.SharedBucketImport().ImportCount.Value())

	rt.ServerContext().TakeDbOnline(base.NewNonCancelCtx(), rt.GetDatabase())
	require.NotNil(t, rt.GetDatabase().ImportListener)

	resp = rt.SendAdminRequest(http.MethodPut, "/{{.keyspace}}/doc3", `{"type":"doc3"}`)
	RequireStatus(t, resp, http.StatusCreated)

	// ensure doc1 is imported now we're online
	rt.WaitForChanges(3, "/{{.keyspace}}/_changes", "", true)
	assert.Equal(t, int64(1), rt.GetDatabase().DbStats.SharedBucketImport().ImportCount.Value())
}

func TestCompactIntervalFromConfig(t *testing.T) {
	testCases := []struct {