Use puma hook to start and stop media listener service automatically

Gemfile

@@ -20,7 +20,7 @@ gem "cssbundling-rails", "~> 1.2.0"
 gem "jsbundling-rails", "~> 1.1.2"
 
 # Use Puma as the app server
-gem "puma", "~> 6.3.0"
+gem "puma", "~> 6.4.0"
 
 # Build JSON APIs with ease. Read more: https://github.com/rails/jbuilder
 gem "jbuilder", "~> 2.11.5"

Gemfile.lock

@@ -248,7 +248,7 @@ GEM
     psych (5.1.1.1)
       stringio
     public_suffix (5.0.3)
-    puma (6.3.1)
+    puma (6.4.0)
       nio4r (~> 2.0)
     racc (1.7.1)
     rack (3.0.8)
@@ -415,7 +415,7 @@ DEPENDENCIES
   pagy (~> 6.0.0)
   pg (~> 1.3.2)
   propshaft (~> 0.7.0)
-  puma (~> 6.3.0)
+  puma (~> 6.4.0)
   rails (~> 7.1.0)
   ransack (~> 4.1.0)
   redis (~> 4.0)

config/puma.rb

@@ -23,13 +23,6 @@
 # Specifies the `pidfile` that Puma will use.
 pidfile ENV.fetch("PIDFILE") { "tmp/pids/server.pid" }
 
-# Specifies that the worker count should equal the number of processors in production.
-if ENV["RAILS_ENV"] == "production"
-  require "concurrent-ruby"
-  worker_count = Integer(ENV.fetch("WEB_CONCURRENCY") { Concurrent.physical_processor_count })
-  workers worker_count if worker_count > 1
-end
-
 # Use the `preload_app!` method when specifying a `workers` number.
 # This directive tells Puma to first boot the application and load code
 # before forking the application. This takes advantage of Copy On Write
@@ -40,6 +33,27 @@
 # Allow puma to be restarted by `rails restart` command.
 plugin :tmp_restart
 
+on_booted do
+  MediaListener.start if Setting.enable_media_listener? && !MediaListener.running?
+end
+
+if ENV["RAILS_ENV"] == "production"
+  # Specifies that the worker count should equal the number of processors in production.
+  require "concurrent-ruby"
+  worker_count = Integer(ENV.fetch("WEB_CONCURRENCY") { Concurrent.physical_processor_count })
+  workers worker_count if worker_count > 1
+
+  on_worker_shutdown do
+    MediaListener.stop if MediaListener.running?
+  end
+end
+
+if ENV["RAILS_ENV"] == "development"
+  on_thread_exit do
+    MediaListener.stop if MediaListener.running?
+  end
+end
+
 if BlackCandy::Config.embedded_sidekiq?
   # Preloading the application is necessary to ensure
   # the configuration in your initializer runs before