commit 214d846a40647b5fba18abf43680d1aad7881594
parent 132339820bd099213234576d2cd7a5090d5390d7
Author: Antoine A <>
Date: Wed, 21 Oct 2026 19:53:41 +0200
bank: make tokens creation in test setup serial to reduce the number of database connections
Diffstat:
1 file changed, 17 insertions(+), 25 deletions(-)
diff --git a/libeufin-bank/src/api.rs b/libeufin-bank/src/api.rs
@@ -405,32 +405,24 @@ pub mod test {
}
pub async fn cache_tokens(&mut self, usernames: &[&str]) {
- let tasks = usernames
- .iter()
- .map(|username| {
- let username = CompactString::from(*username);
- async {
- let res = pw_auth(
- self.server.post(format!("/accounts/{username}/token")),
- Some(&username),
- )
- .json(json!({
- "scope": "readwrite",
- "duration": {
- "d_us": "forever"
- }
- }))
- .await
- .maybe_challenge(self)
- .await
- .assert_ok_json::<serde_json::Value>();
- let token = res["access_token"].as_str().unwrap();
- (username, format!("Bearer {token}"))
+ for username in usernames {
+ let username = CompactString::from(*username);
+ let res = pw_auth(
+ self.server.post(format!("/accounts/{username}/token")),
+ Some(&username),
+ )
+ .json(json!({
+ "scope": "readwrite",
+ "duration": {
+ "d_us": "forever"
}
- })
- .collect::<Vec<_>>();
- for (username, token) in futures::future::join_all(tasks).await {
- self.tokens.insert(username, token);
+ }))
+ .await
+ .maybe_challenge(self)
+ .await
+ .assert_ok_json::<serde_json::Value>();
+ let token = res["access_token"].as_str().unwrap();
+ self.tokens.insert(username, format!("Bearer {token}"));
}
}