mirror of
https://github.com/skoelle/kctl-tui.git
synced 2026-09-17 20:10:24 +00:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
73cc510347 | ||
|
|
d17eb6971c | ||
|
|
fb4c1be12b | ||
|
|
9e3fefb71a | ||
|
|
2d382441a1 | ||
|
|
ad7d8534ab | ||
|
|
a0b937e882 | ||
|
|
d32ccd5952 |
@@ -335,6 +335,10 @@ func (m *fullModel) startTmuxSessionTmux() tea.Cmd {
|
||||
|
||||
// startWtSession creates the session using Windows Terminal's native
|
||||
// split-pane feature. This avoids the psmux focus-freeze issue on Windows.
|
||||
// Note: In Windows Terminal, -H (horizontal) stacks panes top/bottom,
|
||||
// while -V (vertical) places them side by side — opposite of tmux.
|
||||
// The -s flag controls the split ratio: first split gives k9sA 75%
|
||||
// (panel keeps 25%), second split divides k9sA equally (37.5% each).
|
||||
func (m *fullModel) startWtSession() tea.Cmd {
|
||||
selfPath, err := os.Executable()
|
||||
if err != nil {
|
||||
@@ -351,20 +355,19 @@ func (m *fullModel) startWtSession() tea.Cmd {
|
||||
kubeexec.VerboseLog("[debug] panelCmd=%s\n", panelCmd)
|
||||
kubeexec.VerboseLog("[debug] k9sCmdA=%s\n", k9sCmdA)
|
||||
|
||||
args := []string{"new-tab", panelCmd, ";", "split-pane", "-V", k9sCmdA}
|
||||
wtCmd := fmt.Sprintf("wt -F new-tab %s ; split-pane -H -s 0.75 %s", panelCmd, k9sCmdA)
|
||||
|
||||
if len(m.cfg.Envs) > 1 {
|
||||
envB := m.cfg.Envs[1]
|
||||
ctxB := m.cfg.ResolveContext(envB, m.selectedContext)
|
||||
k9sCmdB := fmt.Sprintf("k9s --context %s --namespace %s --command pods", ctxB, m.selectedNamespace)
|
||||
kubeexec.VerboseLog("[debug] k9sCmdB=%s\n", k9sCmdB)
|
||||
args = append(args, ";", "split-pane", "-V", k9sCmdB)
|
||||
wtCmd += fmt.Sprintf(" ; split-pane -H -s 0.5 %s", k9sCmdB)
|
||||
}
|
||||
|
||||
c := exec.Command("wt", args...)
|
||||
return tea.ExecProcess(c, func(err error) tea.Msg {
|
||||
return tmuxDoneMsg{err: err}
|
||||
})
|
||||
c := exec.Command("cmd", "/c", wtCmd)
|
||||
_ = c.Start()
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *fullModel) View() string {
|
||||
|
||||
@@ -94,7 +94,12 @@ func main() {
|
||||
fmt.Fprintf(os.Stderr, "WARNING: failed to load config: %v\n", cfgErr)
|
||||
}
|
||||
if cfgErr == nil && cfg.IsAutoUpdateCheckEnabled() {
|
||||
if checkForUpdateInteractive(verbose) {
|
||||
updated, err := checkForUpdateInteractive(verbose)
|
||||
if err != nil {
|
||||
fmt.Fprintln(os.Stderr, err)
|
||||
os.Exit(1)
|
||||
}
|
||||
if updated {
|
||||
os.Exit(0)
|
||||
}
|
||||
}
|
||||
|
||||
+16
-1
@@ -8,6 +8,7 @@ import (
|
||||
"flag"
|
||||
"fmt"
|
||||
"os/exec"
|
||||
"runtime"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -61,6 +62,11 @@ type panelModel struct {
|
||||
err error
|
||||
}
|
||||
|
||||
// isWtMode returns true when running on Windows with multiplexer: "wt".
|
||||
func (m *panelModel) isWtMode() bool {
|
||||
return runtime.GOOS == "windows" && m.cfg.MultiplexerBackend() == "wt"
|
||||
}
|
||||
|
||||
func runPanel(args []string) error {
|
||||
fs := flag.NewFlagSet("panel", flag.ContinueOnError)
|
||||
context := fs.String("context", "", "context (e.g. internal/external)")
|
||||
@@ -88,6 +94,9 @@ func newPanelModel(context, ns, team string) *panelModel {
|
||||
l.SetFilteringEnabled(false)
|
||||
|
||||
m := &panelModel{context: context, ns: ns, team: team, cfg: cfg, step: stepEnvMenu, list: l, input: ti}
|
||||
if m.isWtMode() {
|
||||
l.KeyMap.Quit.SetEnabled(false) // "q" deaktivieren, "ctrl+c" bleibt
|
||||
}
|
||||
if loadErr != nil {
|
||||
m.err = fmt.Errorf("config load failed: %w", loadErr)
|
||||
m.step = stepError
|
||||
@@ -99,7 +108,9 @@ func newPanelModel(context, ns, team string) *panelModel {
|
||||
|
||||
func (m *panelModel) showEnvMenu() {
|
||||
items := make([]list.Item, 0, len(m.cfg.Envs)+1)
|
||||
if !m.isWtMode() {
|
||||
items = append(items, simpleItem{label: "Quit (closes this tmux session)", value: "quit"})
|
||||
}
|
||||
for _, env := range m.cfg.Envs {
|
||||
items = append(items, simpleItem{label: env, value: env})
|
||||
}
|
||||
@@ -179,10 +190,14 @@ func (m *panelModel) usesTextInput() bool {
|
||||
// handleEsc navigates one level up: action menu -> env menu, most
|
||||
// sub-steps -> action menu. From the top-level env menu it closes the
|
||||
// whole tmux session (all panes, including the two k9s status panes)
|
||||
// before quitting this program, per SPEC.md 3.6.
|
||||
// before quitting this program, per SPEC.md 3.6. In wt mode, Esc on
|
||||
// the env menu does nothing — the user closes the wt window manually.
|
||||
func (m *panelModel) handleEsc() (tea.Model, tea.Cmd) {
|
||||
switch m.step {
|
||||
case stepEnvMenu:
|
||||
if m.isWtMode() {
|
||||
return m, nil
|
||||
}
|
||||
exec.Command("tmux", "kill-session", "-t", "kctl").Run()
|
||||
return m, tea.Quit
|
||||
case stepActionMenu:
|
||||
|
||||
+12
-12
@@ -83,14 +83,15 @@ func runUpdate(verbose bool) error {
|
||||
}
|
||||
|
||||
// checkForUpdateInteractive checks for a new version and prompts the user to update.
|
||||
// Returns true if an update was applied.
|
||||
func checkForUpdateInteractive(verbose bool) bool {
|
||||
// Returns (true, nil) if an update was applied successfully, (false, nil) if no
|
||||
// update was needed or the user declined, and (false, err) if the update failed.
|
||||
func checkForUpdateInteractive(verbose bool) (bool, error) {
|
||||
if version == "dev" {
|
||||
return false
|
||||
return false, nil
|
||||
}
|
||||
|
||||
if !term.IsTerminal(int(os.Stdin.Fd())) {
|
||||
return false
|
||||
return false, nil
|
||||
}
|
||||
|
||||
updater, err := initUpdater(verbose)
|
||||
@@ -98,7 +99,7 @@ func checkForUpdateInteractive(verbose bool) bool {
|
||||
if verbose {
|
||||
fmt.Fprintf(os.Stderr, "Update check failed: %v\n", err)
|
||||
}
|
||||
return false
|
||||
return false, nil
|
||||
}
|
||||
|
||||
ctx, cancel := context.WithTimeout(context.Background(), updateTimeout)
|
||||
@@ -110,10 +111,10 @@ func checkForUpdateInteractive(verbose bool) bool {
|
||||
if verbose {
|
||||
fmt.Fprintf(os.Stderr, "Update check failed: %v\n", err)
|
||||
}
|
||||
return false
|
||||
return false, nil
|
||||
}
|
||||
if !found {
|
||||
return false
|
||||
return false, nil
|
||||
}
|
||||
|
||||
current, _ := semver.NewVersion(version)
|
||||
@@ -121,7 +122,7 @@ func checkForUpdateInteractive(verbose bool) bool {
|
||||
newVer, _ := semver.NewVersion(newVersion)
|
||||
|
||||
if current != nil && !current.LessThan(newVer) {
|
||||
return false
|
||||
return false, nil
|
||||
}
|
||||
|
||||
fmt.Printf("New version %s available (current: %s). Update now? [y/N] ", newVersion, version)
|
||||
@@ -131,17 +132,16 @@ func checkForUpdateInteractive(verbose bool) bool {
|
||||
answer = strings.TrimSpace(strings.ToLower(answer))
|
||||
|
||||
if answer != "y" && answer != "yes" {
|
||||
return false
|
||||
return false, nil
|
||||
}
|
||||
|
||||
fmt.Println("Updating...")
|
||||
if err := updater.UpdateTo(ctx, rel, ""); err != nil {
|
||||
fmt.Fprintf(os.Stderr, "Update failed: %v\n", err)
|
||||
return false
|
||||
return false, fmt.Errorf("update failed: %w", err)
|
||||
}
|
||||
|
||||
fmt.Printf("Updated to %s. Please restart kctl-tui.\n", newVersion)
|
||||
return true
|
||||
return true, nil
|
||||
}
|
||||
|
||||
type verboseLogger struct{}
|
||||
|
||||
Reference in New Issue
Block a user