gem 'safe', github: 'caiena/safe', branch: 'master'

# app/workflows/sample_workflow.rb
class NotificationWorkflow < SAFE::Workflow
  def configure(user_id)

    # método opcional, serve para linkar um objeto que responda ao método :id,
    # possibilitando o vínculo entra um workflow e o registro
    link User.find(user_id)

    run ComputeUserJob, params: { id: user_id }
    run UpdateUserJob, params: { id: user_id }

    run NotifyUserJob, after: [ComputeUserJob, UpdateUserJob], params: { id: user_id }

    run NotifyAdminJob, after: NotifyUserJob
  end
end

class ComputeUserJob < SAFE::Job
  # definição dos procedimentos a serem executados
  def perform
    # método com hash de variáveis passadas no workflow
    params #=> {id: 10}
    user = User.find(params[:id])

    # o método track aceita um bloco envolvendo uma etapa de
    # computação. Se o bloco não levantar um erro o método track
    # irá incrementar o número de sucessos do monitor do job em questão
    track { user.compute }
    track { user.finish_computation }
  end

  # número total de passos a serem executados dentro
  # do método perform. Nesse caso, o total são 2 pois
  # temos dois processamentos (um em cada block `track`)
  def total_steps
    2
  end
end

class UpdateUserJob < SAFE::Job

  def perform
    # o método order_and_track aceita uma coleção
    # de registros e um segundo parâmetro para ordenação.
    # Esse método deve envelopar coleções para o caso
    # de que o Job sofra um erro crítico, ao ser retomado,
    # o job irá iniciar a partir do último id registrado com sucesso.
    order_and_track(orders).each do |order|

      # agora o método track também aceita um objeto que responda a :id,
      # com isso a execução do bloco com sucesso registrará o id do último
      # registro executado com sucesso
      track(order) { order.compute }
    end
  end

  def total_steps
    orders.count
  end

  def orders
    @orders ||= User.find(params[:id]).orders
  end

  private

  # esse método permite que algumas exceções esperadas
  # evitem a falha de execução do job. Se uma dessas
  # exceções for levantada durante o processamento o método
  # `track` irá incrementar o número de falhas e criará um
  # registro de `error_occurrence` para o job.
  def recoverable_exceptions
    [OrderInvalidException, OrderNotFound]
  end
end

flow = NotificationWorkflow.create(user.id)

flow.start! #=> inicia os jobs em segundo plano

flow.reload
flow.status
#=> :running|:finished|:failed

monitor = flow.monitor
monitor #=> SAFE::WorkflowMonitor
monitor.monitorable #=> user<# id: 10>
monitor.jobs

job = monitor.jobs.first
job #=> SAFE::JobMonitor

job.processed
job.total #=> 2
job.successes
job.failures
job.processed

# erros recuperáveis geram ocorrências dentro de um job
occurrence = job.error_occurrences.first
occurrence #=> SAFE::ErrorOccurrence

# config/initializers/safe.rb
SAFE.configure do |config|
  config.ttl = 3600*24*10
end

rspec spec