Reboot if running

lib/mrsk/cli/app.rb

@@ -3,15 +3,21 @@ require "mrsk/cli/base"
 class Mrsk::Cli::App < Mrsk::Cli::Base
   desc "boot", "Boot app on servers (or start them if they've already been booted)"
   def boot
-    using_version(options[:version] || most_recent_version_available) do
+    cli = self
+
+    using_version(options[:version] || most_recent_version_available) do |version|
       MRSK.config.roles.each do |role|
         on(role.hosts) do |host|
           begin
             execute *MRSK.app.run(role: role.name)
           rescue SSHKit::Command::Failed => e
             if e.message =~ /already in use/
-              error "Container with same version already deployed on #{host}, starting that instead"
-              execute *MRSK.app.start, host: host
+              error "Rebooting container with same version already deployed on #{host}"
+
+              cli.stop
+              cli.remove_container version
+
+              execute *MRSK.app.run(role: role.name)
             else
               raise
             end

test/cli/app_test.rb

@@ -5,6 +5,24 @@ class CliAppTest < CliTestCase
     assert_match /Running docker run -d --restart unless-stopped/, run_command("boot")
   end
 
+  test "boot will reboot if same version is already running" do
+    run_command("details") # Preheat MRSK const
+
+    # Prevent expected failures from outputting to terminal
+    Thread.report_on_exception = false
+
+    MRSK.app.stubs(:run).raises(SSHKit::Command::Failed.new("already in use")).then.returns([ :docker, :run ])
+
+    run_command("boot").tap do |output|
+      assert_match /Rebooting container with same version already deployed/, output # Can't start what's already running
+      assert_match /docker ps -q --filter label=service=app | xargs docker stop/, output # Stop what's running
+      assert_match /docker container ls -a -f name=app-999 -q | docker container rm/, output # Remove old container
+      assert_match /docker run/, output # Start new container
+    end
+  ensure
+    Thread.report_on_exception = true
+  end
+
   test "reboot to default version" do
     run_command("reboot").tap do |output|
       assert_match /docker ps --filter label=service=app/, output # Find current container