Function TestRemoveObsoleteDesignDocsErrors

db/design_doc_test.go:156–198

Test remove obsolete design docs returns the same in both preview and non-preview

(t *testing.T)

// Test remove obsolete design docs returns the same in both preview and non-preview
func TestRemoveObsoleteDesignDocsErrors(t *testing.T) {
	setDesignDocPreviousVersionsForTest(t, "test")

	ctx := base.TestCtx(t)
	bucket := base.NewLeakyBucket(base.GetTestBucket(t), base.LeakyBucketConfig{})
	defer bucket.Close(ctx)

	mapFunction := `function (doc, meta){ emit(); }`

	viewStore, ok := base.AsViewStore(bucket.DefaultDataStore())
	require.True(t, ok)

	err := viewStore.PutDDoc(ctx, DesignDocSyncGatewayPrefix+"_test", &sgbucket.DesignDoc{
		Views: sgbucket.ViewMap{
			"channels": sgbucket.ViewDef{Map: mapFunction},
		},
	})
	require.NoError(t, err)
	err = viewStore.PutDDoc(ctx, DesignDocSyncHousekeepingPrefix+"_test", &sgbucket.DesignDoc{
		Views: sgbucket.ViewMap{
			"channels": sgbucket.ViewDef{Map: mapFunction},
		},
	})
	require.NoError(t, err)

	// Verify creation was successful
	base.RequireAllAssertions(t,
		assertDesignDocExists(t, viewStore, DesignDocSyncGatewayPrefix+"_test"),
		assertDesignDocExists(t, viewStore, DesignDocSyncHousekeepingPrefix+"_test"),
	)

	leakyDataStore, ok := base.AsLeakyDataStore(bucket.DefaultDataStore())
	require.Truef(t, ok, "bucket is not a leaky bucket")
	leakyDataStore.SetDDocGetErrorCount(1)
	leakyDataStore.SetDDocDeleteErrorCount(1)

	removedDDocsPreview, err := removeObsoleteDesignDocs(ctx, viewStore, true, false)
	assert.NoError(t, err)
	removedDDocsNonPreview, err := removeObsoleteDesignDocs(ctx, viewStore, false, false)
	require.NoError(t, err)

	assert.Equalf(t, removedDDocsPreview, removedDDocsNonPreview, "preview and non-preview should return the same design docs")
}