Function TestRevocationScenario7

rest/revocation_test.go:497–542

(t *testing.T)

}

func TestRevocationScenario7(t *testing.T) {
	defer db.SuspendSequenceBatching()()

	revocationTester, rt := InitScenario(t, nil)
	defer rt.Close()

	resp := rt.SendAdminRequest("PUT", "/{{.keyspace}}/doc1", `{"channels": "ch1"}`)
	RequireStatus(t, resp, http.StatusCreated)

	revocationTester.fillToSeq(4)
	revocationTester.addRoleChannel("foo", "ch1")

	changes := revocationTester.getChanges(5, 0)
	assert.Equal(t, "5", changes.Last_Seq.String())

	revocationTester.fillToSeq(19)
	revocationTester.addRole("user", "foo")
	revocationTester.fillToSeq(25)

	changes = revocationTester.getChanges(5, 1)
	assert.Equal(t, "20:3", changes.Last_Seq.String())

	revocationTester.fillToSeq(44)
	revocationTester.removeRole("user", "foo")
	revocationTester.fillToSeq(54)
	revocationTester.removeRoleChannel("foo", "ch1")
	revocationTester.fillToSeq(64)
	revocationTester.addRole("user", "foo")
	revocationTester.fillToSeq(74)
	revocationTester.addRoleChannel("foo", "ch1")
	revocationTester.fillToSeq(84)
	revocationTester.removeRoleChannel("foo", "ch1")
	revocationTester.fillToSeq(94)
	revocationTester.removeRole("user", "foo")

	revocationTester.fillToSeq(100)

	changes = revocationTester.getChanges(25, 1)
	assert.Equal(t, "45:3", changes.Last_Seq.String())
	assert.True(t, changes.Results[0].Revoked)

	revocationTester.fillToSeq(110)

	changes = revocationTester.getChanges(100, 0)
	assert.Equal(t, "100", changes.Last_Seq.String())
}

func TestRevocationScenario8(t *testing.T) {
	defer db.SuspendSequenceBatching()()