Merge pull request #142 from samply/fix/aesthetics

Fix/aesthetics

src/exporter.rs

@@ -54,27 +54,17 @@ pub async fn post_exporter_query(body: &String, task_type: TaskType) -> Result<S
     }
 
     if task_type == TaskType::Status {
-        let value: Value = serde_json::from_str(
-            String::from_utf8(util::base64_decode(&body)?)
-                .map_err(|e| {
-                    FocusError::DeserializationError(format!(
-                        r#"Task body is not a valid string {}"#,
-                        e
-                    ))
-                })?
-                .as_str(),
-        )
+        let value: Value = serde_json::from_slice(&(util::base64_decode(body))?)
         .map_err(|e| {
             FocusError::DeserializationError(format!(r#"Task body is not a valid JSON: {}"#, e))
         })?;
         let id = value["query-execution-id"].as_str();
-        if id.is_none() {
+        let Some(id) = id else {
             return Err(FocusError::ParsingError(format!(
                 r#"Body does not contain the id of the query to check the status of: {}"#,
                 value
             )));
-        }
-        let id: &str = id.unwrap(); //we already made sure that it is not None
+        };
 
         let resp = CONFIG
             .client

src/main.rs

@@ -160,11 +160,11 @@ async fn process_task(
         ));
     }
     if metadata.project == "exporter" {
-        if metadata.task_type.is_none() {
-            return Err(FocusError::MissingExporterTaskType)
-        }
+        let Some(task_type) = metadata.task_type else {
+            return Err(FocusError::MissingExporterTaskType);
+        };
         let body = &task.body;
-        return Ok(run_exporter_query(task, body, metadata.task_type.unwrap()).await)?; //we already made sure that it is not None
+        return Ok(run_exporter_query(task, body, task_type).await)?; //we already made sure that it is not None
     }
 
     if CONFIG.endpoint_type == EndpointType::Blaze {