lib/floe/workflow/retrier.rb in floe-0.11.3 vs lib/floe/workflow/retrier.rb in floe-0.12.0

@@ -1,18 +1,24 @@
 # frozen_string_literal: true
 
 module Floe
   class Workflow
     class Retrier
-      attr_reader :error_equals, :interval_seconds, :max_attempts, :backoff_rate
+      include ErrorMatcherMixin
+      include ValidationMixin
 
-      def initialize(payload)
-        @payload = payload
+      attr_reader :error_equals, :interval_seconds, :max_attempts, :backoff_rate, :name
 
+      def initialize(_workflow, name, payload)
+        @name             = name
+        @payload          = payload
+
         @error_equals     = payload["ErrorEquals"]
         @interval_seconds = payload["IntervalSeconds"] || 1.0
         @max_attempts     = payload["MaxAttempts"] || 3
         @backoff_rate     = payload["BackoffRate"] || 2.0
+
+        missing_field_error!("ErrorEquals") if !@error_equals.kind_of?(Array) || @error_equals.empty?
       end
 
       # @param [Integer] attempt 1 for the first attempt
       def sleep_duration(attempt)
         interval_seconds * (backoff_rate**(attempt - 1))