トップ WebAssemblyに関する質問【Rust】wasm_bindgen_futures::spawn_localを使ったコードの自動テストが一見パスしているようにみえるが処理が完了する前にプログラムが終了してしまうようなので解決したい

編集履歴

質問編集履歴

authors追加

2022/12/04 02:13

投稿

akira_kano1101

スコア25

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -35,6 +35,7 @@
 [package]
 name = "wasm_bindgen_futures_test"
 version = "0.1.0"
+authors = ["Akira Kano <a.kano1101@gmail.com>"]
 edition = "2021"
 [dependencies]

WebAssembly Firefox 非同期処理 Rust

assert!(false)のコメント文追加

2022/12/04 01:56

投稿

akira_kano1101

スコア25

test CHANGED Viewed

	@@ -1 +1 @@
1	- 【Rust】wasm_bindgen_futures::spawn_localを使ったコードの自動テストが一見パスしている~~ものの~~処理が完了する前にプログラムが終了してしまうようなので解決したい
1	+ 【Rust】wasm_bindgen_futures::spawn_localを使ったコードの自動テストが一見パスしているようにみえるが処理が完了する前にプログラムが終了してしまうようなので解決したい

test CHANGED Viewed

@@ -9,7 +9,7 @@
 ## 発生している問題・エラーメッセージ
-GitHubを用意しました。よろしければこちらも参照お願いします。
+GitHubを用意しました。よろしければこちらからも確認できますので、参照お願いします。
 [https://github.com/kano1101/wasm_bindgen_futures_test](https://github.com/kano1101/wasm_bindgen_futures_test)
@@ -43,7 +43,7 @@
 log = "0.4.6"
 once_cell = "1.16.0"
 reqwest = { version = "0.11.13", default-features = false, features = ["json"] }
-serde = { version = "1.0.148", features = ["derive"] }
+serde = { version = "1.0.148", default-features = false, features = ["derive"] }
 tokio = { version = "1.22.0", default-features = false, features = ["sync"] }
 wasm-bindgen-futures = "0.4.33"
 wasm-bindgen-test = "0.3.33"
@@ -201,6 +201,10 @@
         let origin = space::get().await;
         assert!(origin.is_some());
         log::debug!("ip.origin: {:?}", origin);
+        // 当然ですがコメントアウトを外すと、localhost:8080からの実行ではエラーになる
+        // しかし自動テストの方ではエラーにならない(処理が到達していないことがわかる)
+        // assert!(false);
     };
     wasm_bindgen_futures::spawn_local(fut());

WebAssembly Firefox 非同期処理 Rust

該当のソースコードのリファクタリング

2022/12/04 01:38

投稿

akira_kano1101

スコア25

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -157,8 +157,6 @@
 ##### main.rs
 ```rust
-use log::{debug, error, info, trace, warn};
 use serde::Deserialize;
 #[derive(Deserialize)]
 struct Ip {
@@ -166,18 +164,12 @@
 }
 mod space {
-    use anyhow::Result;
     use once_cell::sync::Lazy;
     use tokio::sync::Mutex;
     static INSTANCE: Lazy<Mutex<Option<String>>> = Lazy::new(|| Mutex::new(None));
-    pub async fn init() -> Result<()> {
-        let mut lock = INSTANCE.lock().await;
-        *lock = None;
-        Ok(())
-    }
-    pub async fn pull() -> Result<()> {
+    pub async fn pull() -> anyhow::Result<()> {
         use super::Ip;
         let response = reqwest::get("http://httpbin.org/ip")
             .await?
@@ -195,26 +187,27 @@
 fn run() {
     console_error_panic_hook::set_once();
     wasm_logger::init(wasm_logger::Config::default());
-    trace!("some trace log");
+    log::trace!("some trace log");
-    debug!("some debug log");
+    log::debug!("some debug log");
-    info!("some info log");
+    log::info!("some info log");
-    warn!("some warn log");
+    log::warn!("some warn log");
-    error!("some error log");
+    log::error!("some error log");
     let fut = || async move {
-        assert!(space::get().await.is_none());
-        assert!(space::init().await.is_ok());
         assert!(space::get().await.is_none());
         assert!(space::pull().await.is_ok());
         let origin = space::get().await;
         assert!(origin.is_some());
-        debug!("ip.origin: {:?}", origin);
+        log::debug!("ip.origin: {:?}", origin);
     };
     wasm_bindgen_futures::spawn_local(fut());
+}
+fn main() {
+    run();
 }
 use wasm_bindgen_test::wasm_bindgen_test;
@@ -223,10 +216,6 @@
 #[wasm_bindgen_test]
 async fn first_test() {
-    run();
-}
-fn main() {
     run();
 }
 ```

WebAssembly Firefox 非同期処理 Rust

該当するソースコード(main.rs)が見にくかったので見やすく修正

2022/12/04 01:31

投稿

akira_kano1101

スコア25

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -113,7 +113,8 @@
 ![イメージ説明](https://ddjkaamml8q8x.cloudfront.net/questions/2022-12-03/28fe5598-0a8a-4484-9ccd-419ae33ac98b.png)
+上図のように、コンソールログに`ip.origin: XXX`が表示されています。
-上図のように、正しくコンソールログに出力されていることが確認できました。
+この出力から、プログラムが正しく動作していることが確認できました。
 ## 問題となっている自動テストについて
 下記コマンドを実行します。
@@ -159,79 +160,40 @@
 use log::{debug, error, info, trace, warn};
 use serde::Deserialize;
-#[derive(Clone, Deserialize)]
+#[derive(Deserialize)]
 struct Ip {
     origin: String,
 }
-#[derive(Debug, Clone)]
-enum Perform<T> {
-    None,
-    Yet(T),
-    Already(T),
-}
-impl<T> Default for Perform<T> {
-    fn default() -> Perform<T> {
-        Perform::None
-    }
-}
-impl<T> From<Perform<T>> for Option<T> {
-    fn from(from: Perform<T>) -> Option<T> {
-        let perform = from;
-        match perform {
-            Perform::None => Option::None,
-            Perform::Yet(_) => Option::None,
-            Perform::Already(t) => Some(t),
-        }
-    }
-}
 mod space {
-    use super::{Ip, Perform};
+    use anyhow::Result;
     use once_cell::sync::Lazy;
     use tokio::sync::Mutex;
-    static INSTANCE: Lazy<Mutex<Perform<String>>> = Lazy::new(|| {
+    static INSTANCE: Lazy<Mutex<Option<String>>> = Lazy::new(|| Mutex::new(None));
-        let perform = Perform::None;
-        Mutex::new(perform)
-    });
-    pub async fn wasm_future_init() -> anyhow::Result<()> {
+    pub async fn init() -> Result<()> {
-        let mut m = INSTANCE.lock().await;
+        let mut lock = INSTANCE.lock().await;
-        *m = Perform::Yet("yet".to_string());
+        *lock = None;
         Ok(())
     }
-    pub async fn wasm_future_pull() -> anyhow::Result<()> {
+    pub async fn pull() -> Result<()> {
+        use super::Ip;
         let response = reqwest::get("http://httpbin.org/ip")
             .await?
             .json::<Ip>()
             .await?;
-        let mut m = INSTANCE.lock().await;
+        let mut lock = INSTANCE.lock().await;
-        *m = Perform::Already(response.origin);
+        *lock = Some(response.origin);
         Ok(())
     }
-    pub async fn wasm_future_get() -> Option<String> {
+    pub async fn get() -> Option<String> {
-        let l = INSTANCE.lock().await;
+        let lock = INSTANCE.lock().await;
-        let m: Perform<String> = l.clone();
-        From::from(m)
+        lock.clone()
     }
 }
 fn run() {
-    let fut = || async move {
-        assert!(space::wasm_future_get().await.is_none());
-        assert!(space::wasm_future_init().await.is_ok());
-        assert!(space::wasm_future_get().await.is_none());
-        assert!(space::wasm_future_pull().await.is_ok());
-        let s = space::wasm_future_get().await;
-        assert!(s.is_some());
-        debug!("ip.origin: {:?}", s);
-    };
-    wasm_bindgen_futures::spawn_local(fut());
-}
-fn main() {
     console_error_panic_hook::set_once();
     wasm_logger::init(wasm_logger::Config::default());
@@ -242,7 +204,17 @@
     warn!("some warn log");
     error!("some error log");
+    let fut = || async move {
+        assert!(space::get().await.is_none());
+        assert!(space::init().await.is_ok());
+        assert!(space::get().await.is_none());
+        assert!(space::pull().await.is_ok());
+        let origin = space::get().await;
-    run()
+        assert!(origin.is_some());
+        debug!("ip.origin: {:?}", origin);
+    };
+    wasm_bindgen_futures::spawn_local(fut());
 }
 use wasm_bindgen_test::wasm_bindgen_test;
@@ -251,18 +223,11 @@
 #[wasm_bindgen_test]
 async fn first_test() {
-    console_error_panic_hook::set_once();
-    wasm_logger::init(wasm_logger::Config::default());
-    trace!("some trace log");
-    debug!("some debug log");
-    info!("some info log");
-    warn!("some warn log");
-    error!("some error log");
     run();
+}
+fn main() {
-    assert!(true);
+    run();
 }
 ```

WebAssembly Firefox 非同期処理 Rust

GitHub参照の追加

2022/12/04 00:25

投稿

akira_kano1101

スコア25

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -8,6 +8,10 @@
 - [ ] `wasm_bindgen_futures::spawn_local`を使うコードの自動テストを実行できるようにする
 ## 発生している問題・エラーメッセージ
+GitHubを用意しました。よろしければこちらも参照お願いします。
+[https://github.com/kano1101/wasm_bindgen_futures_test](https://github.com/kano1101/wasm_bindgen_futures_test)
 ##### プロジェクトの構成
 ```console

WebAssembly Firefox 非同期処理 Rust

本文わかりやすく修正

2022/12/03 23:52

投稿

akira_kano1101

スコア25

test CHANGED Viewed

	@@ -1 +1 @@
1	- 【Rust】wasm_bindgen_futures::spawn_localを使ったコードの自動テストがパスはするものの処理が完了する前にプログラムが終了してしまう模様なので解決したい
1	+ 【Rust】wasm_bindgen_futures::spawn_localを使ったコードの自動テストが一見パスしているものの処理が完了する前にプログラムが終了してしまうようなので解決したい

test CHANGED Viewed

@@ -9,7 +9,10 @@
 ## 発生している問題・エラーメッセージ
+##### プロジェクトの構成
-```console
+```console
+% pwd
+/Users/a.kano/development/rust/github_crate/wasm_bindgen_futures_test
 % tree -L 2 .
 .
 |-- Cargo.toml
@@ -138,11 +141,12 @@
     font-weight: bold; color: inherit
     background: inherit; color: inherit
 ```
-自動テスト自体はパスします。
+上記から、一見すると自動テスト自体はパスしているように見えます。
-ただ、見る限りどうやら目的とする処理に辿り着く前にプログラムが終了してしまっているようなのです。
+ただ、よく見るとどうやら目的とする処理に辿り着く前にプログラムが終了してしまっているようなのです。
-うまくテストが実行されていれば、上記のログに`ip.origin: XXX`が出力されているはずです。
+なぜならうまくテストが実行されていれば、上記のログに`ip.origin: XXX`が出力されているはずです。
 しかし、該当する出力は確認できないため、自動テストが意味を成していないことがわかります。
 これが、今回の問題です！
+私は、この非同期の終了を待ちたいです。どうすれば待つことができるでしょうか？
 ## 該当のソースコード

WebAssembly Firefox 非同期処理 Rust