added support for multiple-compose files

cmd/convert.go

@@ -47,7 +47,7 @@ var convertCmd = &cobra.Command{
 			CreateChart:            ConvertChart,
 			GenerateYaml:           ConvertYaml,
 			Replicas:               ConvertReplicas,
-			InputFile:              GlobalFile,
+			InputFiles:             GlobalFiles,
 			OutFile:                ConvertOut,
 			Provider:               strings.ToLower(GlobalProvider),
 			CreateD:                ConvertDeployment,

cmd/down.go

@@ -38,10 +38,10 @@ var downCmd = &cobra.Command{
 
 		// Create the Convert options.
 		DownOpt = kobject.ConvertOptions{
-			Replicas:  DownReplicas,
-			InputFile: GlobalFile,
-			Provider:  strings.ToLower(GlobalProvider),
-			EmptyVols: DownEmptyVols,
+			Replicas:   DownReplicas,
+			InputFiles: GlobalFiles,
+			Provider:   strings.ToLower(GlobalProvider),
+			EmptyVols:  DownEmptyVols,
 		}
 	},
 	Run: func(cmd *cobra.Command, args []string) {

cmd/root.go

@@ -40,8 +40,9 @@ func (errorOnWarningHook) Fire(entry *logrus.Entry) error {
 }
 
 var (
-	GlobalBundle, GlobalFile, GlobalProvider                    string
+	GlobalBundle, GlobalProvider                                string
 	GlobalVerbose, GlobalSuppressWarnings, GlobalErrorOnWarning bool
+	GlobalFiles                                                 []string
 )
 
 var RootCmd = &cobra.Command{
@@ -86,7 +87,7 @@ func init() {
 	RootCmd.PersistentFlags().BoolVarP(&GlobalVerbose, "verbose", "v", false, "verbose output")
 	RootCmd.PersistentFlags().BoolVar(&GlobalSuppressWarnings, "suppress-warnings", false, "Suppress all warnings")
 	RootCmd.PersistentFlags().BoolVar(&GlobalErrorOnWarning, "error-on-warning", false, "Treat any warning as an error")
-	RootCmd.PersistentFlags().StringVarP(&GlobalFile, "file", "f", "docker-compose.yml", "Specify an alternative compose file")
+	RootCmd.PersistentFlags().StringArrayVarP(&GlobalFiles, "file", "f", []string{}, "Specify an alternative compose file")
 	RootCmd.PersistentFlags().StringVarP(&GlobalBundle, "bundle", "b", "", "Specify a Distributed Application GlobalBundle (DAB) file")
 	RootCmd.PersistentFlags().StringVar(&GlobalProvider, "provider", "kubernetes", "Specify a provider. Kubernetes or OpenShift.")
 }

cmd/up.go

@@ -38,10 +38,10 @@ var upCmd = &cobra.Command{
 
 		// Create the Convert options.
 		UpOpt = kobject.ConvertOptions{
-			Replicas:  UpReplicas,
-			InputFile: GlobalFile,
-			Provider:  strings.ToLower(GlobalProvider),
-			EmptyVols: UpEmptyVols,
+			Replicas:   UpReplicas,
+			InputFiles: GlobalFiles,
+			Provider:   strings.ToLower(GlobalProvider),
+			EmptyVols:  UpEmptyVols,
 		}
 	},
 	Run: func(cmd *cobra.Command, args []string) {

pkg/app/app.go

@@ -114,7 +114,7 @@ func ValidateFlags(bundle string, args []string, cmd *cobra.Command, opt *kobjec
 
 	if len(bundle) > 0 {
 		inputFormat = "bundle"
-		opt.InputFile = bundle
+		opt.InputFiles = []string{bundle}
 	}
 
 	if len(bundle) > 0 && isFileSet {
@@ -185,7 +185,7 @@ func Convert(opt kobject.ConvertOptions) {
 	komposeObject := kobject.KomposeObject{
 		ServiceConfigs: make(map[string]kobject.ServiceConfig),
 	}
-	komposeObject = l.LoadFile(opt.InputFile)
+	komposeObject = l.LoadFile(opt.InputFiles)
 
 	// Get a transformer that maps komposeObject to provider's primitives
 	t := getTransformer(opt)
@@ -211,7 +211,7 @@ func Up(opt kobject.ConvertOptions) {
 	komposeObject := kobject.KomposeObject{
 		ServiceConfigs: make(map[string]kobject.ServiceConfig),
 	}
-	komposeObject = l.LoadFile(opt.InputFile)
+	komposeObject = l.LoadFile(opt.InputFiles)
 
 	// Get the transformer
 	t := getTransformer(opt)
@@ -237,7 +237,7 @@ func Down(opt kobject.ConvertOptions) {
 	komposeObject := kobject.KomposeObject{
 		ServiceConfigs: make(map[string]kobject.ServiceConfig),
 	}
-	komposeObject = l.LoadFile(opt.InputFile)
+	komposeObject = l.LoadFile(opt.InputFiles)
 
 	// Get the transformer
 	t := getTransformer(opt)

pkg/kobject/kobject.go

@@ -39,7 +39,7 @@ type ConvertOptions struct {
 	GenerateYaml           bool
 	EmptyVols              bool
 	Replicas               int
-	InputFile              string
+	InputFiles             []string
 	OutFile                string
 	Provider               string
 }

pkg/loader/bundle/bundle.go

@@ -173,12 +173,12 @@ func loadPorts(service Service) ([]kobject.Ports, string) {
 }
 
 // load dab file into KomposeObject
-func (b *Bundle) LoadFile(file string) kobject.KomposeObject {
+func (b *Bundle) LoadFile(files []string) kobject.KomposeObject {
 	komposeObject := kobject.KomposeObject{
 		ServiceConfigs: make(map[string]kobject.ServiceConfig),
 		LoadedFrom:     "bundle",
 	}
-
+	file := files[0]
 	buf, err := ioutil.ReadFile(file)
 	if err != nil {
 		logrus.Fatalf("Failed to read bundles file: %s ", err)

pkg/loader/compose/compose.go

@@ -221,16 +221,16 @@ func loadPorts(composePorts []string) ([]kobject.Ports, error) {
 }
 
 // load compose file into KomposeObject
-func (c *Compose) LoadFile(file string) kobject.KomposeObject {
+func (c *Compose) LoadFile(files []string) kobject.KomposeObject {
 	komposeObject := kobject.KomposeObject{
 		ServiceConfigs: make(map[string]kobject.ServiceConfig),
 		LoadedFrom:     "compose",
 	}
 	context := &project.Context{}
-	if file == "" {
-		file = "docker-compose.yml"
+	if len(files) == 0 {
+		files = append(files, "docker-compose.yml")
 	}
-	context.ComposeFiles = []string{file}
+	context.ComposeFiles = files
 
 	if context.ResourceLookup == nil {
 		context.ResourceLookup = &lookup.FileResourceLookup{}

pkg/loader/loader.go

@@ -26,7 +26,7 @@ import (
 )
 
 type Loader interface {
-	LoadFile(file string) kobject.KomposeObject
+	LoadFile(files []string) kobject.KomposeObject
 	///Name() string
 }
 

pkg/transformer/kubernetes/k8sutils.go

@@ -46,11 +46,12 @@ import (
 /**
  * Generate Helm Chart configuration
  */
-func generateHelm(filename string, outFiles []string) error {
+func generateHelm(filenames []string, outFiles []string) error {
 	type ChartDetails struct {
 		Name string
 	}
-
+	// Let assume all the docker-compose files are in the same directory
+	filename := filenames[0]
 	extension := filepath.Ext(filename)
 	dirName := filename[0 : len(filename)-len(extension)]
 	details := ChartDetails{dirName}
@@ -231,7 +232,7 @@ func PrintList(objects []runtime.Object, opt kobject.ConvertOptions) error {
 		}
 	}
 	if opt.CreateChart {
-		generateHelm(opt.InputFile, files)
+		generateHelm(opt.InputFiles, files)
 	}
 	return nil
 }

pkg/transformer/openshift/openshift.go

@@ -112,7 +112,9 @@ func getGitCurrentBranch(composeFileDir string) (string, error) {
 }
 
 // getComposeFileDir returns compose file directory
-func getComposeFileDir(inputFile string) (string, error) {
+func getComposeFileDir(inputFiles []string) (string, error) {
+	// Lets assume all the docker-compose files are in the same directory
+	inputFile := inputFiles[0]
 	if strings.Index(inputFile, "/") != 0 {
 		workDir, err := os.Getwd()
 		if err != nil {
@@ -332,7 +334,7 @@ func (o *OpenShift) Transform(komposeObject kobject.KomposeObject, opt kobject.C
 			// buildconfig needs to be added to objects after imagestream because of this Openshift bug: https://github.com/openshift/origin/issues/4518
 			if service.Build != "" {
 				if !hasBuild {
-					composeFileDir, err = getComposeFileDir(opt.InputFile)
+					composeFileDir, err = getComposeFileDir(opt.InputFiles)
 					if err != nil {
 						logrus.Warningf("Error in detecting compose file's directory.")
 						continue

pkg/transformer/openshift/openshift_test.go

@@ -214,8 +214,8 @@ func TestGetComposeFileDir(t *testing.T) {
 	wd, _ := os.Getwd()
 
 	testCases := map[string]struct {
-		inputFile string
-		output    string
+		inputFiles []string
+		output     string
 	}{
 		"Get compose file dir for relative input file path": {"foo/bar.yaml", filepath.Join(wd, "foo")},
 		"Get compose file dir for abs input file path":      {"/abs/path/to/compose.yaml", "/abs/path/to"},
@@ -224,7 +224,7 @@ func TestGetComposeFileDir(t *testing.T) {
 	for name, test := range testCases {
 		t.Log("Test case: ", name)
 
-		output, err = getComposeFileDir(test.inputFile)
+		output, err = getComposeFileDir(test.inputFiles)
 
 		if err != nil {
 			t.Errorf("Expected success, got error: %#v", err)

script/test/cmd/tests.sh

@@ -98,6 +98,11 @@ convert::expect_failure "kompose -f $KOMPOSE_ROOT/script/test/fixtures/bundles/f
 # Test related to kompose --bundle convert to ensure that docker bundles are converted properly
 convert::expect_success "kompose --bundle $KOMPOSE_ROOT/script/test/fixtures/bundles/dab/docker-compose-bundle.dab convert --stdout" "$KOMPOSE_ROOT/script/test/fixtures/bundles/dab/output-k8s.json"
 
+# Test related to multiple-compose files
+# Kubernets test
+convert::expect_success_and_warning "kompose -f $KOMPOSE_ROOT/script/test/fixtures/multiple-compose-files/docker-k8s.yml -f $KOMPOSE_ROOT/script/test/fixtures/multiple-compose-files/docker-os.yml convert --stdout" "$KOMPOSE_ROOT/script/test/fixtures/multiple-compose-files/output-k8s.json" "Unsupported depends_on key - ignoring"
+convert::expect_success_and_warning "kompose --provider=openshift -f $KOMPOSE_ROOT/script/test/fixtures/multiple-compose-files/docker-k8s.yml -f $KOMPOSE_ROOT/script/test/fixtures/multiple-compose-files/docker-os.yml convert --stdout" "$KOMPOSE_ROOT/script/test/fixtures/multiple-compose-files/output-openshift.json" "Unsupported depends_on key - ignoring"
+
 ######
 # Test related to kompose --bundle convert to ensure that DSB bundles are converted properly
 convert::expect_success_and_warning "kompose --bundle $KOMPOSE_ROOT/script/test/fixtures/bundles/dsb/docker-voting-bundle.dsb convert --stdout" "$KOMPOSE_ROOT/script/test/fixtures/bundles/dsb/output-k8s.json" "Service cannot be created because of missing port."
@@ -170,5 +175,4 @@ convert::files_exist "kompose -f $KOMPOSE_ROOT/examples/docker-compose.yml conve
 # Behavior with -o <dirname>/<dirname>/<filename>
 convert::files_exist "kompose -f $KOMPOSE_ROOT/examples/docker-compose.yml convert -o output_dir/output_dir_nested/output_file" "$TEMP_DIR/output_dir/output_dir_nested" "$TEMP_DIR/output_dir/output_dir_nested/output_file"
 
-
 exit $EXIT_STATUS

script/test/fixtures/multiple-compose-files/docker-k8s.yml

@@ -0,0 +1,27 @@
+version: "2"
+
+services:
+  mariadb:
+    image: centos/mariadb
+    ports:
+      - "3306"
+    environment:
+      MYSQL_ROOT_PASSWORD: kubernetes
+      MYSQL_DATABASE: kubernetes
+      MYSQL_PASSWORD: kubernetes
+      MYSQL_USER: kubernetes
+    volumes:
+      - /var/lib/mysql
+
+  etherpad:
+    image: centos/etherpad
+    ports:
+      - "80:9001"
+    depends_on:
+      - mariadb
+    environment:
+      DB_HOST: kubernetes
+      DB_DBID: kubernetes
+      DB_PASS: kubernetes
+      DB_PORT: kubernetes
+      DB_USER: kubernetes

script/test/fixtures/multiple-compose-files/docker-os.yml

@@ -0,0 +1,27 @@
+version: "2"
+
+services:
+  mariadb:
+    image: centos/mariadb
+    ports:
+      - "3307"
+    environment:
+      MYSQL_ROOT_PASSWORD: openshift
+      MYSQL_DATABASE: openshift
+      MYSQL_PASSWORD: openshift
+      MYSQL_USER: openshift
+    volumes:
+      - /var/lib/mysql
+
+  etherpad:
+    image: centos/etherpad
+    ports:
+      - "80:9001"
+    depends_on:
+      - mariadb
+    environment:
+      DB_HOST: openshift
+      DB_DBID: openshift
+      DB_PASS: openshift
+      DB_PORT: openshift
+      DB_USER: openshift