Contents

#
# Testing OpenWFE
#
# John Mettraux at openwfe.org
#
# Tue Feb 19 10:58:43 JST 2008
#

require 'rubygems'

require 'test/unit'
require 'fileutils'
require 'openwfe/def'
require 'openwfe/engine/file_persisted_engine'


class Back0916Test < Test::Unit::TestCase

  WORK = 'work_back'

  def setup

    FileUtils.rm_rf WORK
    FileUtils.mkdir WORK

    `cd work_back && tar xzvf ../test/expool_20031219_0916.tgz`

    ac = { :work_directory => WORK }

    @engine = OpenWFE::FilePersistedEngine.new ac
  end

  def teardown

    $OWFE_LOG.level = Logger::INFO
    FileUtils.rm_rf WORK
  end

  def test_0

    $OWFE_LOG.level = Logger::DEBUG

    trace = []

    @engine.register_participant :alpha do
      trace << :alpha
    end

    @engine.reload

    ps = @engine.process_status '20080212-moshijuzuke' # an XML process
    #p ps.expressions.collect { |e| e.fei.to_s }
    exp = ps.expressions.first
    wi = exp.applied_workitem
    wi.message = "back from obsolesence"

    @engine.reply wi

    sleep 0.350

    assert_equal [ :alpha ], trace

    ps = @engine.process_status '20080212-moshijuzuke'
    #puts ps.size
    #puts ps.collect { |e| e.fei.to_s }.join("\n")

    assert_nil ps

    @engine.stop

    sleep 0.300
  end

  def test_1

    $OWFE_LOG.level = Logger::DEBUG

    trace = []

    #@engine.register_participant :employee do
    #  trace << :assistant
    #end
    #@engine.register_participant :employee do
    #  trace << :employee
    #end
    [ :user_bob, :user_alice ].each do |p|
      @engine.register_participant(p) { trace << p }
    end

    @engine.reload

    ps = @engine.process_status '20080213-depejetzube' # a ruby procdef
    exp = ps.expressions.first
    wi = exp.applied_workitem

    @engine.reply wi

    sleep 0.400

    assert_equal [ :user_bob, :user_bob ], trace

    assert_nil @engine.process_status('20080213-depejetzube')

    @engine.stop

    sleep 0.300
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ruote-0.9.19	test/back_0916_test.rb