2 Commits
Author SHA1 Message Date
reya 584ab34df6 chore: release version 1.0.1 2026-09-07 13:58:43 +07:00
reya 0514c1d982 fix: panic on flatpak installations 2026-09-07 13:49:36 +07:00
37 changed files with 384 additions and 836 deletions
Generated
+49 -57
View File
@@ -273,16 +273,12 @@ dependencies = [
[[package]]
name = "assets"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"futures",
"gpui",
"log",
"reqwest",
"rust-embed",
"wasm-bindgen-futures",
"web-sys",
]
[[package]]
@@ -539,7 +535,7 @@ dependencies = [
[[package]]
name = "auto_update"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"gpui",
"gpui-updater",
@@ -1071,7 +1067,7 @@ dependencies = [
[[package]]
name = "chat"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"common",
@@ -1093,7 +1089,7 @@ dependencies = [
[[package]]
name = "chat_ui"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"chat",
@@ -1251,7 +1247,7 @@ dependencies = [
[[package]]
name = "collections"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"gpui_util",
"indexmap",
@@ -1276,7 +1272,7 @@ dependencies = [
[[package]]
name = "common"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"chrono",
"dirs 5.0.1",
@@ -1404,7 +1400,7 @@ dependencies = [
[[package]]
name = "coop"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"assets",
"auto_update",
@@ -1430,7 +1426,7 @@ dependencies = [
[[package]]
name = "coop_web"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"assets",
"chat",
@@ -1445,7 +1441,6 @@ dependencies = [
"gpui_platform",
"gpui_web",
"instant",
"js-sys",
"log",
"person",
"settings",
@@ -1455,8 +1450,6 @@ dependencies = [
"ui",
"universal-time 0.3.1 (git+https://github.com/shadowylab/universal-time)",
"wasm-bindgen",
"wasm-bindgen-futures",
"web-sys",
"workspace",
]
@@ -1768,7 +1761,7 @@ dependencies = [
[[package]]
name = "derive_refineable"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"proc-macro2",
"quote",
@@ -1777,7 +1770,7 @@ dependencies = [
[[package]]
name = "device"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"common",
@@ -2665,7 +2658,7 @@ dependencies = [
[[package]]
name = "gpui"
version = "0.2.2"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"accesskit",
"anyhow",
@@ -2750,7 +2743,7 @@ dependencies = [
[[package]]
name = "gpui_apple"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"block",
@@ -2773,7 +2766,7 @@ dependencies = [
[[package]]
name = "gpui_linux"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"accesskit",
"accesskit_unix",
@@ -2819,7 +2812,7 @@ dependencies = [
[[package]]
name = "gpui_macos"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"accesskit",
"accesskit_macos",
@@ -2865,7 +2858,7 @@ dependencies = [
[[package]]
name = "gpui_macros"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"heck 0.5.0",
"proc-macro2",
@@ -2876,7 +2869,7 @@ dependencies = [
[[package]]
name = "gpui_platform"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"console_error_panic_hook",
"gpui",
@@ -2889,7 +2882,7 @@ dependencies = [
[[package]]
name = "gpui_shared_string"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"schemars",
"serde",
@@ -2899,7 +2892,7 @@ dependencies = [
[[package]]
name = "gpui_tokio"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"gpui",
@@ -2910,7 +2903,7 @@ dependencies = [
[[package]]
name = "gpui_util"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"log",
@@ -2920,7 +2913,7 @@ dependencies = [
[[package]]
name = "gpui_web"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"console_error_panic_hook",
@@ -2944,7 +2937,7 @@ dependencies = [
[[package]]
name = "gpui_wgpu"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"bytemuck",
@@ -2970,7 +2963,7 @@ dependencies = [
[[package]]
name = "gpui_windows"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"accesskit",
"accesskit_windows",
@@ -3148,9 +3141,9 @@ dependencies = [
[[package]]
name = "hermit-abi"
version = "0.5.3"
version = "0.5.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e17592d60ebacc7d5e169f4663c5f84f9161cc90328abcfe8456f41e4dfcb284"
checksum = "fc0fef456e4baa96da950455cd02c081ca953b141298e41db3fc7e36b1da849c"
[[package]]
name = "hex"
@@ -3245,7 +3238,7 @@ dependencies = [
[[package]]
name = "http_client"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"async-compression",
@@ -3265,7 +3258,7 @@ dependencies = [
[[package]]
name = "http_client_tls"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"log",
"rustls",
@@ -3949,9 +3942,9 @@ dependencies = [
[[package]]
name = "lyon_algorithms"
version = "1.0.21"
version = "1.0.20"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "cdfa8785f95e57914ddb35e3b59994aeba6f5e79e9cfd03da1c269f010f36009"
checksum = "8575c0d003ae459399623c4def180c63b77f343b1a7fee64f249b349e7699a31"
dependencies = [
"lyon_path",
"num-traits",
@@ -3980,9 +3973,9 @@ dependencies = [
[[package]]
name = "lyon_tessellation"
version = "1.0.21"
version = "1.0.20"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "dabea159dc6eea9171a541b458134b70ca95e3162d068132b2b3b9bc01aad06e"
checksum = "8e43b7e44161571868f5c931d12583592c223c5583eef86b08aa02b7048a3552"
dependencies = [
"float_next_after",
"lyon_path",
@@ -4044,7 +4037,7 @@ dependencies = [
[[package]]
name = "media"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"bindgen",
@@ -4600,7 +4593,6 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d49e936b501e5c5bf01fda3a9452ff86dc3ea98ad5f283e1455153142d97518c"
dependencies = [
"bitflags 2.13.1",
"block2 0.6.2",
"objc2 0.6.4",
"objc2-core-foundation",
"objc2-foundation 0.3.2",
@@ -4971,7 +4963,7 @@ checksum = "9b4f627cb1b25917193a259e49bdad08f671f8d9708acfd5fe0a8c1455d87220"
[[package]]
name = "perf"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"collections",
"serde",
@@ -4980,12 +4972,11 @@ dependencies = [
[[package]]
name = "person"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"common",
"flume 0.11.1",
"futures",
"gpui",
"instant",
"log",
@@ -5743,7 +5734,7 @@ dependencies = [
[[package]]
name = "refineable"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"derive_refineable",
]
@@ -5825,7 +5816,7 @@ dependencies = [
[[package]]
name = "reqwest_client"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"bytes",
@@ -6126,7 +6117,7 @@ dependencies = [
[[package]]
name = "scheduler"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"async-task",
"backtrace",
@@ -6394,7 +6385,7 @@ dependencies = [
[[package]]
name = "settings"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"common",
@@ -6638,7 +6629,7 @@ checksum = "6ce2be8dc25455e1f91df71bfa12ad37d7af1092ae736f3a6cd0e37bc7810596"
[[package]]
name = "state"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"browser-signer-proxy",
@@ -6720,7 +6711,7 @@ checksum = "13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292"
[[package]]
name = "sum_tree"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"heapless 0.9.3",
"log",
@@ -6989,7 +6980,7 @@ dependencies = [
[[package]]
name = "theme"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"gpui",
@@ -7538,7 +7529,7 @@ dependencies = [
[[package]]
name = "ui"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"common",
@@ -7759,7 +7750,7 @@ checksum = "b6c140620e7ffbb22c2dee59cafe6084a59b5ffc27a8859a5f0d494b5d52b6be"
[[package]]
name = "util_macros"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"perf",
"quote",
@@ -7798,9 +7789,9 @@ checksum = "ba73ea9cf16a25df0c8caa16c51acb937d5712a8429db78a3ee29d5dcacd3a65"
[[package]]
name = "value-bag"
version = "1.13.2"
version = "1.14.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "068e763e8279de7ab94b6afebded2cb701678af094feb1c12ccb061b4783c1be"
checksum = "11d4788a546b899f8656382fe210e0c478fe3d2dcd6263d50cb6cc268240de6c"
dependencies = [
"value-bag-serde1",
"value-bag-sval2",
@@ -8934,10 +8925,11 @@ checksum = "1ebf944e87a7c253233ad6766e082e3cd714b5d03812acc24c318f549614536e"
[[package]]
name = "workspace"
version = "1.0.0"
version = "1.0.1"
dependencies = [
"anyhow",
"auto_update",
"browser-signer-proxy",
"chat",
"chat_ui",
"common",
@@ -9434,7 +9426,7 @@ checksum = "34b31d188d9d685a4f9c7b46d6e36631b07058d2cfe190267adce54dc230bf12"
[[package]]
name = "zlog"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"anyhow",
"chrono",
@@ -9451,7 +9443,7 @@ checksum = "29666d0abbfad1e3dc4dcf6144730dd3a3ab225bbbdac83319345b1b44ccfc1b"
[[package]]
name = "ztracing"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
dependencies = [
"tracing",
"tracing-subscriber",
@@ -9462,7 +9454,7 @@ dependencies = [
[[package]]
name = "ztracing_macro"
version = "0.1.0"
source = "git+https://github.com/zed-industries/zed#ce48461eaadd16c65c31f835511ab96bd3b6e746"
source = "git+https://github.com/zed-industries/zed#bce0c5785bfd9172c939aca4083fd70bc4930927"
[[package]]
name = "zune-core"
+2 -1
View File
@@ -4,7 +4,7 @@ members = ["crates/*", "desktop", "web"]
default-members = ["desktop"]
[workspace.package]
version = "1.0.0"
version = "1.0.1"
edition = "2024"
publish = false
@@ -43,6 +43,7 @@ smallvec = "1.14.0"
smol = "2"
webbrowser = "1.0.4"
tracing-subscriber = { version = "0.3.18", features = ["fmt"] }
errno = { version = "0.3.14", default-features = false }
instant = "0.1"
[patch.crates-io]
-8
View File
@@ -8,12 +8,4 @@ publish.workspace = true
gpui.workspace = true
anyhow.workspace = true
log.workspace = true
[target.'cfg(not(target_family = "wasm"))'.dependencies]
rust-embed.workspace = true
[target.'cfg(target_family = "wasm")'.dependencies]
futures.workspace = true
reqwest = { version = "0.12", default-features = false }
wasm-bindgen-futures = "0.4"
web-sys = { version = "0.3", features = ["Window", "Location"] }
-58
View File
@@ -1,58 +0,0 @@
//! Generates a compile-time manifest of the asset files served on wasm, so
//! the web entrypoint can preload them before the first frame.
//!
//! `WASM_ASSETS` is emitted into `OUT_DIR` and included by
//! `src/wasm_assets.rs` on wasm targets. Native builds keep using
//! `rust-embed` and ignore it.
use std::path::Path;
use std::{env, fs};
fn main() {
let manifest_dir = env::var("CARGO_MANIFEST_DIR").expect("CARGO_MANIFEST_DIR not set by cargo");
let assets_dir = Path::new(&manifest_dir).join("../../assets");
let mut paths = Vec::new();
for dir in ["icons", "brand"] {
let dir_path = assets_dir.join(dir);
let entries = fs::read_dir(&dir_path).unwrap_or_else(|error| {
panic!(
"expected asset directory {} to exist: {error}",
dir_path.display()
)
});
for entry in entries {
let entry = entry.expect("failed to read asset directory entry");
if entry.file_type().is_ok_and(|t| t.is_file()) {
let name = entry.file_name().to_string_lossy().into_owned();
if !name.starts_with('.') {
paths.push(format!("{dir}/{name}"));
}
}
}
}
paths.sort();
let manifest = format!(
"/// Asset files served by the wasm asset loader. Generated by build.rs.\npub const WASM_ASSETS: &[&str] = &[\n{}\n];\n",
paths
.iter()
.map(|path| format!(" \"{path}\","))
.collect::<Vec<_>>()
.join("\n")
);
let out_dir = env::var("OUT_DIR").expect("OUT_DIR not set by cargo");
fs::write(Path::new(&out_dir).join("wasm_assets.rs"), manifest)
.expect("failed to write wasm asset manifest");
// Rerun when the asset files change (adding/removing files updates the
// directory mtime).
for dir in ["icons", "brand"] {
if let Ok(canonical) = assets_dir.join(dir).canonicalize() {
println!("cargo:rerun-if-changed={}", canonical.display());
}
}
println!("cargo:rerun-if-changed=build.rs");
}
+48 -16
View File
@@ -1,19 +1,51 @@
//! Application assets for Coop.
//!
//! ## Platform differences
//!
//! - **Native (desktop)**: assets are embedded into the binary at compile time
//! with `rust-embed`.
//! - **WASM (web)**: assets are downloaded on demand from `{endpoint}/assets/{path}`
//! and cached in memory. This keeps the WASM bundle size small.
use anyhow::Context;
use gpui::{App, AssetSource, Result, SharedString};
use rust_embed::RustEmbed;
#[cfg(not(target_family = "wasm"))]
mod native_assets;
#[derive(RustEmbed)]
#[folder = "../../assets"]
#[include = "fonts/**/*"]
#[include = "brand/**/*"]
#[include = "icons/**/*"]
#[include = "themes/**/*"]
#[exclude = "*.DS_Store"]
pub struct Assets;
#[cfg(target_family = "wasm")]
mod wasm_assets;
impl AssetSource for Assets {
fn load(&self, path: &str) -> Result<Option<std::borrow::Cow<'static, [u8]>>> {
Self::get(path)
.map(|f| Some(f.data))
.with_context(|| format!("loading asset at path {path:?}"))
}
#[cfg(not(target_family = "wasm"))]
pub use native_assets::Assets;
#[cfg(target_family = "wasm")]
pub use wasm_assets::Assets;
fn list(&self, path: &str) -> Result<Vec<SharedString>> {
Ok(Self::iter()
.filter_map(|p| {
if p.starts_with(path) {
Some(p.into())
} else {
None
}
})
.collect())
}
}
impl Assets {
/// Populate the [`TextSystem`] of the given [`AppContext`] with all `.ttf` fonts in the `fonts` directory.
pub fn load_fonts(&self, cx: &App) -> anyhow::Result<()> {
let font_paths = self.list("fonts")?;
let mut embedded_fonts = Vec::new();
for font_path in font_paths {
if font_path.ends_with(".ttf") {
let font_bytes = cx
.asset_source()
.load(&font_path)?
.expect("Assets should never return None");
embedded_fonts.push(font_bytes);
}
}
cx.text_system().add_fonts(embedded_fonts)
}
}
-63
View File
@@ -1,63 +0,0 @@
use std::borrow::Cow;
use anyhow::Context;
use gpui::{App, AssetSource, Result, SharedString};
use rust_embed::RustEmbed;
/// Native implementation using `rust-embed`: assets are embedded into the
/// binary at compile time.
#[derive(RustEmbed)]
#[folder = "../../assets"]
#[include = "fonts/**/*"]
#[include = "brand/**/*"]
#[include = "icons/**/*"]
#[include = "themes/**/*"]
#[exclude = "*.DS_Store"]
pub struct Assets;
impl Assets {
/// Create a new Assets instance. The endpoint parameter is ignored for
/// native builds.
pub fn new(_endpoint: impl Into<SharedString>) -> Self {
Self
}
}
impl AssetSource for Assets {
fn load(&self, path: &str) -> Result<Option<Cow<'static, [u8]>>> {
Self::get(path)
.map(|f| Some(f.data))
.with_context(|| format!("loading asset at path {path:?}"))
}
fn list(&self, path: &str) -> Result<Vec<SharedString>> {
Ok(Self::iter()
.filter_map(|p| {
if p.starts_with(path) {
Some(p.into())
} else {
None
}
})
.collect())
}
}
impl Assets {
/// Populate the [`TextSystem`] of the given [`AppContext`] with all `.ttf` fonts in the `fonts` directory.
pub fn load_fonts(&self, cx: &App) -> anyhow::Result<()> {
let font_paths = self.list("fonts")?;
let mut embedded_fonts = Vec::new();
for font_path in font_paths {
if font_path.ends_with(".ttf") {
let font_bytes = cx
.asset_source()
.load(&font_path)?
.expect("Assets should never return None");
embedded_fonts.push(font_bytes);
}
}
cx.text_system().add_fonts(embedded_fonts)
}
}
-176
View File
@@ -1,176 +0,0 @@
use std::borrow::Cow;
use std::collections::HashMap;
use std::sync::{Arc, RwLock};
use gpui::{AssetSource, Result, SharedString};
use wasm_bindgen_futures::spawn_local;
// Compile-time manifest of every asset file served on wasm (see build.rs).
include!(concat!(env!("OUT_DIR"), "/wasm_assets.rs"));
/// Path prefixes that the wasm loader serves. Fonts and themes are not
/// downloaded on web: the web platform bundles its own fonts, and the theme
/// registry falls back to the built-in default theme.
const SERVED_PREFIXES: [&str; 2] = ["icons/", "brand/"];
/// WASM implementation - download assets on demand.
///
/// Assets are fetched from `{endpoint}/assets/{path}` and cached in memory
/// after the first successful download. This keeps the WASM bundle small
/// while still providing the full asset set at runtime.
pub struct Assets {
endpoint: SharedString,
cache: Arc<RwLock<HashMap<String, Vec<u8>>>>,
pending: Arc<RwLock<HashMap<String, bool>>>,
}
impl Assets {
/// Create a new Assets instance backed by the given endpoint.
///
/// Assets are resolved as `{endpoint}/assets/{path}`. An empty endpoint
/// resolves against the current page origin (e.g. `/assets/icons/foo.svg`).
pub fn new(endpoint: impl Into<SharedString>) -> Self {
Self {
endpoint: endpoint.into(),
cache: Arc::new(RwLock::new(HashMap::new())),
pending: Arc::new(RwLock::new(HashMap::new())),
}
}
/// Absolute URL of the given asset path.
///
/// `reqwest` requires absolute URLs, so a relative endpoint is resolved
/// against the current page origin.
fn asset_url(&self, path: &str) -> String {
let endpoint = if self.endpoint.is_empty() {
web_sys::window()
.and_then(|window| window.location().origin().ok())
.unwrap_or_default()
} else {
self.endpoint.to_string()
};
format!("{endpoint}/assets/{path}")
}
/// Download every asset in [`WASM_ASSETS`] into the cache, in parallel,
/// before the app starts.
///
/// Preloading is required for two reasons:
/// - Assets loaded through GPUI's [`gpui::Asset`] machinery (e.g. `img()`)
/// cache failed loads and never retry them.
/// - SVG painting only re-attempts an empty load on the next repaint, so
/// an icon would stay invisible until the window happens to redraw.
pub async fn preload(&self) {
let downloads = WASM_ASSETS.iter().map(|path| async move {
let result = reqwest::get(self.asset_url(path)).await;
match result {
Ok(response) if response.status().is_success() => match response.bytes().await {
Ok(bytes) => {
if let Ok(mut cache) = self.cache.write() {
cache.insert(path.to_string(), bytes.to_vec());
}
}
Err(e) => {
log::warn!("Failed to read asset {}: {}", path, e);
}
},
Ok(response) => {
log::warn!(
"Failed to download asset {}: HTTP {}",
path,
response.status()
);
}
Err(e) => {
log::warn!("Failed to fetch asset {}: {}", path, e);
}
}
});
futures::future::join_all(downloads).await;
}
}
impl AssetSource for Assets {
fn load(&self, path: &str) -> Result<Option<Cow<'static, [u8]>>> {
if path.is_empty() {
return Ok(None);
}
// Only serve paths the web build actually ships.
if !SERVED_PREFIXES
.iter()
.any(|prefix| path.starts_with(prefix))
{
return Ok(None);
}
// Serve from the in-memory cache when available.
if let Ok(cache) = self.cache.read() {
if let Some(data) = cache.get(path) {
return Ok(Some(Cow::Owned(data.clone())));
}
}
// Kick off a single download per path; concurrent requests for the
// same path share it.
let is_pending = self
.pending
.read()
.map(|pending| pending.contains_key(path))
.unwrap_or(false);
if !is_pending {
if let Ok(mut pending) = self.pending.write() {
pending.insert(path.to_string(), true);
}
let url = self.asset_url(path);
let path_clone = path.to_string();
let cache = self.cache.clone();
let pending = self.pending.clone();
spawn_local(async move {
match reqwest::get(&url).await {
Ok(response) if response.status().is_success() => {
match response.bytes().await {
Ok(bytes) => {
if let Ok(mut cache) = cache.write() {
cache.insert(path_clone.clone(), bytes.to_vec());
}
}
Err(e) => {
log::warn!("Failed to read asset {}: {}", path_clone, e);
}
}
}
Ok(response) => {
log::warn!(
"Failed to download asset {}: HTTP {}",
path_clone,
response.status()
);
}
Err(e) => {
log::warn!("Failed to fetch asset {}: {}", path_clone, e);
}
}
// Allow retrying failed downloads on subsequent requests.
if let Ok(mut pending) = pending.write() {
pending.remove(&path_clone);
}
});
}
// The asset is not available yet. GPUI's SVG atlas does not cache
// empty loads, so the next repaint will call `load` again and find
// the asset in the cache once the download completes.
Ok(None)
}
fn list(&self, _path: &str) -> Result<Vec<SharedString>> {
// The asset manifest is not available at runtime on web; embedded
// directories are not listed.
Ok(Vec::new())
}
}
+36 -6
View File
@@ -5,6 +5,7 @@ use gpui_updater::{EngineConfig, GitHubSource, UpdateStatus, Updater, Version};
use instant::{Duration, Instant};
const COOP_UPDATE_EXPLANATION: &str = "COOP_UPDATE_EXPLANATION";
const COOP_BUNDLE_TYPE: &str = "COOP_BUNDLE_TYPE";
fn get_github_repo_owner() -> String {
std::env::var("COOP_GITHUB_REPO_OWNER").unwrap_or_else(|_| "reyakov".to_string())
@@ -14,18 +15,27 @@ fn get_github_repo_name() -> String {
std::env::var("COOP_GITHUB_REPO_NAME").unwrap_or_else(|_| "coop".to_string())
}
fn is_flatpak_installation() -> bool {
std::env::var("FLATPAK_ID").is_ok() || std::env::var(COOP_UPDATE_EXPLANATION).is_ok()
/// Whether updates are managed by an external distribution channel
/// (Flatpak/Snap), in which case the in-app updater must not run.
fn uses_managed_updates() -> bool {
// The Flatpak runtime exports `FLATPAK_ID` inside the sandbox.
std::env::var("FLATPAK_ID").is_ok()
// Allow opting out of in-app updates via an explicit environment variable.
|| std::env::var(COOP_UPDATE_EXPLANATION).is_ok()
// The Snap package sets `COOP_BUNDLE_TYPE=snap` (see snapcraft.yaml.in).
|| std::env::var(COOP_BUNDLE_TYPE).is_ok_and(|value| value == "snap")
}
/// Initialize the auto-update system.
///
/// Skips initialization when running as a Flatpak (updates are handled by the
/// Flatpak distribution channel). Otherwise creates the global [`AutoUpdater`]
/// Skips initialization when updates are handled by an external distribution
/// channel (Flatpak/Snap). Otherwise creates the global [`AutoUpdater`]
/// entity and schedules a check for updates after a 2-minute delay.
pub fn init(window: &mut Window, cx: &mut App) {
if is_flatpak_installation() {
log::info!("Skipping auto-update initialization: App is installed via Flatpak");
if uses_managed_updates() {
log::info!(
"Skipping auto-update initialization: App is installed via a managed distribution channel (Flatpak/Snap)"
);
return;
}
@@ -57,7 +67,27 @@ pub struct AutoUpdater {
}
impl AutoUpdater {
/// Whether auto-update is available for this installation.
///
/// Returns `false` on managed distribution channels (Flatpak/Snap), where
/// updates are handled by the channel and no global updater is created.
pub fn is_available(cx: &App) -> bool {
cx.try_global::<GlobalAutoUpdater>().is_some()
}
/// Retrieve the global auto updater instance, if one was initialized.
pub fn try_global(cx: &App) -> Option<Entity<Self>> {
cx.try_global::<GlobalAutoUpdater>()
.map(|global| global.0.clone())
}
/// Retrieve the global auto updater instance.
///
/// # Panics
///
/// Panics when auto-update is not available for this installation. Prefer
/// [`AutoUpdater::try_global`] when the installation type is not known at
/// compile time (e.g. Flatpak/Snap).
pub fn global(cx: &App) -> Entity<Self> {
cx.global::<GlobalAutoUpdater>().0.clone()
}
+20 -29
View File
@@ -233,7 +233,7 @@ impl ChatRegistry {
if event.kind == Kind::InboxRelays {
let current_user = signer.get_public_key_async().await?;
if event.pubkey == current_user {
tx.send_async(Signal::InboxReady).await.ok();
tx.send_async(Signal::InboxReady).await?;
}
}
@@ -262,24 +262,24 @@ impl ChatRegistry {
if rumor.tags.is_empty() {
let signal = Signal::error(&event, "Recipient is missing");
tx.send_async(signal).await.ok();
tx.send_async(signal).await?;
}
// Emit message for both new and backlog events
let signal = Signal::message(event.id, rumor);
tx.send_async(signal).await.ok();
tx.send_async(signal).await?;
}
Err(e) => {
let reason = format!("Failed to extract rumor: {e}");
let signal = Signal::error(event.as_ref(), reason);
tx.send_async(signal).await.ok();
tx.send_async(signal).await?;
}
}
}
RelayMessage::EndOfStoredEvents(id)
if (id.as_ref() == &sub_id1 || id.as_ref() == &sub_id2) =>
{
tx.send_async(Signal::Eose).await.ok();
tx.send_async(Signal::Eose).await?;
}
_ => {}
}
@@ -290,42 +290,34 @@ impl ChatRegistry {
self.signal_consumer = Some(cx.spawn(async move |this, cx| {
while let Ok(message) = rx.recv_async().await {
// `update_in` (rather than `update`) routes through a
// try-borrow: on wasm a task poll that lands while the app
// context is borrowed can't panic and kill this consumer
// (which would stall all message delivery).
this.update_in(cx, |this, _window, cx| {
// Drain the whole queue in a single update so a burst of
// events (e.g. history sync after login) collapses into
// one repaint instead of one per message (important on
// wasm, where everything runs on the main thread).
let mut batch = vec![message];
while let Ok(extra) = rx.try_recv() {
batch.push(extra);
}
for message in batch {
match message {
Signal::Message(message) => {
this.update(cx, |this, cx| {
this.new_message(message, cx);
})?;
}
Signal::InboxReady => {
this.update(cx, |this, cx| {
this.get_messages(cx);
})?;
}
Signal::Eose => {
this.update(cx, |this, _cx| {
this.tracking.store(false, Ordering::Release);
})?;
this.update(cx, |this, cx| {
this.get_rooms(cx);
})?;
}
Signal::Error(failed) => {
let _ = trash.update(cx, |this, cx| {
trash.update(cx, |this, cx| {
this.insert(failed);
cx.notify();
});
})?;
}
};
}
})?;
}
Ok(())
}));
@@ -378,7 +370,7 @@ impl ChatRegistry {
.is_some();
if !found {
this.update_in(cx, |_this, _window, cx| {
this.update(cx, |_this, cx| {
cx.emit(ChatEvent::InboxRelayNotFound);
})?;
}
@@ -429,7 +421,7 @@ impl ChatRegistry {
});
if let Err(e) = task.await {
this.update_in(cx, |_this, _window, cx| {
this.update(cx, |_this, cx| {
cx.emit(ChatEvent::Error(e.to_string()));
})?;
}
@@ -438,7 +430,6 @@ impl ChatRegistry {
}));
}
/// Get all messages for the provided signer
/// Reload the chat registry, fetching messages and contact list from relays.
pub fn reload(&mut self, cx: &mut Context<Self>) {
self.reset(cx);
@@ -643,13 +634,13 @@ impl ChatRegistry {
self.tasks.push(cx.spawn(async move |this, cx| {
match task.await {
Ok(rooms) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.extend_rooms(rooms, cx);
this.sort(cx);
})?;
}
Err(e) => {
this.update_in(cx, |_, _window, cx| {
this.update(cx, |_, cx| {
cx.emit(ChatEvent::Error(e.to_string()));
})?;
}
+5 -21
View File
@@ -242,16 +242,6 @@ impl ChatPanel {
while let Ok(status) = rx.recv_async().await {
{
let mut map = reports.write().unwrap();
// Drain the whole queue in a single update so bursts of
// send statuses collapse into one repaint (important on
// wasm, where everything runs on the main thread).
let mut statuses = vec![status];
while let Ok(extra) = rx.try_recv() {
statuses.push(extra);
}
for status in statuses {
let status_id = match &*status {
SendStatus::Ok { id, .. } => *id,
SendStatus::Failed { id, .. } => *id,
@@ -278,8 +268,7 @@ impl ChatPanel {
}
}
}
}
this.update_in(cx, |_, _window, cx| cx.notify()).ok();
this.update(cx, |_, cx| cx.notify()).ok();
}
Ok(())
}));
@@ -336,10 +325,8 @@ impl ChatPanel {
self.tasks.push(cx.spawn(async move |this, cx| {
let events = get_messages.await?;
// Update message list. `update_in` (rather than `update`) routes
// through a try-borrow: on wasm a task poll that lands while the
// app context is borrowed can't panic and kill this task.
this.update_in(cx, |this, _window, cx| {
// Update message list
this.update(cx, |this, cx| {
this.insert_messages(&events, cx);
})?;
@@ -481,10 +468,7 @@ impl ChatPanel {
let mut sent_ids = sent_ids.lock().await;
sent_ids.extend(outputs.iter().filter_map(|output| output.gift_wrap_id));
// `update_in` (rather than `update`) routes through a try-borrow:
// on wasm a poll that lands while the app context is borrowed
// can't panic and kill this task.
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.insert_reports(id, outputs, cx);
})?;
@@ -655,7 +639,7 @@ impl ChatPanel {
});
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_uploading(true, cx);
})?;
+11 -11
View File
@@ -184,7 +184,7 @@ impl DeviceRegistry {
}
// New response event from the master device
Kind::Custom(4455) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.extract_encryption(event, cx);
})?;
}
@@ -272,7 +272,7 @@ impl DeviceRegistry {
return Ok(());
}
this.update_in(cx, |_this, _window, cx| {
this.update(cx, |_this, cx| {
cx.emit(DeviceEvent::NotSet);
})?;
@@ -287,13 +287,13 @@ impl DeviceRegistry {
self.tasks.push(cx.spawn(async move |this, cx| {
match task.await {
Ok(keys) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_signer(keys, cx);
this.wait_for_request(cx);
})?;
}
Err(e) => {
this.update_in(cx, |_this, _window, cx| {
this.update(cx, |_this, cx| {
cx.emit(DeviceEvent::error(e.to_string()));
})?;
}
@@ -358,12 +358,12 @@ impl DeviceRegistry {
self.tasks.push(cx.spawn(async move |this, cx| {
if let Ok(keys) = task.await {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_signer(keys, cx);
this.wait_for_request(cx);
})?;
} else {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.request(cx);
})?;
}
@@ -439,17 +439,17 @@ impl DeviceRegistry {
self.tasks.push(cx.spawn(async move |this, cx| {
match task.await {
Ok(Some(event)) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.extract_encryption(event, cx);
})?;
}
Ok(None) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.wait_for_approval(cx);
})?;
}
Err(e) => {
this.update_in(cx, |_this, _window, cx| {
this.update(cx, |_this, cx| {
cx.emit(DeviceEvent::error(e.to_string()));
})?;
}
@@ -508,12 +508,12 @@ impl DeviceRegistry {
self.tasks.push(cx.spawn(async move |this, cx| {
match task.await {
Ok(keys) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_signer(keys, cx);
})?;
}
Err(e) => {
this.update_in(cx, |_this, _window, cx| {
this.update(cx, |_this, cx| {
cx.emit(DeviceEvent::error(e.to_string()));
})?;
}
-1
View File
@@ -15,4 +15,3 @@ anyhow.workspace = true
smallvec.workspace = true
flume.workspace = true
log.workspace = true
futures.workspace = true
+18 -48
View File
@@ -3,8 +3,7 @@ use std::sync::RwLock;
use anyhow::{Error, anyhow};
use common::EventExt;
use futures::FutureExt;
use gpui::{App, AppContext, BackgroundExecutor, Context, Entity, Global, Task, Window};
use gpui::{App, AppContext, Context, Entity, Global, Task, Window};
use instant::Duration;
use nostr_sdk::prelude::*;
use smallvec::{SmallVec, smallvec};
@@ -73,28 +72,13 @@ impl PersonRegistry {
}));
let client3 = client.clone();
let executor = cx.background_executor().clone();
tasks.push(cx.background_spawn(async move {
Self::handle_requests(&client3, &metadata_rx, &executor).await;
Self::handle_requests(&client3, &metadata_rx).await;
}));
tasks.push(cx.spawn(async move |this, cx| {
while let Ok(event) = rx.recv_async().await {
// `update_in` (rather than `update`) routes through a
// try-borrow: on wasm a task poll that lands while the app
// context is borrowed can't panic and kill this consumer
// (which would stall the whole metadata pipeline).
this.update_in(cx, |this, _window, cx| {
// Drain the whole queue in a single update so a burst of
// events collapses into one repaint instead of one per
// event (important on wasm, where everything runs on the
// main thread).
let mut dispatch = vec![event];
while let Ok(extra) = rx.try_recv() {
dispatch.push(extra);
}
for event in dispatch {
this.update(cx, |this, cx| {
match event {
Dispatch::Person(person) => {
this.insert(person, cx);
@@ -106,7 +90,6 @@ impl PersonRegistry {
this.set_messaging_relays(&event, cx);
}
};
}
})
.ok();
}
@@ -173,39 +156,24 @@ impl PersonRegistry {
}
/// Handle request for metadata
///
/// Requests are collected into batches and flushed when the batch is
/// full or the timeout expires.
///
/// Note: `flume::Selector::wait_timeout` is intentionally not used here:
/// it relies on `std::time::Instant` and `thread::park_timeout`, which are
/// unavailable on `wasm32-unknown-unknown` (the former panics, the latter
/// is a no-op that would turn the wait into a busy loop on the main
/// thread).
async fn handle_requests(
client: &Client,
rx: &flume::Receiver<PublicKey>,
executor: &BackgroundExecutor,
) {
async fn handle_requests(client: &Client, rx: &flume::Receiver<PublicKey>) {
let mut batch: HashSet<PublicKey> = HashSet::new();
loop {
// Wait for the next request, or the batch timeout.
futures::select! {
result = rx.recv_async() => match result {
Ok(public_key) => {
match flume::Selector::new()
.recv(rx, |result| result.ok())
.wait_timeout(Duration::from_secs(TIMEOUT))
{
Ok(Some(public_key)) => {
batch.insert(public_key);
// Keep collecting until the batch is full
if batch.len() < 20 {
continue;
// Process the batch if it's full
if batch.len() >= 20
&& let Err(e) = get_metadata(client, std::mem::take(&mut batch)).await
{
log::warn!("Failed to get metadata batch: {e}");
}
}
Err(_) => return,
},
_ = executor.timer(Duration::from_secs(TIMEOUT)).fuse() => {}
}
// Flush the batch
_ => {
if !batch.is_empty()
&& let Err(e) = get_metadata(client, std::mem::take(&mut batch)).await
{
@@ -213,6 +181,8 @@ impl PersonRegistry {
}
}
}
}
}
/// Load all user profiles from the database
fn load(&mut self, cx: &mut Context<Self>) {
@@ -235,7 +205,7 @@ impl PersonRegistry {
self.tasks.push(cx.spawn(async move |this, cx| {
if let Ok(persons) = task.await {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.bulk_insert(persons, cx);
})
.ok();
+3 -3
View File
@@ -105,7 +105,7 @@ impl Person {
/// Get profile avatar
pub fn avatar(&self) -> SharedString {
self.metadata
self.metadata()
.picture
.as_ref()
.filter(|picture| !picture.is_empty())
@@ -115,13 +115,13 @@ impl Person {
/// Get profile name
pub fn name(&self) -> SharedString {
if let Some(display_name) = self.metadata.display_name.as_ref()
if let Some(display_name) = self.metadata().display_name.as_ref()
&& !display_name.is_empty()
{
return SharedString::from(display_name.trim());
}
if let Some(name) = self.metadata.name.as_ref()
if let Some(name) = self.metadata().name.as_ref()
&& !name.is_empty()
{
return SharedString::from(name.trim());
+9 -11
View File
@@ -3,10 +3,8 @@ use std::collections::HashMap;
use anyhow::{Error, anyhow};
#[cfg(not(target_arch = "wasm32"))]
use browser_signer_proxy::prelude::*;
#[cfg(not(target_arch = "wasm32"))]
use common::config_dir;
use gpui::{App, AppContext, Context, Entity, EventEmitter, Global, Task, Window};
#[cfg(not(target_arch = "wasm32"))]
use gpui_tokio::Tokio;
use instant::Duration;
use nostr_connect::prelude::*;
@@ -181,7 +179,7 @@ impl NostrRegistry {
let task = cx.spawn(async move |this, cx| {
match new_signer.get_public_key_async().await {
Ok(public_key) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.signer.swap_inner(new_signer);
this.current_user = Some(public_key);
cx.emit(StateEvent::SignerChanged);
@@ -189,7 +187,7 @@ impl NostrRegistry {
})?;
}
Err(e) => {
this.update_in(cx, |_this, _window, cx| {
this.update(cx, |_this, cx| {
cx.emit(StateEvent::error(e.to_string()));
})?;
}
@@ -226,7 +224,7 @@ impl NostrRegistry {
self.tasks.push(cx.spawn(async move |this, cx| {
if let Err(e) = task.await {
this.update_in(cx, |_this, _window, cx| {
this.update(cx, |_this, cx| {
cx.emit(StateEvent::error(e.to_string()));
})?;
}
@@ -248,7 +246,7 @@ impl NostrRegistry {
let secret_key = SecretKey::parse(&content)?;
let keys = Keys::new(secret_key);
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_signer(keys, cx);
cx.notify();
})?;
@@ -263,19 +261,19 @@ impl NostrRegistry {
// Handle auth url with the default browser
signer.auth_url_handler(CoopAuthUrlHandler);
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_signer(signer, cx);
cx.notify();
})?;
} else if content == "proxy" {
#[cfg(not(target_arch = "wasm32"))]
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.connect_proxy(cx);
})?;
}
}
_ => {
this.update_in(cx, |_, _window, cx| {
this.update(cx, |_, cx| {
cx.emit(StateEvent::NoSigner);
})?;
}
@@ -352,7 +350,7 @@ impl NostrRegistry {
let proxy = proxy.clone();
async move |this, cx| {
while let Ok(url) = rx.recv_async().await {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
let save = cx.write_credentials(USER_KEYRING, "proxy", b"proxy");
cx.background_spawn(async move { save.await.ok() }).detach();
cx.open_url(&url);
@@ -374,7 +372,7 @@ impl NostrRegistry {
loop {
executor.timer(Duration::from_secs(5)).await;
if !proxy.is_session_active() {
_ = this.update_in(cx, |this, _window, cx| {
_ = this.update(cx, |this, cx| {
// Only notify if this proxy is still the active signer
if this.current_user.is_some() {
this.signer.swap_inner(Keys::generate());
+7 -13
View File
@@ -1,16 +1,16 @@
use std::rc::Rc;
use instant::Duration;
use gpui::prelude::FluentBuilder as _;
use gpui::{
Animation, AnimationExt, AnyElement, App, Div, ElementId, InteractiveElement, IntoElement,
ParentElement, RenderOnce, SharedString, StatefulInteractiveElement, StyleRefinement, Styled,
Window, div, px, relative, rems, svg,
div, px, relative, rems, svg, Animation, AnimationExt, AnyElement, App, Div, ElementId,
InteractiveElement, IntoElement, ParentElement, RenderOnce, SharedString,
StatefulInteractiveElement, StyleRefinement, Styled, Window,
};
use instant::Duration;
use theme::ActiveTheme;
use crate::icon::IconNamed;
use crate::{Disableable, IconName, Selectable, Sizable, Size, StyledExt as _, v_flex};
use crate::{v_flex, Disableable, IconName, Selectable, Sizable, Size, StyledExt as _};
/// A Checkbox element.
#[allow(clippy::type_complexity)]
@@ -172,16 +172,10 @@ pub(crate) fn checkbox_check_icon(
if !disabled && checked != *toggle_state.read(cx) {
let duration = Duration::from_secs_f64(0.25);
cx.spawn({
let toggle_state = toggle_state.downgrade();
let toggle_state = toggle_state.clone();
async move |cx| {
cx.background_executor().timer(duration).await;
// `update_in` (rather than `update`) routes through a
// try-borrow: on wasm a task poll that lands while
// the app context is borrowed can't panic and kill
// this task.
toggle_state
.update_in(cx, |this, _window, _| *this = checked)
.ok();
toggle_state.update(cx, |this, _| *this = checked);
}
})
.detach();
+9 -9
View File
@@ -1,6 +1,7 @@
use gpui::{Context, Pixels, Task, px};
use instant::Duration;
use gpui::{Context, Pixels, Task, px};
static INTERVAL: Duration = Duration::from_millis(500);
static PAUSE_DELAY: Duration = Duration::from_millis(300);
@@ -62,11 +63,9 @@ impl BlinkCursor {
let epoch = self.next_epoch();
self._task = cx.spawn(async move |this, cx| {
cx.background_executor().timer(INTERVAL).await;
// `update_in` (rather than `update`) routes through a try-borrow:
// on wasm a task poll that lands while the app context is
// borrowed can't panic and kill this recurring task.
this.update_in(cx, |this, _window, cx| this.blink(epoch, cx))
.ok();
if let Some(this) = this.upgrade() {
this.update(cx, |this, cx| this.blink(epoch, cx));
}
});
}
@@ -86,11 +85,12 @@ impl BlinkCursor {
self._task = cx.spawn(async move |this, cx| {
cx.background_executor().timer(PAUSE_DELAY).await;
this.update_in(cx, |this, _window, cx| {
if let Some(this) = this.upgrade() {
this.update(cx, |this, cx| {
this.paused = false;
this.blink(epoch, cx);
})
.ok();
});
}
});
}
}
+2 -3
View File
@@ -14,16 +14,15 @@ chat = { path = "../chat" }
chat_ui = { path = "../chat_ui" }
settings = { path = "../settings" }
person = { path = "../person" }
auto_update = { path = "../auto_update" }
gpui.workspace = true
nostr-sdk.workspace = true
instant.workspace = true
nostr-connect.workspace = true
browser-signer-proxy = { path = "../browser-signer-proxy" }
anyhow.workspace = true
serde.workspace = true
log.workspace = true
smallvec.workspace = true
[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
auto_update = { path = "../auto_update" }
+2 -7
View File
@@ -129,7 +129,7 @@ impl ImportIdentity {
})?;
}
Err(e) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_error(e.to_string(), cx);
})?;
}
@@ -172,11 +172,6 @@ impl ImportIdentity {
});
}
// The "Connect via Web Extension" button is hidden on wasm (`is_wasm`),
// so this stub is never invoked in the browser.
#[cfg(target_arch = "wasm32")]
fn proxy(&mut self, _cx: &mut Context<Self>) {}
fn set_loading(&mut self, status: bool, cx: &mut Context<Self>) {
self.loading = status;
cx.notify();
@@ -198,7 +193,7 @@ impl ImportIdentity {
self.tasks.push(cx.spawn(async move |this, cx| {
cx.background_executor().timer(Duration::from_secs(3)).await;
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.error.update(cx, |this, cx| {
*this = None;
cx.notify();
+1 -1
View File
@@ -83,7 +83,7 @@ impl RestoreEncryption {
self.tasks.push(cx.spawn(async move |this, cx| {
cx.background_executor().timer(Duration::from_secs(3)).await;
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.error.update(cx, |this, cx| {
*this = None;
cx.notify();
+4 -4
View File
@@ -105,7 +105,7 @@ impl Screening {
self.tasks.push(cx.spawn(async move |this, cx| {
let result = task.await.unwrap_or(false);
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.followed = result;
cx.notify();
})
@@ -139,7 +139,7 @@ impl Screening {
self.tasks.push(cx.spawn(async move |this, cx| {
match task.await {
Ok(contacts) => {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.mutual_contacts = contacts;
cx.notify();
})
@@ -185,7 +185,7 @@ impl Screening {
self.tasks.push(cx.spawn(async move |this, cx| {
let result = task.await;
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.last_active = result;
cx.notify();
})
@@ -208,7 +208,7 @@ impl Screening {
self.tasks.push(cx.spawn(async move |this, cx| {
let result = task.await.unwrap_or(false);
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.verified = result;
cx.notify();
})
+24 -30
View File
@@ -2,7 +2,6 @@ use std::sync::Arc;
use ::settings::AppSettings;
use anyhow::Error;
#[cfg(not(target_arch = "wasm32"))]
use auto_update::AutoUpdater;
use chat::{ChatEvent, ChatRegistry};
use common::{CoopImageCache, download_dir};
@@ -380,18 +379,17 @@ impl Workspace {
Command::ImportEncryption => {
self.import_encryption(window, cx);
}
#[cfg(not(target_arch = "wasm32"))]
Command::Update => {
let auto_updater = AutoUpdater::global(cx);
// No-op on managed distribution channels (Flatpak/Snap) where
// the in-app updater is never initialized.
if let Some(auto_updater) = AutoUpdater::try_global(cx) {
auto_updater.update(cx, |this, cx| {
this.updater.update(cx, |updater, cx| {
updater.check(cx);
});
});
}
// Auto-update is a desktop-only feature; no-op in the browser.
#[cfg(target_arch = "wasm32")]
Command::Update => {}
}
}
}
@@ -564,12 +562,11 @@ impl Workspace {
.caret()
.compact()
.transparent()
.dropdown_menu(move |this, _window, _cx| {
.dropdown_menu(move |this, _window, cx| {
let avatar = avatar.clone();
let name = name.clone();
let menu = this
.min_w(px(256.))
this.min_w(px(256.))
.item(PopupMenuItem::element(move |_window, cx| {
h_flex()
.gap_1p5()
@@ -599,17 +596,16 @@ impl Workspace {
IconName::Sun,
Box::new(Command::ToggleTheme),
)
.separator();
// Auto-update is a desktop-only feature; there is no updater in the browser.
#[cfg(not(target_arch = "wasm32"))]
let menu = menu.menu_with_icon(
// Only offer in-app updates when auto-update is
// enabled (managed channels update themselves).
.when(AutoUpdater::is_available(cx), |this| {
this.separator().menu_with_icon(
"Check for Updates",
IconName::Device,
Box::new(Command::Update),
);
menu.menu_with_icon(
)
})
.menu_with_icon(
"Settings",
IconName::Settings,
Box::new(Command::ShowSettings),
@@ -632,22 +628,20 @@ impl Workspace {
let profile = persons.read(cx).get(&public_key, cx);
let announcement = profile.announcement();
let titlebar = h_flex()
.when(!cx.theme().platform.is_mac(), |this| this.pr_2())
.gap_2();
// Update status is only shown when auto-update is available. On
// managed distribution channels (Flatpak/Snap) no updater exists, so
// nothing is rendered.
let updater_status = AutoUpdater::try_global(cx).and_then(|updater| {
let updater = updater.read(cx);
(!updater.idle(cx)).then(|| updater.status(cx))
});
// Auto-update is a desktop-only feature; there is no updater in the browser.
#[cfg(not(target_arch = "wasm32"))]
let titlebar = {
let updater = AutoUpdater::global(cx);
let updater_idle = updater.read(cx).idle(cx);
titlebar.when(!updater_idle, |this| {
let status = updater.read(cx).status(cx);
h_flex()
.when(!cx.theme().platform.is_mac(), |this| this.pr_2())
.gap_2()
.when_some(updater_status, |this, status| {
this.child(div().text_xs().italic().child(status))
})
};
titlebar
.when(nip4e_enabled, |this| {
this.child(
Button::new("key")
+1 -1
View File
@@ -97,7 +97,7 @@ impl BackupPanel {
cx.background_executor().timer(Duration::from_secs(2)).await;
// Clear the error message after a delay
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_copied(false, cx);
})?;
+4 -9
View File
@@ -108,10 +108,8 @@ impl ContactListPanel {
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
let public_keys = task.await?;
// Update state. `update_in` (rather than `update`) routes through
// a try-borrow, so on wasm a poll that happens to land while the
// app context is borrowed can't panic and kill this task.
this.update_in(cx, |this, _window, cx| {
// Update state
this.update(cx, |this, cx| {
this.contacts.extend(public_keys);
cx.notify();
})?;
@@ -150,11 +148,8 @@ impl ContactListPanel {
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
cx.background_executor().timer(Duration::from_secs(2)).await;
// Clear the error message after a delay. `update_in` (rather than
// `update`) routes through a try-borrow, so on wasm a poll that
// happens to land while the app context is borrowed can't panic
// and kill this task.
this.update_in(cx, |this, _window, cx| {
// Clear the error message after a delay
this.update(cx, |this, cx| {
this.error = None;
cx.notify();
})?;
@@ -103,10 +103,8 @@ impl MessagingRelayPanel {
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
let relays = task.await?;
// Update state. `update_in` (rather than `update`) routes through
// a try-borrow: on wasm a poll that lands while the app context
// is borrowed can't panic and kill this task.
this.update_in(cx, |this, _window, cx| {
// Update state
this.update(cx, |this, cx| {
this.relays.extend(relays);
cx.notify();
})?;
@@ -150,11 +148,8 @@ impl MessagingRelayPanel {
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
cx.background_executor().timer(Duration::from_secs(2)).await;
// Clear the error message after a delay. `update_in` (rather than
// `update`) routes through a try-borrow: on wasm a poll that
// lands while the app context is borrowed can't panic and kill
// this task.
this.update_in(cx, |this, _window, cx| {
// Clear the error message after a delay
this.update(cx, |this, cx| {
this.error = None;
cx.notify();
})?;
+1 -1
View File
@@ -167,7 +167,7 @@ impl ProfilePanel {
});
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_uploading(true, cx);
})?;
+4 -9
View File
@@ -121,10 +121,8 @@ impl RelayListPanel {
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
let relays = task.await?;
// Update state. `update_in` (rather than `update`) routes through
// a try-borrow: on wasm a poll that lands while the app context
// is borrowed can't panic and kill this task.
this.update_in(cx, |this, _window, cx| {
// Update state
this.update(cx, |this, cx| {
this.relays.extend(relays);
cx.notify();
})?;
@@ -169,11 +167,8 @@ impl RelayListPanel {
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
cx.background_executor().timer(Duration::from_secs(2)).await;
// Clear the error message after a delay. `update_in` (rather than
// `update`) routes through a try-borrow: on wasm a poll that
// lands while the app context is borrowed can't panic and kill
// this task.
this.update_in(cx, |this, _window, cx| {
// Clear the error message after a delay
this.update(cx, |this, cx| {
this.error = None;
cx.notify();
})?;
+1 -4
View File
@@ -178,10 +178,7 @@ impl Sidebar {
self.tasks.push(cx.spawn_in(window, async move |this, cx| {
match task.await {
Ok(contacts) => {
// `update_in` (rather than `update`) routes through a
// try-borrow: on wasm a poll that lands while the app
// context is borrowed can't panic and kill this task.
this.update_in(cx, |this, _window, cx| {
this.update(cx, |this, cx| {
this.set_contact_list(contacts, cx);
})?;
}
+1 -1
View File
@@ -14,7 +14,7 @@ product-name = "Coop"
description = "Chat Freely, Stay Private on Nostr"
identifier = "su.reya.coop"
category = "SocialNetworking"
version = "1.0.0"
version = "1.0.1"
out-dir = "../dist"
before-packaging-command = "cargo build --release"
resources = ["Cargo.toml", "src"]
+4
View File
@@ -1,3 +1,7 @@
# Snaps built by snapcraft without Snap Store credentials are unsigned and
# cannot be installed without bypassing signature checks. Use:
# sudo snap install --dangerous ./coop_<version>_<arch>.snap
# For signed installs (`snap install coop`), publish via the Snap Store.
name: coop
title: Coop
base: core24
+4
View File
@@ -35,3 +35,7 @@ SNAP_NAME="coop_${1}_${ARCH_SUFFIX}.snap"
snapcraft --destructive-mode --output "$SNAP_NAME"
echo "Created snap package: $SNAP_NAME"
echo ""
echo "This snap is unsigned (built without Snap Store credentials)."
echo "To install it locally, use:"
echo " sudo snap install --dangerous ./$SNAP_NAME"
+16 -10
View File
@@ -29,23 +29,29 @@ fi
# Function to update version in a Cargo.toml file
update_version() {
local file="$1"
local backup="${file}.bak"
local tmp="${file}.tmp"
# Backup the original file
cp "$file" "$backup"
# More flexible regex that handles various version formats and whitespace
if sed -i -E "s/^[[:space:]]*version[[:space:]]*=[[:space:]]*\"[^\"]+\"/version = \"$NEW_VERSION\"/" "$file"; then
# Portable in-place edit. `sed -i` behaves differently on GNU sed (Linux)
# and BSD sed (macOS): on macOS `sed -i -E` treats `-E` as the backup
# suffix instead of the extended-regex flag, leaving a stray
# `Cargo.toml-E` behind and never updating the file.
# Writing to a temp file and moving it over works on both implementations.
if sed -E "s/^[[:space:]]*version[[:space:]]*=[[:space:]]*\"[^\"]+\"/version = \"$NEW_VERSION\"/" "$file" > "$tmp" \
&& mv "$tmp" "$file"; then
echo "✓ Updated version to $NEW_VERSION in $file"
else
echo "Error: Failed to update version in $file"
# Restore original backup
mv "$backup" "$file"
# Remove any partial temp file; the original file is untouched
rm -f "$tmp"
exit 1
fi
# Remove the backup file
rm -f "$backup"
# The substitution can silently match nothing (e.g. a `version.workspace` key),
# so verify the new version actually landed before moving on.
if ! grep -q "^[[:space:]]*version[[:space:]]*=[[:space:]]*\"$NEW_VERSION\"" "$file"; then
echo "Error: Version line not found/updated in $file"
exit 1
fi
}
# Update both Cargo.toml files
+16 -1
View File
@@ -15,11 +15,26 @@ if [ "$#" -ne 1 ]; then
exit 1
fi
# Get system architecture (same mapping as script/bundle-snap)
ARCH=$(uname -m)
case "$ARCH" in
x86_64) ARCH_SUFFIX="x86_64" ;;
aarch64) ARCH_SUFFIX="aarch64" ;;
*) echo "Unsupported architecture: $ARCH"; exit 1 ;;
esac
snap_file="coop_${1}_${ARCH_SUFFIX}.snap"
if [ ! -f "$snap_file" ]; then
echo "Snap file not found: $snap_file"
echo "Build it first with: script/bundle-snap $1"
exit 1
fi
# Rerun as root
[ "$UID" -eq 0 ] || exec sudo bash -e "$0" "$@"
snap remove coop || true
mkdir -p snap
rm -rf snap/unpacked
unsquashfs -dest snap/unpacked "coop_$1_amd64.snap"
unsquashfs -dest snap/unpacked "$snap_file"
snap try --classic snap/unpacked
-3
View File
@@ -30,9 +30,6 @@ console_error_panic_hook = "0.1"
tracing-wasm = "0.2"
console_log = "1.0"
wasm-bindgen = "0.2"
wasm-bindgen-futures = "0.4"
js-sys = "0.3"
web-sys = { version = "0.3", features = ["Window", "Performance", "console", "DomException"] }
universal-time = { git = "https://github.com/shadowylab/universal-time" }
[target.'cfg(target_arch = "wasm32")'.dependencies]
-5
View File
@@ -36,11 +36,6 @@ if [[ "$(uname)" == "Darwin" ]]; then
fi
# Step 1: Build WASM
#
# Single-threaded build: `+bulk-memory` only. The multithreaded web backend
# is disabled in `web/src/lib.rs` (gpui's wasm workers freeze their JS event
# loop in `Atomics.wait`, which breaks nostr-sdk's spawn_local-driven client
# and the WebSocket transport), so no atomics/shared-memory flags here.
echo -e "${GREEN}Step 1: Building WASM...${NC}"
cd "$PROJECT_ROOT"
export CARGO_TARGET_DIR="$PROJECT_ROOT/target"
+11 -136
View File
@@ -1,8 +1,4 @@
use std::borrow::Cow;
use std::cell::RefCell;
use gpui::*;
use theme::{Theme, ThemeMode};
use ui::Root;
use universal_time::{Instant, MonotonicClock, SystemTime, WallClock, define_time_provider};
use wasm_bindgen::prelude::*;
@@ -11,64 +7,22 @@ struct CustomTimeProvider;
impl WallClock for CustomTimeProvider {
fn system_time(&self) -> SystemTime {
// Browser wall clock: milliseconds since the Unix epoch.
let millis = js_sys::Date::now();
SystemTime::from_unix_duration(instant::Duration::from_millis(millis as u64))
SystemTime::from_unix_duration(instant::Duration::from_secs(0))
}
}
impl MonotonicClock for CustomTimeProvider {
fn instant(&self) -> Instant {
// `performance.now()` is monotonic; fall back to the wall clock if
// it's unavailable.
let millis = web_sys::window()
.and_then(|window| window.performance())
.map(|performance| performance.now())
.unwrap_or_else(js_sys::Date::now);
Instant::from_ticks(instant::Duration::from_millis(millis as u64))
Instant::from_ticks(instant::Duration::from_secs(0))
}
}
define_time_provider!(CustomTimeProvider);
thread_local! {
static APPLICATION: RefCell<Option<ApplicationHandle>> = const { RefCell::new(None) };
}
/// Applies a theme mode and restores the bundled web fonts.
///
/// `Theme::change` reapplies the theme config, which can carry its own font
/// family; host system fonts are unavailable in wasm, so the bundled Inter
/// fonts are put back afterwards.
fn apply_theme(mode: ThemeMode, cx: &mut App) {
Theme::change(mode, None, cx);
Theme::global_mut(cx).font_family = "Inter".into();
}
/// Switches the app between light and dark after it is running.
///
/// The embedding page calls this to keep the app in sync with its own
/// appearance.
#[cfg(target_family = "wasm")]
#[wasm_bindgen]
pub fn set_theme(dark: bool) {
let mode = if dark {
ThemeMode::Dark
} else {
ThemeMode::Light
};
APPLICATION.with(|application| {
if let Some(handle) = application.borrow().as_ref() {
handle.update(|cx| {
apply_theme(mode, cx);
cx.refresh_windows();
});
}
});
}
pub fn run() -> Result<(), JsValue> {
console_error_panic_hook::set_once();
#[wasm_bindgen]
pub async fn run() -> Result<(), JsValue> {
// Initialize logging to browser console
console_log::init_with_level(log::Level::Info).expect("Failed to initialize logger");
@@ -78,92 +32,21 @@ pub async fn run() -> Result<(), JsValue> {
#[cfg(target_family = "wasm")]
gpui_platform::web_init();
// Install the panic hook AFTER `web_init` (which sets the default
// `console_error_panic_hook`), so ours wins. It prints the entire
// JS/wasm stack as a single string: `console_error_panic_hook`'s default
// output is an `Error` object whose stack is collapsed in the console,
// and on wasm the frames below the panic machinery name the task that
// panicked (debug builds keep symbol names) — essential for diagnosing
// `RefCell already borrowed`.
#[cfg(target_family = "wasm")]
std::panic::set_hook(Box::new(|info| {
// Capture the JS stack (which includes the wasm frames with symbol
// names in debug builds) without constructing DOM objects.
let stack = js_sys::Reflect::get(&js_sys::Error::new(""), &"stack".into())
.ok()
.and_then(|v| v.as_string())
.unwrap_or_default();
web_sys::console::error_1(
&format!("{info}\n\n==== full stack ====\n{stack}\n=====================").into(),
);
}));
#[cfg(not(target_family = "wasm"))]
let app = gpui_platform::application();
#[cfg(target_family = "wasm")]
let app = {
// Assets are not embedded in the WASM bundle; they are served from
// the `/assets/...` URL prefix (see `web/www/vite.config.js`) and
// downloaded by the `assets` crate.
let assets = assets::Assets::new("");
let app = gpui_platform::single_threaded_web();
// Download every icon and brand asset before the first frame: brand
// images are loaded through GPUI's image cache, which does not retry
// failed loads, and pre-caching the icons lets them render
// immediately instead of waiting for a repaint.
assets.preload().await;
// NOTE: the multithreaded web backend (application_with_web_backend)
// cannot host this app's backend. gpui's wasm background workers
// block on `Atomics.wait` while idle, freezing their JS event loop,
// so `spawn_local`-driven tasks (nostr-sdk's client actor, the
// WebSocket transport) and fetch promises never make progress on a
// worker thread. Everything must run on the main thread.
gpui_platform::single_threaded_web().with_assets(assets)
// Temporary fix: intentionally leak the `Rc<AppCell>` to keep the application alive
struct WasmApplication(std::rc::Rc<AppCell>);
let wasm_app = unsafe { std::mem::transmute::<Application, WasmApplication>(app) };
std::mem::forget(wasm_app.0.clone());
unsafe { std::mem::transmute::<WasmApplication, Application>(wasm_app) }
};
let launch = move |cx: &mut App| {
// Load the embedded Inter font stack for WASM, where host system
// fonts are unavailable. Inter is the app's UI font on Linux; the
// wasm build reuses it so the web app matches the desktop look.
let inter_regular =
Cow::Borrowed(include_bytes!("../../assets/fonts/Inter/Inter-Regular.ttf").as_slice());
let inter_italic =
Cow::Borrowed(include_bytes!("../../assets/fonts/Inter/Inter-Italic.ttf").as_slice());
let inter_medium =
Cow::Borrowed(include_bytes!("../../assets/fonts/Inter/Inter-Medium.ttf").as_slice());
let inter_medium_italic = Cow::Borrowed(
include_bytes!("../../assets/fonts/Inter/Inter-MediumItalic.ttf").as_slice(),
);
let inter_semibold =
Cow::Borrowed(include_bytes!("../../assets/fonts/Inter/Inter-SemiBold.ttf").as_slice());
let inter_semibold_italic = Cow::Borrowed(
include_bytes!("../../assets/fonts/Inter/Inter-SemiBoldItalic.ttf").as_slice(),
);
let inter_bold =
Cow::Borrowed(include_bytes!("../../assets/fonts/Inter/Inter-Bold.ttf").as_slice());
let inter_bold_italic = Cow::Borrowed(
include_bytes!("../../assets/fonts/Inter/Inter-BoldItalic.ttf").as_slice(),
);
cx.text_system()
.add_fonts(vec![
inter_regular,
inter_italic,
inter_medium,
inter_medium_italic,
inter_semibold,
inter_semibold_italic,
inter_bold,
inter_bold_italic,
])
.expect("Failed to load fonts");
// Apply the system appearance before the first frame, so the app
// never flashes the default light theme.
apply_theme(cx.window_appearance().into(), cx);
app.run(|cx| {
// Open the root window
cx.open_window(WindowOptions::default(), |window, cx| {
// Initialize components
@@ -195,15 +78,7 @@ pub async fn run() -> Result<(), JsValue> {
.expect("Failed to open window. Please restart the application.");
cx.activate(true);
};
#[cfg(target_family = "wasm")]
APPLICATION.with(|application| {
*application.borrow_mut() = Some(app.run_embedded(launch));
});
#[cfg(not(target_family = "wasm"))]
app.run(launch);
Ok(())
}
+3 -7
View File
@@ -10,11 +10,7 @@ export default defineConfig({
viteStaticCopy({
targets: [
{
src: path.resolve(__dirname, "../../assets/icons"),
dest: "assets",
},
{
src: path.resolve(__dirname, "../../assets/brand"),
src: path.resolve(__dirname, "../../../assets/icons"),
dest: "assets",
},
],
@@ -23,9 +19,9 @@ export default defineConfig({
name: "serve-assets",
configureServer(server) {
server.middlewares.use(
"/assets",
"/coop/assets",
(req, res, next) => {
const assetsPath = path.resolve(__dirname, "../../assets");
const assetsPath = path.resolve(__dirname, "../../../assets");
const filePath = path.join(
assetsPath,
req.url.replace("/assets", ""),