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.



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

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

Instance Method Details

#deleteObject



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

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

#redisObject



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

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

#retryObject



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

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



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

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