1
1
package io .crawlab .sdk ;
2
2
3
+ import com .fasterxml .jackson .databind .annotation .JsonSerialize ;
3
4
import org .junit .jupiter .api .Test ;
4
5
import org .junit .jupiter .api .BeforeEach ;
5
6
@@ -19,31 +20,53 @@ void setUp() {
19
20
20
21
@ Test
21
22
void testSaveItemWithMap () {
22
- Map <String , Object > data = Map .of ("name" , "John" , "age" , 25 );
23
- CrawlabSDK .saveItem (data );
23
+ Map <String , Object > data1 = Map .of ("name" , "John" , "age" , 25 );
24
+ Map <String , Object > data2 = Map .of ("name" , "Jane" , "age" , 30 );
25
+ CrawlabSDK .saveItem (data1 , data2 );
24
26
String output = outputStreamCaptor .toString ().trim ();
25
27
26
28
assertTrue (output .contains ("\" type\" :\" data\" " ));
27
29
assertTrue (output .contains ("\" payload\" :[" ));
28
30
assertTrue (output .contains ("\" name\" :\" John\" " ));
29
31
assertTrue (output .contains ("\" age\" :25" ));
32
+ assertTrue (output .contains ("\" name\" :\" Jane\" " ));
33
+ assertTrue (output .contains ("\" age\" :30" ));
30
34
assertTrue (output .contains ("\" ipc\" :true" ));
31
35
}
32
36
33
37
@ Test
34
38
void testSaveItemWithClass () {
35
- TestData data = new TestData ("John" , 25 );
36
- CrawlabSDK .saveItem (data );
39
+ Person data1 = new Person ("John" , 25 );
40
+ Person data2 = new Person ("Jane" , 30 );
41
+ CrawlabSDK .saveItem (data1 , data2 );
37
42
String output = outputStreamCaptor .toString ().trim ();
38
43
39
44
assertTrue (output .contains ("\" type\" :\" data\" " ));
40
45
assertTrue (output .contains ("\" payload\" :[" ));
41
46
assertTrue (output .contains ("\" name\" :\" John\" " ));
42
47
assertTrue (output .contains ("\" age\" :25" ));
48
+ assertTrue (output .contains ("\" name\" :\" Jane\" " ));
49
+ assertTrue (output .contains ("\" age\" :30" ));
43
50
assertTrue (output .contains ("\" ipc\" :true" ));
44
51
}
45
52
46
53
// Helper class for testing object serialization
47
- private record TestData (String name , int age ) {
54
+ @ JsonSerialize
55
+ class Person {
56
+ private String name ;
57
+ private int age ;
58
+
59
+ public Person (String name , int age ) {
60
+ this .name = name ;
61
+ this .age = age ;
62
+ }
63
+
64
+ public String getName () {
65
+ return name ;
66
+ }
67
+
68
+ public int getAge () {
69
+ return age ;
70
+ }
48
71
}
49
- }
72
+ }
0 commit comments