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_FOLDER = f"{ DRIVERS_TOOLS } /.evergreen/csfle"
8
+ CSFLE_DIR = f"{ DRIVERS_TOOLS } /.evergreen/csfle"
9
9
10
10
11
11
def _setup_azure_vm (base_env : dict [str , str ]) -> None :
12
12
LOGGER .info ("Setting up Azure VM..." )
13
13
env = base_env .copy ()
14
14
env ["AZUREKMS_SRC" ] = TMP_DRIVER_FILE
15
15
env ["AZUREKMS_DST" ] = "~/"
16
- run_command (f"{ CSFLE_FOLDER } /azurekms/copy-file.sh" , env = env )
16
+ run_command (f"{ CSFLE_DIR } /azurekms/copy-file.sh" , env = env )
17
17
18
18
env = base_env .copy ()
19
19
env ["AZUREKMS_CMD" ] = "tar xf mongo-python-driver.tgz"
20
- run_command (f"{ CSFLE_FOLDER } /azurekms/run-command.sh" , env = env )
20
+ run_command (f"{ CSFLE_DIR } /azurekms/run-command.sh" , env = env )
21
21
22
22
env ["AZUREKMS_CMD" ] = "bash .evergreen/just.sh setup-tests kms azure-remote"
23
- run_command (f"{ CSFLE_FOLDER } /azurekms/run-command.sh" , env = env )
23
+ run_command (f"{ CSFLE_DIR } /azurekms/run-command.sh" , env = env )
24
24
LOGGER .info ("Setting up Azure VM... done." )
25
25
26
26
@@ -29,14 +29,14 @@ def _setup_gcp_vm(base_env: dict[str, str]) -> None:
29
29
env = base_env .copy ()
30
30
env ["GCPKMS_SRC" ] = TMP_DRIVER_FILE
31
31
env ["GCPKMS_DST" ] = f"{ env ['GCPKMS_INSTANCENAME' ]} :"
32
- run_command (f"{ CSFLE_FOLDER } /gcpkms/copy-file.sh" , env = env )
32
+ run_command (f"{ CSFLE_DIR } /gcpkms/copy-file.sh" , env = env )
33
33
34
34
env = base_env .copy ()
35
35
env ["GCPKMS_CMD" ] = "tar xf mongo-python-driver.tgz"
36
- run_command (f"{ CSFLE_FOLDER } /gcpkms/run-command.sh" , env = env )
36
+ run_command (f"{ CSFLE_DIR } /gcpkms/run-command.sh" , env = env )
37
37
38
38
env ["GCPKMS_CMD" ] = "bash ./.evergreen/just.sh setup-tests kms gcp-remote"
39
- run_command (f"{ CSFLE_FOLDER } /gcpkms/run-command.sh" , env = env )
39
+ run_command (f"{ CSFLE_DIR } /gcpkms/run-command.sh" , env = env )
40
40
LOGGER .info ("Setting up GCP VM..." )
41
41
42
42
@@ -47,7 +47,7 @@ def _create_archive() -> None:
47
47
48
48
49
49
def _load_kms_config (sub_test_target : str ) -> dict [str , str ]:
50
- config = read_env (f"{ CSFLE_FOLDER } /{ sub_test_target } kms/secrets-export.sh" )
50
+ config = read_env (f"{ CSFLE_DIR } /{ sub_test_target } kms/secrets-export.sh" )
51
51
base_env = os .environ .copy ()
52
52
for key , value in config .items ():
53
53
base_env [key ] = str (value )
@@ -64,6 +64,7 @@ def setup_kms(sub_test_name: str) -> None:
64
64
assert sub_test_target in ["azure" , "gcp" ], sub_test_target
65
65
assert sub_test_type in ["" , "remote" , "fail" ], sub_test_type
66
66
success = sub_test_type != "fail"
67
+ kms_dir = f"{ CSFLE_DIR } /{ sub_test_target } kms"
67
68
68
69
if sub_test_target == "azure" :
69
70
write_env ("TEST_FLE_AZURE_AUTO" )
@@ -81,7 +82,7 @@ def setup_kms(sub_test_name: str) -> None:
81
82
if sub_test_target == "azure" :
82
83
os .environ ["AZUREKMS_VMNAME_PREFIX" ] = "PYTHON_DRIVER"
83
84
84
- run_command (f" { CSFLE_FOLDER } / { sub_test_target } kms/ setup.sh" )
85
+ run_command (" setup.sh", cwd = kms_dir )
85
86
base_env = _load_kms_config (sub_test_target )
86
87
87
88
if sub_test_target == "azure" :
@@ -90,8 +91,8 @@ def setup_kms(sub_test_name: str) -> None:
90
91
_setup_gcp_vm (base_env )
91
92
92
93
if sub_test_target == "azure" :
93
- run_command (f" { CSFLE_FOLDER } / { sub_test_target } kms/ setup-secrets.sh" )
94
- config = read_env (f"{ CSFLE_FOLDER } / { sub_test_target } kms /secrets-export.sh" )
94
+ run_command (" setup-secrets.sh", cwd = kms_dir )
95
+ config = read_env (f"{ kms_dir } /secrets-export.sh" )
95
96
write_env ("KEY_NAME" , config ["AZUREKMS_KEYNAME" ])
96
97
write_env ("KEY_VAULT_ENDPOINT" , config ["AZUREKMS_KEYVAULTENDPOINT" ])
97
98
write_env ("AZUREKMS_VMNAME" , config ["AZUREKMS_KEYNAME" ])
@@ -107,12 +108,12 @@ def test_kms_vm(sub_test_name: str) -> None:
107
108
] = f'KEY_NAME="{ key_name } " KEY_VAULT_ENDPOINT="{ key_vault_endpoint } " bash ./.evergreen/just.sh run-tests'
108
109
else :
109
110
env ["GCPKMS_CMD" ] = "./.evergreen/just.sh run-tests"
110
- cmd = f"{ CSFLE_FOLDER } /{ sub_test_name } kms/run-command.sh"
111
+ cmd = f"{ CSFLE_DIR } /{ sub_test_name } kms/run-command.sh"
111
112
run_command (cmd , env = env )
112
113
113
114
114
115
def teardown_kms (sub_test_name : str ) -> None :
115
- run_command (f"bash { CSFLE_FOLDER } /{ sub_test_name } kms/teardown.sh" )
116
+ run_command (f"{ CSFLE_DIR } /{ sub_test_name } kms/teardown.sh" )
116
117
117
118
118
119
if __name__ == "__main__" :
0 commit comments