feat(add docker plugin object)

Author: jr-k

internal/dao/docker.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/tls"
 	"crypto/x509"
+	"encoding/json"
 	"fmt"
 	"io"
 	"log"
@@ -51,6 +52,13 @@ type Task = task.Task
 type ComposeProject = compose.ComposeProject
 
 // Cached container info for instant scoped queries (drill-down)
+type PluginInfo struct {
+	ID          string
+	Name        string
+	Description string
+	Enabled     bool
+}
+
 type containerInfoCache struct {
 	Mounts []mountInfoCache
 	NetIDs map[string]bool
@@ -626,6 +634,88 @@ func (d *DockerClient) CreateContext(name, description, host string) error {
 	return nil
 }
 
+func (d *DockerClient) ListPlugins() ([]PluginInfo, error) {
+	cmd := exec.Command("docker", "plugin", "ls", "--format", "{{json .}}")
+	output, err := cmd.CombinedOutput()
+	if err != nil {
+		return nil, fmt.Errorf("error listing plugins: %v, output: %s", err, string(output))
+	}
+
+	var plugins []PluginInfo
+	for _, line := range strings.Split(strings.TrimSpace(string(output)), "\n") {
+		if line == "" {
+			continue
+		}
+		var p struct {
+			ID              string `json:"ID"`
+			Name            string `json:"Name"`
+			Description     string `json:"Description"`
+			Enabled         bool   `json:"Enabled"`
+			PluginReference string `json:"PluginReference"`
+		}
+		if err := json.Unmarshal([]byte(line), &p); err != nil {
+			continue
+		}
+		plugins = append(plugins, PluginInfo{
+			ID:          p.ID,
+			Name:        p.Name,
+			Description: p.Description,
+			Enabled:     p.Enabled,
+		})
+	}
+	return plugins, nil
+}
+
+func (d *DockerClient) InspectPlugin(name string) (string, error) {
+	cmd := exec.Command("docker", "plugin", "inspect", name)
+	output, err := cmd.CombinedOutput()
+	if err != nil {
+		return "", fmt.Errorf("error inspecting plugin: %v, output: %s", err, string(output))
+	}
+	return string(output), nil
+}
+
+func (d *DockerClient) RemovePlugin(name string, force bool) error {
+	args := []string{"plugin", "rm"}
+	if force {
+		args = append(args, "-f")
+	}
+	args = append(args, name)
+	cmd := exec.Command("docker", args...)
+	output, err := cmd.CombinedOutput()
+	if err != nil {
+		return fmt.Errorf("error removing plugin: %v, output: %s", err, string(output))
+	}
+	return nil
+}
+
+func (d *DockerClient) EnablePlugin(name string) error {
+	cmd := exec.Command("docker", "plugin", "enable", name)
+	output, err := cmd.CombinedOutput()
+	if err != nil {
+		return fmt.Errorf("error enabling plugin: %v, output: %s", err, string(output))
+	}
+	return nil
+}
+
+func (d *DockerClient) DisablePlugin(name string) error {
+	cmd := exec.Command("docker", "plugin", "disable", name)
+	output, err := cmd.CombinedOutput()
+	if err != nil {
+		return fmt.Errorf("error disabling plugin: %v, output: %s", err, string(output))
+	}
+	return nil
+}
+
+func (d *DockerClient) InstallPlugin(name string) error {
+	cmd := exec.Command("docker", "plugin", "install", "--grant-all-permissions", name)
+	output, err := cmd.CombinedOutput()
+	if err != nil {
+		return fmt.Errorf("error installing plugin: %v, output: %s", err, string(output))
+	}
+	return nil
+}
+
 func (d *DockerClient) ListTasks() ([]common.Resource, error) {
 	return d.Task.List()
 }

internal/ui/app.go

@@ -28,6 +28,7 @@ import (
 	"github.com/jr-k/d4s/internal/ui/views/configs"
 	"github.com/jr-k/d4s/internal/ui/views/secrets"
 	"github.com/jr-k/d4s/internal/ui/views/contexts"
+	"github.com/jr-k/d4s/internal/ui/views/plugins"
 	"github.com/jr-k/d4s/internal/ui/views/stacks"
 	"github.com/jr-k/d4s/internal/ui/views/tasks"
 	"github.com/jr-k/d4s/internal/ui/views/services"
@@ -390,6 +391,18 @@ func (a *App) initUI() {
 	}
 	a.Views[styles.TitleContexts] = vContexts
 
+	// Plugins
+	vPlugins := view.NewResourceView(a, styles.TitlePlugins)
+	vPlugins.ShortcutsFunc = plugins.GetShortcuts
+	vPlugins.FetchFunc = plugins.Fetch
+	vPlugins.InspectFunc = plugins.Inspect
+	vPlugins.RemoveFunc = plugins.Remove
+	vPlugins.Headers = plugins.Headers
+	vPlugins.InputHandler = func(event *tcell.EventKey) *tcell.EventKey {
+		return plugins.InputHandler(vPlugins, event)
+	}
+	a.Views[styles.TitlePlugins] = vPlugins
+
 	for title, view := range a.Views {
 		a.Pages.AddPage(title, view.Table, true, false)
 	}
@@ -603,6 +616,8 @@ func (a *App) resolveDefaultView() string {
 		return styles.TitleTasks
 	case "contexts", "context":
 		return styles.TitleContexts
+	case "plugins", "plugin":
+		return styles.TitlePlugins
 	default:
 		return styles.TitleContainers
 	}

internal/ui/app_navigation.go

@@ -49,6 +49,8 @@ func (a *App) ExecuteCmd(cmd string) {
 		switchToRoot(styles.TitleTasks)
 	case "o", "ctx", "context", "contexts":
 		switchToRoot(styles.TitleContexts)
+	case "g", "pl", "plugin", "plugins":
+		switchToRoot(styles.TitlePlugins)
 	case "h", "help", "?":
 		a.Pages.AddPage("help", a.Help, true, true)
 	default:

internal/ui/components/command/command.go

@@ -118,6 +118,7 @@ var availableCommands = []string{
 	"stacks",
 	"tasks",
 	"contexts",
+	"plugins",
 	"help",
 	"aliases",
 	"q",
@@ -132,6 +133,7 @@ var availableCommands = []string{
 	"k",
 	"t",
 	"o",
+	"g",
 	"d",
 }
 

internal/ui/dialogs/help.go

@@ -29,6 +29,7 @@ func NewHelpView(app common.AppController) tview.Primitive {
 		{fmt.Sprintf("[%s]:c[-]        Containers", k), fmt.Sprintf("[%s]:i[-]        Images", k)},
 		{fmt.Sprintf("[%s]:v[-]        Volumes", k), fmt.Sprintf("[%s]:n[-]        Networks", k)},
 		{fmt.Sprintf("[%s]:p[-]        Compose", k), fmt.Sprintf("[%s]:o[-]        Contexts", k)},
+		{fmt.Sprintf("[%s]:g[-]        Plugins", k), ""},
 		{"", ""},
 		{fmt.Sprintf("[%s::b]SWARM", a), ""},
 		{fmt.Sprintf("[%s]:d[-]        Nodes", k), fmt.Sprintf("[%s]:t[-]        Tasks", k)},

internal/ui/styles/styles.go

@@ -139,6 +139,7 @@ const (
 	TitleStacks     = "Stacks"
 	TitleTasks      = "Tasks"
 	TitleContexts   = "Contexts"
+	TitlePlugins    = "Plugins"
 )
 
 // invertColor inverts a tcell.Color by flipping its lightness while preserving hue and saturation.

internal/ui/views/aliases/aliases.go

@@ -70,6 +70,7 @@ func Fetch(app common.AppController, v *view.ResourceView) ([]dao.Resource, erro
 		{Title: styles.TitleStacks, Resource: "stacks", Group: "swarm", Shortcuts: []string{"k", "st", "stack", "stacks"}},
 		{Title: styles.TitleTasks, Resource: "tasks", Group: "swarm", Shortcuts: []string{"t", "task", "tasks"}},
 		{Title: styles.TitleContexts, Resource: "contexts", Group: "docker", Shortcuts: []string{"o", "ctx", "context", "contexts"}},
+		{Title: styles.TitlePlugins, Resource: "plugins", Group: "docker", Shortcuts: []string{"g", "pl", "plugin", "plugins"}},
 		{Title: styles.TitleCompose, Resource: "compose", Group: "compose", Shortcuts: []string{"p", "cp", "compose", "project", "projects"}},
 	}
 

internal/ui/views/contexts/contexts.go

@@ -24,18 +24,18 @@ type Context struct {
 
 func (c Context) GetID() string { return c.Name }
 func (c Context) GetCells() []string {
-	current := ""
+	current := "False"
 	if c.Current {
-		current = "✓"
+		current = "True"
 	}
 	return []string{c.Name, current, c.Description, c.Endpoint}
 }
 
 func (c Context) GetStatusColor() (tcell.Color, tcell.Color) {
 	if c.Current {
-		return styles.ColorStatusGreen, styles.ColorBlack
+		return styles.ColorIdle, styles.ColorBlack
 	}
-	return styles.ColorIdle, styles.ColorBlack
+	return styles.ColorStatusGray, styles.ColorBlack
 }
 
 func (c Context) GetColumnValue(column string) string {
@@ -44,9 +44,9 @@ func (c Context) GetColumnValue(column string) string {
 		return c.Name
 	case "current":
 		if c.Current {
-			return "✓"
+			return "True"
 		}
-		return ""
+		return "False"
 	case "description":
 		return c.Description
 	case "endpoint":