Warp требует абсурдно длинных и сложных явных аннотаций типов, есть ли другой способ?

Я получаю следующую ошибку:

error[E0283]: type annotations needed for `warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<impl warp::Filter+std::marker::Copy, impl warp::Filte
r+std::marker::Copy>, impl warp::Filter+std::marker::Copy>, [closure@src/http.rs:12:13: 24:4]>`
  --> src/http.rs:12:4
   |
9  |     let create_user = warp::post()
   |         ----------- consider giving `create_user` the explicit type `warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<impl warp::Filter+std:
:marker::Copy, impl warp::Filter+std::marker::Copy>, impl warp::Filter+std::marker::Copy>, [closure@src/http.rs:12:13: 24:4]>`, with the type parameters specified
...
12 |         .and_then(|user: super::user::User| async move {
   |          ^^^^^^^^ cannot infer type
   |
   = note: cannot satisfy `_: reject::sealed::CombineRejection<Rejection>`

Это то, что я написал. Я не понимаю, как это должно выглядеть,

pub async fn users() -> impl Filter<Extract = impl warp::Reply, Error = warp::Rejection> + Clone {
  let create_user = warp::post()
    .and(warp::path::end())
    .and(warp::body::json())
    .and_then(|user: super::user::User| async move {
      match &user.id_user {
        None => {
          if let Ok(u) = user.insert().await {
            Ok(warp::reply::json(&u))
          }
          else {
            Ok(warp::reply::json(&"FOO".to_owned()))
          }
        }
        Some(_) => Ok(warp::reply::json(&"FOO".to_owned())),
      }
    });

  let routes = warp::path("users");
  routes.and(create_user)
}

Как это должно выглядеть, действительно ли я должен использовать явный тип, например,

warp :: filter :: and_then :: AndThen ‹warp :: filter :: and :: And‹ warp :: filter :: and :: And ‹impl warp :: Filter + std :: marker :: Copy, impl warp: : Filter + std :: marker :: Copy ›, impl warp :: Filter + std :: marker :: Copy›

Чтобы было ясно, что я хочу здесь, это конечная точка создания пользователя.

  • Я хочу, чтобы пользовательский объект был десериализован из JSON
  • Я хочу иметь возможность отклонить запрос (ошибка HTTP), если этот пользовательский объект после десериализации имеет идентификатор. Я не хочу, чтобы пользователь мог выбирать идентификатор.
  • &user.insert() вставит объект пользователя в базу данных и вернет новый объект пользователя с идентификатором.
  • Я хочу, чтобы пользователю была возвращена либо ошибка, либо объект пользователя.

Как я могу разобраться в абсурдно сложных аннотациях типов, которые запрашивает Warp? Это действительно необходимо, или я ошибаюсь?


person Evan Carroll    schedule 06.05.2021    source источник


Ответы (1)


Проблема здесь в невозможности определения типа для асинхронного блока в закрытии and_then(). Не существует Err() пути, который сообщал бы компилятору, каким будет вариант Error, поэтому вывод не выполняется. Вы можете исправить это, добавив аннотации к полному типу Result в одной из ветвей возврата:

Ok::<_, warp::Rejection>(warp::reply::json(&u))

Для дополнительной информации:

https://users.rust-lang.org/t/async-function-parameter-results-in-type-annotation-error/45379

и обходной путь для аналогичной проблемы с использованием ? в асинхронных блоках:

https://rust-lang.github.io/async-book/07_workarounds/02_err_in_async_blocks.html

person sebpuetz    schedule 06.05.2021