Use graceful defaults for controller interrupts.

Assisted-By: devx/3236e566-7538-432e-a30a-2bdf37265ed4

Author: samuel-williams-shopify

lib/async/container/controller.rb

@@ -12,6 +12,7 @@
 
 require "async"
 require "async/signals"
+require "async/signals/graceful"
 
 module Async
 	module Container
@@ -50,8 +51,6 @@ def call
 			end
 
 			SIGHUP = Signal.list["HUP"]
-			SIGINT = Signal.list["INT"]
-			SIGTERM = Signal.list["TERM"]
 			SIGUSR1 = Signal.list["USR1"]
 			SIGUSR2 = Signal.list["USR2"]
 
@@ -69,14 +68,6 @@ def initialize(notify: Notify.open!, container_class: Container, graceful_stop:
 				# Serializes lifecycle transitions such as start, restart and reload. `Container#stop` (which can also take time) is performed outside this guard, so that live container events are not blocked by the stop operation (e.g. restarting).
 				@guard = ::Thread::Mutex.new
 
-				@signals.trap(SIGINT) do |_signal, context|
-					context.raise(Interrupt)
-				end
-				
-				@signals.trap(SIGTERM) do |_signal, context|
-					context.raise(Interrupt)
-				end
-				
 				self.trap(SIGHUP) do
 					self.restart
 				rescue SetupError => error

test/async/container/controller.rb

@@ -261,42 +261,6 @@ def controller.setup(container)
 			expect(handlers.fetch("USR2")).to be_nil
 		end
 
-		it "raises interrupt for SIGINT" do
-			context = Object.new
-			
-			def context.raise(exception)
-				@exception = exception
-			end
-			
-			def context.exception
-				@exception
-			end
-			
-			handlers = controller.instance_variable_get(:@signals).to_h
-			
-			handlers.fetch("INT").call(Async::Container::Controller::SIGINT, context)
-			
-			expect(context.exception).to be == Interrupt
-		end
-		
-		it "raises interrupt for SIGTERM" do
-			context = Object.new
-			
-			def context.raise(exception)
-				@exception = exception
-			end
-			
-			def context.exception
-				@exception
-			end
-			
-			handlers = controller.instance_variable_get(:@signals).to_h
-			
-			handlers.fetch("TERM").call(Async::Container::Controller::SIGTERM, context)
-			
-			expect(context.exception).to be == Interrupt
-		end
-		
 		it "queues trapped signal events" do
 			controller = Async::Container::Controller.new(notify: nil)
 			applied = false