Function TestBlipRevokeNonExistentRole

rest/revocation_test.go:2479–2520

Regression test for CBG-2183.

(t *testing.T)

// Regression test for CBG-2183.
func TestBlipRevokeNonExistentRole(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelInfo, base.KeyAll)

	btcRunner := NewBlipTesterClientRunner(t)

	btcRunner.Run(func(t *testing.T) {
		rt := NewRestTester(t,
			&RestTesterConfig{
				GuestEnabled: false,
			})
		defer rt.Close()

		dataStore := rt.GetSingleDataStore()

		// 1. Create user with admin_roles including two roles not previously defined (a1 and a2, for example)
		res := rt.SendAdminRequest(http.MethodPut, fmt.Sprintf("/%s/_user/bilbo", rt.GetDatabase().Name), GetUserPayload(t, "bilbo", RestTesterDefaultUserPassword, "", dataStore, []string{"c1"}, []string{"a1", "a2"}))
		RequireStatus(t, res, http.StatusCreated)

		// Create a doc so we have something to replicate
		res = rt.SendAdminRequest(http.MethodPut, "/{{.keyspace}}/testdoc", `{"channels": ["c1"]}`)
		RequireStatus(t, res, http.StatusCreated)

		// 3. Update the user to not reference one of the roles (update to ['a1'], for example)
		// [also revoke channel c1 so the doc shows up in the revocation queries]
		res = rt.SendAdminRequest(http.MethodPut, fmt.Sprintf("/%s/_user/bilbo", rt.GetDatabase().Name), GetUserPayload(t, "bilbo", RestTesterDefaultUserPassword, "", dataStore, []string{}, []string{"a1"}))
		RequireStatus(t, res, http.StatusOK)

		// 4. Try to sync
		bt := btcRunner.NewBlipTesterClientOptsWithRT(rt, &BlipTesterClientOpts{
			Username:        "bilbo",
			SendRevocations: true,
		})
		defer bt.Close()

		btcRunner.StartPull(bt.id)

		// in the failing case we'll panic before hitting this
		base.RequireWaitForStat(t, func() int64 {
			return rt.GetDatabase().DbStats.CBLReplicationPull().NumPullReplCaughtUp.Value()
		}, 1)
	})
}

func TestReplicatorSwitchPurgeNoReset(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll)