Fixing panic issue in Validate when properties are nil (#3242)

pkg/api/apiloader.go

@@ -6,6 +6,8 @@ import (
 	"io/ioutil"
 	"reflect"
 
+	"fmt"
+
 	"github.com/Azure/acs-engine/pkg/api/agentPoolOnlyApi/v20170831"
 	"github.com/Azure/acs-engine/pkg/api/agentPoolOnlyApi/v20180331"
 	apvlabs "github.com/Azure/acs-engine/pkg/api/agentPoolOnlyApi/vlabs"
@@ -82,6 +84,9 @@ func (a *Apiloader) LoadContainerService(
 			}
 		}
 		setContainerServiceDefaultsv20160930(containerService)
+		if containerService.Properties == nil {
+			return nil, fmt.Errorf("missing ContainerService Properties")
+		}
 		if e := containerService.Properties.Validate(); validate && e != nil {
 			return nil, e
 		}
@@ -102,6 +107,9 @@ func (a *Apiloader) LoadContainerService(
 			}
 		}
 		setContainerServiceDefaultsv20160330(containerService)
+		if containerService.Properties == nil {
+			return nil, fmt.Errorf("missing ContainerService Properties")
+		}
 		if e := containerService.Properties.Validate(); validate && e != nil {
 			return nil, e
 		}
@@ -123,6 +131,9 @@ func (a *Apiloader) LoadContainerService(
 			}
 		}
 		setContainerServiceDefaultsv20170131(containerService)
+		if containerService.Properties == nil {
+			return nil, fmt.Errorf("missing ContainerService Properties")
+		}
 		if e := containerService.Properties.Validate(); validate && e != nil {
 			return nil, e
 		}
@@ -143,6 +154,9 @@ func (a *Apiloader) LoadContainerService(
 				return nil, e
 			}
 		}
+		if containerService.Properties == nil {
+			return nil, fmt.Errorf("missing ContainerService Properties")
+		}
 		if e := containerService.Properties.Validate(isUpdate); validate && e != nil {
 			return nil, e
 		}
@@ -168,6 +182,9 @@ func (a *Apiloader) LoadContainerService(
 				return nil, e
 			}
 		}
+		if containerService.Properties == nil {
+			return nil, fmt.Errorf("missing ContainerService Properties")
+		}
 		if e := containerService.Properties.Validate(isUpdate); validate && e != nil {
 			return nil, e
 		}

pkg/api/apiloader_test.go

@@ -11,6 +11,8 @@ import (
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
 
+	"io/ioutil"
+	"os"
 	"path"
 	"testing"
 )
@@ -211,3 +213,30 @@ func TestLoadContainerServiceForAgentPoolOnlyCluster(t *testing.T) {
 		})
 	})
 }
+
+func TestLoadContainerServiceWithNilProperties(t *testing.T) {
+	jsonWithoutProperties := `{
+        "type": "Microsoft.ContainerService/managedClusters",
+        "name": "[parameters('clusterName')]",
+        "apiVersion": "2017-07-01",
+        "location": "[resourceGroup().location]"
+        }`
+
+	tmpFile, err := ioutil.TempFile("", "containerService-invalid")
+	fileName := tmpFile.Name()
+	defer os.Remove(fileName)
+
+	err = ioutil.WriteFile(fileName, []byte(jsonWithoutProperties), os.ModeAppend)
+
+	apiloader := &Apiloader{}
+	existingContainerService := &ContainerService{Name: "test",
+		Properties: &Properties{OrchestratorProfile: &OrchestratorProfile{OrchestratorType: Kubernetes, OrchestratorVersion: "1.6.9"}}}
+	_, _, err = apiloader.LoadContainerServiceFromFile(fileName, true, false, existingContainerService)
+	if err == nil {
+		t.Errorf("Expected error to be thrown")
+	}
+	expectedMsg := "missing ContainerService Properties"
+	if err.Error() != expectedMsg {
+		t.Errorf("Expected error with message %s but got %s", expectedMsg, err.Error())
+	}
+}

pkg/api/vlabs/validate.go

@@ -96,6 +96,9 @@ func init() {
 
 // Validate implements APIObject
 func (a *Properties) Validate(isUpdate bool) error {
+	if a == nil {
+		return fmt.Errorf("missing ContainerService Properties")
+	}
 	if e := validate.Struct(a); e != nil {
 		return handleValidationErrors(e.(validator.ValidationErrors))
 	}

pkg/api/vlabs/validate_test.go

@@ -852,6 +852,15 @@ func Test_Properties_ValidateAddons(t *testing.T) {
 	}
 }
 
+func TestPropertiesValidationNil(t *testing.T) {
+	containerService := &ContainerService{}
+	err := containerService.Properties.Validate(true)
+	expected := "missing ContainerService Properties"
+	if err == nil || err.Error() != expected {
+		t.Errorf("Expected error with message %s", expected)
+	}
+}
+
 func TestWindowsVersions(t *testing.T) {
 	for _, version := range common.GetAllSupportedKubernetesVersionsWindows() {
 		p := getK8sDefaultProperties(true)