installer: env uses repoio
diff --git a/core/installer/cmd/env.go b/core/installer/cmd/env.go
index 4b258b1..798b89f 100644
--- a/core/installer/cmd/env.go
+++ b/core/installer/cmd/env.go
@@ -4,22 +4,17 @@
package main
import (
- "bytes"
"embed"
"encoding/base64"
"fmt"
- "io"
"log"
"os"
"path"
"text/template"
- "golang.org/x/exp/slices"
-
"github.com/giolekva/pcloud/core/installer"
"github.com/giolekva/pcloud/core/installer/soft"
"github.com/spf13/cobra"
- "sigs.k8s.io/yaml"
)
//go:embed env-tmpl
@@ -27,6 +22,8 @@
var createEnvFlags struct {
name string
+ ip string
+ port int
adminPrivKey string
}
@@ -42,6 +39,18 @@
"",
)
cmd.Flags().StringVar(
+ &createEnvFlags.ip,
+ "ip",
+ "",
+ "",
+ )
+ cmd.Flags().IntVar(
+ &createEnvFlags.port,
+ "ip",
+ 22,
+ "",
+ )
+ cmd.Flags().StringVar(
&createEnvFlags.adminPrivKey,
"admin-priv-key",
"",
@@ -55,7 +64,7 @@
if err != nil {
return err
}
- ss, err := soft.NewClient("192.168.0.211", 22, adminPrivKey, log.Default())
+ ss, err := soft.NewClient(createEnvFlags.ip, createEnvFlags.port, adminPrivKey, log.Default())
if err != nil {
return err
}
@@ -82,69 +91,42 @@
if err := ss.AddCollaborator(createEnvFlags.name, fluxUserName); err != nil {
return err
}
- repo, err := ss.CloneRepository("pcloud")
+ repo, err := ss.GetRepo("pcloud")
if err != nil {
return err
}
- wt, err := repo.Worktree()
+ repoIO := installer.NewRepoIO(repo, ss.Signer)
+ kust, err := repoIO.ReadKustomization("environments/kustomization.yaml")
if err != nil {
return err
}
- envKust := "environments/kustomization.yaml"
- envKustFile, err := wt.Filesystem.Open(envKust)
- if err != nil {
- return err
- }
- kust, err := installer.ReadKustomization(envKustFile)
- if err != nil {
- return err
- }
- if slices.Contains(kust.Resources, createEnvFlags.name) {
- return fmt.Errorf("Environment already exists: %s", createEnvFlags.name)
- }
+ kust.AddResources(createEnvFlags.name)
tmpls, err := template.ParseFS(filesTmpls, "env-tmpl/*.yaml")
if err != nil {
return err
}
for _, tmpl := range tmpls.Templates() {
dstPath := path.Join("environments", createEnvFlags.name, tmpl.Name())
- fmt.Println(dstPath)
- dst, err := wt.Filesystem.Create(dstPath)
+ dst, err := repoIO.Writer(dstPath)
if err != nil {
return err
}
+ defer dst.Close()
if err := tmpl.Execute(dst, map[string]string{
"Name": createEnvFlags.name,
"PrivateKey": base64.StdEncoding.EncodeToString([]byte(priv)),
"PublicKey": base64.StdEncoding.EncodeToString([]byte(pub)),
- "GitHost": "192.168.0.211",
- "KnownHosts": base64.StdEncoding.EncodeToString([]byte(fmt.Sprintf("192.168.0.211 %s", ssPubKey))),
+ "GitHost": createEnvFlags.ip,
+ "KnownHosts": base64.StdEncoding.EncodeToString([]byte(fmt.Sprintf("%s %s", createEnvFlags.ip, ssPubKey))),
}); err != nil {
return err
}
- if _, err := wt.Add(dstPath); err != nil {
- return err
- }
}
kust.AddResources(createEnvFlags.name)
- ff, err := wt.Filesystem.Create(envKust)
- if err != nil {
+ if err := repoIO.WriteKustomization("environments/kustomization.yaml", *kust); err != nil {
return err
}
- contents, err := yaml.Marshal(kust)
- if err != nil {
- return err
- }
- if _, err := io.Copy(ff, bytes.NewReader(contents)); err != nil {
- return err
- }
- if _, err := wt.Add(envKust); err != nil {
- return err
- }
- if err := ss.Commit(wt, fmt.Sprintf("%s: new environment", createEnvFlags.name)); err != nil {
- return err
- }
- if err := ss.Push(repo); err != nil {
+ if err := repoIO.CommitAndPush(fmt.Sprintf("%s: initialize environment", createEnvFlags.name)); err != nil {
return err
}
return nil