core/installer/cmd/env_manager.go

package main

import (
	"log"
	"net/netip"
	"os"

	"github.com/spf13/cobra"

	"github.com/giolekva/pcloud/core/installer"
	"github.com/giolekva/pcloud/core/installer/soft"
	"github.com/giolekva/pcloud/core/installer/welcome"
)

var envManagerFlags struct {
	repoAddr string
	repoName string
	sshKey   string
	port     int
}

func envManagerCmd() *cobra.Command {
	cmd := &cobra.Command{
		Use:  "envmanager",
		RunE: envManagerCmdRun,
	}
	cmd.Flags().StringVar(
		&envManagerFlags.repoAddr,
		"repo-addr",
		"",
		"",
	)
	cmd.Flags().StringVar(
		&envManagerFlags.repoName,
		"repo-name",
		"",
		"",
	)
	cmd.Flags().StringVar(
		&envManagerFlags.sshKey,
		"ssh-key",
		"",
		"",
	)
	cmd.Flags().IntVar(
		&envManagerFlags.port,
		"port",
		8080,
		"",
	)
	return cmd
}

func envManagerCmdRun(cmd *cobra.Command, args []string) error {
	sshKey, err := os.ReadFile(envManagerFlags.sshKey)
	if err != nil {
		return err
	}
	repoAddr, err := netip.ParseAddrPort(envManagerFlags.repoAddr)
	if err != nil {
		return err
	}
	ss, err := soft.NewClient(repoAddr, sshKey, log.Default())
	if err != nil {
		return err
	}
	repo, err := ss.GetRepo(envManagerFlags.repoName)
	if err != nil {
		return err
	}
	repoIO := installer.NewRepoIO(repo, ss.Signer)
	nsCreator, err := newNSCreator()
	if err != nil {
		return err
	}
	s := welcome.NewEnvServer(
		envManagerFlags.port,
		ss,
		repoIO,
		nsCreator,
	)
	s.Start()
	return nil
}