@@ -4,9 +4,9 @@ pub mod models;
44mod unit_tests {
55
66 use crate :: models:: duration:: * ;
7- use crate :: models:: map:: * ;
8- use crate :: models:: task:: * ;
97 use crate :: models:: workflow:: * ;
8+ use crate :: models:: task:: * ;
9+ use crate :: models:: map:: * ;
1010 use serde_json:: json;
1111
1212 #[ test]
@@ -16,43 +16,19 @@ mod unit_tests {
1616 let version = "1.0.0" ;
1717 let title = Some ( "fake-title" . to_string ( ) ) ;
1818 let summary = Some ( "fake-summary" . to_string ( ) ) ;
19- let document = WorkflowDefinitionMetadata :: new (
20- namespace,
21- name,
22- version,
23- title. clone ( ) ,
24- summary. clone ( ) ,
25- None ,
26- ) ;
19+ let document = WorkflowDefinitionMetadata :: new ( namespace, name, version, title. clone ( ) , summary. clone ( ) , None ) ;
2720 let mut call_task = CallTaskDefinition :: new ( "http" , None , Some ( true ) ) ;
2821 call_task. common . then = Some ( "continue" . to_string ( ) ) ;
29- let do_task = DoTaskDefinition :: new ( Map :: from ( vec ! [ (
30- "set" . to_string( ) ,
31- TaskDefinition :: Wait ( WaitTaskDefinition :: new(
32- OneOfDurationOrIso8601Expression :: Duration ( Duration :: from_milliseconds( 200 ) ) ,
33- ) ) ,
34- ) ] ) ) ;
22+ let do_task = DoTaskDefinition :: new ( Map :: from ( vec ! [ ( "set" . to_string( ) , TaskDefinition :: Wait ( WaitTaskDefinition :: new( OneOfDurationOrIso8601Expression :: Duration ( Duration :: from_milliseconds( 200 ) ) ) ) ) ] ) ) ;
3523 let mut workflow = WorkflowDefinition :: new ( document) ;
3624 workflow. do_ = Map :: new ( ) ;
37- workflow
38- . do_
39- . add ( "callTask" . to_string ( ) , TaskDefinition :: Call ( call_task) ) ;
40- workflow
41- . do_
42- . add ( "doTask" . to_string ( ) , TaskDefinition :: Do ( do_task) ) ;
25+ workflow. do_ . add ( "callTask" . to_string ( ) , TaskDefinition :: Call ( call_task) ) ;
26+ workflow. do_ . add ( "doTask" . to_string ( ) , TaskDefinition :: Do ( do_task) ) ;
4327 let json_serialization_result = serde_json:: to_string_pretty ( & workflow) ;
4428 let yaml_serialization_result = serde_yaml:: to_string ( & workflow) ;
45- assert ! (
46- json_serialization_result. is_ok( ) ,
47- "JSON Serialization failed: {:?}" ,
48- json_serialization_result. err( )
49- ) ;
50- assert ! (
51- yaml_serialization_result. is_ok( ) ,
52- "YAML Serialization failed: {:?}" ,
53- yaml_serialization_result. err( )
54- ) ;
55- if let Result :: Ok ( yaml) = yaml_serialization_result {
29+ assert ! ( json_serialization_result. is_ok( ) , "JSON Serialization failed: {:?}" , json_serialization_result. err( ) ) ;
30+ assert ! ( yaml_serialization_result. is_ok( ) , "YAML Serialization failed: {:?}" , yaml_serialization_result. err( ) ) ;
31+ if let Result :: Ok ( yaml) = yaml_serialization_result{
5632 println ! ( "{}" , yaml)
5733 }
5834 assert_eq ! ( workflow. document. namespace, namespace) ;
@@ -261,4 +237,4 @@ mod unit_tests {
261237 }
262238 }
263239 }
264- }
240+ }
0 commit comments