Deno JavaScriptランタイムを使ってアプリにユーザー拡張機能を加えよう

use deno_core::{
  JsRuntime, 
  serde_v8, 
  v8,
  PollEventLoopOptions,
  RuntimeOptions
};
use serde::Deserialize;

/// ユーザースクリプトを実行して結果を返します。
pub async fn execute_script<R: for<'de> Deserialize<'de>>(
   js_code: impl Into<String>
) -> Result<R, anyhow::Error> {
    // JSランタイムの新しいインスタンスを作成します。
    let runtime = JsRuntime::new(RuntimeOptions::default());

    // JSコードの文字列を`ModuleCodeString`に変換し、
    // 結果を取り出します。このスニペットは、`js_code`から
    // のJSコードが非同期であり`Promise`を返すと想定しています。
    // たとえば、以下のようなものです：
    // r#"(async () => {{ return 2 + 2; }})();"#
    let script_result_promise = runtime
        .execute_script("<anon>", js_code.into().into())?;

    // 今、プロミスが解決するのを待ちます。
    let resolve = runtime.resolve(script_result_promise);
    let script_result = runtime
        .with_event_loop_promise(
            resolve, 
            PollEventLoopOptions::default()
        )
        .await?;

    // v8型からスクリプトの結果をデシリアライズして返します。
    let scope = &mut runtime.handle_scope();
    let local = v8::Local::new(scope, script_result);
    serde_v8::from_v8(scope, local)
}

use deno_core::{serde_v8, v8};
use serde::Serialize;

// パラメータをv8互換型にシリアライズできることを
// 確認してください。
#[derive(Serialize, Debug, PartialEq, Eq, Clone)]
struct ScriptParams {
    arg_num: usize,
    arg_str: String,
    arg_array: Vec<String>,
    arg_buf: Vec<u8>,
}

// パラメータを作成します。
let script_params = ScriptParams {
    arg_num: 1,
    arg_str: "Hello, world!".to_string(),
    arg_array: vec!["one".to_string(), "two".to_string()],
    arg_buf: vec![1, 2, 3],
};

// スクリプトの "scope" を取得します。
let scope = &mut runtime.handle_scope();
let context = scope.get_current_context();
let scope = &mut v8::ContextScope::new(scope, context);

// グローバルスコープにパラメータを保存するためのキーを準備します。
let params_key = v8::String::new(scope, "param").unwrap();
// パラメータ値をv8互換型にシリアライズします。
let params_value = serde_v8::to_v8(scope, script_params)?;
// グローバルスコープに値を設定します（`globalThis.param`）。
context
    .global(scope)
    .set(scope, params_key.into(), params_value); 

(() => {
    // 無限ループ。
    while (true) {}
})(); 

use std::{
    sync::{atomic::{AtomicBool, Ordering}, Arc},
    time::{Duration, Instant},
};

// スクリプトが終了されるタイムアウトを定義します。
let termination_timeout = Duration::from_secs(30);

// メインスレッドがスクリプトの実行が完了したことを
// 終了スレッドに通知し、終了する必要がないことを伝えるための
// "キャンセレーショントークン"を定義します。
let timeout_token = Arc::new(AtomicBool::new(false));

// v8::Isolateのハンドルを取得します。
let isolate_handle = runtime.v8_isolate().thread_safe_handle();
let timeout_token_clone = timeout_token.clone();
std::thread::spawn(move || {
    let now = Instant::now();
    loop {
        // もしメインスレッドがスクリプトの実行が完了したことを
        // 通知したら、終了します。
        if timeout_token_clone.load(Ordering::Relaxed) {
            return;
        }

        // そうでなければ、時間切れの場合は実行を終了するか、
        // 最大2秒間スリープします<br><br>こちらの記事はdev.toの良い記事を日本人向けに翻訳しています。<br>[https://dev.to/azasypkin/supercharge-your-app-with-user-extensions-using-deno-runtime-5hck](https://dev.to/azasypkin/supercharge-your-app-with-user-extensions-using-deno-runtime-5hck)