| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 1 | package installer |
| 2 | |
| 3 | import ( |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 4 | "fmt" |
| Giorgi Lekveishvili | 03ee585 | 2023-05-30 13:20:10 +0400 | [diff] [blame] | 5 | "io/ioutil" |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 6 | |
| Giorgi Lekveishvili | 7efe22f | 2023-05-30 13:01:53 +0400 | [diff] [blame] | 7 | "sigs.k8s.io/yaml" |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 8 | ) |
| 9 | |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 10 | const appDirName = "apps" |
| 11 | const configFileName = "config.yaml" |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 12 | const kustomizationFileName = "kustomization.yaml" |
| 13 | |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 14 | type AppManager struct { |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 15 | repoIO RepoIO |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 16 | } |
| 17 | |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 18 | func NewAppManager(repoIO RepoIO) (*AppManager, error) { |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 19 | return &AppManager{ |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 20 | repoIO, |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 21 | }, nil |
| 22 | } |
| 23 | |
| Giorgi Lekveishvili | 7efe22f | 2023-05-30 13:01:53 +0400 | [diff] [blame] | 24 | func (m *AppManager) Config() (Config, error) { |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 25 | configF, err := m.repoIO.Reader(configFileName) |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 26 | if err != nil { |
| Giorgi Lekveishvili | 7efe22f | 2023-05-30 13:01:53 +0400 | [diff] [blame] | 27 | return Config{}, err |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 28 | } |
| 29 | defer configF.Close() |
| 30 | config, err := ReadConfig(configF) |
| 31 | if err != nil { |
| Giorgi Lekveishvili | 7efe22f | 2023-05-30 13:01:53 +0400 | [diff] [blame] | 32 | return Config{}, err |
| 33 | } |
| 34 | return config, nil |
| 35 | } |
| 36 | |
| Giorgi Lekveishvili | 03ee585 | 2023-05-30 13:20:10 +0400 | [diff] [blame] | 37 | func (m *AppManager) AppConfig(name string) (map[string]any, error) { |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 38 | configF, err := m.repoIO.Reader(fmt.Sprintf("%s/%s/%s", appDirName, name, configFileName)) |
| Giorgi Lekveishvili | 03ee585 | 2023-05-30 13:20:10 +0400 | [diff] [blame] | 39 | if err != nil { |
| 40 | return nil, err |
| 41 | } |
| 42 | defer configF.Close() |
| 43 | var cfg map[string]any |
| 44 | contents, err := ioutil.ReadAll(configF) |
| 45 | if err != nil { |
| 46 | return cfg, err |
| 47 | } |
| 48 | err = yaml.UnmarshalStrict(contents, &cfg) |
| 49 | return cfg, err |
| 50 | } |
| 51 | |
| Giorgi Lekveishvili | 7efe22f | 2023-05-30 13:01:53 +0400 | [diff] [blame] | 52 | func (m *AppManager) Install(app App, config map[string]any) error { |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 53 | // if err := m.repoIO.Fetch(); err != nil { |
| 54 | // return err |
| 55 | // } |
| Giorgi Lekveishvili | 7efe22f | 2023-05-30 13:01:53 +0400 | [diff] [blame] | 56 | globalConfig, err := m.Config() |
| 57 | if err != nil { |
| 58 | return err |
| 59 | } |
| 60 | all := map[string]any{ |
| 61 | "Global": globalConfig.Values, |
| 62 | "Values": config, |
| 63 | } |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 64 | return m.repoIO.InstallApp(app, "apps", all) |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 65 | } |