feat(force restart a swarm service)

Author: jr-k

internal/dao/docker.go

@@ -310,6 +310,10 @@ func (d *DockerClient) UpdateServiceImage(id string, image string) error {
 	return d.Service.UpdateImage(id, image)
 }
 
+func (d *DockerClient) RestartService(id string) error {
+	return d.Service.Restart(id)
+}
+
 func (d *DockerClient) RemoveService(id string) error {
 	return d.Service.Remove(id)
 }

internal/dao/swarm/service/service.go

@@ -192,6 +192,18 @@ func (m *Manager) UpdateImage(id string, image string) error {
 	return err
 }
 
+func (m *Manager) Restart(id string) error {
+	service, _, err := m.cli.ServiceInspectWithRaw(m.ctx, id, swarm.ServiceInspectOptions{})
+	if err != nil {
+		return err
+	}
+
+	service.Spec.TaskTemplate.ForceUpdate++
+
+	_, err = m.cli.ServiceUpdate(m.ctx, id, service.Version, service.Spec, swarm.ServiceUpdateOptions{})
+	return err
+}
+
 func (m *Manager) Remove(id string) error {
 	return m.cli.ServiceRemove(m.ctx, id)
 }

internal/ui/views/services/services.go

@@ -149,6 +149,7 @@ func GetShortcuts() []string {
 		common.FormatSCHeader("p", "Ps"),
 		common.FormatSCHeader("d", "Describe"),
 		common.FormatSCHeader("s", "Scale"),
+		common.FormatSCHeader("r", "Restart"),
 		common.FormatSCHeader("z", "No Replica"),
 		common.FormatSCHeader("shift-x", "Attach Secrets"),
 		common.FormatSCHeader("shift-n", "Attach Networks"),
@@ -195,6 +196,9 @@ func InputHandler(v *view.ResourceView, event *tcell.EventKey) *tcell.EventKey {
 	case 'p':
 		Ps(app, v)
 		return nil
+	case 'r':
+		RestartAction(app, v)
+		return nil
 	case 'z':
 		ScaleZero(app, v)
 		return nil
@@ -331,6 +335,20 @@ func ScaleAction(app common.AppController, v *view.ResourceView) {
 	Scale(app, id, currentReplicas)
 }
 
+func RestartAction(app common.AppController, v *view.ResourceView) {
+	ids, err := v.GetSelectedIDs()
+	if err != nil {
+		return
+	}
+
+	dialogs.ShowConfirmation(app, "RESTART", fmt.Sprintf("%d services", len(ids)), func(force bool) {
+		restartAction := func(id string) error {
+			return app.GetDocker().RestartService(id)
+		}
+		app.PerformAction(restartAction, "restarting", styles.ColorStatusOrange)
+	})
+}
+
 func ScaleZero(app common.AppController, v *view.ResourceView) {
 	ids, err := v.GetSelectedIDs()
 	if err != nil { return }