diff --git a/tests/integration_ocr_queue_management_tests.rs b/tests/integration_ocr_queue_management_tests.rs index dc569b0..497676e 100644 --- a/tests/integration_ocr_queue_management_tests.rs +++ b/tests/integration_ocr_queue_management_tests.rs @@ -142,7 +142,7 @@ impl OCRQueueTestClient { let token = self.token.as_ref().ok_or("Not authenticated")?; let response = self.client - .post(&format!("{}/api/queue/requeue/failed", get_base_url())) + .post(&format!("{}/api/queue/requeue-failed", get_base_url())) .header("Authorization", format!("Bearer {}", token)) .send() .await?; @@ -615,7 +615,7 @@ async fn test_queue_error_handling() { // Test unauthorized requeue attempt let unauth_requeue_response = unauth_client - .post(&format!("{}/api/queue/requeue/failed", get_base_url())) + .post(&format!("{}/api/queue/requeue-failed", get_base_url())) .send() .await .expect("Request should complete"); diff --git a/tests/integration_role_based_access_control_tests.rs b/tests/integration_role_based_access_control_tests.rs index 3878012..1373dc4 100644 --- a/tests/integration_role_based_access_control_tests.rs +++ b/tests/integration_role_based_access_control_tests.rs @@ -17,6 +17,7 @@ use serde_json::{json, Value}; use uuid::Uuid; use readur::models::{CreateUser, LoginRequest, LoginResponse, UserRole}; +use readur::routes::documents::types::PaginatedDocumentsResponse; fn get_base_url() -> String { std::env::var("API_URL").unwrap_or_else(|_| "http://localhost:8000".to_string()) @@ -223,7 +224,11 @@ impl RBACTestClient { return Err(format!("Get documents failed: {}", response.text().await?).into()); } - let documents: Vec = response.json().await?; + let paginated_response: PaginatedDocumentsResponse = response.json().await?; + let documents: Vec = paginated_response.documents + .into_iter() + .map(|doc| serde_json::to_value(doc).unwrap()) + .collect(); Ok(documents) } @@ -343,7 +348,7 @@ impl RBACTestClient { } AdminOperation::RequeueFailedJobs => { self.client - .post(&format!("{}/api/queue/requeue/failed", get_base_url())) + .post(&format!("{}/api/queue/requeue-failed", get_base_url())) .header("Authorization", format!("Bearer {}", token)) .send() .await?