enhancement: added docker and k8s integration

Author: mahendraintelops

internal/languages/dotnet/frameworks/dotnet-clean-architecture/copier.go

@@ -146,6 +146,7 @@ func NewCopier(gitPlatformURL, gitPlatformUserName, gitRepositoryName, nodeName,
 	data := map[string]interface{}{
 		"GitRepositoryName":   gitRepositoryName,
 		"NodeName":            strings.ToLower(nodeName),
+		"MicroServiceName":    frameworks.GetMicroServiceName(nodeDirectoryName),
 		"GitPlatformUserName": gitPlatformUserName,
 		"GitPlatformURL":      strings.Replace(gitPlatformURL, "https://", "", -1),
 	}
@@ -196,11 +197,6 @@ func NewCopier(gitPlatformURL, gitPlatformUserName, gitRepositoryName, nodeName,
 	}
 }
 
-func getMicroServiceName(name string) string {
-	splitted := strings.Split(name, "/")
-	return splitted[len(splitted)-1]
-}
-
 // createRestServerDirectories creates rest server directories.
 func (c *Copier) createRestServerDirectories() error {
 	applicationDirectory := c.NodeDirectoryName + ApplicationPath
@@ -287,7 +283,7 @@ func (c *Copier) createRestServerDirectories() error {
 		return err
 	}
 
-	microServiceNameDirectory := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName)
+	microServiceNameDirectory := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName)
 	microServiceNameControllersDirectory := microServiceNameDirectory + MicroServiceNameControllersPath
 	microServiceNamePropertiesDirectory := microServiceNameDirectory + MicroServiceNamePropertiesPath
 	if err := utils.CreateDirectories(microServiceNameDirectory); err != nil {
@@ -579,7 +575,7 @@ func (c *Copier) addInfrastructureRelatedDirectoriesAndFiles(resource *corenode.
 func (c *Copier) addMicroServiceNameRelatedDirectoriesAndFiles(resource *corenode.Resource, filePaths *[]*string) error {
 	var err error
 	// copy MicroServiceName/Controllers/ResourceNameServiceController.cs
-	targetMicroServiceNameControllersResourceNameServiceControllerFileName := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName) + MicroServiceNameControllersPath + "/" + resource.Name + "ServiceController.cs"
+	targetMicroServiceNameControllersResourceNameServiceControllerFileName := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + MicroServiceNameControllersPath + "/" + resource.Name + "ServiceController.cs"
 	_, err = utils.CopyFile(targetMicroServiceNameControllersResourceNameServiceControllerFileName, c.TemplatesRootPath+MicroServiceNameControllersResourceNameServiceControllerCSFile)
 	if err != nil {
 		log.Errorf("error copying MicroServiceName controllers resource name service controller file: %v", err)
@@ -588,7 +584,7 @@ func (c *Copier) addMicroServiceNameRelatedDirectoriesAndFiles(resource *corenod
 	*filePaths = append(*filePaths, &targetMicroServiceNameControllersResourceNameServiceControllerFileName)
 
 	// copy MicroServiceName/Properties/launchSettings.json
-	targetMicroServiceNamePropertiesLaunchSettingsJSONFileName := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName) + MicroServiceNamePropertiesPath + "/" + "launchSettings.json"
+	targetMicroServiceNamePropertiesLaunchSettingsJSONFileName := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + MicroServiceNamePropertiesPath + "/" + "launchSettings.json"
 	_, err = utils.CopyFile(targetMicroServiceNamePropertiesLaunchSettingsJSONFileName, c.TemplatesRootPath+MicroServiceNamePropertiesLaunchSettingsJSONFile)
 	if err != nil {
 		log.Errorf("error copying MicroServiceName properties launch settings json file: %v", err)
@@ -597,7 +593,7 @@ func (c *Copier) addMicroServiceNameRelatedDirectoriesAndFiles(resource *corenod
 	*filePaths = append(*filePaths, &targetMicroServiceNamePropertiesLaunchSettingsJSONFileName)
 
 	// copy MicroServiceName/MicroServiceName.csproj
-	targetMicroServiceNameCSProjFileName := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName) + "/" + getMicroServiceName(c.NodeDirectoryName) + ".csproj"
+	targetMicroServiceNameCSProjFileName := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + ".csproj"
 	_, err = utils.CopyFile(targetMicroServiceNameCSProjFileName, c.TemplatesRootPath+MicroServiceNameCSProjFile)
 	if err != nil {
 		log.Errorf("error copying MicroServiceName csproj file: %v", err)
@@ -606,7 +602,7 @@ func (c *Copier) addMicroServiceNameRelatedDirectoriesAndFiles(resource *corenod
 	*filePaths = append(*filePaths, &targetMicroServiceNameCSProjFileName)
 
 	// copy MicroServiceName/MicroServiceName.csproj.user
-	targetMicroServiceNameCSProjUserFileName := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName) + "/" + getMicroServiceName(c.NodeDirectoryName) + ".csproj.user"
+	targetMicroServiceNameCSProjUserFileName := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + ".csproj.user"
 	_, err = utils.CopyFile(targetMicroServiceNameCSProjUserFileName, c.TemplatesRootPath+MicroServiceNameCSProjUserFile)
 	if err != nil {
 		log.Errorf("error copying MicroServiceName csproj.user file: %v", err)
@@ -615,7 +611,7 @@ func (c *Copier) addMicroServiceNameRelatedDirectoriesAndFiles(resource *corenod
 	*filePaths = append(*filePaths, &targetMicroServiceNameCSProjUserFileName)
 
 	// copy MicroServiceName/Program.cs
-	targetMicroServiceNameProgramCSFileName := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName) + "/" + "Program.cs"
+	targetMicroServiceNameProgramCSFileName := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + "/" + "Program.cs"
 	_, err = utils.CopyFile(targetMicroServiceNameProgramCSFileName, c.TemplatesRootPath+MicroServiceNameProgramCSFile)
 	if err != nil {
 		log.Errorf("error copying MicroServiceName program cs file: %v", err)
@@ -624,7 +620,7 @@ func (c *Copier) addMicroServiceNameRelatedDirectoriesAndFiles(resource *corenod
 	*filePaths = append(*filePaths, &targetMicroServiceNameProgramCSFileName)
 
 	// copy MicroServiceName/appsettings.Development.json
-	targetMicroServiceNameAppSettingsDevelopmentFileName := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName) + "/" + "appsettings.Development.json"
+	targetMicroServiceNameAppSettingsDevelopmentFileName := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + "/" + "appsettings.Development.json"
 	_, err = utils.CopyFile(targetMicroServiceNameAppSettingsDevelopmentFileName, c.TemplatesRootPath+MicroServiceNameAppSettingsDevelopmentFile)
 	if err != nil {
 		log.Errorf("error copying MicroServiceName appsettings.Development.json file: %v", err)
@@ -633,7 +629,7 @@ func (c *Copier) addMicroServiceNameRelatedDirectoriesAndFiles(resource *corenod
 	*filePaths = append(*filePaths, &targetMicroServiceNameAppSettingsDevelopmentFileName)
 
 	// copy MicroServiceName/appsettings.json
-	targetMicroServiceNameAppSettingsFileName := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName) + "/" + "appsettings.json"
+	targetMicroServiceNameAppSettingsFileName := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + "/" + "appsettings.json"
 	_, err = utils.CopyFile(targetMicroServiceNameAppSettingsFileName, c.TemplatesRootPath+MicroServiceNameAppSettingsFile)
 	if err != nil {
 		log.Errorf("error copying MicroServiceName appsettings.json file: %v", err)
@@ -861,7 +857,7 @@ func (c *Copier) copyTestsFiles() error {
 
 func (c *Copier) copyMicroServiceNameSlnFile() error {
 	filePaths := &[]*string{}
-	targetMicroServiceNameSLNFileName := c.NodeDirectoryName + "/" + getMicroServiceName(c.NodeDirectoryName) + ".sln"
+	targetMicroServiceNameSLNFileName := c.NodeDirectoryName + "/" + frameworks.GetMicroServiceName(c.NodeDirectoryName) + ".sln"
 	_, err := utils.CopyFile(targetMicroServiceNameSLNFileName, c.TemplatesRootPath+MicroServiceNameSlnFile)
 	if err != nil {
 		log.Errorf("error copying MicroServiceName.sln file: %v", err)

internal/languages/dotnet/frameworks/utils.go

@@ -1,5 +1,7 @@
 package frameworks
 
+import "strings"
+
 type RestResourceData struct {
 	SmallKebabCaseResourceNameSingular string
 	SmallSnakeCaseResourceNameSingular string
@@ -47,3 +49,8 @@ func AddRESTAllowedMethods(restResourceData *RestResourceData, restAllowedMethod
 		}
 	}
 }
+
+func GetMicroServiceName(name string) string {
+	splitted := strings.Split(name, "/")
+	return splitted[len(splitted)-1]
+}

internal/languages/dotnet/generator.go

@@ -8,6 +8,8 @@ import (
 	corenode "github.com/intelops/compage/internal/core/node"
 	"github.com/intelops/compage/internal/languages"
 	"github.com/intelops/compage/internal/languages/dotnet/frameworks/dotnet-clean-architecture"
+	"github.com/intelops/compage/internal/languages/dotnet/integrations/docker"
+	"github.com/intelops/compage/internal/languages/dotnet/integrations/kubernetes"
 	"github.com/intelops/compage/internal/languages/templates"
 	log "github.com/sirupsen/logrus"
 	"strings"
@@ -24,6 +26,13 @@ func Generate(ctx context.Context) error {
 		return err
 	}
 
+	// integrations config
+	err = generateIntegrationConfig(&goValues)
+	if err != nil {
+		log.Errorf("err : %s", err)
+		return err
+	}
+
 	return nil
 }
 
@@ -63,8 +72,8 @@ func getDotNetCleanArchitectureCopier(dotNetValues *DotNetValues) (*dotnetcleana
 	gitPlatformURL := dotNetValues.Values.Get(languages.GitPlatformURL)
 	gitPlatformUserName := dotNetValues.Values.Get(languages.GitPlatformUserName)
 	gitRepositoryName := dotNetValues.Values.Get(languages.GitRepositoryName)
-	nodeName := dotNetValues.Values.Get(languages.NodeName)
 	// dotnet nodes usually have a directory name same as node name itself but in caps.
+	nodeName := dotNetValues.Values.Get(languages.NodeName)
 	nodeDirectoryName := strings.Replace(dotNetValues.Values.NodeDirectoryName, nodeName, strcase.ToCamel(nodeName), 1)
 	isRestServer := dotNetValues.LDotNetLangNode.RestConfig != nil && dotNetValues.LDotNetLangNode.RestConfig.Server != nil
 	var restServerPort string
@@ -95,3 +104,58 @@ func getDotNetCleanArchitectureCopier(dotNetValues *DotNetValues) (*dotnetcleana
 
 	return copier, nil
 }
+
+func generateIntegrationConfig(dotNetValues *DotNetValues) error {
+	m, err := getIntegrationsCopier(dotNetValues)
+	if err != nil {
+		log.Errorf("error while getting the integrations copier [" + err.Error() + "]")
+		return err
+	}
+	// dockerfile needs to be generated for the whole project, so it should be here.
+	dockerCopier := m["docker"].(*docker.Copier)
+	if err = dockerCopier.CreateDockerFile(); err != nil {
+		log.Errorf("err : %s", err)
+		return err
+	}
+
+	// k8s files need to be generated for the whole project, so it should be here.
+	k8sCopier := m["k8s"].(*kubernetes.Copier)
+	if err = k8sCopier.CreateKubernetesFiles(); err != nil {
+		log.Errorf("err : %s", err)
+		return err
+	}
+
+	return nil
+}
+
+func getIntegrationsCopier(dotNetValues *DotNetValues) (map[string]interface{}, error) {
+	dotNetTemplatesRootPath := GetDotNetTemplatesRootPath()
+	if dotNetTemplatesRootPath == "" {
+		return nil, errors.New("dotnet templates root path is empty")
+	}
+
+	gitPlatformUserName := dotNetValues.Values.Get(languages.GitPlatformUserName)
+	gitRepositoryName := dotNetValues.Values.Get(languages.GitRepositoryName)
+	nodeName := dotNetValues.Values.Get(languages.NodeName)
+	// dotnet nodes usually have a directory name same as node name itself but in caps.
+	nodeDirectoryName := strings.Replace(dotNetValues.Values.NodeDirectoryName, nodeName, strcase.ToCamel(nodeName), 1)
+	// rest
+	isRestServer := dotNetValues.LDotNetLangNode.RestConfig != nil && dotNetValues.LDotNetLangNode.RestConfig.Server != nil
+	var restServerPort string
+	if isRestServer {
+		restServerPort = dotNetValues.LDotNetLangNode.RestConfig.Server.Port
+	} else {
+		restServerPort = ""
+	}
+
+	// create dotnet specific dockerCopier
+	dockerCopier := docker.NewCopier(gitPlatformUserName, gitRepositoryName, nodeName, nodeDirectoryName, dotNetTemplatesRootPath, isRestServer, restServerPort)
+
+	// create dotnet specific k8sCopier
+	k8sCopier := kubernetes.NewCopier(gitPlatformUserName, gitRepositoryName, nodeName, nodeDirectoryName, dotNetTemplatesRootPath, isRestServer, restServerPort)
+
+	return map[string]interface{}{
+		"docker": dockerCopier,
+		"k8s":    k8sCopier,
+	}, nil
+}

internal/languages/dotnet/integrations/docker/copier.go

@@ -0,0 +1,57 @@
+package docker
+
+import (
+	"github.com/intelops/compage/internal/languages/dotnet/frameworks"
+	"github.com/intelops/compage/internal/languages/executor"
+	"github.com/intelops/compage/internal/utils"
+	log "github.com/sirupsen/logrus"
+	"strings"
+)
+
+const File = "Dockerfile.tmpl"
+
+// Copier integrations specific copier
+type Copier struct {
+	NodeDirectoryName string
+	TemplatesRootPath string
+	Data              map[string]interface{}
+	IsRestServer      bool
+	RestServerPort    string
+}
+
+func NewCopier(gitPlatformUserName, gitRepositoryName, nodeName, nodeDirectoryName, templatesRootPath string, isRestServer bool, restServerPort string) *Copier {
+	// populate map to replace templates
+	data := map[string]interface{}{
+		"GitRepositoryName":   gitRepositoryName,
+		"NodeName":            strings.ToLower(nodeName),
+		"MicroServiceName":    frameworks.GetMicroServiceName(nodeDirectoryName),
+		"GitPlatformUserName": gitPlatformUserName,
+	}
+
+	if isRestServer {
+		data["RestServerPort"] = restServerPort
+	}
+	data["IsRestServer"] = isRestServer
+
+	return &Copier{
+		TemplatesRootPath: templatesRootPath,
+		NodeDirectoryName: nodeDirectoryName,
+		IsRestServer:      isRestServer,
+		RestServerPort:    restServerPort,
+		Data:              data,
+	}
+}
+
+// CreateDockerFile creates the required file from language template.
+func (c Copier) CreateDockerFile() error {
+	var filePaths []*string
+	// copy dockerfile
+	targetDockerFileName := c.NodeDirectoryName + "/" + File
+	_, err := utils.CopyFile(targetDockerFileName, c.TemplatesRootPath+"/"+File)
+	if err != nil {
+		log.Errorf("error while copying dockerfile [" + err.Error() + "]")
+		return err
+	}
+	filePaths = append(filePaths, &targetDockerFileName)
+	return executor.Execute(filePaths, c.Data)
+}

internal/languages/dotnet/integrations/kubernetes/copier.go

@@ -0,0 +1,74 @@
+package kubernetes
+
+import (
+	"github.com/intelops/compage/internal/languages/dotnet/frameworks"
+	"github.com/intelops/compage/internal/languages/executor"
+	"github.com/intelops/compage/internal/utils"
+	log "github.com/sirupsen/logrus"
+	"strings"
+)
+
+const Path = "/kubernetes"
+const DeploymentFile = "deployment.yaml.tmpl"
+const ServiceFile = "service.yaml.tmpl"
+
+// Copier integrations specific copier
+type Copier struct {
+	NodeDirectoryName string
+	TemplatesRootPath string
+	Data              map[string]interface{}
+	IsRestServer      bool
+	RestServerPort    string
+}
+
+func NewCopier(gitPlatformUserName, gitRepositoryName, nodeName, nodeDirectoryName, templatesRootPath string, isRestServer bool, restServerPort string) *Copier {
+	// populate map to replace templates
+	data := map[string]interface{}{
+		"GitRepositoryName":   gitRepositoryName,
+		"NodeName":            strings.ToLower(nodeName),
+		"MicroServiceName":    frameworks.GetMicroServiceName(nodeDirectoryName),
+		"GitPlatformUserName": gitPlatformUserName,
+	}
+
+	if isRestServer {
+		data["RestServerPort"] = restServerPort
+	}
+	data["IsRestServer"] = isRestServer
+
+	return &Copier{
+		TemplatesRootPath: templatesRootPath,
+		NodeDirectoryName: nodeDirectoryName,
+		IsRestServer:      isRestServer,
+		RestServerPort:    restServerPort,
+		Data:              data,
+	}
+}
+
+// CreateKubernetesFiles creates required directory and copies files from language template.
+func (c Copier) CreateKubernetesFiles() error {
+	destKubernetesDirectory := c.NodeDirectoryName + Path
+	if err := utils.CreateDirectories(destKubernetesDirectory); err != nil {
+		log.Errorf("error creating directory %s", destKubernetesDirectory)
+		return err
+	}
+	var filePaths []*string
+	if c.IsRestServer {
+		// copy service files to the generated kubernetes manifests
+		targetKubernetesServiceFileName := c.NodeDirectoryName + Path + "/" + ServiceFile
+		_, err := utils.CopyFile(targetKubernetesServiceFileName, c.TemplatesRootPath+Path+"/"+ServiceFile)
+		if err != nil {
+			log.Errorf("error copying file %s", targetKubernetesServiceFileName)
+			return err
+		}
+		filePaths = append(filePaths, &targetKubernetesServiceFileName)
+	}
+	// copy deployment files to the generated kubernetes manifests
+	targetKubernetesDeploymentFileName := c.NodeDirectoryName + Path + "/" + DeploymentFile
+	_, err := utils.CopyFile(targetKubernetesDeploymentFileName, c.TemplatesRootPath+Path+"/"+DeploymentFile)
+	if err != nil {
+		log.Errorf("error copying file %s", targetKubernetesDeploymentFileName)
+		return err
+	}
+	filePaths = append(filePaths, &targetKubernetesDeploymentFileName)
+	return executor.Execute(filePaths, c.Data)
+}