1
+ package org .apache .hertzbeat .common .serialize ;
2
+
3
+ import com .fasterxml .jackson .core .JsonProcessingException ;
4
+ import com .fasterxml .jackson .databind .ObjectMapper ;
5
+ import com .fasterxml .jackson .databind .module .SimpleModule ;
6
+ import org .apache .hertzbeat .common .cache .CacheFactory ;
7
+ import org .apache .hertzbeat .common .cache .CommonCacheService ;
8
+ import org .apache .hertzbeat .common .entity .dto .vo .NoticeReceiverVO ;
9
+ import org .junit .jupiter .api .BeforeEach ;
10
+ import org .junit .jupiter .api .Test ;
11
+
12
+ import static org .junit .jupiter .api .Assertions .*;
13
+
14
+ class EmailDesensitizationSerializerTest {
15
+
16
+ private EmailDesensitizationSerializer emailDesensitizationSerializer ;
17
+
18
+ @ BeforeEach
19
+ void setUp () {
20
+ emailDesensitizationSerializer = new EmailDesensitizationSerializer ();
21
+ }
22
+
23
+ @ Test
24
+ public void test () throws JsonProcessingException {
25
+ NoticeReceiverVO noticeReceiver = new NoticeReceiverVO ();
26
+ noticeReceiver .setId (1L );
27
+ noticeReceiver .
setEmail (
"[email protected] " );
28
+
29
+ ObjectMapper objectMapper = new ObjectMapper ();
30
+ SimpleModule simpleModule = new SimpleModule ();
31
+ simpleModule .addSerializer (String .class ,emailDesensitizationSerializer );
32
+
33
+ objectMapper .registerModule (simpleModule );
34
+
35
+ String jsonString = objectMapper .writeValueAsString (noticeReceiver );
36
+ NoticeReceiverVO noticeReceiverVO = objectMapper .readValue (jsonString , NoticeReceiverVO .class );
37
+
38
+ CommonCacheService <String , Object > desensitizationMapCache = CacheFactory .getDesensitizationMapCache ();
39
+
40
+ assertEquals (noticeReceiver .getEmail (),desensitizationMapCache .get (noticeReceiverVO .getId ()+"_" +noticeReceiverVO .getEmail ()));
41
+ }
42
+ }
0 commit comments