participant : setting the field 'params'

TODO.txt

@@ -34,7 +34,7 @@
 
 [o] wi test (and fix) ${f:xyz}
 [o] wi#to_h #from_h
-[ ] wi.params ?
+[o] wi.params
 
 [o] self rec for [main] process
 

lib/ruote/exp/attribute.rb → lib/ruote/exp/attributes.rb

@@ -29,7 +29,7 @@ module Ruote
   # Those methods are mixed in FlowExpression. They were put here to offload
   # FlowExpression and especially, to gather them around their attribute topic.
   #
-  module AttributeMixin
+  module AttributesMixin
 
     # Given a list of attribute names, returns the first attribute name for
     # which there is a value.
@@ -112,6 +112,14 @@ def lookup_value (prefix)
       end
     end
 
+    # Returns a Hash containing all attributes set for an expression with
+    # their values resolved.
+    #
+    def lookup_attributes
+
+      attributes.keys.inject({}) { |h, k| h[k] = attribute(k); h }
+    end
+
     protected
 
     def list_att_keys (prefix, suffixes)

lib/ruote/exp/fe_participant.rb

@@ -55,15 +55,13 @@ def apply
       ) unless participant
 
       @applied_workitem.participant_name = @participant_name
+      @applied_workitem.fields['params'] = lookup_attributes
 
       persist
 
       dispatch_to(participant)
     end
 
-    #def reply (workitem)
-    #end
-
     def cancel
 
       participant = plist.lookup(@participant_name)
@@ -73,6 +71,12 @@ def cancel
       reply_to_parent(@applied_workitem)
     end
 
+    def reply_to_parent (workitem)
+
+      workitem.fields.delete('params')
+      super(workitem)
+    end
+
     protected
 
     def dispatch_to (participant)

lib/ruote/exp/flowexpression.rb

@@ -25,15 +25,15 @@
 require 'ruote/util/ometa'
 require 'ruote/util/dollar'
 require 'ruote/engine/context'
-require 'ruote/exp/attribute'
+require 'ruote/exp/attributes'
 
 
 module Ruote
 
   class FlowExpression < ObjectWithMeta
 
     include EngineContext
-    include AttributeMixin
+    include AttributesMixin
 
 
     attr_accessor :fei

test/functional/eft_6_concurrence.rb

@@ -123,7 +123,7 @@ def test_concurrence_merge_type_isolate
     wi = run_concurrence({ :merge_type => :isolate }, false)
 
     assert_equal(
-      {1=>{"seen"=>"0_0_0_1"}, 0=>{"seen"=>"0_0_0_0"}},
+      {1=>{"seen"=>"0_0_0_1"}, 0=>{"seen"=>"0_0_0_0"}, "params"=>{"ref"=>"alpha"}},
       wi.fields)
   end
 

test/functional/ft_16_participant_params.rb

@@ -0,0 +1,45 @@
+
+#
+# Testing Ruote (OpenWFEru)
+#
+# Wed Jul  1 09:51:30 JST 2009
+#
+
+require File.dirname(__FILE__) + '/base'
+
+require 'ruote/part/hash_participant'
+
+
+class FtParticipantParamsTest < Test::Unit::TestCase
+  include FunctionalBase
+
+  def test_params
+
+    pdef = Ruote.process_definition do
+      sequence do
+        alpha
+        alpha :activity => 'buy groceries'
+        alpha
+      end
+    end
+
+    alpha = @engine.register_participant :alpha, Ruote::HashParticipant
+
+    #noisy
+
+    wfid = @engine.launch(pdef)
+
+    wait_for(:alpha)
+    assert_equal({ 'ref' => 'alpha' }, alpha.first.fields['params'])
+    alpha.reply(alpha.first)
+
+    wait_for(:alpha)
+    assert_equal('buy groceries', alpha.first.fields['params']['activity'])
+    alpha.reply(alpha.first)
+
+    wait_for(:alpha)
+    assert_equal({ 'ref' => 'alpha' }, alpha.first.fields['params'])
+    alpha.reply(alpha.first)
+  end
+end
+