fedichat/confetti
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed post buffer filtering

Browse Source 
Oops
This commit is contained in:
Waylon Cude
2026-05-31 16:11:59 -07:00
parent f1de605d19
commit 2770d8d6a5
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client.rs
+5 -1
View File
@@ -153,7 +153,10 @@ impl Client {
// Probably should check that we're still in a room maybe? Not sure how // Probably should check that we're still in a room maybe? Not sure how
// kicks are going to work. // kicks are going to work.
if let Some(relevance) = result.get_relevance() { if let Some(relevance) = result.get_relevance() {
if self.subscriptions.contains(&relevance) { if self.subscriptions.contains(&relevance) ||
(self.username.is_some() && relevance == Relevance::Post(
fedichat::User{name: self.username.clone().unwrap(),server: config.hostname.clone()}))
{
match self.message_ack.send(relevance.clone()).await { match self.message_ack.send(relevance.clone()).await {
Ok(()) => (), Ok(()) => (),
Err(e) => { Err(e) => {
@@ -275,6 +278,7 @@ impl Client {
if authed { if authed {
debug!("Sending post"); debug!("Sending post");
tagged_message = Some(message.clone().tag(user.clone(),my_addr.clone())); tagged_message = Some(message.clone().tag(user.clone(),my_addr.clone()));
debug!("{:?}",tagged_message);
// This is a safe unwrap because the tagged message is set to Some() // This is a safe unwrap because the tagged message is set to Some()
// right above // right above
self.message_send.send(tagged_message.clone().unwrap()) self.message_send.send(tagged_message.clone().unwrap())