@@ -35,9 +35,14 @@ func TestDarwinRouteFailsOnConflictIntegrationTest(t *testing.T) {
35
35
IP : net .IPv4 (10 , 96 , 0 , 0 ),
36
36
Mask : net .IPv4Mask (255 , 240 , 0 , 0 ),
37
37
},
38
+ ClusterDomain : "cluster.local" ,
39
+ ClusterDNSIP : net .IPv4 (10 , 96 , 0 , 10 ),
38
40
}
41
+ conflictingCfg := * cfg
42
+ conflictingCfg .Gateway = net .IPv4 (127 , 0 , 0 , 2 )
39
43
40
- addRoute (t , "10.96.0.0/12" , "127.0.0.2" )
44
+ addRoute (t , & conflictingCfg )
45
+ defer cleanRoute (t , & conflictingCfg )
41
46
err := (& osRouter {}).EnsureRouteIsAdded (cfg )
42
47
if err == nil {
43
48
t .Errorf ("add should have error, but it is nil" )
@@ -51,9 +56,11 @@ func TestDarwinRouteIdempotentIntegrationTest(t *testing.T) {
51
56
IP : net .IPv4 (10 , 96 , 0 , 0 ),
52
57
Mask : net .IPv4Mask (255 , 240 , 0 , 0 ),
53
58
},
59
+ ClusterDomain : "cluster.local" ,
60
+ ClusterDNSIP : net .IPv4 (10 , 96 , 0 , 10 ),
54
61
}
55
62
56
- cleanRoute (t , "10.96.0.0/12" )
63
+ cleanRoute (t , cfg )
57
64
err := (& osRouter {}).EnsureRouteIsAdded (cfg )
58
65
if err != nil {
59
66
t .Errorf ("add error: %s" , err )
@@ -64,7 +71,7 @@ func TestDarwinRouteIdempotentIntegrationTest(t *testing.T) {
64
71
t .Errorf ("add error: %s" , err )
65
72
}
66
73
67
- cleanRoute (t , "10.96.0.0/12" )
74
+ cleanRoute (t , cfg )
68
75
}
69
76
70
77
func TestDarwinRouteCleanupIdempontentIntegrationTest (t * testing.T ) {
@@ -75,10 +82,12 @@ func TestDarwinRouteCleanupIdempontentIntegrationTest(t *testing.T) {
75
82
IP : net .IPv4 (10 , 96 , 0 , 0 ),
76
83
Mask : net .IPv4Mask (255 , 240 , 0 , 0 ),
77
84
},
85
+ ClusterDomain : "cluster.local" ,
86
+ ClusterDNSIP : net .IPv4 (10 , 96 , 0 , 10 ),
78
87
}
79
88
80
- cleanRoute (t , "10.96.0.0/12" )
81
- addRoute (t , "10.96.0.0/12" , "192.168.1.1" )
89
+ cleanRoute (t , cfg )
90
+ addRoute (t , cfg )
82
91
err := (& osRouter {}).Cleanup (cfg )
83
92
if err != nil {
84
93
t .Errorf ("cleanup failed with %s" , err )
@@ -89,20 +98,32 @@ func TestDarwinRouteCleanupIdempontentIntegrationTest(t *testing.T) {
89
98
}
90
99
}
91
100
92
- func addRoute (t * testing.T , cidr string , gw string ) {
101
+ func addRoute (t * testing.T , r * Route ) {
102
+ cidr := r .DestCIDR .String ()
103
+ gw := r .Gateway .String ()
93
104
command := exec .Command ("sudo" , "route" , "-n" , "add" , cidr , gw )
94
105
_ , err := command .CombinedOutput ()
95
106
if err != nil {
96
107
t .Logf ("add route error (should be ok): %s" , err )
97
108
}
109
+ err = writeResolverFile (r )
110
+ if err != nil {
111
+ t .Logf ("add route DNS resolver error (should be ok): %s" , err )
112
+ }
98
113
}
99
114
100
- func cleanRoute (t * testing.T , cidr string ) {
115
+ func cleanRoute (t * testing.T , r * Route ) {
116
+ cidr := r .DestCIDR .String ()
101
117
command := exec .Command ("sudo" , "route" , "-n" , "delete" , cidr )
102
118
_ , err := command .CombinedOutput ()
103
119
if err != nil {
104
120
t .Logf ("cleanup error (should be ok): %s" , err )
105
121
}
122
+ command := exec .Command ("sudo" , "rm" , "-f" , fmt .Sprintf ("/etc/resolver/%s" , r .ClusterDomain ))
123
+ _ , err := command .CombinedOutput ()
124
+ if err != nil {
125
+ t .Logf ("cleanup DNS resolver error (should be ok): %s" , err )
126
+ }
106
127
}
107
128
108
129
func TestCIDRPadding (t * testing.T ) {
0 commit comments