..

Author: sxyazi

yazi-core/src/tab/commands/cd.rs

@@ -3,6 +3,7 @@ use std::{mem, time::Duration};
 use tokio::{fs, pin};
 use tokio_stream::{wrappers::UnboundedReceiverStream, StreamExt};
 use yazi_config::popup::InputCfg;
+use yazi_dds::Pubsub;
 use yazi_proxy::{CompletionProxy, InputProxy, ManagerProxy, TabProxy};
 use yazi_shared::{event::Cmd, fs::{expand_path, Url}, render, Debounce, InputError};
 
@@ -64,6 +65,7 @@ impl Tab {
 			self.backstack.push(opt.target.clone());
 		}
 
+		Pubsub::pub_from_cd(&self.current.cwd);
 		ManagerProxy::refresh();
 		render!();
 	}

yazi-dds/src/client.rs

@@ -81,13 +81,15 @@ impl Client {
 	}
 
 	fn handle_hey(s: String) {
-		if let Ok(Body::Hey(hey)) = Payload::from_str(&s).map(|p| p.body) {
+		if let Ok(Body::Hey(mut hey)) = Payload::from_str(&s).map(|p| p.body) {
+			hey.peers.retain(|&id, _| id != *ID);
 			*PEERS.write() = hey.peers;
 		}
 	}
 }
 
 impl Peer {
+	#[inline]
 	pub(super) fn new(abilities: &HashSet<String>) -> Self { Self { abilities: abilities.clone() } }
 
 	#[inline]

yazi-dds/src/pubsub.rs

@@ -2,9 +2,9 @@ use std::collections::HashMap;
 
 use mlua::Function;
 use parking_lot::RwLock;
-use yazi_shared::{emit, event::Cmd, timestamp_ms, Layer, RoCell};
+use yazi_shared::{emit, event::Cmd, fs::Url, timestamp_ms, Layer, RoCell};
 
-use crate::{Body, BodyHi, Payload, ID, PEERS, QUEUE};
+use crate::{Body, BodyCd, BodyHi, Payload, ID, PEERS, QUEUE};
 
 pub static LOCAL: RoCell<RwLock<HashMap<String, HashMap<String, Function<'static>>>>> =
 	RoCell::new();
@@ -97,4 +97,17 @@ impl Pubsub {
 		});
 		true
 	}
+
+	pub fn pub_from_cd(url: &Url) {
+		if LOCAL.read().contains_key("cd") {
+			Self::pub_with(Body::Cd(BodyCd { url: url.clone() }));
+		}
+		if PEERS.read().values().any(|p| p.able("cd")) {
+			_ = QUEUE.send(Payload {
+				receiver:  0,
+				timestamp: timestamp_ms(),
+				body:      Body::Cd(BodyCd { url: url.clone() }),
+			});
+		}
+	}
 }