package gui import ( "bufio" "context" "encoding/json" "fmt" "os/exec" "time" "github.com/go-errors/errors" "github.com/jesseduffield/gocui" "github.com/jesseduffield/lazydocker/pkg/commands" "github.com/jesseduffield/lazydocker/pkg/utils" ) // list panel functions func (gui *Gui) getContainerContexts() []string { return []string{"logs", "config", "stats"} } func (gui *Gui) getSelectedContainer(g *gocui.Gui) (*commands.Container, error) { selectedLine := gui.State.Panels.Containers.SelectedLine if selectedLine == -1 { return &commands.Container{}, gui.Errors.ErrNoContainers } return gui.State.Containers[selectedLine], nil } func (gui *Gui) handleContainersFocus(g *gocui.Gui, v *gocui.View) error { if gui.popupPanelFocused() { return nil } cx, cy := v.Cursor() _, oy := v.Origin() prevSelectedLine := gui.State.Panels.Containers.SelectedLine newSelectedLine := cy - oy if newSelectedLine > len(gui.State.Containers)-1 || len(utils.Decolorise(gui.State.Containers[newSelectedLine].Name)) < cx { return gui.handleContainerSelect(gui.g, v, false) } gui.State.Panels.Containers.SelectedLine = newSelectedLine if prevSelectedLine == newSelectedLine && gui.currentViewName() == v.Name() { return gui.handleContainerPress(gui.g, v) } else { return gui.handleContainerSelect(gui.g, v, true) } } func (gui *Gui) handleContainerSelect(g *gocui.Gui, v *gocui.View, alreadySelected bool) error { if _, err := gui.g.SetCurrentView(v.Name()); err != nil { return err } container, err := gui.getSelectedContainer(g) if err != nil { if err != gui.Errors.ErrNoContainers { return err } return gui.renderString(g, "main", gui.Tr.SLocalize("NoChangedContainers")) } if err := gui.focusPoint(0, gui.State.Panels.Containers.SelectedLine, len(gui.State.Containers), v); err != nil { return err } mainView := gui.getMainView() gui.State.MainWriterID++ writerID := gui.State.MainWriterID mainView.Clear() mainView.SetOrigin(0, 0) mainView.SetCursor(0, 0) switch gui.getContainerContexts()[gui.State.Panels.Containers.ContextIndex] { case "logs": if err := gui.renderLogs(mainView, container, writerID); err != nil { return err } case "config": if err := gui.renderConfig(mainView, container, writerID); err != nil { return err } case "stats": if err := gui.renderStats(mainView, container, writerID); err != nil { return err } default: return errors.New("Unknown context for containers panel") } return nil } func (gui *Gui) renderConfig(mainView *gocui.View, container *commands.Container, writerID int) error { mainView.Autoscroll = false mainView.Title = "Config" data, err := json.MarshalIndent(&container.Container, "", " ") if err != nil { return err } gui.renderString(gui.g, "main", string(data)) return nil } func (gui *Gui) renderStats(mainView *gocui.View, container *commands.Container, writerID int) error { mainView.Autoscroll = false mainView.Title = "Stats" stream, err := gui.DockerCommand.Client.ContainerStats(context.Background(), container.ID, true) if err != nil { return err } go func() { cpuUsageHistory := []float64{} memoryUsageHistory := []float64{} scanner := bufio.NewScanner(stream.Body) for scanner.Scan() { data := scanner.Bytes() var stats commands.ContainerStats json.Unmarshal(data, &stats) if len(cpuUsageHistory) >= 20 { cpuUsageHistory = cpuUsageHistory[1:] } if len(memoryUsageHistory) >= 20 { memoryUsageHistory = memoryUsageHistory[1:] } width, _ := mainView.Size() contents, err := stats.RenderStats(width, cpuUsageHistory, memoryUsageHistory) if err != nil { gui.createErrorPanel(gui.g, err.Error()) } if gui.State.MainWriterID != writerID { stream.Body.Close() return } gui.reRenderString(gui.g, "main", contents) } stream.Body.Close() }() return nil } func (gui *Gui) renderLogs(mainView *gocui.View, container *commands.Container, writerID int) error { mainView.Autoscroll = true mainView.Title = "Logs" var cmd *exec.Cmd cmd = gui.OSCommand.RunCustomCommand("docker logs --since=60m --timestamps --follow " + container.ID) cmd.Stdout = mainView cmd.Start() go func() { for { time.Sleep(time.Second / 100) if gui.State.MainWriterID != writerID { cmd.Process.Kill() return } } }() return nil } func (gui *Gui) refreshContainers() error { selectedContainer, _ := gui.getSelectedContainer(gui.g) containersView := gui.getContainersView() if containersView == nil { // if the containersView hasn't been instantiated yet we just return return nil } if err := gui.refreshStateContainers(); err != nil { return err } if len(gui.State.Containers) > 0 && gui.State.Panels.Containers.SelectedLine == -1 { gui.State.Panels.Containers.SelectedLine = 0 } gui.g.Update(func(g *gocui.Gui) error { containersView.Clear() isFocused := gui.g.CurrentView().Name() == "containers" list, err := utils.RenderList(gui.State.Containers, isFocused) if err != nil { return err } fmt.Fprint(containersView, list) if containersView == g.CurrentView() { newSelectedContainer, _ := gui.getSelectedContainer(gui.g) alreadySelected := newSelectedContainer.Name == selectedContainer.Name return gui.handleContainerSelect(g, containersView, alreadySelected) } return nil }) return nil } func (gui *Gui) refreshStateContainers() error { containers, err := gui.DockerCommand.GetContainers() if err != nil { return err } gui.State.Containers = containers return nil } func (gui *Gui) handleContainersNextLine(g *gocui.Gui, v *gocui.View) error { if gui.popupPanelFocused() { return nil } panelState := gui.State.Panels.Containers gui.changeSelectedLine(&panelState.SelectedLine, len(gui.State.Containers), false) return gui.handleContainerSelect(gui.g, v, false) } func (gui *Gui) handleContainersPrevLine(g *gocui.Gui, v *gocui.View) error { if gui.popupPanelFocused() { return nil } panelState := gui.State.Panels.Containers gui.changeSelectedLine(&panelState.SelectedLine, len(gui.State.Containers), true) return gui.handleContainerSelect(gui.g, v, false) } func (gui *Gui) handleContainerPress(g *gocui.Gui, v *gocui.View) error { return nil } func (gui *Gui) handleContainersPrevContext(g *gocui.Gui, v *gocui.View) error { contexts := gui.getContainerContexts() if gui.State.Panels.Containers.ContextIndex >= len(contexts)-1 { gui.State.Panels.Containers.ContextIndex = 0 } else { gui.State.Panels.Containers.ContextIndex++ } gui.handleContainerSelect(gui.g, v, true) return nil } func (gui *Gui) handleContainersNextContext(g *gocui.Gui, v *gocui.View) error { contexts := gui.getContainerContexts() if gui.State.Panels.Containers.ContextIndex <= 0 { gui.State.Panels.Containers.ContextIndex = len(contexts) - 1 } else { gui.State.Panels.Containers.ContextIndex-- } gui.handleContainerSelect(gui.g, v, true) return nil }