Extract verify options method in search cli (#25121)
This commit is contained in:
		
							parent
							
								
									b489c200a6
								
							
						
					
					
						commit
						cd4f0feab8
					
				@ -29,15 +29,7 @@ module Mastodon::CLI
 | 
				
			|||||||
      database will be imported into the indices, unless overridden with --no-import.
 | 
					      database will be imported into the indices, unless overridden with --no-import.
 | 
				
			||||||
    LONG_DESC
 | 
					    LONG_DESC
 | 
				
			||||||
    def deploy
 | 
					    def deploy
 | 
				
			||||||
      if options[:concurrency] < 1
 | 
					      verify_deploy_options!
 | 
				
			||||||
        say('Cannot run with this concurrency setting, must be at least 1', :red)
 | 
					 | 
				
			||||||
        exit(1)
 | 
					 | 
				
			||||||
      end
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
      if options[:batch_size] < 1
 | 
					 | 
				
			||||||
        say('Cannot run with this batch_size setting, must be at least 1', :red)
 | 
					 | 
				
			||||||
        exit(1)
 | 
					 | 
				
			||||||
      end
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
      indices = if options[:only]
 | 
					      indices = if options[:only]
 | 
				
			||||||
                  options[:only].map { |str| "#{str.camelize}Index".constantize }
 | 
					                  options[:only].map { |str| "#{str.camelize}Index".constantize }
 | 
				
			||||||
@ -98,5 +90,26 @@ module Mastodon::CLI
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
      say("Indexed #{added} records, de-indexed #{removed}", :green, true)
 | 
					      say("Indexed #{added} records, de-indexed #{removed}", :green, true)
 | 
				
			||||||
    end
 | 
					    end
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    private
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    def verify_deploy_options!
 | 
				
			||||||
 | 
					      verify_deploy_concurrency!
 | 
				
			||||||
 | 
					      verify_deploy_batch_size!
 | 
				
			||||||
 | 
					    end
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    def verify_deploy_concurrency!
 | 
				
			||||||
 | 
					      return unless options[:concurrency] < 1
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					      say('Cannot run with this concurrency setting, must be at least 1', :red)
 | 
				
			||||||
 | 
					      exit(1)
 | 
				
			||||||
 | 
					    end
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    def verify_deploy_batch_size!
 | 
				
			||||||
 | 
					      return unless options[:batch_size] < 1
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					      say('Cannot run with this batch_size setting, must be at least 1', :red)
 | 
				
			||||||
 | 
					      exit(1)
 | 
				
			||||||
 | 
					    end
 | 
				
			||||||
  end
 | 
					  end
 | 
				
			||||||
end
 | 
					end
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user