Merge pull request #22 from antoni/master

Add tests for entrypoint dependencies

dependencies/config/config.go

@@ -66,26 +66,27 @@ func (c Config) IsResolved(entrypoint entry.EntrypointInterface) (bool, error) {
 	if err := createDirectory(c.GetName()); err != nil {
 		return false, fmt.Errorf("Couldn't create directory: %v", err)
 	}
-	if err := createAndTemplateConfig(c.GetName(), c.params, c.prefix); err != nil {
+	if err := c.createAndTemplateConfig(); err != nil {
 		return false, fmt.Errorf("Cannot template %s: %v", c.GetName(), err)
 	}
 	return true, nil
 
 }
 
-func createAndTemplateConfig(name string, params configParams, prefix string) (err error) {
-	config, err := os.Create(name)
+func (c Config) createAndTemplateConfig() (err error) {
+	config, err := os.Create(c.name)
 	if err != nil {
 		return err
 	}
-	file := filepath.Base(name)
-	temp := template.Must(template.New(file).ParseFiles(getSrcConfig(prefix, file)))
-	if err = temp.Execute(config, params); err != nil {
+	file := filepath.Base(c.name)
+
+	temp := template.Must(template.New(file).ParseFiles(getSrcConfig(c.prefix, file)))
+	if err = temp.Execute(config, c.params); err != nil {
 		return err
 	}
-
 	return
 }
+
 func (c Config) GetName() string {
 	return c.name
 }

dependencies/config/config_suite_test.go

@@ -0,0 +1,13 @@
+package config_test
+
+import (
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"testing"
+)
+
+func TestConfig(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Config Suite")
+}

dependencies/config/config_test.go

@@ -1,76 +1,141 @@
-package config
+package config_test
 
 import (
 	"fmt"
 	"io/ioutil"
 	"net"
 	"os"
-	"strings"
-	"testing"
+	"path/filepath"
 
-	mocks "github.com/stackanetes/kubernetes-entrypoint/mocks"
+	. "github.com/stackanetes/kubernetes-entrypoint/dependencies/config"
+	"github.com/stackanetes/kubernetes-entrypoint/entrypoint"
+	"github.com/stackanetes/kubernetes-entrypoint/mocks"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
 )
 
-func prepareEnv() (err error) {
+const (
+	testDir        = "/tmp"
+	interfaceName  = "INTERFACE_NAME"
+	testConfigName = "KUBERNETES_ENTRYPOINT_TEST_CONFIG"
+
+	testConfigContentsFormat = "TEST_CONFIG %s\n"
+
+	// configPath       = "/tmp/lgtm"
+	templatePrefix = "/tmp/templates"
+)
+
+var testEntrypoint entrypoint.EntrypointInterface
+var testConfigContents string
+var testConfigPath string
+var testTemplatePath string
+var hostname string
+
+// var testClient cli.ClientInterface
+
+func init() {
+	var err error
+	testConfigContents = fmt.Sprintf(testConfigContentsFormat, "{{ .HOSTNAME }}")
+
+	testTemplatePath = fmt.Sprintf("%s/%s/%s", templatePrefix, testConfigName, testConfigName)
+	testConfigPath = fmt.Sprintf("%s/%s", testDir, testConfigName)
+
+	hostname, err = os.Hostname()
+
+	if err != nil {
+		fmt.Errorf("Could not get hostname", err)
+	}
+}
+
+func setupOsEnvironment() (err error) {
 	ifaces, err := net.Interfaces()
 	if err != nil {
 		return err
 	}
 
 	ifaceName := ifaces[0].Name
-	os.Setenv("INTERFACE_NAME", ifaceName)
-	return nil
-
+	return os.Setenv(interfaceName, ifaceName)
 }
 
-func createTemplate(template string) (err error) {
-	configContent := []byte("LGTM {{ .HOSTNAME }}\n")
-	if err = createDirectory(template); err != nil {
-		return fmt.Errorf("Couldn't create directory in tmp: %v", err)
-	}
+func teardownOsEnvironment() (err error) {
+	return os.Unsetenv(interfaceName)
+}
 
-	if err = ioutil.WriteFile(template, configContent, 0644); err != nil {
+func setupConfigTemplate(templatePath string) (err error) {
+	configContent := []byte(testConfigContents)
+	if err := os.MkdirAll(filepath.Dir(templatePath), 0755); err != nil {
 		return err
 	}
+
+	if err = ioutil.WriteFile(templatePath, configContent, 0644); err != nil {
+		return err
+	}
+
 	return
-
 }
-func TestIsResolved(t *testing.T) {
-	name := "/tmp/lgtm"
-	template := "/tmp/templates/lgtm/lgtm"
-	hostname, err := os.Hostname()
-	if err != nil {
-		t.Errorf("couldn't get hostname", err)
+
+func teardownConfigTemplate(templatePath string) (err error) {
+	if err := os.RemoveAll(templatePath); err != nil {
+		return err
 	}
 
-	entry := mocks.NewEntrypoint()
-
-	err = prepareEnv()
-	if err != nil {
-		t.Errorf("Something went wrong: %v", err)
-	}
-
-	if err = createTemplate(template); err != nil {
-		t.Errorf("Couldn't create %s template: %v", template, err)
-	}
-
-	config, err := NewConfig(name, "/tmp/templates")
-	if err != nil {
-		t.Errorf("Cannot create config dep: %v", err)
-	}
-	if _, err := config.IsResolved(entry); err != nil {
-		t.Errorf("Something went wrong: %v", err)
-	}
-
-	result, err := ioutil.ReadFile(name)
-	if err != nil {
-		t.Errorf("Something went wrong file %s: doesnt exist: %v", name, err)
-	}
-
-	expectedFile := fmt.Sprintf("LGTM %s", hostname)
-
-	same := strings.Compare(strings.TrimRight(string(result[:]), "\n"), expectedFile)
-	if same != 0 {
-		t.Errorf("Expected: %s got: %s: same %v", expectedFile, string(result[:]), same)
-	}
+	return
 }
+
+var _ = Describe("Config", func() {
+
+	BeforeEach(func() {
+		err := setupOsEnvironment()
+		Expect(err).NotTo(HaveOccurred())
+
+		err = setupConfigTemplate(testTemplatePath)
+		Expect(err).NotTo(HaveOccurred())
+
+		testEntrypoint = mocks.NewEntrypoint()
+	})
+
+	AfterEach(func() {
+		err := teardownOsEnvironment()
+		Expect(err).NotTo(HaveOccurred())
+
+		err = teardownConfigTemplate(testTemplatePath)
+		Expect(err).NotTo(HaveOccurred())
+	})
+
+	It("creates new config from file", func() {
+		config, err := NewConfig(testConfigPath, templatePrefix)
+
+		Expect(config).NotTo(Equal(nil))
+		Expect(err).NotTo(HaveOccurred())
+	})
+
+	It("checks the name of a newly created config file", func() {
+		config, _ := NewConfig(testConfigPath, templatePrefix)
+
+		Expect(config.GetName()).To(Equal(testConfigPath))
+	})
+
+	It("checks the format of a newly created config file", func() {
+		config, _ := NewConfig(testConfigPath, templatePrefix)
+		config.IsResolved(testEntrypoint)
+
+		result, err := ioutil.ReadFile(fmt.Sprintf("%s/%s", testDir, testConfigName))
+		Expect(err).NotTo(HaveOccurred())
+
+		expectedFile := fmt.Sprintf(testConfigContentsFormat, hostname)
+
+		readConfig := string(result[:])
+		Expect(readConfig).To(BeEquivalentTo(expectedFile))
+	})
+
+	It("checks resolution of a config", func() {
+		config, _ := NewConfig(testConfigPath, templatePrefix)
+
+		isResolved, err := config.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(true))
+		Expect(err).NotTo(HaveOccurred())
+	})
+
+})

dependencies/container/container.go

@@ -2,11 +2,14 @@ package container
 
 import (
 	"fmt"
+	"os"
+
 	entry "github.com/stackanetes/kubernetes-entrypoint/entrypoint"
 	"github.com/stackanetes/kubernetes-entrypoint/util/env"
-	"os"
 )
 
+const PodNameNotSetError = "Environment variable POD_NAME not set"
+
 type Container struct {
 	name string
 }
@@ -28,7 +31,7 @@ func NewContainer(name string) Container {
 func (c Container) IsResolved(entrypoint entry.EntrypointInterface) (bool, error) {
 	myPodName := os.Getenv("POD_NAME")
 	if myPodName == "" {
-		return false, fmt.Errorf("Environment variable POD_NAME not set")
+		return false, fmt.Errorf(PodNameNotSetError)
 	}
 	pod, err := entrypoint.Client().Pods(entrypoint.GetNamespace()).Get(myPodName)
 	if err != nil {

dependencies/container/container_suite_test.go

@@ -0,0 +1,13 @@
+package container_test
+
+import (
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"testing"
+)
+
+func TestContainer(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Container Suite")
+}

dependencies/container/container_test.go

@@ -1,18 +1,67 @@
-package container
+package container_test
 
 import (
+	"fmt"
 	"os"
-	"testing"
 
+	. "github.com/stackanetes/kubernetes-entrypoint/dependencies/container"
+	"github.com/stackanetes/kubernetes-entrypoint/entrypoint"
 	"github.com/stackanetes/kubernetes-entrypoint/mocks"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
 )
 
-func TestResolveContainer(t *testing.T) {
-	entrypoint := mocks.NewEntrypoint()
-	c := NewContainer("container_test")
-	os.Setenv("POD_NAME", "lgtm")
-	_, err := c.IsResolved(entrypoint)
-	if err != nil {
-		t.Errorf("Resolving container failed: %v", err)
-	}
-}
+const (
+	podEnvVariableName = "POD_NAME"
+)
+
+var testEntrypoint entrypoint.EntrypointInterface
+
+var _ = Describe("Container", func() {
+
+	BeforeEach(func() {
+		err := os.Setenv(podEnvVariableName, mocks.PodEnvVariableValue)
+		Expect(err).NotTo(HaveOccurred())
+
+		testEntrypoint = mocks.NewEntrypoint()
+	})
+
+	It("checks the name of a newly created container", func() {
+		container := NewContainer(mocks.MockContainerName)
+
+		Expect(container.GetName()).To(Equal(mocks.MockContainerName))
+	})
+
+	It(fmt.Sprintf("checks container resolution failure with %s not set", podEnvVariableName), func() {
+		os.Unsetenv(podEnvVariableName)
+		container := NewContainer(mocks.MockContainerName)
+
+		isResolved, err := container.IsResolved(testEntrypoint)
+		Expect(isResolved).To(Equal(false))
+		Expect(err).To(HaveOccurred())
+		Expect(err.Error()).To(Equal(PodNameNotSetError))
+	})
+
+	It("checks resolution of a succeeding container", func() {
+		container := NewContainer(mocks.MockContainerName)
+
+		isResolved, err := container.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(true))
+		Expect(err).NotTo(HaveOccurred())
+	})
+
+	It(fmt.Sprintf("fails to resolve a mocked container for a given %s value", podEnvVariableName), func() {
+		err := os.Setenv(podEnvVariableName, "INVALID_POD_LIST_VALUE")
+		Expect(err).NotTo(HaveOccurred())
+
+		container := NewContainer(mocks.PodNotPresent)
+		Expect(container).NotTo(Equal(nil))
+
+		var isResolved bool
+		isResolved, err = container.IsResolved(testEntrypoint)
+		Expect(isResolved).To(Equal(false))
+		Expect(err).To(BeNil())
+	})
+})

dependencies/daemonset/daemonset.go

@@ -12,6 +12,11 @@ import (
 	"k8s.io/client-go/1.5/pkg/labels"
 )
 
+const (
+	PodNameEnvVar            = "POD_NAME"
+	PodNameNotSetErrorFormat = "Env POD_NAME not set. Daemonset dependency %s will be ignored!"
+)
+
 type Daemonset struct {
 	name    string
 	podName string
@@ -32,12 +37,12 @@ func init() {
 }
 
 func NewDaemonset(name string) (*Daemonset, error) {
-	if os.Getenv("POD_NAME") == "" {
-		return nil, fmt.Errorf("Env POD_NAME not set. Daemonset dependency %s will be ignored!", name)
+	if os.Getenv(PodNameEnvVar) == "" {
+		return nil, fmt.Errorf(PodNameNotSetErrorFormat, name)
 	}
 	return &Daemonset{
 		name:    name,
-		podName: os.Getenv("POD_NAME"),
+		podName: os.Getenv(PodNameEnvVar),
 	}, nil
 }
 
@@ -58,7 +63,7 @@ func (d Daemonset) IsResolved(entrypoint entry.EntrypointInterface) (bool, error
 
 	myPod, err := entrypoint.Client().Pods(entrypoint.GetNamespace()).Get(d.podName)
 	if err != nil {
-		panic(fmt.Sprintf("Getting POD: %v failed : %v", myPodName, err))
+		return false, fmt.Errorf("Getting POD: %v failed : %v", myPodName, err)
 	}
 
 	myHost := myPod.Status.HostIP

dependencies/daemonset/daemonset_suite_test.go

@@ -0,0 +1,13 @@
+package daemonset_test
+
+import (
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"testing"
+)
+
+func TestDaemonset(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Daemonset Suite")
+}

dependencies/daemonset/daemonset_test.go

@@ -1,22 +1,92 @@
-package daemonset
+package daemonset_test
 
 import (
+	"fmt"
 	"os"
-	"testing"
 
-	mocks "github.com/stackanetes/kubernetes-entrypoint/mocks"
+	. "github.com/stackanetes/kubernetes-entrypoint/dependencies/daemonset"
+	"github.com/stackanetes/kubernetes-entrypoint/entrypoint"
+	"github.com/stackanetes/kubernetes-entrypoint/mocks"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
 )
 
-func TestResolveDaemonset(t *testing.T) {
-	entrypoint := mocks.NewEntrypoint()
-	os.Setenv("POD_NAME", "podlist")
-	daemonset, err := NewDaemonset("lgtm")
-	if err != nil {
-		t.Errorf("Cannot initialize daemonset: %v", err)
-	}
-	status, err := daemonset.IsResolved(entrypoint)
-	if err != nil {
-		t.Errorf("Something went wrong status: %s : %v", status, err)
-	}
+const (
+	podEnvVariableValue = "podlist"
+)
 
-}
+var testEntrypoint entrypoint.EntrypointInterface
+
+var _ = Describe("Daemonset", func() {
+
+	BeforeEach(func() {
+		err := os.Setenv(PodNameEnvVar, podEnvVariableValue)
+		Expect(err).NotTo(HaveOccurred())
+
+		testEntrypoint = mocks.NewEntrypoint()
+	})
+
+	It(fmt.Sprintf("checks failure of new daemonset creation without %s set", PodNameEnvVar), func() {
+		os.Unsetenv(PodNameEnvVar)
+		daemonset, err := NewDaemonset(mocks.SucceedingDaemonsetName)
+
+		Expect(daemonset).To(BeNil())
+		Expect(err.Error()).To(Equal(fmt.Sprintf(PodNameNotSetErrorFormat, mocks.SucceedingDaemonsetName)))
+	})
+
+	It(fmt.Sprintf("creates new daemonset with %s set and checks its name", PodNameEnvVar), func() {
+		daemonset, err := NewDaemonset(mocks.SucceedingDaemonsetName)
+		Expect(daemonset).NotTo(Equal(nil))
+		Expect(err).NotTo(HaveOccurred())
+
+		Expect(daemonset.GetName()).To(Equal(mocks.SucceedingDaemonsetName))
+	})
+
+	It("checks resolution of a succeeding daemonset", func() {
+		daemonset, _ := NewDaemonset(mocks.SucceedingDaemonsetName)
+
+		isResolved, err := daemonset.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(true))
+		Expect(err).NotTo(HaveOccurred())
+	})
+
+	It("checks resolution failure of a daemonset with incorrect name", func() {
+		daemonset, _ := NewDaemonset(mocks.FailingDaemonsetName)
+
+		isResolved, err := daemonset.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(false))
+		Expect(err).To(HaveOccurred())
+	})
+
+	It("checks resolution failure of a daemonset with incorrect match labels", func() {
+		daemonset, _ := NewDaemonset(mocks.IncorrectMatchLabelsDaemonsetName)
+
+		isResolved, err := daemonset.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(false))
+		Expect(err).To(HaveOccurred())
+	})
+
+	It(fmt.Sprintf("checks resolution failure of a daemonset with incorrect %s value", PodNameEnvVar), func() {
+		// Set POD_NAME to value not present in the mocks
+		os.Setenv(PodNameEnvVar, mocks.PodNotPresent)
+		daemonset, _ := NewDaemonset(mocks.IncorrectMatchLabelsDaemonsetName)
+
+		isResolved, err := daemonset.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(false))
+		Expect(err).To(HaveOccurred())
+	})
+
+	It("checks resolution failure of a daemonset with none of the pods with Ready status", func() {
+		daemonset, _ := NewDaemonset(mocks.NotReadyMatchLabelsDaemonsetName)
+
+		isResolved, err := daemonset.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(false))
+		Expect(err).To(HaveOccurred())
+	})
+})

dependencies/job/job.go

@@ -7,6 +7,8 @@ import (
 	"github.com/stackanetes/kubernetes-entrypoint/util/env"
 )
 
+const FailingStatusFormat = "Job %v is not completed yet"
+
 type Job struct {
 	name string
 }
@@ -31,7 +33,7 @@ func (j Job) IsResolved(entrypoint entry.EntrypointInterface) (bool, error) {
 		return false, err
 	}
 	if job.Status.Succeeded == 0 {
-		return false, fmt.Errorf("Job %v is not completed yet", j.GetName())
+		return false, fmt.Errorf(FailingStatusFormat, j.GetName())
 	}
 	return true, nil
 }

dependencies/job/job_suite_test.go

@@ -0,0 +1,13 @@
+package job_test
+
+import (
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"testing"
+)
+
+func TestJob(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Job Suite")
+}

dependencies/job/job_test.go

@@ -1,27 +1,47 @@
-package job
+package job_test
 
 import (
-	mocks "github.com/stackanetes/kubernetes-entrypoint/mocks"
-	"testing"
+	"fmt"
+
+	. "github.com/stackanetes/kubernetes-entrypoint/dependencies/job"
+	"github.com/stackanetes/kubernetes-entrypoint/entrypoint"
+	"github.com/stackanetes/kubernetes-entrypoint/mocks"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
 )
 
-func TestResolveNewJob(t *testing.T) {
+const testJobName = "TEST_JOB"
 
-	entrypoint := mocks.NewEntrypoint()
-	job := NewJob("lgtm")
-	status, err := job.IsResolved(entrypoint)
-	if status != true {
-		t.Errorf("Resolving job failed: %v", err)
-	}
-}
+var testEntrypoint entrypoint.EntrypointInterface
 
-func TestFailResolveNewJob(t *testing.T) {
+var _ = Describe("Job", func() {
 
-	entrypoint := mocks.NewEntrypoint()
-	job := NewJob("fail")
-	_, err := job.IsResolved(entrypoint)
-	expectedError := "Job fail is not completed yet"
-	if err.Error() != expectedError {
-		t.Errorf("Something went wrong: %v", err)
-	}
-}
+	BeforeEach(func() {
+		testEntrypoint = mocks.NewEntrypoint()
+	})
+
+	It("checks the name of a newly created job", func() {
+		job := NewJob(testJobName)
+
+		Expect(job.GetName()).To(Equal(testJobName))
+	})
+
+	It("checks resolution of a succeeding job", func() {
+		job := NewJob(mocks.SucceedingJobName)
+
+		isResolved, err := job.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(true))
+		Expect(err).NotTo(HaveOccurred())
+	})
+
+	It("checks resolution failure of a failing job", func() {
+		job := NewJob(mocks.FailingJobName)
+
+		isResolved, err := job.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(false))
+		Expect(err.Error()).To(Equal(fmt.Sprintf(FailingStatusFormat, job.GetName())))
+	})
+})

dependencies/service/service.go

@@ -7,6 +7,8 @@ import (
 	"github.com/stackanetes/kubernetes-entrypoint/util/env"
 )
 
+const FailingStatusFormat = "Service %v has no endpoints"
+
 type Service struct {
 	name string
 }
@@ -36,8 +38,7 @@ func (s Service) IsResolved(entrypoint entry.EntrypointInterface) (bool, error)
 			return true, nil
 		}
 	}
-
-	return false, fmt.Errorf("Service %v has no endpoints", s.GetName())
+	return false, fmt.Errorf(FailingStatusFormat, s.GetName())
 }
 
 func (s Service) GetName() string {

dependencies/service/service_suite_test.go

@@ -0,0 +1,13 @@
+package service_test
+
+import (
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"testing"
+)
+
+func TestService(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Service Suite")
+}

dependencies/service/service_test.go

@@ -1,26 +1,55 @@
-package service
+package service_test
 
 import (
+	"fmt"
+
+	. "github.com/stackanetes/kubernetes-entrypoint/dependencies/service"
+	"github.com/stackanetes/kubernetes-entrypoint/entrypoint"
 	"github.com/stackanetes/kubernetes-entrypoint/mocks"
-	"testing"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
 )
 
-func TestResolveService(t *testing.T) {
-	entrypoint := mocks.NewEntrypoint()
-	s := NewService("lgtm")
-	_, err := s.IsResolved(entrypoint)
-	if err != nil {
-		t.Errorf("Checking condition fail with: %v", err)
-	}
+const testServiceName = "TEST_SERVICE"
 
-}
+var testEntrypoint entrypoint.EntrypointInterface
 
-func TestResolveServiceFail(t *testing.T) {
-	entrypoint := mocks.NewEntrypoint()
-	s := NewService("fail")
-	_, err := s.IsResolved(entrypoint)
-	expectedError := "Mock endpoint didnt work"
-	if err.Error() != expectedError {
-		t.Errorf("Checking condition fail with: %v", err)
-	}
-}
+var _ = Describe("Service", func() {
+
+	BeforeEach(func() {
+		testEntrypoint = mocks.NewEntrypoint()
+	})
+
+	It("checks the name of a newly created service", func() {
+		service := NewService(testServiceName)
+
+		Expect(service.GetName()).To(Equal(testServiceName))
+	})
+
+	It("checks resolution of a succeeding service", func() {
+		service := NewService(mocks.SucceedingServiceName)
+
+		isResolved, err := service.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(true))
+		Expect(err).NotTo(HaveOccurred())
+	})
+
+	It("checks resolution failure of a failing service", func() {
+		service := NewService(mocks.FailingServiceName)
+
+		isResolved, err := service.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(false))
+		Expect(err.Error()).To(Equal(mocks.MockEndpointError))
+	})
+
+	It("checks resolution failure of a succeeding service with removed subsets", func() {
+		service := NewService(mocks.EmptySubsetsServiceName)
+
+		isResolved, err := service.IsResolved(testEntrypoint)
+		Expect(isResolved).To(Equal(false))
+		Expect(err.Error()).To(Equal(fmt.Sprintf(FailingStatusFormat, service.GetName())))
+	})
+})

dependencies/socket/socket.go

@@ -2,9 +2,15 @@ package socket
 
 import (
 	"fmt"
+	"os"
+
 	entry "github.com/stackanetes/kubernetes-entrypoint/entrypoint"
 	"github.com/stackanetes/kubernetes-entrypoint/util/env"
-	"os"
+)
+
+const (
+	NonExistingErrorFormat = "Socket %v doesn't exists"
+	NoPermsErrorFormat     = "I have no permission to %v"
 )
 
 type Socket struct {
@@ -34,10 +40,10 @@ func (s Socket) IsResolved(entrypoint entry.EntrypointInterface) (bool, error) {
 		return true, nil
 	}
 	if os.IsNotExist(err) {
-		return false, fmt.Errorf("Socket %v doesn't exists", s.GetName())
+		return false, fmt.Errorf(NonExistingErrorFormat, s.GetName())
 	}
 	if os.IsPermission(err) {
-		return false, fmt.Errorf("I have no permission to %v", s.GetName())
+		return false, fmt.Errorf(NoPermsErrorFormat, s.GetName())
 	}
 	return false, err
 }

dependencies/socket/socket_suite_test.go

@@ -0,0 +1,13 @@
+package socket_test
+
+import (
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"testing"
+)
+
+func TestSocket(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Socket Suite")
+}

dependencies/socket/socket_test.go

@@ -0,0 +1,68 @@
+package socket_test
+
+import (
+	"fmt"
+	"os"
+
+	. "github.com/stackanetes/kubernetes-entrypoint/dependencies/socket"
+	"github.com/stackanetes/kubernetes-entrypoint/entrypoint"
+	"github.com/stackanetes/kubernetes-entrypoint/mocks"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+)
+
+const (
+	existingSocketPath    = "/tmp/k8s-existing-socket"
+	nonExistingSocketPath = "/tmp/k8s-nonexisting-socket"
+	noPermsSocketPath     = "/root/k8s-no-permission-socket"
+)
+
+var testEntrypoint entrypoint.EntrypointInterface
+
+var _ = Describe("Socket", func() {
+
+	BeforeEach(func() {
+		testEntrypoint = mocks.NewEntrypoint()
+
+		_, err := os.Create(existingSocketPath)
+		Expect(err).NotTo(HaveOccurred())
+
+	})
+
+	It("checks the name of a newly created socket", func() {
+		socket := NewSocket(existingSocketPath)
+
+		Expect(socket.GetName()).To(Equal(existingSocketPath))
+	})
+
+	It("resolves an existing socket socket", func() {
+		socket := NewSocket(existingSocketPath)
+
+		isResolved, err := socket.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(true))
+		Expect(err).NotTo(HaveOccurred())
+	})
+
+	It("fails on trying to resolve a nonexisting socket", func() {
+		socket := NewSocket(nonExistingSocketPath)
+
+		isResolved, err := socket.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(false))
+		Expect(err).To(HaveOccurred())
+		Expect(err.Error()).To(Equal(fmt.Sprintf(NonExistingErrorFormat, socket.GetName())))
+	})
+
+	It("fails on trying to resolve a socket without permissions", func() {
+		socket := NewSocket(noPermsSocketPath)
+
+		isResolved, err := socket.IsResolved(testEntrypoint)
+
+		Expect(isResolved).To(Equal(false))
+		Expect(err).To(HaveOccurred())
+		Expect(err.Error()).To(Equal(fmt.Sprintf(NoPermsErrorFormat, socket.GetName())))
+	})
+
+})

entrypoint/entrypoint_test.go

@@ -37,7 +37,6 @@ func (d dummyResolver) GetName() (name string) {
 func init() {
 	testClient = mocks.NewClient()
 	testEntrypoint = mocks.NewEntrypointInNamespace(testNamespace)
-
 }
 
 func registerNilResolver() {

mocks/daemonset.go

@@ -13,18 +13,34 @@ import (
 type dClient struct {
 }
 
+const (
+	SucceedingDaemonsetName = "DAEMONSET_SUCCEED"
+	FailingDaemonsetName    = "DAEMONSET_FAIL"
+
+	IncorrectMatchLabelsDaemonsetName = "DAEMONSET_INCORRECT_MATCH_LABELS"
+	NotReadyMatchLabelsDaemonsetName  = "DAEMONSET_NOT_READY_MATCH_LABELS"
+)
+
 func (d dClient) Get(name string) (*extensions.DaemonSet, error) {
-	if name != "lgtm" {
+	matchLabelName := MockContainerName
+
+	if name == FailingDaemonsetName {
 		return nil, fmt.Errorf("Mock daemonset didnt work")
+	} else if name == IncorrectMatchLabelsDaemonsetName {
+		matchLabelName = IncorrectMatchLabel
+	} else if name == NotReadyMatchLabelsDaemonsetName {
+		matchLabelName = NotReadyMatchLabel
 	}
+
 	ds := &extensions.DaemonSet{
 		ObjectMeta: v1.ObjectMeta{Name: name},
 		Spec: extensions.DaemonSetSpec{
 			Selector: &extensions.LabelSelector{
-				MatchLabels: map[string]string{"name": "test"},
+				MatchLabels: map[string]string{"name": matchLabelName},
 			},
 		},
 	}
+
 	return ds, nil
 }
 func (d dClient) Create(ds *extensions.DaemonSet) (*extensions.DaemonSet, error) {

mocks/endpoints.go

@@ -13,20 +13,32 @@ import (
 type eClient struct {
 }
 
+const (
+	MockEndpointError = "Mock endpoint didnt work"
+)
+
 func (e eClient) Get(name string) (*v1.Endpoints, error) {
-	if name != "lgtm" {
-		return nil, fmt.Errorf("Mock endpoint didnt work")
+	if name == FailingServiceName {
+		return nil, fmt.Errorf(MockEndpointError)
 	}
-	endpoint := &v1.Endpoints{
-		ObjectMeta: v1.ObjectMeta{Name: name},
-		Subsets: []v1.EndpointSubset{
+
+	subsets := []v1.EndpointSubset{}
+
+	if name != EmptySubsetsServiceName {
+		subsets = []v1.EndpointSubset{
 			{
 				Addresses: []v1.EndpointAddress{
 					{IP: "127.0.0.1"},
 				},
 			},
-		},
+		}
 	}
+
+	endpoint := &v1.Endpoints{
+		ObjectMeta: v1.ObjectMeta{Name: name},
+		Subsets:    subsets,
+	}
+
 	return endpoint, nil
 }
 func (e eClient) Create(ds *v1.Endpoints) (*v1.Endpoints, error) {

mocks/job.go

@@ -9,16 +9,21 @@ import (
 	"k8s.io/client-go/1.5/pkg/watch"
 )
 
+const (
+	SucceedingJobName = "succeed"
+	FailingJobName    = "fail"
+)
+
 type jClient struct {
 }
 
 func (j jClient) Get(name string) (*batch.Job, error) {
-	if name == "lgtm" {
+	if name == SucceedingJobName {
 		return &batch.Job{
 			Status: batch.JobStatus{Succeeded: 1},
 		}, nil
 	}
-	if name == "fail" {
+	if name == FailingJobName {
 		return &batch.Job{
 			Status: batch.JobStatus{Succeeded: 0},
 		}, nil

mocks/pod.go

@@ -11,16 +11,31 @@ import (
 	"k8s.io/client-go/1.5/rest"
 )
 
+const MockContainerName = "TEST_CONTAINER"
+
 type pClient struct {
 }
 
+const (
+	PodNotPresent             = "NOT_PRESENT"
+	PodEmptyContainerStatuses = "EMPTY_CONTAINTER_STATUSES"
+	PodEnvVariableValue       = "podlist"
+
+	IncorrectMatchLabel = "INCORRECT"
+	NotReadyMatchLabel  = "INCORRECT"
+)
+
 func (p pClient) Get(name string) (*v1.Pod, error) {
+	if name == PodNotPresent {
+		return nil, fmt.Errorf("Could not get pod with the name %s", name)
+	}
+
 	return &v1.Pod{
 		ObjectMeta: v1.ObjectMeta{Name: name},
 		Status: v1.PodStatus{
 			ContainerStatuses: []v1.ContainerStatus{
 				{
-					Name:  "container_test",
+					Name:  MockContainerName,
 					Ready: true,
 				},
 			},
@@ -42,10 +57,20 @@ func (p pClient) DeleteCollection(options *api.DeleteOptions, listOptions api.Li
 }
 
 func (p pClient) List(options api.ListOptions) (*v1.PodList, error) {
+	if options.LabelSelector.String() == "name=INCORRECT" {
+		return nil, fmt.Errorf("Client received incorrect pod label names")
+	}
+
+	readyStatus := true
+
+	if options.LabelSelector.String() == "name=NOT_READY" {
+		readyStatus = false
+	}
+
 	return &v1.PodList{
 		Items: []v1.Pod{
 			{
-				ObjectMeta: v1.ObjectMeta{Name: "podList"},
+				ObjectMeta: v1.ObjectMeta{Name: PodEnvVariableValue},
 				Status: v1.PodStatus{
 					HostIP: "127.0.01",
 					Conditions: []v1.PodCondition{
@@ -56,15 +81,14 @@ func (p pClient) List(options api.ListOptions) (*v1.PodList, error) {
 					},
 					ContainerStatuses: []v1.ContainerStatus{
 						{
-							Name:  "container_test",
-							Ready: true,
+							Name:  MockContainerName,
+							Ready: readyStatus,
 						},
 					},
 				},
 			},
 		},
 	}, nil
-
 }
 
 func (p pClient) Update(pod *v1.Pod) (*v1.Pod, error) {

mocks/service.go

@@ -13,9 +13,16 @@ import (
 type sClient struct {
 }
 
+const (
+	MockServiceError        = "Mock service didnt work"
+	SucceedingServiceName   = "succeed"
+	EmptySubsetsServiceName = "empty-subsets"
+	FailingServiceName      = "fail"
+)
+
 func (s sClient) Get(name string) (*v1.Service, error) {
-	if name != "lgtm" {
-		return nil, fmt.Errorf("Mock service didnt work")
+	if name == FailingServiceName {
+		return nil, fmt.Errorf(MockServiceError)
 	}
 	return &v1.Service{
 		ObjectMeta: v1.ObjectMeta{Name: name},