mirror of https://github.com/docusealco/docuseal
				
				
				
			
			You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							71 lines
						
					
					
						
							1.3 KiB
						
					
					
				
			
		
		
	
	
							71 lines
						
					
					
						
							1.3 KiB
						
					
					
				| # frozen_string_literal: true
 | |
| 
 | |
| require 'puma/plugin'
 | |
| 
 | |
| # rubocop:disable Metrics
 | |
| Puma::Plugin.create do
 | |
|   def start(launcher)
 | |
|     return if ENV['LOCAL_REDIS_URL'].to_s.empty?
 | |
| 
 | |
|     @puma_pid = $PROCESS_ID
 | |
| 
 | |
|     launcher.events.on_booted do
 | |
|       @redis_server_pid = fork_redis
 | |
|     end
 | |
| 
 | |
|     in_background { monitor_redis }
 | |
| 
 | |
|     at_exit do
 | |
|       stop_redis_server if Process.pid == @puma_pid
 | |
|     end
 | |
| 
 | |
|     launcher.events.on_stopped { stop_redis_server }
 | |
|     launcher.events.on_restart { stop_redis_server }
 | |
|   end
 | |
| 
 | |
|   private
 | |
| 
 | |
|   def monitor_redis
 | |
|     loop do
 | |
|       if redis_dead?
 | |
|         Process.kill(:INT, @puma_pid)
 | |
| 
 | |
|         break
 | |
|       end
 | |
| 
 | |
|       sleep 5
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def redis_dead?
 | |
|     return false unless @redis_server_pid
 | |
| 
 | |
|     Process.waitpid(@redis_server_pid, Process::WNOHANG)
 | |
| 
 | |
|     false
 | |
|   rescue Errno::ECHILD, Errno::ESRCH
 | |
|     true
 | |
|   end
 | |
| 
 | |
|   def fork_redis
 | |
|     fork do
 | |
|       Process.setsid
 | |
| 
 | |
|       Dir.chdir(ENV.fetch('WORKDIR', nil)) unless ENV['WORKDIR'].to_s.empty?
 | |
| 
 | |
|       exec('redis-server', '--requirepass', Digest::SHA1.hexdigest("redis#{ENV.fetch('SECRET_KEY_BASE', '')}"),
 | |
|            out: '/dev/null')
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def stop_redis_server
 | |
|     if @redis_server_pid
 | |
|       Process.kill(:INT, @redis_server_pid)
 | |
|       Process.wait(@redis_server_pid)
 | |
|     end
 | |
|   rescue Errno::ECHILD, Errno::ESRCH
 | |
|     nil
 | |
|   end
 | |
| end
 | |
| # rubocop:enable Metrics
 |