Project: OpenWFEru

Revision: 1655

Author: jmettraux

Date: 09 Apr 2008 22:00:10

• /tags/engine__before_move_to_github/test/ft_54b_listen.rb

  ......	@@ -0,0 +1,66 @@
  	1
  	2	#
  	3	# Testing OpenWFEru
  	4	#
  	5	# John Mettraux at openwfe.org
  	6	#
  	7
  	8	require 'flowtestbase'
  	9	require 'openwfe/def'
  	10	require 'openwfe/participants/participants'
  	11
  	12
  	13	class FlowTest54b < Test::Unit::TestCase
  	14	include FlowTestBase
  	15
  	16	#def setup
  	17	#end
  	18
  	19	#def teardown
  	20	#end
  	21
  	22
  	23	#
  	24	# Test 0
  	25	#
  	26
  	27	class Test0 < OpenWFE::ProcessDefinition
  	28	sequence do
  	29	listen :to => "^channel_.$", :upon => :reply
  	30	_print "ok"
  	31	end
  	32	end
  	33
  	34	def test_0
  	35
  	36	#log_level_to_debug
  	37
  	38	@engine.launch Test0
  	39
  	40	sleep 0.350
  	41
  	42	assert_equal @tracer.to_s, ""
  	43
  	44	wi = OpenWFE::InFlowWorkItem.new
  	45	wi.participant_name = "channel_z"
  	46
  	47	r = @engine.reply wi
  	48	assert r
  	49
  	50	sleep 0.350
  	51
  	52	#
  	53	# "post test", checking that engine replies 'false' when
  	54	# nobody consumed the message
  	55
  	56	assert_equal @tracer.to_s, "ok"
  	57
  	58	wi = OpenWFE::InFlowWorkItem.new
  	59	wi.participant_name = "channel_unknown"
  	60
  	61	r = @engine.reply wi
  	62	assert (not r)
  	63	end
  	64
  	65	end
  	66

• /tags/engine__before_move_to_github/test/ps_representation.rb

  ......	@@ -0,0 +1,70 @@
  	1
  	2	#
  	3	# Testing OpenWFE
  	4	#
  	5	# John Mettraux at openwfe.org
  	6	#
  	7	# Tue Apr 8 18:33:11 JST 2008
  	8	#
  	9
  	10	require 'rubygems'
  	11
  	12	require 'test/unit'
  	13
  	14	require 'openwfe/engine'
  	15
  	16
  	17	class PsRepresentationTest < Test::Unit::TestCase
  	18
  	19	def setup
  	20
  	21	@engine = OpenWFE::Engine.new
  	22	end
  	23
  	24	def teardown
  	25
  	26	@engine.stop if @engine
  	27	end
  	28
  	29	#
  	30	# TESTS
  	31
  	32	class Test0 < OpenW
  0	33	[the rest of the diff is cut off - it was too big (1739091). Our limit is 50000.]

• /tags/engine__before_move_to_github/test/ft_23c_wait.rb

  ......	@@ -0,0 +1,80 @@
  	1
  	2	#
  	3	# Testing OpenWFEru
  	4	#
  	5	# John Mettraux at openwfe.org
  	6	#
  	7
  	8	require 'flowtestbase'
  	9	require 'openwfe/def'
  	10
  	11
  	12	class FlowTest23c < Test::Unit::TestCase
  	13	include FlowTestBase
  	14
  	15	#def setup
  	16	#end
  	17
  	18	#def teardown
  	19	#end
  	20
  	21	#
  	22	# Test 0
  	23	#
  	24
  	25	class Wait0c < OpenWFE::ProcessDefinition
  	26	sequence do
  	27	concurrence do
  	28	sequence do
  	29	wait :until => "${done} == true", :frequency => "500"
  	30	_print "after wait"
  	31	end
  	32	sequence do
  	33	_sleep "200"
  	34	_print "before done"
  	35	_set :variable => "done", :value => "true"
  	36	end
  	37	end
  	38	_print "over"
  	39	end
  	40	end
  	41
  	42	def test_0
  	43
  	44	#log_level_to_debug
  	45
  	46	dotest Wait0c, [ 'before done', 'after wait', 'over' ].join("\n")
  	47	end
  	48
  	49	#
  	50	# Test 1
  	51	#
  	52
  	53	class Wait1c < OpenWFE::ProcessDefinition
  	54	sequence do
  	55	concurrence do
  	56	sequence do
  	57	wait :frequency => "500" do
  	58	equals :variable_value => "done", :other_value => "true"
  	59	end
  	60	_print "after wait"
  	61	end
  	62	sequence do
  	63	_sleep "200"
  	64	_print "before done"
  	65	_set :variable => "done", :value => "true"
  	66	end
  	67	end
  	68	_print "over"
  	69	end
  	70	end
  	71
  	72	def test_1
  	73
  	74	#log_level_to_debug
  	75
  	76	dotest Wait1c, [ 'before done', 'after wait', 'over' ].join("\n")
  	77	end
  	78
  	79	end
  	80

• /tags/engine__before_move_to_github/test/ft_38_tag.rb

  ......	@@ -0,0 +1,127 @@
  	1
  	2	#
  	3	# Testing OpenWFE
  	4	#
  	5	# John Mettraux at openwfe.org
  	6	#
  	7	# Mon Oct 9 22:19:44 JST 2006
  	8	#
  	9
  	10	require 'flowtestbase'
  	11
  	12	require 'openwfe/def'
  	13
  	14
  	15	class FlowTest38 < Test::Unit::TestCase
  	16	include FlowTestBase
  	17
  	18	#def teardown
  	19	#end
  	20
  	21	#def setup
  	22	#end
  	23
  	24	#
  	25	# test 0
  	26	#
  	27
  	28	class TestTag0 < OpenWFE::ProcessDefinition
  	29	concurrence do
  	30	sequence :tag => "seq0" do
  	31	_sleep "1s"
  	32	_print "hello"
  	33	end
  	34	_undo :ref => "seq0"
  	35	_print "blah"
  	36	end
  	37	end
  	38
  	39	def test_tag_0
  	40
  	41	#log_level_to_debug
  	42
  	43	dotest TestTag0, "blah"
  	44	end
  	45
  	46
  	47	#
  	48	# test 1
  	49	#
  	50
  	51	class TestTag1 < OpenWFE::ProcessDefinition
  	52	concurrence do
  	53	sequence :tag => "seq0" do
  	54	count
  	55	_sleep "1s"
  	56	_print "hello"
  	57	end
  	58	_redo :ref => "seq0"
  	59	_print "blah"
  	60	end
  	61	end
  	62
  	63	def test_tag_1
  	64
  	65	count = 0
  	66
  	67	@engine.register_participant :count do
  	68	count += 1
  	69	end
  	70
  	71	dotest TestTag1, "blah\nhello"
  	72
  	73	assert_equal 1, count
  	74	end
  	75
  	76
  	77	#
  	78	# test 2
  	79	#
  	80
  	81	class TestTag2 < OpenWFE::ProcessDefinition
  	82	sequence do
  	83	sequence :tag => "seq0" do
  	84	count
  	85	_print "hello"
  	86	end
  	87	_redo :ref => "seq0"
  	88	_print "blah"
  	89	end
  	90	end
  	91
  	92	def test_tag_2
  	93
  	94	count = 0
  	95
  	96	@engine.register_participant(:count) do
  	97	count += 1
  	98	end
  	99
  	100	dotest TestTag2, "hello\nblah", true
  	101
  	102	assert_equal 1, count
  	103	end
  	104
  	105
  	106	#
  	107	# test 3
  	108	#
  	109
  	110	class TestTag3 < OpenWFE::ProcessDefinition
  	111	sequence do
  	112	sequence :tag => "seq0" do
  	113	_print "1"
  	114	undo :ref => "seq0"
  	115	_print "2"
  	116	end
  	117	_print "3"
  	118	end
  	119	end
  	120
  	121	def test_tag_3
  	122
  	123	dotest TestTag3, "1\n3"
  	124	end
  	125
  	126	end
  	127

• /tags/engine__before_move_to_github/test/file_persistence_test.rb

  ......	@@ -0,0 +1,134 @@
  	1
  	2	require 'test/unit'
  	3
  	4	require 'openwfe/engine/engine'
  	5	require 'openwfe/expool/expstorage'
  	6	require 'openwfe/expool/yamlexpstorage'
  	7
  	8
  	9	class FilePersistenceTest < Test::Unit::TestCase
  	10
  	11	def setup
  	12	@engine = Engine.new
  	13	end
  	14
  	15	def teardown
  	16	@engine.stop
  	17	end
  	18
  	19	def ac
  	20	@engine.application_context
  	21	end
  	22
  	23	#
  	24	# test persistence using yaml
  	25	def test_yaml_persistence
  	26	fes = OpenWFE::YamlFileExpressionStorage.new("yaml", ac)
  	27	test_persistence(fes)
  	28	end
  	29
  	30	#
  	31	# flow expression check
  	32	def test_flow_expression
  	33	fei = new_fei()
  	34	fes = OpenWFE::YamlFileExpressionStorage.new "yaml", ac
  	35	fe = OpenWFE::SequenceExpression.new_exp fei, nil, nil, nil, nil
  	36	test_persistence(fes,fe)
  	37	end
  	38
  	39	def test_path_splitting
  	40
  	41	fei = new_fei
  	42	fes = OpenWFE::YamlFileExpressionStorage.new("yaml", ac)
  	43	class << fes
  	44	public :compute_file_path
  	45	end
  	46	path = fes.compute_file_path fei
  	47	a = fes.class.split_file_path path
  	48
  	49	assert_equal a[0], fei.wfid
  	50	assert_equal a[1], fei.expression_id
  	51	assert_equal a[2], fei.expression_name
  	52	end
  	53
  	54	def test_other_workdir
  	55
  	56	context = ac
  	57	context[:work_directory] = "work2"
  	58
  	59	fei = new_fei()
  	60	fes = OpenWFE::YamlFileExpressionStorage.new("yaml", ac)
  	61	#fe = SequenceExpression.new(fei, nil, nil, nil, nil)
  	62	#fes[fei] = fe
  	63
  	64	assert File.exist?("work2")
  	65
  	66	FileUtils.rm_rf("work2")
  	67	assert (not File.exist?("work2"))
  	68	end
  	69
  	70	#
  	71	# test UTF-8 data persistence
  	72	def test_utf8_with_file
  	73
  	74	workflow_definition_name = "みんなにARIGATOU★☆に関する最新の情報公開"
  	75	fei = new_fei workflow_definition_name
  	76	fes = OpenWFE::YamlFileExpressionStorage.new "yaml", ac
  	77	fe = OpenWFE::SequenceExpression.new_exp fei, nil, nil, nil, nil
  	78
  	79	loaded = test_persistence(fes, fe)
  	80
  	81	#puts
  	82	#puts fei.workflow_definition_name
  	83	#puts loaded.fei.workflow_definition_name
  	84
  	85	assert_equal loaded.fei.workflow_definition_name, fei.workflow_definition_name
  	86	end
  	87
  	88
  	89	protected
  	90
  	91	def test_persistence (fes, fe=nil)
  	92
  	93	fei = new_fei()
  	94	fes.delete(fei) if (fes.has_key?(fei))
  	95
  	96	raw = fe ? \
  	97	fe : \
  	98	OpenWFE::RawExpression.new_raw(fei, 'parent', 'env', nil, nil)
  	99
  	100	assert \
  	101	(not fes.has_key?(fei)),
  	102	"they key is present in the file system. "+
  	103	"Maybe a previous test did not delete the "
  	104
  	105	fes[fei] = raw
  	106	assert fes.has_key?(fei)
  	107
  	108	loaded = fes[fei]
  	109
  	110	fes.delete(fei)
  	111	assert !(fes.has_key?(fei))
  	112	return loaded
  	113	end
  	114
  	115	def new_fei (definition_name=nil)
  	116
  	117	fei = OpenWFE::FlowExpressionId.new()
  	118	fei.owfe_version = OPENWFERU_VERSION
  	119	fei.engine_id = 'this'
  	120	fei.initial_engine_id = 'that'
  	121	fei.workflow_definition_url = 'http://test/test.xml'
  	122	fei.workflow_definition_name = if definition_name == nil
  	123	'test'
  	124	else
  	125	definition_name
  	126	end
  	127	fei.workflow_definition_revision = '1.0'
  	128	fei.workflow_instance_id = @engine.get_wfid_generator.generate
  	129	fei.expression_name = 'do-test'
  	130	fei.expression_id = '0.0'
  	131	return fei
  	132	end
  	133
  	134	end

• /tags/engine__before_move_to_github/test/ft_57_a.rb

  ......	@@ -0,0 +1,124 @@
  	1
  	2	#
  	3	# Testing OpenWFEru
  	4	#
  	5	# John Mettraux at openwfe.org
  	6	#
  	7
  	8	require 'flowtestbase'
  	9	require 'pending'
  	10	require 'openwfe/def'
  	11
  	12
  	13	class FlowTest57 < Test::Unit::TestCase
  	14	include FlowTestBase
  	15
  	16	#def setup
  	17	#end
  	18
  	19	#def teardown
  	20	#end
  	21
  	22
  	23	#
  	24	# Test 0
  	25	#
  	26
  	27	class Test0 < OpenWFE::ProcessDefinition
  	28	sequence do
  	29	_set :field => "list" do
  	30	_a """
  	31	<list>
  	32	<string>a</string>
  	33	<string>b</string>
  	34	<string>c</string>
  	35	</list>
  	36	"""
  	37	end
  	38	_print "${r:wi.list.join('|')}"
  	39	_print "-"
  	40	_set :field => "list" do
  	41	_attribute """
  	42	---
  	43	- a
  	44	- b
  	45	- 3
  	46	"""
  	47	end
  	48	_print "${r:wi.list.join('|')}"
  	49	end
  	50	end
  	51
  	52	def test_0
  	53
  	54	dotest(
  	55	Test0,
  	56	"""
  	57	a|b|c
  	58	-
  	59	a|b|3
  	60	""".strip)
  	61	end
  	62
  	63	def test_1
  	64
  	65	dotest(
  	66	"""
  	67	<process-definition name='57_b' revision='1'>
  	68	<sequence>
  	69	<set field='list'>
  	70	<a>
  	71	---
  	72	- c
  	73	- d
  	74	- e
  	75	</a>
  	76	</set>
  	77	<print>${r:wi.list.join('|')}</print>
  	78	</sequence>
  	79	</process-definition>
  	80	""",
  	81	"c|d|e")
  	82	end
  	83
  	84	def test_2
  	85
  	86	dotest(
  	87	"""
  	88	<process-definition name='57_c' revision='2'>
  	89	<sequence>
  	90	<set field='list'>
  	91	<a>
  	92	<list>
  	93	<string>a</string>
  	94	<string>2</string>
  	95	<string>c</string>
  	96	</list>
  	97	</a>
  	98	</set>
  	99	<print>${r:wi.list.join('|').strip}</print>
  	100	</sequence>
  	101	</process-definition>
  	102	""",
  	103	"a|2|c")
  	104	end
  	105
  	106	#
  	107	# Test 3
  	108	#
  	109
  	110	class Test3 < OpenWFE::ProcessDefinition
  	111	sequence do
  	112	_set :field => "other" do
  	113	reval { "77" }
  	114	end
  	115	_print "${f:other}"
  	116	end
  	117	end
  	118
  	119	def test_3
  	120
  	121	dotest Test3, "77"
  	122	end
  	123	end
  	124

• /tags/engine__before_move_to_github/test/ft_44b_restore.rb

  ......	@@ -0,0 +1,212 @@
  	1
  	2	#
  	3	# Testing OpenWFEru
  	4	#
  	5	# John Mettraux at openwfe.org
  	6	#
  	7
  	8	require 'flowtestbase'
  	9	require 'openwfe/def'
  	10
  	11
  	12	class FlowTest44b < Test::Unit::TestCase
  	13	include FlowTestBase
  	14
  	15	#def setup
  	16	#end
  	17
  	18	#def teardown
  	19	#end
  	20
  	21
  	22	#
  	23	# Test 0
  	24	#
  	25
  	26	class TestCase44b0 < OpenWFE::ProcessDefinition
  	27	sequence do
  	28	set :field => "f", :value => "v"
  	29	save :to_field => "saved"
  	30	#pp_workitem
  	31	_print "${f:saved.f}"
  	32	restore :from_field => "saved"
  	33	_print "${f:saved.f}"
  	34	_print "${f:f}"
  	35	end
  	36	end
  	37
  	38	def test_0
  	39
  	40	dotest TestCase44b0, "v\n\nv"
  	41	end
  	42
  	43
  	44	#
  	45	# Test 1
  	46	#
  	47
  	48	class TestCase44b1 < OpenWFE::ProcessDefinition
  	49	sequence do
  	50	set :field => "f", :value => "field_value"
  	51	save :to_variable => "v"
  	52	#pp_workitem
  	53	set :field => "f", :value => "field_value_x"
  	54	_print "${f:f}"
  	55	restore :from_variable => "v"
  	56	_print "${f:f}"
  	57	end
  	58	end
  	59
  	60	def test_1
  	61
  	62	dotest TestCase44b1, "field_value_x\nfield_value"
  	63	end
  	64
  	65
  	66	#
  	67	# Test 2
  	68	#
  	69
  	70	class TestCase44b2 < OpenWFE::ProcessDefinition
  	71	sequence do
  	72	set :field => "f", :value => "field_value"
  	73	save :to_variable => "v"
  	74	restore :from_variable => :v, :to_field => :f1
  	75	#pp_workitem
  	76	_print "${f:f1.f}"
  	77	end
  	78	end
  	79
  	80	def test_2
  	81
  	82	dotest TestCase44b2, "field_value"
  	83	end
  	84
  	85
  	86	#
  	87	# Test 3
  	88	#
  	89
  	90	class TestCase44b3 < OpenWFE::ProcessDefinition
  	91	sequence do
  	92	set :field => "f0", :value => "value_a"
  	93	save :to_variable => "v"
  	94	set :field => "f0", :value => "value_aa"
  	95	set :field => "f1", :value => "value_b"
  	96	restore :from_variable => :v, :merge_lead => :current
  	97	#pp_workitem
  	98	_print "${f:f0}"
  	99	_print "${f:f1}"
  	100	end
  	101	end
  	102
  	103	def test_3
  	104
  	105	dotest TestCase44b3, "value_aa\nvalue_b"
  	106	end
  	107
  	108
  	109	#
  	110	# Test 4
  	111	#
  	112
  	113	class TestCase44b4 < OpenWFE::ProcessDefinition
  	114	sequence do
  	115	set :field => "f0", :value => "value_a"
  	116	save :to_variable => "v"
  	117	set :field => "f0", :value => "value_aa"
  	118	set :field => "f1", :value => "value_b"
  	119	restore :from_variable => :v, :merge_lead => :restored
  	120	#pp_workitem
  	121	_print "${f:f0}"
  	122	_print "${f:f1}"
  	123	end
  	124	end
  	125
  	126	def test_4
  	127
  	128	dotest TestCase44b4, "value_a\nvalue_b"
  	129	end
  	130
  	131	# tests about set_fields...
  	132
  	133	#
  	134	# Test 5
  	135	#
  	136
  	137	class Test44b5 < OpenWFE::ProcessDefinition
  	138	sequence do
  	139	set_fields :value => {
  	140	"customer" => { "name" => "Zigue", "age" => 34 },
  	141	"approved" => false }
  	142	_print "${f:customer.name} (${f:customer.age}) ${f:approved}"
  	143	#pp_fields
  	144	end
  	145	end
  	146
  	147	def test_5
  	148
  	149	dotest Test44b5, "Zigue (34) false"
  	150	end
  	151
  	152	#
  	153	# Test 6
  	154	#
  	155
  	156	class Test44b6 < OpenWFE::ProcessDefinition
  	157	set_fields :value => {
  	158	"customer" => { "name" => "Zigue", "age" => 34 },
  	159	"approved" => false }
  	160	sequence do
  	161	_print "${f:customer.name} (${f:customer.age}) ${f:approved}"
  	162	end
  	163	end
  	164
  	165	def test_6
  	166
  	167	dotest Test44b6, "Zigue (34) false"
  	168	end
  	169
  	170	#
  	171	# Test 7
  	172	#
  	173
  	174	class Test44b7 < OpenWFE::ProcessDefinition
  	175	set_fields do
  	176	{
  	177	"customer" => { "name" => "Zigue", "age" => 34 },
  	178	"approved" => false
  	179	}
  	180	end
  	181	sequence do
  	182	_print "${f:customer.name} (${f:customer.age}) ${f:approved}"
  	183	end
  	184	end
  	185
  	186	def _test_7
  	187
  	188	dotest Test44b7, "Zigue (34) false"
  	189	end
  	190
  	191	#
  	192	# Test 8
  	193	#
  	194
  	195	class Test44b8 < OpenWFE::ProcessDefinition
  	196	set_fields :value => {