@@ -48,18 +48,16 @@ public class TransformingSourceTest {
48
48
public void setUp () {
49
49
_mockObserver = Mockito .mock (Observer .class );
50
50
_mockSource = Mockito .mock (Source .class );
51
+ _transformSetBuilder = new TransformingSource .TransformationSet .Builder ()
52
+ .setFindAndReplace (ImmutableMap .of (
53
+ "foo/([^/]*)/bar" , ImmutableList .of ("foo/bar" ),
54
+ "cat/([^/]*)/dog" , ImmutableList .of ("cat/dog" , "cat/dog/$1" ),
55
+ "tagged/([^/]*)/dog" , ImmutableList .of ("tagged/dog;animal=$1" ),
56
+ "named/(?<animal>[^/]*)" , ImmutableList .of ("named/extracted_animal;extracted=${animal}" ),
57
+ "tagged/([^/]*)/animal" , ImmutableList .of ("tagged/${animal}/animal" )));
51
58
_transformingSourceBuilder = new TransformingSource .Builder ()
52
59
.setName ("TransformingSourceTest" )
53
- .setTransformations (ImmutableList .of (
54
- new TransformingSource .TransformationSet .Builder ()
55
- .setFindAndReplace (ImmutableMap .of (
56
- "foo/([^/]*)/bar" , ImmutableList .of ("foo/bar" ),
57
- "cat/([^/]*)/dog" , ImmutableList .of ("cat/dog" , "cat/dog/$1" ),
58
- "tagged/([^/]*)/dog" , ImmutableList .of ("tagged/dog;animal=$1" ),
59
- "named/(?<animal>[^/]*)" , ImmutableList .of ("named/extracted_animal;extracted=${animal}" ),
60
- "tagged/([^/]*)/animal" , ImmutableList .of ("tagged/${animal}/animal" )))
61
- .build ()
62
- ))
60
+ .setTransformations (ImmutableList .of (_transformSetBuilder .build ()))
63
61
.setSource (_mockSource );
64
62
}
65
63
@@ -90,17 +88,19 @@ public void testToString() {
90
88
91
89
@ Test
92
90
public void testMergingObserverInvalidEvent () {
91
+ final TransformingSource .TransformationSet transformationSet = new TransformingSource .TransformationSet .Builder ()
92
+ .setFindAndReplace (ImmutableMap .of ())
93
+ .build ();
93
94
final TransformingSource transformingSource = new TransformingSource .Builder ()
94
95
.setName ("testMergingObserverInvalidEventTransformingSource" )
95
96
.setSource (_mockSource )
96
- .setFindAndReplace (ImmutableMap .of ())
97
+ .setTransformations (ImmutableList .of (
98
+ transformationSet ))
97
99
.build ();
98
100
Mockito .reset (_mockSource );
99
101
new TransformingSource .TransformingObserver (
100
102
transformingSource ,
101
- ImmutableMap .of (),
102
- ImmutableMap .of (),
103
- ImmutableList .of ())
103
+ ImmutableList .of (transformationSet ))
104
104
.notify (OBSERVABLE , "Not a Record" );
105
105
Mockito .verifyZeroInteractions (_mockSource );
106
106
}
@@ -405,7 +405,7 @@ public void testMatchOverridesTagInCapture() {
405
405
406
406
@ Test
407
407
public void testStaticDimensionInjection () {
408
- _transformingSourceBuilder .setInject (ImmutableMap .of (
408
+ _transformSetBuilder .setInject (ImmutableMap .of (
409
409
"injected" ,
410
410
new TransformingSource .DimensionInjection .Builder ()
411
411
.setValue ("value" )
@@ -453,7 +453,7 @@ public void testStaticDimensionInjection() {
453
453
454
454
@ Test
455
455
public void testStaticDimensionInjectionOverwrite () {
456
- _transformingSourceBuilder .setInject (ImmutableMap .of (
456
+ _transformSetBuilder .setInject (ImmutableMap .of (
457
457
"injected" ,
458
458
new TransformingSource .DimensionInjection .Builder ()
459
459
.setValue ("new_value" )
@@ -509,7 +509,7 @@ public void testStaticDimensionInjectionOverwrite() {
509
509
510
510
@ Test
511
511
public void testRemoveDimension () {
512
- _transformingSourceBuilder .setRemove (ImmutableList .of ("remove" ));
512
+ _transformSetBuilder .setRemove (ImmutableList .of ("remove" ));
513
513
final Record matchingRecord = TestBeanFactory .createRecordBuilder ()
514
514
.setMetrics (ImmutableMap .of (
515
515
"doesnt_match" ,
@@ -697,6 +697,7 @@ private void assertRecordsEqual(final Record actualRecord, final Record expected
697
697
}
698
698
699
699
private Record mapRecord (final Record record ) {
700
+ _transformingSourceBuilder .setTransformations (ImmutableList .of (_transformSetBuilder .build ()));
700
701
final Source transformingSource = _transformingSourceBuilder .build ();
701
702
transformingSource .attach (_mockObserver );
702
703
notify (_mockSource , record );
@@ -717,6 +718,7 @@ private static void notify(final Observable observable, final Object event) {
717
718
private Observer _mockObserver ;
718
719
private Source _mockSource ;
719
720
private TransformingSource .Builder _transformingSourceBuilder ;
721
+ private TransformingSource .TransformationSet .Builder _transformSetBuilder ;
720
722
721
723
private static final Observable OBSERVABLE = new Observable () {
722
724
@ Override
0 commit comments