diff options
| -rw-r--r-- | lib/WebCoso/Driver.pm | 5 | ||||
| -rw-r--r-- | t/02-driver.t | 13 | ||||
| -rw-r--r-- | t/lib/WebCoso/Pipeline/Test.pm | 6 |
3 files changed, 18 insertions, 6 deletions
diff --git a/lib/WebCoso/Driver.pm b/lib/WebCoso/Driver.pm index 2bbafbd..d5e1db8 100644 --- a/lib/WebCoso/Driver.pm +++ b/lib/WebCoso/Driver.pm @@ -7,7 +7,10 @@ sub run { my @resources=WebCoso::Config->get_all_resources(); for my $resource (@resources) { - WebCoso::Config->get_pipeline_for($resource)->process($resource); + WebCoso::Config->get_pipeline_for($resource)->process($resource,'meta'); + } + for my $resource (@resources) { + WebCoso::Config->get_pipeline_for($resource)->process($resource,'gen'); } return 1; diff --git a/t/02-driver.t b/t/02-driver.t index 444d5d6..bdcf78b 100644 --- a/t/02-driver.t +++ b/t/02-driver.t @@ -21,7 +21,16 @@ ok(WebCoso::Driver->run(), 'il driver va'); my @calls=WebCoso::Pipeline::Test->get_calls(); my @resources=WebCoso::Config->get_all_resources(); -is(scalar @calls,1,'una chiamata'); +is(scalar @calls,2,'due chiamate'); is($calls[0]->{resource}, $resources[0], - 'alla risorsa giusta'); + 'alla risorsa giusta (1)'); +is($calls[1]->{resource}, + $resources[0], + 'alla risorsa giusta (2)'); +is($calls[0]->{stage}, + 'meta', + 'stage1==meta'); +is($calls[1]->{stage}, + 'gen', + 'stage1==gen'); diff --git a/t/lib/WebCoso/Pipeline/Test.pm b/t/lib/WebCoso/Pipeline/Test.pm index 6920f46..2d13d69 100644 --- a/t/lib/WebCoso/Pipeline/Test.pm +++ b/t/lib/WebCoso/Pipeline/Test.pm @@ -8,11 +8,11 @@ __PACKAGE__->set_steps(qw(Step1 Step2)); my @calls; sub process { - my ($class,$resource)=@_; + my ($class,$resource,$stage)=@_; - my $call={ resource => $resource }; + my $call={ resource => $resource, stage => $stage }; - my $ret=$class->SUPER::process($resource); + my $ret=$class->SUPER::process($resource,$stage); push @calls, $call; |