Class: Fanforce::Worker::ErrorList

Inherits:
Object
  • Object
show all
Defined in:
lib/fanforce/worker/errors.rb

Constant Summary collapse

Error =
Fanforce::Worker::Error

Instance Method Summary collapse

Constructor Details

#initialize(queue_id, error_ids) ⇒ ErrorList

Returns a new instance of ErrorList.



157
158
159
160
# File 'lib/fanforce/worker/errors.rb', line 157

def initialize(queue_id, error_ids)
  @queue_id = queue_id
  @error_ids = error_ids
end

Instance Method Details

#deleteObject



190
191
192
193
194
195
196
197
# File 'lib/fanforce/worker/errors.rb', line 190

def delete
  redis.multi do
    @error_ids.each do |error_id|
      Error.delete(@queue_id, error_id)
    end
  end
  return nil
end

#redisObject



162
# File 'lib/fanforce/worker/errors.rb', line 162

def redis; Fanforce::Worker::Errors.redis end

#retryObject



176
177
178
179
180
181
182
183
184
185
186
187
188
# File 'lib/fanforce/worker/errors.rb', line 176

def retry
  redis_responses = []
  redis.multi do
    @error_ids.each do |error_id|
      redis_responses << Error.get_all(@queue_id, error_id)
    end
  end
  redis.multi do
    redis_responses.map do |redis_response|
      Error.retry(@queue_id, redis_response.value)
    end
  end
end

#summariesObject



164
165
166
167
168
169
170
171
172
173
174
# File 'lib/fanforce/worker/errors.rb', line 164

def summaries
  redis_responses = []
  redis.multi do
    @error_ids.each do |error_id|
      redis_responses << Error.get_summary(@queue_id, error_id)
    end
  end
  redis_responses.map do |redis_response|
    Error.format_summary(redis_response.value)
  end
end