Docker test

.github/workflows/go.yml

@@ -16,6 +16,8 @@ jobs:
     env:
       TEST_KUBECTL: yes
       TEST_MINIKUBE_ENABLED: yes
+      TEST_MQTT_LOCAL_ENABLED: yes
+      TEST_DOCKER_ENABLED: yes
     steps:
     - uses: actions/checkout@v3
 
@@ -34,6 +36,9 @@ jobs:
     - name: Install make
       run: sudo apt-get update && sudo apt-get install -y build-essential
 
+    - name: Check docker version and images
+      run: docker --version && docker images
+
     - name: Install kubectl
       run: |
         curl -LO "https://dl.k8s.io/release/$(curl -L -s https://dl.k8s.io/release/stable.txt)/bin/linux/amd64/kubectl"
@@ -49,6 +54,13 @@ jobs:
         sudo mv minikube /usr/local/bin/
         minikube start
         kubectl config view
+
+    - name: Install Mqtt
+      run: | 
+        sudo apt-get update
+        sudo apt-get install mosquitto mosquitto-clients
+        sudo service mosquitto start
+        sudo service mosquitto status
 
     - name: COA Test
       run: cd coa && go test -v ./... -run '^[^C]*$|^[^c][^o]*$|^[^c][^o]*o[^n][^f][^o][^r][^m][^a][^n][^c][^e][^C]*$'

api/pkg/apis/v1alpha1/providers/target/docker/docker_test.go

@@ -146,19 +146,49 @@ func TestDockerTargetProviderRemove(t *testing.T) {
 	assert.Nil(t, err)
 }
 
-func TestGet(t *testing.T) {
+func TestUpdateGetDelete(t *testing.T) {
+	testDockerProvider := os.Getenv("TEST_DOCKER_ENABLED")
+	if testDockerProvider == "" {
+		t.Skip("Skipping because TEST_DOCKER_PROVIDER enviornment variable is not set")
+	}
 	config := DockerTargetProviderConfig{}
 	provider := DockerTargetProvider{}
 	err := provider.Init(config)
 	assert.Nil(t, err)
-	_, err = provider.Get(context.Background(), model.DeploymentSpec{
+
+	// Update
+	component := model.ComponentSpec{
+		Name: "alpine-test",
+		Type: "container",
+		Properties: map[string]interface{}{
+			model.ContainerImage: "alpine:3.18",
+		},
+	}
+	deployment := model.DeploymentSpec{
+		Solution: model.SolutionSpec{
+			Components: []model.ComponentSpec{component},
+		},
+	}
+	step := model.DeploymentStep{
+		Components: []model.ComponentStep{
+			{
+				Action:    "update",
+				Component: component,
+			},
+		},
+	}
+	_, err = provider.Apply(context.Background(), deployment, step, false)
+	assert.Nil(t, err)
+
+	// Get
+	components, err := provider.Get(context.Background(), model.DeploymentSpec{
 		Solution: model.SolutionSpec{
 			Components: []model.ComponentSpec{
 				{
-					Name: "redis-test",
+					Name: "alpine-test",
 					Type: "container",
 					Properties: map[string]interface{}{
-						model.ContainerImage: "redis:latest",
+						model.ContainerImage: "alpine:3.18",
 					},
 				},
 			},
@@ -167,29 +197,44 @@ func TestGet(t *testing.T) {
 		{
 			Action: "update",
 			Component: model.ComponentSpec{
-				Name: "redis-test",
+				Name: "alpine-test",
 				Type: "container",
 				Properties: map[string]interface{}{
-					model.ContainerImage: "redis:latest",
-					"env.REDIS_VERSION":  "7.0.12", // NOTE: Only environment variables passed in by the reference are returned.
+					model.ContainerImage: "alpine:3.18",
 				},
 			},
 		},
 	})
 	assert.Nil(t, err)
+	assert.Equal(t, 1, len(components))
+
+	// Delete
+	step = model.DeploymentStep{
+		Components: []model.ComponentStep{
+			{
+				Action:    "delete",
+				Component: component,
+			},
+		},
+	}
+	_, err = provider.Apply(context.Background(), deployment, step, false)
+	assert.Nil(t, err)
 }
 
-func TestApply(t *testing.T) {
+func TestApplyFailed(t *testing.T) {
+	testDockerProvider := os.Getenv("TEST_DOCKER_ENABLED")
+	if testDockerProvider == "" {
+		t.Skip("Skipping because TEST_DOCKER_PROVIDER enviornment variable is not set")
+	}
 	config := DockerTargetProviderConfig{}
 	provider := DockerTargetProvider{}
 	err := provider.Init(config)
 	assert.Nil(t, err)
+
+	// invalid container image name
 	component := model.ComponentSpec{
-		Name: "redis-test",
+		Name: "",
 		Type: "container",
-		Properties: map[string]interface{}{
-			model.ContainerImage: "redis:latest",
-		},
 	}
 	deployment := model.DeploymentSpec{
 		Solution: model.SolutionSpec{
@@ -204,18 +249,70 @@ func TestApply(t *testing.T) {
 			},
 		},
 	}
+
 	_, err = provider.Apply(context.Background(), deployment, step, false)
 	assert.NotNil(t, err)
 
+	// unknown container image
+	component = model.ComponentSpec{
+		Name: "abcd:latest",
+		Type: "container",
+		Properties: map[string]interface{}{
+			model.ContainerImage: "abc:latest",
+		},
+	}
+	deployment = model.DeploymentSpec{
+		Solution: model.SolutionSpec{
+			Components: []model.ComponentSpec{component},
+		},
+	}
 	step = model.DeploymentStep{
 		Components: []model.ComponentStep{
 			{
-				Action:    "delete",
+				Action:    "update",
 				Component: component,
 			},
 		},
 	}
 	_, err = provider.Apply(context.Background(), deployment, step, false)
+	assert.NotNil(t, err)
+}
+
+func TestApplyAlreadyRunning(t *testing.T) {
+	testDockerProvider := os.Getenv("TEST_DOCKER_ENABLED")
+	if testDockerProvider == "" {
+		t.Skip("Skipping because TEST_DOCKER_PROVIDER enviornment variable is not set")
+	}
+	config := DockerTargetProviderConfig{}
+	provider := DockerTargetProvider{}
+	err := provider.Init(config)
+	assert.Nil(t, err)
+
+	component := model.ComponentSpec{
+		Name: "alpine-test",
+		Type: "container",
+		Properties: map[string]interface{}{
+			model.ContainerImage: "alpine:3.18",
+		},
+	}
+	deployment := model.DeploymentSpec{
+		Solution: model.SolutionSpec{
+			Components: []model.ComponentSpec{component},
+		},
+	}
+	step := model.DeploymentStep{
+		Components: []model.ComponentStep{
+			{
+				Action:    "update",
+				Component: component,
+			},
+		},
+	}
+	_, err = provider.Apply(context.Background(), deployment, step, false)
+	assert.Nil(t, err)
+
+	// already running
+	_, err = provider.Apply(context.Background(), deployment, step, false)
 	assert.Nil(t, err)
 }