Compare commits

..

No commits in common. "c1134f7403bd8258f754a7d9bfec0597dbf69eee" and "c7f8503fb62d460f311152fd8c89cf0999e83757" have entirely different histories.

11 changed files with 93 additions and 147 deletions

View File

@ -12,10 +12,8 @@ type ChartData struct {
Version string `yaml:"version"` Version string `yaml:"version"`
Opts string `yaml:"helm_opts"` Opts string `yaml:"helm_opts"`
Values map[string]string `yaml:"helm_values"` Values string `yaml:"helm_values"`
FileValues []string `yaml:"helm_filevalues"` FileValues string `yaml:"helm_filevalues"`
Overwrite string `yaml:"helm_overwrite"`
} }
type repoData struct { type repoData struct {
@ -35,7 +33,6 @@ type chartsRepoData struct {
func FromConfigFile(filename string) ([]ChartRepoData, error) { func FromConfigFile(filename string) ([]ChartRepoData, error) {
yamlFile, _ := os.ReadFile(filename) yamlFile, _ := os.ReadFile(filename)
var data chartsRepoData var data chartsRepoData
err := yaml.Unmarshal(yamlFile, &data) err := yaml.Unmarshal(yamlFile, &data)
if err != nil { if err != nil {

View File

@ -1,5 +1,7 @@
package chart package chart
// https://pkg.go.dev/github.com/stretchr/testify/assert
import ( import (
"testing" "testing"
"path/filepath" "path/filepath"
@ -7,7 +9,7 @@ import (
) )
func _TestReadConfChart(t *testing.T) { func TestReadConfChart(t *testing.T){
src := filepath.Join(TEST_SRC_DIR, "oc.yml") src := filepath.Join(TEST_SRC_DIR, "oc.yml")
assert.FileExists(t, src, "FromConfigFile error") assert.FileExists(t, src, "FromConfigFile error")
@ -20,15 +22,11 @@ func _TestReadConfChart(t *testing.T) {
assert.Equal(t, "wordpress", wordpress.Name, "FromConfigFile error") assert.Equal(t, "wordpress", wordpress.Name, "FromConfigFile error")
assert.Equal(t, "bitnami/wordpress", wordpress.Chart, "FromConfigFile error") assert.Equal(t, "bitnami/wordpress", wordpress.Chart, "FromConfigFile error")
assert.Equal(t, "23.1.0", wordpress.Version, "FromConfigFile error") assert.Equal(t, "23.1.0", wordpress.Version, "FromConfigFile error")
assert.Equal(t, 0, len(wordpress.FileValues), "FromConfigFile error")
assert.Equal(t, 0, len(wordpress.Values), "FromConfigFile error")
phpmyadmin := data[0].Charts[1] phpmyadmin := data[0].Charts[1]
assert.Equal(t, "phpmyadmin", phpmyadmin.Name, "FromConfigFile error") assert.Equal(t, "phpmyadmin", phpmyadmin.Name, "FromConfigFile error")
assert.Equal(t, "bitnami/phpmyadmin", phpmyadmin.Chart,"FromConfigFile error") assert.Equal(t, "bitnami/phpmyadmin", phpmyadmin.Chart,"FromConfigFile error")
assert.Equal(t, "17.0.4", phpmyadmin.Version, "FromConfigFile error") assert.Equal(t, "17.0.4", phpmyadmin.Version, "FromConfigFile error")
assert.Equal(t, 2, len(phpmyadmin.FileValues), "FromConfigFile error")
assert.Equal(t, 1, len(phpmyadmin.Values), "FromConfigFile error")
data1 := data[1] data1 := data[1]
assert.Equal(t, "", data1.Repository.Name, "FromConfigFile error") assert.Equal(t, "", data1.Repository.Name, "FromConfigFile error")
@ -37,14 +35,5 @@ func _TestReadConfChart(t *testing.T) {
myfirstrelease := data1.Charts[0] myfirstrelease := data1.Charts[0]
assert.Equal(t, "myfirstrelease", myfirstrelease.Name, "FromConfigFile error") assert.Equal(t, "myfirstrelease", myfirstrelease.Name, "FromConfigFile error")
assert.Equal(t, "https://zzzz/myfirstchart-0.1.0.tgz", myfirstrelease.Url, "FromConfigFile error") assert.Equal(t, "https://zzzz/myfirstchart-0.1.0.tgz", myfirstrelease.Url, "FromConfigFile error")
} }
func TestReadConfChartOverwrite(t *testing.T){
src := filepath.Join(TEST_SRC_DIR, "oc_overwrite.yml")
assert.FileExists(t, src, "FromConfigFile error")
data, _ := FromConfigFile(src)
// Nombre de lettres
assert.Equal(t, 70, len(data[0].Charts[0].Overwrite), "TestReadConfChartOverwrite error")
}

View File

@ -1,23 +1,28 @@
package cmd package cmd
import ( import (
"fmt"
log "oc-deploy/log_wrapper" log "oc-deploy/log_wrapper"
// "oc-deploy/versionOc" "oc-deploy/versionOc"
"oc-deploy/install" "oc-deploy/generate"
) )
func GenerateCmd(prcontextoject string, version string) error { func GenerateCmd(project string, version string) error {
log.Log().Info().Msg("Generate >> ") log.Log().Info().Msg("Generate >> ")
workspace := fmt.Sprintf("workspace_%s", context) version, err := versionOc.GetFromFile(version)
if err != nil {
log.Log().Fatal().Msg("OpenCloud >> " + err.Error())
}
log.Log().Info().Msg(" >> Version : " + version)
obj := install.InstallClass{Workspace: workspace, Version: version} obj := generate.GenerateClass{Workspace: "workspace_" + project, Version: version}
_, err := obj.NewGenerate() fic, err := obj.New()
if err != nil { if err != nil {
log.Log().Fatal().Msg(" >> " + err.Error()) log.Log().Fatal().Msg(" >> " + err.Error())
} }
log.Log().Info().Msg(" >> Value : " + fic)
return err return err
} }

22
src/generate/generate.go Normal file
View File

@ -0,0 +1,22 @@
package generate
import (
"fmt"
"oc-deploy/utils"
)
type GenerateClass struct {
Version string
Workspace string
}
func (this GenerateClass) New() (string, error) {
src := fmt.Sprintf("../offline/default_value_%s.yml", this.Version)
dst := fmt.Sprintf("%s/default_value.yml", this.Workspace)
err := utils.CopyFile(src, dst)
if err != nil {
return "", err
}
return src, nil
}

View File

@ -20,8 +20,8 @@ type HelmChart struct {
Workspace string Workspace string
Opts string Opts string
Values map[string]string Values string
FileValues []string FileValues string
} }
type installInfoOutput struct { type installInfoOutput struct {
@ -66,19 +66,8 @@ func (this HelmCommand) ChartInstall(data HelmChart) (string, error) {
msg = fmt.Sprintf("%s --version %s", msg, data.Version) msg = fmt.Sprintf("%s --version %s", msg, data.Version)
} }
for key, value := range data.Values { if data.FileValues != "" {
msg = fmt.Sprintf("%s --set %s=%s", msg, key, value) fic := filepath.Join(data.Workspace, data.FileValues)
}
ficoverwrite := filepath.Join(data.Workspace, fmt.Sprintf("value-%s.yml", data.Name))
if _, err := os.Stat(ficoverwrite); err != nil {
log.Log().Warn().Msg(ficoverwrite)
} else {
msg = fmt.Sprintf("%s --values %s", msg, ficoverwrite)
}
for _, valuefilename := range data.FileValues {
fic := filepath.Join(data.Workspace, valuefilename)
if _, err := os.Stat(fic); err != nil { if _, err := os.Stat(fic); err != nil {
log.Log().Warn().Msg(fic) log.Log().Warn().Msg(fic)
} else { } else {

View File

@ -2,30 +2,14 @@ package install
import ( import (
"fmt" "fmt"
"os"
"errors" "errors"
log "oc-deploy/log_wrapper" log "oc-deploy/log_wrapper"
"oc-deploy/tool" "oc-deploy/tool"
"oc-deploy/chart"
"oc-deploy/kubectl" "oc-deploy/kubectl"
"oc-deploy/helm" "oc-deploy/helm"
"oc-deploy/versionOc"
"oc-deploy/utils"
) )
type InstallClass struct {
Version string
Workspace string
tools []tool.ToolData
toolsBin map[string]string
charts []chart.ChartRepoData
commandHelm helm.HelmCommand
commandKubectl kubectl.KubectlCommand
}
func (this *InstallClass) Tools() (error) { func (this *InstallClass) Tools() (error) {
var mem []tool.ToolClass var mem []tool.ToolClass
@ -118,32 +102,3 @@ func (this *InstallClass) K8s(context string) (error) {
return nil return nil
} }
func (this *InstallClass) extractVersion() (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.GetFromOnline(this.Version)
if err != nil {
return "", err
}
this.Version = version
err = utils.CopyContentFile(fileversion, dst)
if err != nil {
return "", err
}
}
return dst, nil
}

View File

@ -1,36 +0,0 @@
package install
import (
"fmt"
"path/filepath"
log "oc-deploy/log_wrapper"
"oc-deploy/utils"
"oc-deploy/chart"
)
func (this *InstallClass) NewGenerate() (string, error) {
// Extraction du fichier de la version
dst, err := this.extractVersion()
if err != nil {
return "", err
}
this.charts, _ = chart.FromConfigFile(dst)
if err != nil {
return dst, err
}
for _, ele1 := range this.charts {
for _, ele2 := range ele1.Charts {
filename := filepath.Join(this.Workspace, fmt.Sprintf("values-%s.yml", ele2.Name) )
utils.CopyContentFile(ele2.Overwrite, filename)
log.Log().Info().Msg(fmt.Sprintf(">> %s : %s", ele2.Name, filename))
}
}
return dst, nil
}

View File

@ -3,6 +3,7 @@ package install
import ( import (
"fmt" "fmt"
"sync" "sync"
"os"
log "oc-deploy/log_wrapper" log "oc-deploy/log_wrapper"
"oc-deploy/utils" "oc-deploy/utils"
@ -10,17 +11,50 @@ import (
"oc-deploy/chart" "oc-deploy/chart"
"oc-deploy/helm" "oc-deploy/helm"
"oc-deploy/kubectl" "oc-deploy/kubectl"
"oc-deploy/versionOc"
) )
type InstallClass struct {
Version string
Workspace string
tools []tool.ToolData
toolsBin map[string]string
charts []chart.ChartRepoData
commandHelm helm.HelmCommand
commandKubectl kubectl.KubectlCommand
}
func (this *InstallClass) NewInstall() (string, error) { func (this *InstallClass) NewInstall() (string, error) {
// Extraction du fichier de la version // Extraction du fichier de version
dst, err := this.extractVersion() dst := fmt.Sprintf("%s/oc.yml", this.Workspace)
if err != nil { log.Log().Debug().Msg(fmt.Sprintf("Check du fichier de version : %s", dst))
return "", err 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 // Lecture du fichier de conf
var err error
this.tools, err = tool.FromConfigFile(dst) this.tools, err = tool.FromConfigFile(dst)
if err != nil { if err != nil {
return dst, err return dst, err
@ -30,6 +64,9 @@ func (this *InstallClass) NewInstall() (string, error) {
return dst, err return dst, err
} }
bin_path, _ := this.getToolBin("helm")
fmt.Println("Install 67 bin_path", bin_path)
return dst, nil return dst, nil
} }
@ -55,6 +92,8 @@ func (this *InstallClass) ChartRepo() (error) {
func (this *InstallClass) InstallCharts(modules []string) (error) { func (this *InstallClass) InstallCharts(modules []string) (error) {
// helm_bin, _ := this.getToolBin("helm")
// kubectl_bin, _ := this.getToolBin("kubectl")
var wg sync.WaitGroup var wg sync.WaitGroup
@ -87,6 +126,7 @@ func (this *InstallClass) installChart(chart chart.ChartData) {
Values: chart.Values, Values: chart.Values,
FileValues: chart.FileValues} FileValues: chart.FileValues}
res, err := this.commandHelm.ChartInstall(data) res, err := this.commandHelm.ChartInstall(data)
if err != nil { if err != nil {
log.Log().Error().Msg(fmt.Sprintf(" >> %s %s (%s)", data.Name, "KO", err)) log.Log().Error().Msg(fmt.Sprintf(" >> %s %s (%s)", data.Name, "KO", err))

View File

@ -3,6 +3,7 @@ package versionOc
import ( import (
"fmt" "fmt"
"testing" "testing"
// "encoding/base64"
"oc-deploy/occonst" "oc-deploy/occonst"
@ -56,5 +57,6 @@ func TestGetOnlineLatest(t *testing.T) {
version, _, err := GetFromOnline("latest") version, _, err := GetFromOnline("latest")
assert.Nilf(t, err, "error message %s", err) assert.Nilf(t, err, "error message %s", err)
assert.Equal(t, "99.0", version, "TestGetFromFile error") assert.Equal(t, "99.0", version, "TestGetFromFile error")
fmt.Println("TestGetOnlineLatest ", version, err)
} }

View File

@ -8,16 +8,12 @@ opencloud:
- name: wordpress - name: wordpress
chart: bitnami/wordpress chart: bitnami/wordpress
version: 23.1.0 version: 23.1.0
helm_values: [] values: {}
- name: phpmyadmin - name: phpmyadmin
chart: bitnami/phpmyadmin chart: bitnami/phpmyadmin
version: 17.0.4 version: 17.0.4
helm_values: values: {}
VAR1: aaa
helm_filevalues:
- values-global.yml
- values-phpmyadmin.yml
- charts: - charts:
- name: myfirstrelease - name: myfirstrelease

View File

@ -1,13 +0,0 @@
---
opencloud:
- charts:
- name: mongo
chart: bitnami/wordpress
version: 23.1.0
helm_overwrite: |
---
# Texte Mot de passe
# mongo:
# name: <user>
# password: <_mdp>