Тайм-аут на тестах с использованием рабочего POST-маршрута с помощью actix-web

Я успешно перенес веб-приложение из Rocket в actix-web. Используя почтальона, я убедился, что одни и те же запросы дают одинаковые ответы. Миграция тестов, однако, оказалась немного сложнее.

Мой POST запрашивает тайм-аут при запуске cargo test, хотя приложение просто принимает и возвращает ожидаемый ответ просто отлично при запуске cargo run,

#[cfg(test)]
mod test {
    use actix_web::{client, http, test, App};

    #[test]
    fn main() {
        let mut ts = TestSuite::new();

        assert!(ts.get_request("/health").status().is_success()); // works

        let filter_test_body =
            r#"{"key_1":[{"id":"a string"},{"id":"another string"}],"int_1":100}"#;
        assert!(
            ts.post_request("/post_route", filter_test_body)
                .status()
                .is_success()
        ); // times out while actual app returns success with same payload within a few ms
    }

    fn create_app() -> App<project_name::AppState> {
        // {...} some initialization and defining app_state

        return App::with_state(&app_state)
            .resource("/health", |r| {
                r.method(http::Method::GET).f(project_name::health)
            })
            .resource("/post_route", |r| {
                r.method(http::Method::POST)
                    .with(project_name::post_route_handler)
            });
    }

    struct TestSuite {
        server: test::TestServer,
    }

    impl TestSuite {
        pub fn new() -> TestSuite {
            TestSuite {
                server: test::TestServer::with_factory(create_app),
            }
        }
        pub fn get_request(&mut self, endpoint: &str) -> client::ClientResponse {
            let request = self.server
                .client(http::Method::GET, endpoint)
                .finish()
                .unwrap();

            self.server.execute(request.send()).unwrap()
        }
        pub fn post_request(&mut self, endpoint: &str, body: &str) -> client::ClientResponse {
            let request_payload: other_lib::request::RequestPayload =
                serde_json::from_str(body).unwrap();
            let request = self.server
                .client(http::Method::POST, endpoint)
                .header(http::header::CONTENT_TYPE, "application/json")
                .json(request_payload)
                //.body(body.to_string())
                .unwrap();

            self.server.execute(request.send()).unwrap() // thread 'test::main' panicked at 'called `Result::unwrap()` on an `Err` value: Timeout'
        }
    }
}

Напротив, вот тест POST из кодовой базы, использующей Rocket.

#[test]
fn test_filters() {
    let client = mount_test_rocket(); // getting access to the test server (rocket::local::Client)
    let mut response = client.post("/post_route").header(ContentType::JSON)
        .body(r#"{"key_1":[{"id":"a string"},{"id":"another string"}],"int_1":100}"#).dispatch();
    assert_eq!(response.status(), Status::Ok);
    // + more assertions looking into the actual response body
}

1 ответ

Решение простое. Оказывается, запрос действительно истекает cargo test, Потенциальное решение было бы получить в timeout метод в цепочке, или гораздо проще в моем случае, включить ту же оптимизацию, которую я использую при запуске приложения, передав --release флаг.

Другие вопросы по тегам