main_test.go

func newTestK8s() *k8s {
        client := k8s{
                clientset: &fake.Clientset{},
        }
        return &client
}

func TestCanICreateDeploymentsFalse(t *testing.T) {
	k8s := newTestSimpleK8s()
	c, err := k8s.canICreateDeployments()
	if err != nil {
		t.Fatal("canICreateDeployments should not raise an error")
	}
	if c != false {
		t.Fatal("canICreateDeployments should return false")
	}
}

func TestCanICreateDeplaoymentsTrue(t *testing.T) {
	k8s := newTestK8s()
	k8s.clientset.(*fake.Clientset).Fake.AddReactor("create", "selfsubjectaccessreviews", func(action k8stesting.Action) (handled bool, ret runtime.Object, err error) {
		mysar := &authorizationv1.SelfSubjectAccessReview{
			Status: authorizationv1.SubjectAccessReviewStatus{
				Allowed: true,
				Reason:  "I want to test it",
			},
		}
		return true, mysar, nil
	})
	c, err := k8s.canICreateDeployments()
	if err != nil {
		t.Fatal("canICreateDeployments should not raise an error")
	}
	if c != true {
		t.Fatal("canICreateDeployments should return true")
	}
}

func TestCanICreateDeplaoymentsError(t *testing.T) {
	k8s := newTestK8s()
	k8s.clientset.(*fake.Clientset).Fake.AddReactor("create", "selfsubjectaccessreviews", func(action k8stesting.Action) (handled bool, ret runtime.Object, err error) {
		return true, &authorizationv1.SelfSubjectAccessReview{}, errors.New("Error creating ssar")
	})
	_, err := k8s.canICreateDeployments()
	if err == nil {
		t.Fatal("canICreateDeployments should raise an error")
	}
}