154 lines
4.3 KiB
Go
154 lines
4.3 KiB
Go
package install
|
|
|
|
import (
|
|
"fmt"
|
|
"sync"
|
|
"os"
|
|
|
|
log "oc-deploy/log_wrapper"
|
|
"oc-deploy/utils"
|
|
"oc-deploy/tool"
|
|
"oc-deploy/chart"
|
|
"oc-deploy/helm"
|
|
"oc-deploy/kubectl"
|
|
"oc-deploy/versionOc"
|
|
)
|
|
|
|
type InstallClass struct {
|
|
Version string
|
|
Workspace string
|
|
|
|
tools []tool.ToolData
|
|
toolsBin map[string]string
|
|
charts []chart.ChartRepoData
|
|
}
|
|
|
|
func (this *InstallClass) NewInstall() (string, error) {
|
|
|
|
// Extraction du fichier de version
|
|
dst := fmt.Sprintf("%s/oc.yml", this.Workspace)
|
|
log.Log().Debug().Msg(fmt.Sprintf("Check du fichier de version : %s", dst))
|
|
if _, err := os.Stat(dst); err == nil {
|
|
log.Log().Debug().Msg("Existe déjà")
|
|
version, err := versionOc.GetFromFile(dst)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
this.Version = version
|
|
} else {
|
|
log.Log().Debug().Msg("Téléchargement du fichier de version")
|
|
// version, fileversion, err := versionOc.Get(this.Version)
|
|
version, fileversion, err := versionOc.GetFromOnline(this.Version)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
this.Version = version
|
|
|
|
err = utils.CopyContentFile(fileversion, dst)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
}
|
|
|
|
// Lecture du fichier de conf
|
|
var err error
|
|
this.tools, err = tool.FromConfigFile(dst)
|
|
if err != nil {
|
|
return dst, err
|
|
}
|
|
this.charts, _ = chart.FromConfigFile(dst)
|
|
if err != nil {
|
|
return dst, err
|
|
}
|
|
|
|
return dst, nil
|
|
}
|
|
|
|
|
|
func (this *InstallClass) ChartRepo() (error) {
|
|
|
|
bin_path, _ := this.getToolBin("helm")
|
|
|
|
for _, v := range this.charts {
|
|
if v.Repository.Name != "" {
|
|
log.Log().Info().Msg(fmt.Sprintf(" >> Helm Repo : %s", v.Repository.Name))
|
|
repo := helm.HelmRepo{Bin: bin_path,
|
|
Name: v.Repository.Name,
|
|
Repository: v.Repository.Url,
|
|
ForceUpdate: v.Repository.ForceUpdate}
|
|
res, err := repo.AddRepository()
|
|
if err != nil {
|
|
log.Log().Info().Msg(fmt.Sprintf(" << %s ", err))
|
|
return err
|
|
}
|
|
log.Log().Info().Msg(fmt.Sprintf(" << %s ", res))
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
|
|
func (this *InstallClass) InstallCharts(modules []string) (error) {
|
|
helm_bin, _ := this.getToolBin("helm")
|
|
kubectl_bin, _ := this.getToolBin("kubectl")
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
for _, v := range this.charts {
|
|
for _, v1 := range v.Charts {
|
|
if len(modules) == 0 || stringInSlice(v1.Name, modules) {
|
|
wg.Add(1)
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
this.installChart(helm_bin, kubectl_bin, v1)
|
|
} ()
|
|
}
|
|
}
|
|
}
|
|
wg.Wait()
|
|
return nil
|
|
}
|
|
|
|
func stringInSlice(a string, list []string) bool {
|
|
for _, b := range list {
|
|
if b == a {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
|
|
func (this *InstallClass) installChart(helm_bin string, kubectl_bin string, chart chart.ChartData) {
|
|
|
|
log.Log().Info().Msg(fmt.Sprintf(" << Chart : %s ", chart.Name))
|
|
|
|
helmchart := helm.HelmChart{Bin: helm_bin,
|
|
Name: chart.Name,
|
|
Chart: chart.Chart,
|
|
Url: chart.Url,
|
|
Version: chart.Version,
|
|
Workspace: this.Workspace,
|
|
Opts: chart.Opts,
|
|
Values: chart.Values,
|
|
FileValues: chart.FileValues}
|
|
|
|
obj := kubectl.KubeObject{Bin: kubectl_bin,
|
|
Name: chart.Name}
|
|
|
|
res, err := helmchart.Install()
|
|
if err != nil {
|
|
log.Log().Error().Msg(fmt.Sprintf(" >> %s %s (%s)", helmchart.Name, "KO", err))
|
|
return
|
|
}
|
|
log.Log().Info().Msg(fmt.Sprintf(" >> %s (%s)", helmchart.Name, res))
|
|
|
|
err = obj.Wait()
|
|
if err != nil {
|
|
log.Log().Error().Msg(fmt.Sprintf(" >> %s %s (%s)", chart.Name, "KO", err))
|
|
} else {
|
|
log.Log().Info().Msg(fmt.Sprintf(" >> %s %s", chart.Name, "OK"))
|
|
}
|
|
}
|