External/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-08-18 06:50:31 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix policy receipts for cold-launch invite links (#2005)

Browse Source 
Signed-off-by: npub12gtutshhh76rx0jx697f32f9tffd4hhp3hx58fp4x6u4uemkm7sqf8f757 <5217c5c2f7bfb4333e46d17c98a9255a52dadee18dcd43a43536b95e6776dfa0@sprout-oss.stage.blox.sqprod.co>
Co-authored-by: npub12gtutshhh76rx0jx697f32f9tffd4hhp3hx58fp4x6u4uemkm7sqf8f757 <5217c5c2f7bfb4333e46d17c98a9255a52dadee18dcd43a43536b95e6776dfa0@sprout-oss.stage.blox.sqprod.co>
This commit is contained in:
Tyler
2026-07-16 19:27:28 -04:00
committed by GitHub
co-authored by npub12gtutshhh76rx0jx697f32f9tffd4hhp3hx58fp4x6u4uemkm7sqf8f757
parent fb8e6827c7
commit 1d8d006aaf
1 changed files with 18 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
desktop/src-tauri/src/deep_link.rs
+18 -2
View File
@@ -13,6 +13,7 @@ pub(crate) struct PendingCommunityDeepLink {
kind: String,
relay_url: String,
code: Option<String>,
policy_receipt: Option<String>,
name: Option<String>,
}
@@ -26,6 +27,7 @@ impl PendingCommunityDeepLinks {
item.kind == pending.kind
&& item.relay_url == pending.relay_url
&& item.code == pending.code
&& item.policy_receipt == pending.policy_receipt
&& item.name == pending.name
}) {
return;
@@ -72,6 +74,7 @@ fn queue_community_deep_link(
kind: &str,
relay_url: String,
code: Option<String>,
policy_receipt: Option<String>,
name: Option<String>,
) {
app.state::<PendingCommunityDeepLinks>()
@@ -80,6 +83,7 @@ fn queue_community_deep_link(
kind: kind.to_owned(),
relay_url,
code,
policy_receipt,
name,
});
}
@@ -312,7 +316,7 @@ pub(crate) fn handle_deep_link_url(app: &tauri::AppHandle, url_str: &str) {
return;
};
activate_main_window(app);
queue_community_deep_link(app, "connect", relay_url.clone(), None, None);
queue_community_deep_link(app, "connect", relay_url.clone(), None, None, None);
let _ = app.emit("deep-link-connect", relay_url);
}
Some("join") => {
@@ -326,7 +330,8 @@ pub(crate) fn handle_deep_link_url(app: &tauri::AppHandle, url_str: &str) {
activate_main_window(app);
let relay_url = payload["relayUrl"].as_str().unwrap_or_default().to_owned();
let code = payload["code"].as_str().map(str::to_owned);
queue_community_deep_link(app, "join", relay_url, code, None);
let policy_receipt = payload["policyReceipt"].as_str().map(str::to_owned);
queue_community_deep_link(app, "join", relay_url, code, policy_receipt, None);
let _ = app.emit("deep-link-join", payload);
}
Some("add-community") => {
@@ -340,6 +345,7 @@ pub(crate) fn handle_deep_link_url(app: &tauri::AppHandle, url_str: &str) {
"add-community",
payload.relay_url.clone(),
None,
None,
payload.name.clone(),
);
let _ = app.emit("deep-link-add-community", payload);
@@ -393,10 +399,20 @@ mod tests {
kind: if code.is_some() { "join" } else { "connect" }.to_owned(),
relay_url: relay_url.to_owned(),
code: code.map(str::to_owned),
policy_receipt: None,
name: None,
}
}
#[test]
fn pending_join_serializes_policy_receipt_for_cold_launch_recovery() {
let mut link = pending("join", "wss://relay.example", Some("invite"));
link.policy_receipt = Some("relay-signed-receipt".to_owned());
let payload = serde_json::to_value(link).unwrap();
assert_eq!(payload["policyReceipt"], "relay-signed-receipt");
}
#[test]
fn pending_community_links_are_fifo_and_acknowledged_in_order() {
let queue = PendingCommunityDeepLinks::default();