mirror of
https://github.com/lexmount/moli.git
synced 2026-11-13 16:10:01 +00:00
ldm0
d9290e87ad
Support type: text through the shared module map, Window, child Documents and workers. Export UTF-8 decoded strings without executing their contents, preserve typed-module identity, and carry text request metadata through network, preload and Service Worker loaders. Regressions cover static/dynamic import sharing, BOM and invalid UTF-8, CORS, integrity, worker environments and unsupported-type rejection. Extracted from development commita6de018613. Base: main (62e527cd34). Validation (32 build jobs and test threads): cargo fmt --all; cargo clippy --workspace --all-targets --all-features -- -D warnings; cargo nextest run --no-fail-fast. Summary [ 146.817s] 22203 tests run: 22203 passed (9 slow), 20 skipped
42 lines
1.8 KiB
Rust
42 lines
1.8 KiB
Rust
use super::*;
|
|
|
|
#[tokio::test(flavor = "multi_thread")]
|
|
async fn text_modules_decode_and_cache_in_window_and_worker_realms() -> Result<()> {
|
|
let server = FixtureServer::spawn().await?;
|
|
let browser = Browser::new(AppConfig::default())?;
|
|
let mut page = browser.fetch(&server.url("/static")).await?;
|
|
let probe = include_str!("../fixtures/text-modules.js");
|
|
let expression = format!(
|
|
r#"(async () => {{
|
|
const probe = {probe};
|
|
const results = [await probe()];
|
|
for (const type of ['classic', 'module']) {{
|
|
const source = '(' + probe.toString() + ')().then(postMessage, e => postMessage({{error:e.name}}));';
|
|
const url = URL.createObjectURL(new Blob([source], {{type:'text/javascript'}}));
|
|
const worker = new Worker(url, {{type}});
|
|
try {{
|
|
results.push(await new Promise((resolve, reject) => {{
|
|
worker.onmessage = event => resolve(event.data);
|
|
worker.onerror = event => reject(new Error(event.message));
|
|
}}));
|
|
}} finally {{ worker.terminate(); URL.revokeObjectURL(url); }}
|
|
}}
|
|
return JSON.stringify(results);
|
|
}})()"#,
|
|
);
|
|
let result = tokio::time::timeout(
|
|
Duration::from_secs(15),
|
|
page.evaluate_runtime_expression_with_await_async(&expression, true),
|
|
)
|
|
.await??;
|
|
let observed: serde_json::Value =
|
|
serde_json::from_str(result["value"].as_str().expect("text module probe results"))?;
|
|
for realm in observed.as_array().expect("three probe realms") {
|
|
assert_eq!(realm["failures"], serde_json::json!([]), "{realm}");
|
|
assert!(realm["checks"].as_u64().unwrap() >= 50, "{realm}");
|
|
}
|
|
assert_eq!(observed.as_array().unwrap().len(), 3);
|
|
server.shutdown().await;
|
|
Ok(())
|
|
}
|