workers.

Cargo.lock

···
 
 [[package]]
 name = "async-compression"
-version = "0.4.34"
+version = "0.4.35"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0e86f6d3dc9dc4352edeea6b8e499e13e3f5dc3b964d7ca5fd411415a3498473"
+checksum = "07a926debf178f2d355197f9caddb08e54a9329d44748034bba349c5848cb519"
 dependencies = [
  "compression-codecs",
  "compression-core",
···
 
 [[package]]
 name = "base64ct"
-version = "1.8.0"
+version = "1.8.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "55248b47b0caf0546f7988906588779981c43bb1bc9d0c44087278f80cdb44ba"
+checksum = "0e050f626429857a27ddccb31e0aca21356bfa709c04041aefddac081a8f068a"
 
 [[package]]
 name = "basic-toml"
···
 
 [[package]]
 name = "cc"
-version = "1.2.48"
+version = "1.2.49"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c481bdbf0ed3b892f6f806287d72acd515b352a4ec27a208489b8c1bc839633a"
+checksum = "90583009037521a116abf44494efecd645ba48b6622457080f080b85544e2215"
 dependencies = [
  "find-msvc-tools",
  "jobserver",
···
 
 [[package]]
 name = "compression-codecs"
-version = "0.4.33"
+version = "0.4.34"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "302266479cb963552d11bd042013a58ef1adc56768016c8b82b4199488f2d4ad"
+checksum = "34a3cbbb8b6eca96f3a5c4bf6938d5b27ced3675d69f95bb51948722870bc323"
 dependencies = [
  "compression-core",
  "flate2",
···
 
 [[package]]
 name = "dlopen2"
-version = "0.8.1"
+version = "0.8.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "8d65cde5fb0c42a3d5882d99807698b459f5928de035fa7f547c784fb7b34219"
+checksum = "5e2c5bd4158e66d1e215c49b837e11d62f3267b30c92f1d171c4d3105e3dc4d4"
 dependencies = [
  "dlopen2_derive",
  "libc",
···
 
 [[package]]
 name = "dlopen2_derive"
-version = "0.4.2"
+version = "0.4.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "95f4a04e1bfbfa4835a6073177aafb95ead4de0722dbb339195fdc7e0a09599b"
+checksum = "0fbbb781877580993a8707ec48672673ec7b81eeba04cfd2310bd28c08e47c8f"
 dependencies = [
  "proc-macro2",
  "quote",
···
 
 [[package]]
 name = "flate2"
-version = "1.1.7"
+version = "1.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a2152dbcb980c05735e2a651d96011320a949eb31a0c8b38b72645ce97dec676"
+checksum = "bfe33edd8e85a12a67454e37f8c75e730830d83e313556ab9ebf9ee7fbeb3bfb"
 dependencies = [
  "crc32fast",
  "miniz_oxide",
···
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "219cb19e96be00ab2e37d6e299658a0cfa83e52429179969b0f0121b4ac46983"
 dependencies = [
- "toml_edit 0.23.8",
+ "toml_edit 0.23.9",
 ]
 
 [[package]]
···
 
 [[package]]
 name = "simd-adler32"
-version = "0.3.7"
+version = "0.3.8"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d66dc143e6b11c1eddc06d5c423cfc97062865baf299914ab64caa38182078fe"
+checksum = "e320a6c5ad31d271ad523dcf3ad13e2767ad8b1cb8f047f75a8aeaf8da139da2"
 
 [[package]]
 name = "simdutf8"
···
 
 [[package]]
 name = "slotmap"
-version = "1.1.0"
+version = "1.1.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "811fec94324ff439b2d5e4a1cf88cc5b6c09d92358715d600b2fe91c0489b5cb"
+checksum = "bdd58c3c93c3d278ca835519292445cb4b0d4dc59ccfdf7ceadaab3f8aeb4038"
 dependencies = [
  "serde",
  "version_check",
···
  "core-graphics",
  "crossbeam-channel",
  "dispatch",
- "dlopen2 0.8.1",
+ "dlopen2 0.8.2",
  "dpi",
  "gdkwayland-sys",
  "gdkx11-sys",
···
 
 [[package]]
 name = "toml_edit"
-version = "0.23.8"
+version = "0.23.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5a9b7ac41d92f2d2803f233e297127bac397df7b337e0460a1cc39d6c006dee4"
+checksum = "5d7cbc3b4b49633d57a0509303158ca50de80ae32c265093b24c414705807832"
 dependencies = [
  "indexmap 2.12.1",
  "toml_datetime 0.7.3",
···
 
 [[package]]
 name = "tower-http"
-version = "0.6.7"
+version = "0.6.8"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9cf146f99d442e8e68e585f5d798ccd3cad9a7835b917e09728880a862706456"
+checksum = "d4e6559d53cc268e5031cd8429d05415bc4cb4aefc4aa5d6cc35fbf5b924a1f8"
 dependencies = [
  "bitflags 2.10.0",
  "bytes",

build-workers.sh

···
+#!/usr/bin/env bash
+set -euo pipefail
+
+echo "==> Building worker WASMs"
+export RUSTFLAGS='--cfg getrandom_backend="wasm_js"'
+cargo build -p weaver-app --bin editor_worker --bin embed_worker \
+    --target wasm32-unknown-unknown --release \
+    --no-default-features --features "web"
+
+echo "==> Running wasm-bindgen"
+wasm-bindgen target/wasm32-unknown-unknown/release/editor_worker.wasm \
+    --out-dir crates/weaver-app/public \
+    --target no-modules \
+    --no-typescript
+wasm-bindgen target/wasm32-unknown-unknown/release/embed_worker.wasm \
+    --out-dir crates/weaver-app/public \
+    --target no-modules \
+    --no-typescript
+
+echo "==> Done"
+ls -lh crates/weaver-app/public/*worker*

crates/weaver-app/Cargo.toml

···
 [[bin]]
 name = "editor_worker"
 path = "src/bin/editor_worker.rs"
+required-features = ["web"]
 
 [[bin]]
 name = "embed_worker"
 path = "src/bin/embed_worker.rs"
+required-features = ["web"]
 
 [features]
 default = ["web", "fullstack-server", "no-app-index"]

crates/weaver-app/public/editor_worker.js

···
         wasm.wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___wasm_bindgen_1add006a0ed82fd3___JsValue_____(arg0, arg1, arg2);
     }
 
-    function wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_81daa69175395078___features__gen_MessageEvent__MessageEvent_____(arg0, arg1, arg2) {
-        wasm.wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_81daa69175395078___features__gen_MessageEvent__MessageEvent_____(arg0, arg1, arg2);
+    function wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_1984c39bba2ffe3a___features__gen_MessageEvent__MessageEvent_____(arg0, arg1, arg2) {
+        wasm.wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_1984c39bba2ffe3a___features__gen_MessageEvent__MessageEvent_____(arg0, arg1, arg2);
     }
 
     function wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___wasm_bindgen_1add006a0ed82fd3___JsValue__wasm_bindgen_1add006a0ed82fd3___JsValue_____(arg0, arg1, arg2, arg3) {
···
             const ret = getStringFromWasm0(arg0, arg1);
             return ret;
         };
+        imports.wbg.__wbindgen_cast_7486151126cca30f = function(arg0, arg1) {
+            // Cast intrinsic for `Closure(Closure { dtor_idx: 66, function: Function { arguments: [NamedExternref("MessageEvent")], shim_idx: 67, ret: Unit, inner_ret: Some(Unit) }, mutable: false }) -> Externref`.
+            const ret = makeClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__Fn__web_sys_1984c39bba2ffe3a___features__gen_MessageEvent__MessageEvent____Output_______, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_1984c39bba2ffe3a___features__gen_MessageEvent__MessageEvent_____);
+            return ret;
+        };
         imports.wbg.__wbindgen_cast_cb9088102bce6b30 = function(arg0, arg1) {
             // Cast intrinsic for `Ref(Slice(U8)) -> NamedExternref("Uint8Array")`.
             const ret = getArrayU8FromWasm0(arg0, arg1);
-            return ret;
-        };
-        imports.wbg.__wbindgen_cast_df669a3c3b68a548 = function(arg0, arg1) {
-            // Cast intrinsic for `Closure(Closure { dtor_idx: 65, function: Function { arguments: [NamedExternref("MessageEvent")], shim_idx: 66, ret: Unit, inner_ret: Some(Unit) }, mutable: false }) -> Externref`.
-            const ret = makeClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__Fn__web_sys_81daa69175395078___features__gen_MessageEvent__MessageEvent____Output_______, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_81daa69175395078___features__gen_MessageEvent__MessageEvent_____);
             return ret;
         };
         imports.wbg.__wbindgen_init_externref_table = function() {

crates/weaver-app/public/embed_worker.js

···
         wasm.wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke______(arg0, arg1);
     }
 
-    function wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_81daa69175395078___features__gen_MessageEvent__MessageEvent_____(arg0, arg1, arg2) {
-        wasm.wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_81daa69175395078___features__gen_MessageEvent__MessageEvent_____(arg0, arg1, arg2);
+    function wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_1984c39bba2ffe3a___features__gen_MessageEvent__MessageEvent_____(arg0, arg1, arg2) {
+        wasm.wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_1984c39bba2ffe3a___features__gen_MessageEvent__MessageEvent_____(arg0, arg1, arg2);
     }
 
     function wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke_______1_(arg0, arg1) {
···
         imports.wbg.__wbg_abort_399ecbcfd6ef3c8e = function(arg0, arg1) {
             arg0.abort(arg1);
         };
-        imports.wbg.__wbg_append_0a085a855907169f = function() { return handleError(function (arg0, arg1, arg2, arg3) {
-            arg0.append(getStringFromWasm0(arg1, arg2), arg3);
-        }, arguments) };
-        imports.wbg.__wbg_append_90fbf76fbc23e35f = function() { return handleError(function (arg0, arg1, arg2, arg3, arg4) {
-            arg0.append(getStringFromWasm0(arg1, arg2), getStringFromWasm0(arg3, arg4));
-        }, arguments) };
         imports.wbg.__wbg_append_c5cbdf46455cc776 = function() { return handleError(function (arg0, arg1, arg2, arg3, arg4) {
             arg0.append(getStringFromWasm0(arg1, arg2), getStringFromWasm0(arg3, arg4));
-        }, arguments) };
-        imports.wbg.__wbg_append_ef47c723098c3768 = function() { return handleError(function (arg0, arg1, arg2, arg3, arg4, arg5) {
-            arg0.append(getStringFromWasm0(arg1, arg2), arg3, getStringFromWasm0(arg4, arg5));
         }, arguments) };
         imports.wbg.__wbg_arrayBuffer_c04af4fce566092d = function() { return handleError(function (arg0) {
             const ret = arg0.arrayBuffer();
···
             const ret = new Object();
             return ret;
         };
-        imports.wbg.__wbg_new_25f239778d6112b9 = function() {
-            const ret = new Array();
-            return ret;
-        };
         imports.wbg.__wbg_new_3c79b3bb1b32b7d3 = function() { return handleError(function () {
             const ret = new Headers();
             return ret;
···
             const ret = new Error(getStringFromWasm0(arg0, arg1));
             return ret;
         };
-        imports.wbg.__wbg_new_e66247b901edc931 = function() { return handleError(function () {
-            const ret = new FormData();
-            return ret;
-        }, arguments) };
         imports.wbg.__wbg_new_ff12d2b041fb48f1 = function(arg0, arg1) {
             try {
                 var state0 = {a: arg0, b: arg1};
···
             const ret = new Request(getStringFromWasm0(arg0, arg1), arg2);
             return ret;
         }, arguments) };
-        imports.wbg.__wbg_new_with_u8_array_sequence_and_options_d4def9ec0588c7ec = function() { return handleError(function (arg0, arg1) {
-            const ret = new Blob(arg0, arg1);
-            return ret;
-        }, arguments) };
         imports.wbg.__wbg_next_138a17bbf04e926c = function(arg0) {
             const ret = arg0.next;
             return ret;
···
         imports.wbg.__wbg_prototypesetcall_dfe9b766cdc1f1fd = function(arg0, arg1, arg2) {
             Uint8Array.prototype.set.call(getArrayU8FromWasm0(arg0, arg1), arg2);
         };
-        imports.wbg.__wbg_push_7d9be8f38fc13975 = function(arg0, arg1) {
-            const ret = arg0.push(arg1);
-            return ret;
-        };
         imports.wbg.__wbg_queueMicrotask_9b549dfce8865860 = function(arg0) {
             const ret = arg0.queueMicrotask;
             return ret;
···
         };
         imports.wbg.__wbg_set_signal_e89be862d0091009 = function(arg0, arg1) {
             arg0.signal = arg1;
-        };
-        imports.wbg.__wbg_set_type_7ce650670a34c68f = function(arg0, arg1, arg2) {
-            arg0.type = getStringFromWasm0(arg1, arg2);
         };
         imports.wbg.__wbg_signal_3c14fbdc89694b39 = function(arg0) {
             const ret = arg0.signal;
···
             const ret = getStringFromWasm0(arg0, arg1);
             return ret;
         };
-        imports.wbg.__wbindgen_cast_600f2adf1b415b72 = function(arg0, arg1) {
-            // Cast intrinsic for `Closure(Closure { dtor_idx: 364, function: Function { arguments: [NamedExternref("MessageEvent")], shim_idx: 365, ret: Unit, inner_ret: Some(Unit) }, mutable: false }) -> Externref`.
-            const ret = makeClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__Fn__web_sys_81daa69175395078___features__gen_MessageEvent__MessageEvent____Output_______, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_81daa69175395078___features__gen_MessageEvent__MessageEvent_____);
+        imports.wbg.__wbindgen_cast_58535cde6944cfce = function(arg0, arg1) {
+            // Cast intrinsic for `Closure(Closure { dtor_idx: 2267, function: Function { arguments: [Externref], shim_idx: 2268, ret: Unit, inner_ret: Some(Unit) }, mutable: true }) -> Externref`.
+            const ret = makeMutClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__FnMut__wasm_bindgen_1add006a0ed82fd3___JsValue____Output_______, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___wasm_bindgen_1add006a0ed82fd3___JsValue_____);
             return ret;
         };
-        imports.wbg.__wbindgen_cast_89cd6f7b6be057aa = function(arg0, arg1) {
-            // Cast intrinsic for `Closure(Closure { dtor_idx: 2024, function: Function { arguments: [], shim_idx: 2025, ret: Unit, inner_ret: Some(Unit) }, mutable: true }) -> Externref`.
-            const ret = makeMutClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__FnMut_____Output________1_, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke_______1_);
+        imports.wbg.__wbindgen_cast_bd3d7d0f0ebc68be = function(arg0, arg1) {
+            // Cast intrinsic for `Closure(Closure { dtor_idx: 1185, function: Function { arguments: [], shim_idx: 1186, ret: Unit, inner_ret: Some(Unit) }, mutable: true }) -> Externref`.
+            const ret = makeMutClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__FnMut_____Output_______, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke______);
             return ret;
         };
-        imports.wbg.__wbindgen_cast_9216bf6c1753368f = function(arg0, arg1) {
-            // Cast intrinsic for `Closure(Closure { dtor_idx: 1144, function: Function { arguments: [], shim_idx: 1145, ret: Unit, inner_ret: Some(Unit) }, mutable: true }) -> Externref`.
-            const ret = makeMutClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__FnMut_____Output_______, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke______);
+        imports.wbg.__wbindgen_cast_c5ee62b4aaae9530 = function(arg0, arg1) {
+            // Cast intrinsic for `Closure(Closure { dtor_idx: 1445, function: Function { arguments: [], shim_idx: 1446, ret: Unit, inner_ret: Some(Unit) }, mutable: true }) -> Externref`.
+            const ret = makeMutClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__FnMut_____Output________1_, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke_______1_);
             return ret;
         };
-        imports.wbg.__wbindgen_cast_eee509cff0277222 = function(arg0, arg1) {
-            // Cast intrinsic for `Closure(Closure { dtor_idx: 2221, function: Function { arguments: [Externref], shim_idx: 2222, ret: Unit, inner_ret: Some(Unit) }, mutable: true }) -> Externref`.
-            const ret = makeMutClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__FnMut__wasm_bindgen_1add006a0ed82fd3___JsValue____Output_______, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___wasm_bindgen_1add006a0ed82fd3___JsValue_____);
+        imports.wbg.__wbindgen_cast_cf4ca89562bb2a76 = function(arg0, arg1) {
+            // Cast intrinsic for `Closure(Closure { dtor_idx: 419, function: Function { arguments: [NamedExternref("MessageEvent")], shim_idx: 420, ret: Unit, inner_ret: Some(Unit) }, mutable: false }) -> Externref`.
+            const ret = makeClosure(arg0, arg1, wasm.wasm_bindgen_1add006a0ed82fd3___closure__destroy___dyn_core_b125d98f3949a913___ops__function__Fn__web_sys_1984c39bba2ffe3a___features__gen_MessageEvent__MessageEvent____Output_______, wasm_bindgen_1add006a0ed82fd3___convert__closures_____invoke___web_sys_1984c39bba2ffe3a___features__gen_MessageEvent__MessageEvent_____);
             return ret;
         };
         imports.wbg.__wbindgen_init_externref_table = function() {

crates/weaver-app/src/components/editor/component.rs

···
                                 doc.commit();
 
                                 // Pre-warm blob cache for images
+                                #[cfg(feature = "fullstack-server")]
                                 if let Some(ref embeds) = loaded.entry.embeds {
                                     if let Some(ref images) = embeds.images {
                                         let ident: &str = match uri.authority() {
···
         paras
     });
 
-    // Background fetch for AT embeds
-    let mut resolved_content_for_fetch = resolved_content.clone();
-    let doc_for_embeds = document.clone();
-    let fetcher_for_embeds = fetcher.clone();
-    use_effect(move || {
-        let refs = doc_for_embeds.collected_refs.read();
-        let current_resolved = resolved_content_for_fetch.peek();
-        let fetcher = fetcher_for_embeds.clone();
+    // Background fetch for AT embeds via worker
+    #[cfg(all(target_arch = "wasm32", target_os = "unknown"))]
+    {
+        use super::worker::{EmbedWorker, EmbedWorkerInput, EmbedWorkerOutput};
+        use dioxus::prelude::Writable;
+        use gloo_worker::Spawnable;
+
+        let resolved_content_for_fetch = resolved_content;
+        let mut embed_worker_bridge: Signal<Option<gloo_worker::WorkerBridge<EmbedWorker>>> =
+            use_signal(|| None);
 
-        // Find AT embeds that need fetching
-        let to_fetch: Vec<String> = refs
-            .iter()
-            .filter_map(|r| match r {
-                weaver_common::ExtractedRef::AtEmbed { uri, .. } => {
-                    // Skip if already resolved
-                    if let Ok(at_uri) = jacquard::types::string::AtUri::new(uri) {
-                        if current_resolved.get_embed_content(&at_uri).is_none() {
-                            return Some(uri.clone());
+        // Spawn embed worker on mount
+        let doc_for_embeds = document.clone();
+        use_effect(move || {
+            // Callback for worker responses - uses write_unchecked since we're in a Fn closure
+            let on_output = move |output: EmbedWorkerOutput| match output {
+                EmbedWorkerOutput::Embeds {
+                    results,
+                    errors,
+                    fetch_ms,
+                } => {
+                    if !results.is_empty() {
+                        let mut rc = resolved_content_for_fetch.write_unchecked();
+                        for (uri_str, html) in results {
+                            if let Ok(at_uri) =
+                                jacquard::types::string::AtUri::new_owned(uri_str)
+                            {
+                                rc.add_embed(at_uri, html, None);
+                            }
                         }
+                        tracing::debug!(
+                            count = rc.embed_content.len(),
+                            fetch_ms,
+                            "embed worker fetched embeds"
+                        );
                     }
-                    None
+                    for (uri, err) in errors {
+                        tracing::warn!("embed worker failed to fetch {}: {}", uri, err);
+                    }
                 }
-                _ => None,
-            })
-            .collect();
+                EmbedWorkerOutput::CacheCleared => {
+                    tracing::debug!("embed worker cache cleared");
+                }
+            };
 
-        if to_fetch.is_empty() {
-            return;
-        }
+            let bridge = EmbedWorker::spawner()
+                .callback(on_output)
+                .spawn("/embed_worker.js");
+            embed_worker_bridge.set(Some(bridge));
+            tracing::info!("Embed worker spawned");
+        });
 
-        // Spawn background fetches
-        dioxus::prelude::spawn(async move {
-            for uri_str in to_fetch {
-                let Ok(at_uri) = jacquard::types::string::AtUri::new(&uri_str) else {
-                    continue;
-                };
+        // Send embeds to worker when collected_refs changes
+        use_effect(move || {
+            let refs = doc_for_embeds.collected_refs.read();
+            let current_resolved = resolved_content_for_fetch.peek();
 
-                match weaver_renderer::atproto::fetch_and_render(&at_uri, &fetcher).await {
-                    Ok(html) => {
-                        let mut rc = resolved_content_for_fetch.write();
-                        rc.add_embed(at_uri.into_static(), html, None);
+            // Find AT embeds that need fetching
+            let to_fetch: Vec<String> = refs
+                .iter()
+                .filter_map(|r| match r {
+                    weaver_common::ExtractedRef::AtEmbed { uri, .. } => {
+                        // Skip if already resolved
+                        if let Ok(at_uri) = jacquard::types::string::AtUri::new(uri) {
+                            if current_resolved.get_embed_content(&at_uri).is_none() {
+                                return Some(uri.clone());
+                            }
+                        }
+                        None
                     }
-                    Err(e) => {
-                        tracing::warn!("failed to fetch embed {}: {}", uri_str, e);
+                    _ => None,
+                })
+                .collect();
+
+            if to_fetch.is_empty() {
+                return;
+            }
+
+            // Send to worker
+            if let Some(ref bridge) = *embed_worker_bridge.peek() {
+                bridge.send(EmbedWorkerInput::FetchEmbeds { uris: to_fetch });
+            }
+        });
+    }
+
+    // Fallback for non-WASM (server-side rendering)
+    #[cfg(not(all(target_arch = "wasm32", target_os = "unknown")))]
+    {
+        let mut resolved_content_for_fetch = resolved_content.clone();
+        let doc_for_embeds = document.clone();
+        let fetcher_for_embeds = fetcher.clone();
+        use_effect(move || {
+            let refs = doc_for_embeds.collected_refs.read();
+            let current_resolved = resolved_content_for_fetch.peek();
+            let fetcher = fetcher_for_embeds.clone();
+
+            // Find AT embeds that need fetching
+            let to_fetch: Vec<String> = refs
+                .iter()
+                .filter_map(|r| match r {
+                    weaver_common::ExtractedRef::AtEmbed { uri, .. } => {
+                        // Skip if already resolved
+                        if let Ok(at_uri) = jacquard::types::string::AtUri::new(uri) {
+                            if current_resolved.get_embed_content(&at_uri).is_none() {
+                                return Some(uri.clone());
+                            }
+                        }
+                        None
+                    }
+                    _ => None,
+                })
+                .collect();
+
+            if to_fetch.is_empty() {
+                return;
+            }
+
+            // Spawn background fetches (main thread fallback)
+            dioxus::prelude::spawn(async move {
+                for uri_str in to_fetch {
+                    let Ok(at_uri) = jacquard::types::string::AtUri::new(&uri_str) else {
+                        continue;
+                    };
+
+                    match weaver_renderer::atproto::fetch_and_render(&at_uri, &fetcher).await {
+                        Ok(html) => {
+                            let mut rc = resolved_content_for_fetch.write();
+                            rc.add_embed(at_uri.into_static(), html, None);
+                        }
+                        Err(e) => {
+                            tracing::warn!("failed to fetch embed {}: {}", uri_str, e);
+                        }
                     }
                 }
-            }
+            });
         });
-    });
+    }
 
     let mut new_tag = use_signal(String::new);
 

crates/weaver-app/src/components/editor/sync.rs

···
     let embeds_map = doc.get_map("embeds");
 
     // Pre-warm blob cache for images
+    #[cfg(feature = "fullstack-server")]
     if let Some(ident) = owner_ident {
         if let Ok(images_container) =
             embeds_map.get_or_create_container("images", loro::LoroList::new())
···
             }
         }
     }
+    #[cfg(not(feature = "fullstack-server"))]
+    let _ = owner_ident;
 
     // Strategy 1: Get embeds from Loro embeds map -> records list
 

crates/weaver-app/src/components/editor/worker.rs

···
                                     results.insert(uri_str, html);
                                 }
                                 Err(e) => {
-                                    errors.insert(uri_str, e.to_string());
+                                    errors.insert(uri_str, format!("{:?}", e));
                                 }
                             }
                         }

crates/weaver-app/src/components/editor/writer.rs

···
 //! Uses Parser::into_offset_iter() to track gaps between events, which
 //! represent consumed formatting characters.
 
-use crate::data::cache_blob;
-
 use super::offset_map::{OffsetMapping, RenderResult};
 use jacquard::types::{ident::AtIdentifier, string::Rkey};
 use loro::LoroText;
···
             self.offset_maps.push(mapping);
             self.current_node_char_offset += utf16_len;
         } else {
-            tracing::warn!("[RECORD_MAPPING] SKIPPED - current_node_id is None!");
+            tracing::debug!("[RECORD_MAPPING] SKIPPED - current_node_id is None!");
         }
     }
 

crates/weaver-app/src/data.rs

···
                         }
                     }
                 }
-                Some(entry)
+                Some((entry.0.clone(), entry.1.clone()))
             } else {
                 None
             }

crates/weaver-renderer/src/atproto/embed_renderer.rs

···
     let did = match ident {
         AtIdentifier::Did(d) => d.clone(),
         AtIdentifier::Handle(h) => {
-            let did_str = agent
-                .resolve_handle(h)
-                .await
-                .map_err(|e| AtProtoPreprocessError::FetchFailed(e.to_string()))?;
+            let did_str = agent.resolve_handle(h).await.map_err(|e| {
+                AtProtoPreprocessError::FetchFailed(format!("resolving handle {:?}", e))
+            })?;
             Did::new(&did_str)
-                .map_err(|e| AtProtoPreprocessError::InvalidUri(e.to_string()))?
+                .map_err(|e| AtProtoPreprocessError::InvalidUri(format!("{:?}", e)))?
                 .into_static()
         }
     };
···
     let (_uri, profile_view) = agent
         .hydrate_profile_view(&did)
         .await
-        .map_err(|e| AtProtoPreprocessError::FetchFailed(e.to_string()))?;
+        .map_err(|e| AtProtoPreprocessError::FetchFailed(format!("{:?}", e)))?;
 
     // Render based on which profile type we got
     render_profile_data_view(&profile_view.inner)
···
     // Use GetPosts for richer data (author info, engagement counts)
     let request = GetPosts::new().uris(vec![uri.clone()]).build();
     let response = agent.send(request).await;
-    let response = response.map_err(|e| AtProtoPreprocessError::FetchFailed(e.to_string()))?;
+    let response = response.map_err(|e| {
+        AtProtoPreprocessError::FetchFailed(format!("getting post from appview {:?}", e))
+    })?;
 
     let output = response
         .into_output()
-        .map_err(|e| AtProtoPreprocessError::FetchFailed(e.to_string()))?;
+        .map_err(|e| AtProtoPreprocessError::FetchFailed(format!("{:?}", e)))?;
 
     let post_view = output
         .posts
···
     let output = agent
         .fetch_record_slingshot(uri)
         .await
-        .map_err(|e| AtProtoPreprocessError::FetchFailed(e.to_string()))?;
+        .map_err(|e| AtProtoPreprocessError::FetchFailed(format!("{:?}", e)))?;
 
     // Probe for meaningful fields
     render_generic_record(&output.value, uri)
···
     ClientWriter::<_, _, ()>::new(parser, &mut content_html)
         .run()
         .map_err(|e| {
-            AtProtoPreprocessError::FetchFailed(format!("Markdown render failed: {}", e))
+            AtProtoPreprocessError::FetchFailed(format!("Markdown render failed: {:?}", e))
         })?;
 
     // Generate unique ID for the toggle checkbox