Function TestSyncedEnforcerSelfRemovePolicies

enforcer_synced_test.go:215–254

(t *testing.T)

}

func TestSyncedEnforcerSelfRemovePolicies(t *testing.T) {
	for i := 0; i < 10; i++ {
		e, _ := NewSyncedEnforcer("examples/basic_model.conf", "examples/basic_policy.csv")
		go func() { _, _ = e.SelfAddPolicy("p", "p", []string{"user1", "data1", "read"}) }()
		go func() { _, _ = e.SelfAddPolicy("p", "p", []string{"user2", "data2", "read"}) }()
		go func() { _, _ = e.SelfAddPolicy("p", "p", []string{"user3", "data3", "read"}) }()
		go func() { _, _ = e.SelfAddPolicy("p", "p", []string{"user4", "data4", "read"}) }()
		go func() { _, _ = e.SelfAddPolicy("p", "p", []string{"user5", "data5", "read"}) }()
		go func() { _, _ = e.SelfAddPolicy("p", "p", []string{"user6", "data6", "read"}) }()

		time.Sleep(100 * time.Millisecond)

		testSyncedEnforcerGetPolicy(t, e, [][]string{
			{"alice", "data1", "read"},
			{"bob", "data2", "write"},
			{"user1", "data1", "read"},
			{"user2", "data2", "read"},
			{"user3", "data3", "read"},
			{"user4", "data4", "read"},
			{"user5", "data5", "read"},
			{"user6", "data6", "read"},
		})

		go func() {
			_, _ = e.SelfRemovePolicies("p", "p", [][]string{{"user1", "data1", "read"}, {"user2", "data2", "read"}})
		}()
		go func() {
			_, _ = e.SelfRemovePolicies("p", "p", [][]string{{"user3", "data3", "read"}, {"user4", "data4", "read"}})
		}()
		go func() {
			_, _ = e.SelfRemovePolicies("p", "p", [][]string{{"user5", "data5", "read"}, {"user6", "data6", "read"}})
		}()

		time.Sleep(100 * time.Millisecond)
		testSyncedEnforcerGetPolicy(t, e, [][]string{
			{"alice", "data1", "read"},
			{"bob", "data2", "write"},
		})
	}
}

func TestSyncedEnforcerSelfRemoveFilteredPolicy(t *testing.T) {
	for i := 0; i < 10; i++ {