chore: removes some unused async

modules/analysis/src/service.rs

@@ -443,7 +443,7 @@ impl AnalysisService {
         Ok(())
     }
 
-    pub async fn clear_all_graphs(&self) -> Result<(), Error> {
+    pub fn clear_all_graphs(&self) -> Result<(), Error> {
         let graph_manager = GraphMap::get_instance();
         let mut manager = graph_manager.write();
         manager.clear();
@@ -469,7 +469,7 @@ impl AnalysisService {
         })
     }
 
-    pub async fn query_ancestor_graph(
+    pub fn query_ancestor_graph(
         component_name: Option<String>,
         component_purl: Option<Purl>,
         query: Option<Query>,
@@ -694,8 +694,7 @@ impl AnalysisService {
             None,
             Option::from(query),
             distinct_sbom_ids,
-        )
-        .await;
+        );
 
         Ok(paginated.paginate_array(&components))
     }
@@ -717,8 +716,7 @@ impl AnalysisService {
             None,
             None,
             distinct_sbom_ids,
-        )
-        .await;
+        );
 
         let mut root_components = Vec::new();
         for component in components {
@@ -764,8 +762,7 @@ impl AnalysisService {
             None,
             None,
             distinct_sbom_ids,
-        )
-        .await;
+        );
 
         Ok(paginated.paginate_array(&components))
     }
@@ -801,8 +798,7 @@ impl AnalysisService {
             Option::from(component_purl),
             None,
             distinct_sbom_ids,
-        )
-        .await;
+        );
 
         Ok(paginated.paginate_array(&components))
     }
@@ -1140,7 +1136,7 @@ mod test {
         assert_eq!(analysis_status.sbom_count, 1);
         assert_eq!(analysis_status.graph_count, 1);
 
-        let _clear_all_graphs = service.clear_all_graphs().await;
+        let _clear_all_graphs = service.clear_all_graphs();
 
         ctx.ingest_documents([
             "spdx/quarkus-bom-3.2.11.Final-redhat-00001.json",

modules/fundamental/src/weakness/endpoints/test.rs

@@ -10,7 +10,7 @@ use zip::ZipArchive;
 #[test_context(TrustifyContext)]
 #[test(actix_web::test)]
 async fn list_weaknesses(ctx: &TrustifyContext) -> Result<(), anyhow::Error> {
-    let zip = document_read("cwec_latest.xml.zip").await?;
+    let zip = document_read("cwec_latest.xml.zip")?;
 
     let mut archive = ZipArchive::new(zip)?;
 
@@ -34,7 +34,7 @@ async fn list_weaknesses(ctx: &TrustifyContext) -> Result<(), anyhow::Error> {
 #[test_context(TrustifyContext)]
 #[test(actix_web::test)]
 async fn query_weaknesses(ctx: &TrustifyContext) -> Result<(), anyhow::Error> {
-    let zip = document_read("cwec_latest.xml.zip").await?;
+    let zip = document_read("cwec_latest.xml.zip")?;
 
     let mut archive = ZipArchive::new(zip)?;
 
@@ -58,7 +58,7 @@ async fn query_weaknesses(ctx: &TrustifyContext) -> Result<(), anyhow::Error> {
 #[test_context(TrustifyContext)]
 #[test(actix_web::test)]
 async fn get_weakness(ctx: &TrustifyContext) -> Result<(), anyhow::Error> {
-    let zip = document_read("cwec_latest.xml.zip").await?;
+    let zip = document_read("cwec_latest.xml.zip")?;
 
     let mut archive = ZipArchive::new(zip)?;
 

modules/fundamental/tests/weakness/mod.rs

@@ -22,7 +22,7 @@ async fn simple(ctx: &TrustifyContext) -> Result<(), anyhow::Error> {
 
     // extract document from zip file
 
-    let zip = document_read("cwec_latest.xml.zip").await?;
+    let zip = document_read("cwec_latest.xml.zip")?;
 
     let mut archive = ZipArchive::new(zip)?;
 

modules/ingestor/src/service/format.rs

@@ -299,7 +299,7 @@ mod test {
         let spdx = document_bytes("ubi9-9.2-755.1697625012.json").await?;
         assert!(matches!(Format::from_bytes(&spdx), Ok(Format::SPDX)));
 
-        let cwe = document_read("cwec_latest.xml.zip").await?;
+        let cwe = document_read("cwec_latest.xml.zip")?;
         let mut cwe = ZipArchive::new(cwe)?;
         let mut cwe = cwe.by_index(0)?;
         let mut xml = Vec::new();

modules/ingestor/src/service/weakness/mod.rs

@@ -207,7 +207,7 @@ mod test {
         let graph = Graph::new(ctx.db.clone());
         let loader = CweCatalogLoader::new(&graph);
 
-        let zip = document_read("cwec_latest.xml.zip").await?;
+        let zip = document_read("cwec_latest.xml.zip")?;
 
         let mut archive = ZipArchive::new(zip)?;
 

test-context/src/lib.rs

@@ -175,7 +175,7 @@ pub async fn document_stream(
 }
 
 /// Read a document from the test-data directory. Does not decompress.
-pub async fn document_read(path: &str) -> Result<impl Read + Seek, anyhow::Error> {
+pub fn document_read(path: &str) -> Result<impl Read + Seek, anyhow::Error> {
     Ok(std::fs::File::open(absolute(path)?)?)
 }
 

xtask/src/main.rs

@@ -22,7 +22,7 @@ impl Xtask {
         match self.command {
             Command::Openapi(command) => command.run().await,
             Command::GenerateDump(command) => command.run().await,
-            Command::GenerateSchemas(command) => command.run().await,
+            Command::GenerateSchemas(command) => command.run(),
             Command::Precommit(command) => command.run().await,
             Command::Ai(command) => command.run().await,
         }

xtask/src/precommit.rs

@@ -13,8 +13,7 @@ impl Precommit {
         GenerateSchema {
             base: Path::new(".").to_path_buf(),
         }
-        .run()
-        .await?;
+        .run()?;
 
         Openapi::default().run().await?;
 

xtask/src/schema.rs

@@ -15,7 +15,7 @@ pub struct GenerateSchema {
 }
 
 impl GenerateSchema {
-    pub async fn run(self) -> anyhow::Result<()> {
+    pub fn run(self) -> anyhow::Result<()> {
         // write schema
         self.write_schema::<Instructions>("xtask/schema/generate-dump.json")?;
         self.write_schema::<AuthConfig>("common/auth/schema/auth.json")?;