Contents

require "novel"
require 'dry/monads'

class BaseStep
  include Dry::Monads[:result]

  def call(context)
    puts "Step #{self.class}, context: #{context.inspect}"
    puts
    Success(result: rand(1..100))
  end
end

class ReserveCar < BaseStep
  def call(context)
    puts "Step #{self.class}, context: #{context.inspect}"
    puts
    Success(result: rand(1..100))
  end
end

class BookHotelProducer < BaseStep; end
class BookHotelHandler < BaseStep; end
class BookTools < BaseStep; end
class BookFlight < BaseStep; end

class CancelCar < BaseStep; end
class CancelHotelProducer < BaseStep; end
class CancelHotelHandler < BaseStep; end
class CancelTools < BaseStep; end
class CancelFlight < BaseStep; end

saga = Novel.compose(logger: Logger.new(STDOUT), repository: :memory) # timeout in seconds
      .build(name: :booking)
      .register_step(:car,           activity: { command: ReserveCar.new },        compensation: { command: CancelCar.new, retry: 3 })
      .register_step(:notify_hotel,  activity: { command: BookHotelProducer.new }, compensation: { command: CancelHotelHandler.new })
      .register_step(:handle_hotel,  activity: { command: BookHotelHandler.new },  compensation: { command: CancelHotelProducer.new })
      .register_step(:tools,         activity: { command: BookTools.new },         compensation: { command: CancelTools.new })
      .register_step(:flight,        activity: { command: BookFlight.new },        compensation: { command: CancelFlight.new })
      .build

result = saga.call(params: { a: 1 })

pp result

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
novel-0.3.0	examples/success_saga.rb