Skip to content

Commit e9aeae2

Browse files
committed
Update return type
1 parent da9ada7 commit e9aeae2

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

tembo-operator/src/trunk.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,9 @@ pub async fn get_trunk_project_names() -> Result<Vec<String>, TrunkError> {
234234
}
235235

236236
// Get all metadata entries for a given trunk project
237-
async fn get_trunk_project_metadata(trunk_project: String) -> Result<Value, TrunkError> {
237+
async fn get_trunk_project_metadata(
238+
trunk_project: String,
239+
) -> Result<Vec<TrunkProjectMetadata>, TrunkError> {
238240
let domain = env::var("TRUNK_REGISTRY_DOMAIN")
239241
.unwrap_or_else(|_| DEFAULT_TRUNK_REGISTRY_DOMAIN.to_string());
240242
let url = format!("https://{}/api/v1/trunk-projects/{}", domain, trunk_project);
@@ -243,7 +245,7 @@ async fn get_trunk_project_metadata(trunk_project: String) -> Result<Value, Trun
243245

244246
if response.status().is_success() {
245247
let response_body = response.text().await?;
246-
let project_metadata: Value = serde_json::from_str(&response_body)?;
248+
let project_metadata: Vec<TrunkProjectMetadata> = serde_json::from_str(&response_body)?;
247249
Ok(project_metadata)
248250
} else {
249251
error!(
@@ -510,7 +512,6 @@ mod tests {
510512
let extension_name = "auto_explain".to_string();
511513
let result = get_loadable_library_name(trunk_project, version, extension_name).await;
512514
assert!(result.is_ok());
513-
println!("{:?}", result.clone().unwrap().unwrap());
514515
assert_eq!(result.unwrap(), Some("auto_explain".to_string()));
515516
}
516517
}

0 commit comments

Comments
 (0)