Streamline misconfiguration detection and error messaging

Author: jherdman

Diff for: lib/solid_queue/configuration.rb

@@ -37,11 +37,21 @@ def configured_processes
     end
 
     def valid?
-      skip_recurring_tasks? || recurring_tasks.none? || recurring_tasks.all?(&:valid?)
+      configured_processes.any? && (skip_recurring_tasks? || invalid_tasks.none?)
     end
 
-    def invalid_tasks
-      recurring_tasks.select(&:invalid?)
+    def error_messages
+      if configured_processes.none?
+        "No workers or processed configured. Exiting..."
+      else
+        error_messages = invalid_tasks.map do |task|
+            all_messages = task.errors.full_messages.map { |msg| "\t#{msg}" }.join("\n")
+            "#{task.key}:\n#{all_messages}"
+          end
+          .join("\n")
+
+        "Invalid processes configured:\n#{error_messages}"
+      end
     end
 
     def max_number_of_threads
@@ -62,6 +72,10 @@ def default_options
         }
       end
 
+      def invalid_tasks
+        recurring_tasks.select(&:invalid?)
+      end
+
       def only_work?
         options[:only_work]
       end

Diff for: lib/solid_queue/supervisor.rb

@@ -10,28 +10,12 @@ def start(**options)
         SolidQueue.supervisor = true
         configuration = Configuration.new(**options)
 
-        if configuration.configured_processes.any?
-          if configuration.valid?
-            new(configuration).tap(&:start)
-          else
-            abort_due_to_invalid_tasks(configuration)
-          end
+        if configuration.valid?
+          new(configuration).tap(&:start)
         else
-          abort "No workers or processed configured. Exiting..."
+          abort configuration.error_messages
         end
       end
-
-      private
-        def abort_due_to_invalid_tasks(configuration)
-          error_messages = configuration.invalid_tasks
-            .map do |task|
-              all_messages = task.errors.full_messages.map { |msg| "\t#{msg}" }.join("\n")
-              "#{task.key}:\n#{all_messages}"
-            end
-            .join("\n")
-
-          abort "Invalid processes configured:\n#{error_messages}"
-        end
     end
 
     def initialize(configuration)