#
# Testing OpenWFE
#
# John Mettraux at openwfe.org
#
# Sun Mar  9 20:43:02 JST 2008
#

require 'flowtestbase'

require 'openwfe/def'
require 'openwfe/worklist/storeparticipant'
require 'openwfe/storage/yamlcustom'


class FlowTest84 < Test::Unit::TestCase
    include FlowTestBase

    #def teardown
    #end

    #def setup
    #end

    #
    # TEST 0

    class TestDefinition0 < ProcessDefinition
       sequence do
           set :var => "v0", :val => "val0"
           store_p
       end
    end

    def test_0

        #sp = @engine.register_participant("store_p", OpenWFE::YamlParticipant)
        sp = @engine.register_participant("store_p", OpenWFE::HashParticipant)

        fei = @engine.launch TestDefinition0

        sleep 0.350

        s = @engine.process_stack fei, true

        env = s.find { |fexp| fexp.is_a?(OpenWFE::Environment) }
        par = s.find { |fexp| fexp.is_a?(OpenWFE::ParticipantExpression) }

        #
        # testing update on env

        assert_equal "val0", @engine.lookup_variable("v0", fei)

        @engine.update_expression_data(
            env.fei, { "v0" => "val0b", "v1" => "val1" })

        assert_equal "val0b", @engine.lookup_variable("v0", fei)
        assert_equal "val1", @engine.lookup_variable("v1", fei)

        #
        # testing update on participant expression

        assert [ 1, 2 ], par.applied_workitem.attributes

        @engine.update_expression_data par.fei, { 'f0' => 'val0' }

        s = @engine.process_stack fei
        par = s.find { |fexp| fexp.is_a?(OpenWFE::ParticipantExpression) }

        assert_equal 'val0', par.applied_workitem.attributes['f0']

        @engine.cancel_process fei.wfid

        sleep 0.350
    end

    #
    # TEST 1

    class TestDefinition1 < ProcessDefinition
       sequence do
           participant "alpha"
           participant "bravo"
       end
    end

    def test_1

        %w{ alpha bravo charly }.each do |pname|
            @engine.register_participant pname, OpenWFE::HashParticipant
        end

        fei = @engine.launch TestDefinition1

        sleep 0.350

        assert 1, @engine.get_participant("alpha").size
        assert 0, @engine.get_participant("bravo").size
        assert 0, @engine.get_participant("charly").size

        ps = @engine.process_stack fei.wfid, true
        #puts ps.collect { |fexp| fexp.to_yaml }.join("\n")

        ebravo = ps.find { |fexp| fexp.fei.expid == '0.0.1' }
        scharly = ebravo.to_yaml.gsub /bravo/, "charly"

        @engine.update_expression(YAML.load(scharly))

        wi = @engine.get_participant("alpha").first_workitem
        @engine.get_participant("alpha").forward(wi)

        sleep 0.350

        assert 0, @engine.get_participant("alpha").size
        assert 0, @engine.get_participant("bravo").size
        assert 1, @engine.get_participant("charly").size

        @engine.cancel_process fei.wfid

        sleep 0.350
    end

end