feat: add is_submitted

api/src/lib.rs

@@ -47,6 +47,7 @@ async fn start() -> Result<(), rocket::Error> {
                 routes::candidate::upload_portfolio_letter,
                 routes::candidate::upload_portfolio_zip,
                 routes::candidate::submit_portfolio,
+                routes::candidate::is_submitted,
             ],
         )
         .mount(

api/src/routes/candidate.rs

@@ -193,3 +193,22 @@ pub async fn submit_portfolio(
 
     Ok("Portfolio submitted".to_string())
 }
+
+#[get("/is_submitted")]
+pub async fn is_submitted(
+    session: CandidateAuth,
+) -> Result<String, Custom<String>> {
+    let candidate: entity::candidate::Model = session.into();
+
+    let is_ok = CandidateService::is_portfolio_submitted(candidate.application).await;
+
+    if !is_ok {
+        // TODO: Correct error
+        return Err(Custom(
+            Status::from_code(404).unwrap_or_default(),
+            "Portfolio not submitted".to_string(),
+        ));
+    }
+
+    Ok("Portfolio ok".to_string())
+}

core/src/services/candidate_service.rs

@@ -192,6 +192,12 @@ impl CandidateService {
         Ok(())
     }
 
+    pub async fn is_portfolio_submitted(candidate_id: i32) -> bool {
+        let path = Path::new(&candidate_id.to_string()).join("PORTFOLIO.age");
+
+        tokio::fs::metadata(path).await.is_ok()
+    }
+
     pub async fn get_portfolio(candidate_id: i32, db: &DbConn) -> Result<Vec<u8>, ServiceError> {
         let candidate = Query::find_candidate_by_id(db, candidate_id)
             .await?