Skip to content

Commit a668683

Browse files
committed
Refactor export saving tmuxp config as private method
1 parent a66b54d commit a668683

File tree

1 file changed

+20
-15
lines changed

1 file changed

+20
-15
lines changed

pkg/kubetmuxp/kubetmuxp.go

Lines changed: 20 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,25 @@ func (c *Config) load(cfgFile string) error {
8585
return nil
8686
}
8787

88+
func (c *Config) saveTmuxpConfig(kubeCfgFile string, cluster Cluster) error {
89+
windows := tmuxp.Windows{{Name: "default"}}
90+
env := tmuxp.Environment{"KUBECONFIG": kubeCfgFile}
91+
for k, v := range cluster.Envs {
92+
env[k] = v
93+
}
94+
95+
tmuxpCfg, err := tmuxp.NewConfig(cluster.Context, windows, env, c.filesystem)
96+
if err != nil {
97+
return err
98+
}
99+
100+
tmuxpCfgFile := path.Join(tmuxpCfg.TmuxpConfigsDir(), fmt.Sprintf("%s.yaml", cluster.Context))
101+
if err := tmuxpCfg.Save(tmuxpCfgFile); err != nil {
102+
return err
103+
}
104+
return nil
105+
}
106+
88107
// Process processes kube-tmuxp configs
89108
func (c *Config) Process() error {
90109
kubeCfgsDir := c.kubeCfg.KubeCfgsDir()
@@ -115,21 +134,7 @@ func (c *Config) Process() error {
115134
c.kubeCfg.RenameContext(defaultCtxName, cluster.Context, kubeCfgFile)
116135

117136
fmt.Println("Creating tmuxp config...")
118-
windows := tmuxp.Windows{{Name: "default"}}
119-
env := tmuxp.Environment{"KUBECONFIG": kubeCfgFile}
120-
for k, v := range cluster.Envs {
121-
env[k] = v
122-
}
123-
124-
tmuxpCfg, err := tmuxp.NewConfig(cluster.Context, windows, env, c.filesystem)
125-
if err != nil {
126-
return err
127-
}
128-
129-
tmuxpCfgFile := path.Join(tmuxpCfg.TmuxpConfigsDir(), fmt.Sprintf("%s.yaml", cluster.Context))
130-
if err := tmuxpCfg.Save(tmuxpCfgFile); err != nil {
131-
return err
132-
}
137+
c.saveTmuxpConfig(kubeCfgFile, cluster)
133138

134139
fmt.Println("")
135140
}

0 commit comments

Comments
 (0)