qs.rb

require 'rubygems'
require 'openwfe/engine/file_persisted_engine' # sudo gem install ruote

engine = OpenWFE::FilePersistedEngine.new(
  :definition_in_launchitem_allowed => true)

#
# the process definition

class MyTodoProcess < OpenWFE::ProcessDefinition
  cursor do
    perform_task
    continue :unless => "${f:over}"
  end
end

#
# the participant

engine.register_participant :perform_task do |workitem|
  puts
  puts "  done :"
  workitem.done.each do |task, time|
    puts "- #{task} - #{time}"
  end
  puts
  puts "  todo :"
  workitem.todo.each_with_index do |task, i|
    puts "#{i}) #{task}"
  end
  puts
  print "task # (n for new, x for exit) ==> "
  i = gets.strip
  if i == 'n'
    print "new task : "
    workitem.todo << gets.strip
  elsif i == 'x'
    exit 0
  else
    t = workitem.todo.delete_at(i.to_i)
    workitem.done << [ t, Time.now.to_s ] if t
  end
  workitem.over = (workitem.todo.size == 0)
end

#
# process already running ?

ps = engine.process_statuses.values[0]

fei = if ps

  #
  # yes, there is already a running process, resume it...

  engine.replay_at_error(ps.errors.values[0])

  puts "using already launched process..."

  sleep 0.350

  ps.wfid

else

  #
  # no process running, launch a new one...

  li = OpenWFE::LaunchItem.new(MyTodoProcess)
  li.goal = "meeting preparation"
  li.todo = [
    "reserve room",
    "reserve beamer",
    "send invitations",
    "order sandwiches"
  ]
  li.done = []

  engine.launch(li)

end

#
# don't exit before the process is over

engine.wait_for(fei)