5
5
from utils import DRIVERS_TOOLS , LOGGER , ROOT , read_env , run_command , write_env
6
6
7
7
TMP_DRIVER_FILE = "/tmp/mongo-python-driver.tgz" # noqa: S108
8
- CSFLE_DIR = f"{ DRIVERS_TOOLS } /.evergreen/csfle"
8
+ DIRS = dict (
9
+ gcp = f"{ DRIVERS_TOOLS } /.evergreen/csfle/gcpkms" ,
10
+ azure = f"{ DRIVERS_TOOLS } /.evergreen/csfle/azurekms" ,
11
+ )
9
12
10
13
11
14
def _setup_azure_vm (base_env : dict [str , str ]) -> None :
12
15
LOGGER .info ("Setting up Azure VM..." )
16
+ azure_dir = DIRS ["azure" ]
13
17
env = base_env .copy ()
14
18
env ["AZUREKMS_SRC" ] = TMP_DRIVER_FILE
15
19
env ["AZUREKMS_DST" ] = "~/"
16
- run_command (f"{ CSFLE_DIR } /azurekms /copy-file.sh" , env = env )
20
+ run_command (f"{ azure_dir } /copy-file.sh" , env = env )
17
21
18
22
env = base_env .copy ()
19
23
env ["AZUREKMS_CMD" ] = "tar xf mongo-python-driver.tgz"
20
- run_command (f"{ CSFLE_DIR } /azurekms /run-command.sh" , env = env )
24
+ run_command (f"{ azure_dir } /run-command.sh" , env = env )
21
25
22
26
env ["AZUREKMS_CMD" ] = "bash .evergreen/just.sh setup-tests kms azure-remote"
23
- run_command (f"{ CSFLE_DIR } /azurekms /run-command.sh" , env = env )
27
+ run_command (f"{ azure_dir } /run-command.sh" , env = env )
24
28
LOGGER .info ("Setting up Azure VM... done." )
25
29
26
30
27
31
def _setup_gcp_vm (base_env : dict [str , str ]) -> None :
28
32
LOGGER .info ("Setting up GCP VM..." )
33
+ gcp_dir = DIRS ["gcp" ]
29
34
env = base_env .copy ()
30
35
env ["GCPKMS_SRC" ] = TMP_DRIVER_FILE
31
36
env ["GCPKMS_DST" ] = f"{ env ['GCPKMS_INSTANCENAME' ]} :"
32
- run_command (f"{ CSFLE_DIR } /gcpkms /copy-file.sh" , env = env )
37
+ run_command (f"{ gcp_dir } /copy-file.sh" , env = env )
33
38
34
39
env = base_env .copy ()
35
40
env ["GCPKMS_CMD" ] = "tar xf mongo-python-driver.tgz"
36
- run_command (f"{ CSFLE_DIR } /gcpkms /run-command.sh" , env = env )
41
+ run_command (f"{ gcp_dir } /run-command.sh" , env = env )
37
42
38
43
env ["GCPKMS_CMD" ] = "bash ./.evergreen/just.sh setup-tests kms gcp-remote"
39
- run_command (f"{ CSFLE_DIR } /gcpkms /run-command.sh" , env = env )
44
+ run_command (f"{ gcp_dir } /run-command.sh" , env = env )
40
45
LOGGER .info ("Setting up GCP VM..." )
41
46
42
47
@@ -47,7 +52,8 @@ def _create_archive() -> None:
47
52
48
53
49
54
def _load_kms_config (sub_test_target : str ) -> dict [str , str ]:
50
- config = read_env (f"{ CSFLE_DIR } /{ sub_test_target } kms/secrets-export.sh" )
55
+ target_dir = DIRS [sub_test_target ]
56
+ config = read_env (f"{ target_dir } /secrets-export.sh" )
51
57
base_env = os .environ .copy ()
52
58
for key , value in config .items ():
53
59
base_env [key ] = str (value )
@@ -64,7 +70,7 @@ def setup_kms(sub_test_name: str) -> None:
64
70
assert sub_test_target in ["azure" , "gcp" ], sub_test_target
65
71
assert sub_test_type in ["" , "remote" , "fail" ], sub_test_type
66
72
success = sub_test_type != "fail"
67
- kms_dir = f" { CSFLE_DIR } / { sub_test_target } kms"
73
+ kms_dir = DIRS [ sub_test_target ]
68
74
69
75
if sub_test_target == "azure" :
70
76
write_env ("TEST_FLE_AZURE_AUTO" )
@@ -108,12 +114,12 @@ def test_kms_vm(sub_test_name: str) -> None:
108
114
] = f'KEY_NAME="{ key_name } " KEY_VAULT_ENDPOINT="{ key_vault_endpoint } " bash ./.evergreen/just.sh run-tests'
109
115
else :
110
116
env ["GCPKMS_CMD" ] = "./.evergreen/just.sh run-tests"
111
- cmd = f"{ CSFLE_DIR } / { sub_test_name } kms /run-command.sh"
117
+ cmd = f"{ DIRS [ sub_test_name ] } /run-command.sh"
112
118
run_command (cmd , env = env )
113
119
114
120
115
121
def teardown_kms (sub_test_name : str ) -> None :
116
- run_command (f"{ CSFLE_DIR } / { sub_test_name } kms /teardown.sh" )
122
+ run_command (f"{ DIRS [ sub_test_name ] } /teardown.sh" )
117
123
118
124
119
125
if __name__ == "__main__" :
0 commit comments