1
- use std:: process:: Command ;
2
1
// Copyright (C) 2023-2024 RabbitMQ Core Team ([email protected] )
3
2
//
4
3
// Licensed under the Apache License, Version 2.0 (the "License");
@@ -12,20 +11,19 @@ use std::process::Command;
12
11
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
12
// See the License for the specific language governing permissions and
14
13
// limitations under the License.
15
- use assert_cmd :: prelude :: * ;
14
+
16
15
use predicates:: prelude:: * ;
17
16
17
+ mod test_helpers;
18
+ use crate :: test_helpers:: * ;
19
+
18
20
#[ test]
19
21
fn test_runtime_parameters ( ) -> Result < ( ) , Box < dyn std:: error:: Error > > {
20
- let mut cmd = Command :: cargo_bin ( "rabbitmqadmin" ) ?;
21
- cmd. args ( [ "declare" , "vhost" , "--name" , "parameters_vhost_1" ] ) ;
22
- cmd. assert ( ) . success ( ) ;
23
-
24
- let mut cmd = Command :: cargo_bin ( "rabbitmqadmin" ) ?;
25
-
26
- cmd. args ( [
22
+ let vh = "parameters_vhost_1" ;
23
+ run_succeeds ( [ "declare" , "vhost" , "--name" , vh] ) ;
24
+ run_succeeds ( [
27
25
"-V" ,
28
- "parameters_vhost_1" ,
26
+ vh ,
29
27
"declare" ,
30
28
"parameter" ,
31
29
"--component" ,
@@ -35,50 +33,37 @@ fn test_runtime_parameters() -> Result<(), Box<dyn std::error::Error>> {
35
33
"--value" ,
36
34
"{\" uri\" :\" amqp://target.hostname\" ,\" expires\" :3600000}" ,
37
35
] ) ;
38
- cmd. assert ( ) . success ( ) ;
39
36
40
- let mut cmd = Command :: cargo_bin ( "rabbitmqadmin" ) ?;
41
- cmd. args ( [
37
+ run_succeeds ( [
42
38
"-V" ,
43
- "parameters_vhost_1" ,
39
+ vh ,
44
40
"list" ,
45
41
"parameters" ,
46
42
"--component" ,
47
43
"federation-upstream" ,
48
- ] ) ;
49
- cmd. assert ( )
50
- . success ( )
51
- . stdout ( predicate:: str:: contains ( "my-upstream" ) . and ( predicate:: str:: contains ( "3600000" ) ) ) ;
44
+ ] ) . stdout ( predicate:: str:: contains ( "my-upstream" ) . and ( predicate:: str:: contains ( "3600000" ) ) ) ;
52
45
53
- let mut cmd = Command :: cargo_bin ( "rabbitmqadmin" ) ?;
54
- cmd. args ( [
46
+ run_succeeds ( [
55
47
"-V" ,
56
- "parameters_vhost_1" ,
48
+ vh ,
57
49
"delete" ,
58
50
"parameter" ,
59
51
"--component" ,
60
52
"federation-upstream" ,
61
53
"--name" ,
62
54
"my-upstream" ,
63
55
] ) ;
64
- cmd. assert ( ) . success ( ) ;
65
56
66
- let mut cmd = Command :: cargo_bin ( "rabbitmqadmin" ) ?;
67
- cmd. args ( [
57
+ run_succeeds ( [
68
58
"-V" ,
69
- "parameters_vhost_1" ,
59
+ vh ,
70
60
"list" ,
71
61
"parameters" ,
72
62
"--component" ,
73
63
"federation-upstream" ,
74
- ] ) ;
75
- cmd. assert ( )
76
- . success ( )
77
- . stdout ( predicate:: str:: contains ( "my-upstream" ) . not ( ) ) ;
64
+ ] ) . stdout ( predicate:: str:: contains ( "my-upstream" ) . not ( ) ) ;
78
65
79
- let mut cmd = Command :: cargo_bin ( "rabbitmqadmin" ) ?;
80
- cmd. args ( [ "delete" , "vhost" , "--name" , "parameters_vhost_1" ] ) ;
81
- cmd. assert ( ) . success ( ) ;
66
+ delete_vhost ( vh) . expect ( "failed to delete a virtual host" ) ;
82
67
83
68
Ok ( ( ) )
84
69
}
0 commit comments