xmppftw/xmpp-rs
Watch
1
0
Fork
You've already forked xmpp-rs
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Ran cargo fmt

Browse source
This commit is contained in:
Werner Kroneman 2023-12-03 16:28:59 +01:00
commit 05a0b6cd8f
1 changed files with 15 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

30
xmpp/src/pubsub/avatar.rs
View file

@ -30,26 +30,26 @@ pub(crate) async fn handle_metadata_pubsub_event(
for item in items { for item in items {
let payload = item.payload.clone().unwrap(); let payload = item.payload.clone().unwrap();
if payload.is("metadata", ns::AVATAR_METADATA) { if payload.is("metadata", ns::AVATAR_METADATA) {
match Metadata::try_from(payload) { match Metadata::try_from(payload) {
Ok(metadata) => for info in metadata.infos { Ok(metadata) => {
let filename = format!("data/{}/{}", from, &*info.id.to_hex()); for info in metadata.infos {
let file_length = match fs::metadata(filename.clone()) { let filename = format!("data/{}/{}", from, &*info.id.to_hex());
Ok(metadata) => metadata.len(), let file_length = match fs::metadata(filename.clone()) {
Err(_) => 0, Ok(metadata) => metadata.len(),
}; Err(_) => 0,
// TODO: Also check the hash. };
if info.bytes as u64 == file_length { // TODO: Also check the hash.
events.push(Event::AvatarRetrieved(from.clone(), filename)); if info.bytes as u64 == file_length {
} else { events.push(Event::AvatarRetrieved(from.clone(), filename));
let iq = download_avatar(from); } else {
let _ = agent.client.send_stanza(iq.into()).await; let iq = download_avatar(from);
let _ = agent.client.send_stanza(iq.into()).await;
}
} }
} }
Err(e) => error!("Error parsing avatar metadata: {}", e) Err(e) => error!("Error parsing avatar metadata: {}", e),
} }
} }
} }
events events