0

Rustのactix-webを使ってAPIサーバを書いているのですが、あるルートにリクエストがあった際に、別サーバのURLにリクエストを送り、結果が帰ってきたらデータベースにインサートする処理を実装したいです。

以下のように作成しましたが、エラーが出てしまいます。

#[post("/backends")]
async fn add_backend(
    pool: web::Data<DbPool>,
    form: web::Json<forms::BackendForm>,
    ) -> Result<HttpResponse, Error>{

    let version = reqwest::get(&(form.url+"/version"))
        .await?
        .text()
        .await?;

    let conn = pool.get().expect("cant get db pool");
    let backend = web::block(move || actions::create_backend(&form.name, &form.url, &version, &conn))
        .await
        .map_err(|e| {
            eprintln!("{}", e);
            HttpResponse::InternalServerError().finish()
        })?;

    Ok(HttpResponse::Ok().json(backend))
}

エラー内容

error[E0277]: the trait bound `reqwest::Error: actix_http::error::ResponseError` is not satisfied
  --> src/main.rs:52:15
   |
52 |         .await?
   |               ^ the trait `actix_http::error::ResponseError` is not implemented for `reqwest::Error`
   |
   = note: required because of the requirements on the impl of `std::convert::From<reqwest::Error>` for `actix_http::error::Error`
   = note: required by `std::convert::From::from`

error[E0277]: the trait bound `reqwest::Error: actix_http::error::ResponseError` is not satisfied
  --> src/main.rs:54:15
   |
54 |         .await?;
   |               ^ the trait `actix_http::error::ResponseError` is not implemented for `reqwest::Error`
   |
   = note: required because of the requirements on the impl of `std::convert::From<reqwest::Error>` for `actix_http::error::Error`
   = note: required by `std::convert::From::from`

error: aborting due to 2 previous errors

エラーを見ると、actix_http::error::ResponseErrorという返り値を期待しているのにも関わらず、reqwest::Errorを返してしまっているので、reqwest::Errorを受けて、ResponseErrorを返すようにすれば良いのではないかと考えましたが、どのようにすればよいのかわからないという状況です。
初歩的な質問かもしれませんがどなたかおわかりになる方ご教授いただけませんでしょうか。

1 件の回答 1

0

map_err を使うとできます。

詳細な状況が分からないので actix-web 2.0, reqwest 0.10, serde, 1.0を仮定してコンパイルが通るようにしてみました。詳細はコメントに書いた通りです。

#[post("/backends")]
async fn add_backend(
    pool: web::Data<DbPool>,
    form: web::Json<forms::BackendForm>,
) -> Result<HttpResponse, Error> {
    // 所有権エラーが出るので `format!` を使って結合する
    let version = reqwest::get(&format!("{}/version", form.url))
        .await
        // map_errを使ってError型に変換可能な値に変換する。
        // ここでは安直にInternalServerErrorを使う。
        // もっと詳細にエラーを出したければ自分で定義した型を使うとよい。
        .map_err(|e| {
            eprintln!("{}", e);
            HttpResponse::InternalServerError().finish()
        })?
        .text()
        .await
        // 同上
        .map_err(|e| {
            eprintln!("{}", e);
            HttpResponse::InternalServerError().finish()
        })?;

    let conn = pool.get().expect("cant get db pool");
    let backend =
        web::block(move || actions::create_backend(&form.name, &form.url, &version, &conn))
            .await
            .map_err(|e| {
                eprintln!("{}", e);
                HttpResponse::InternalServerError().finish()
            })?;

    Ok(HttpResponse::Ok().json(backend))
}

コンパイルの通るコードはこちらに置いておきます。
https://gist.github.com/KeenS/f814f1c564b109cbb83a5c3be8a0de46

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。