feat(filamento): user avatar publishing and processing

1 files changed, 36 insertions, 9 deletions

diff --git a/filamento/src/logic/offline.rs b/filamento/src/logic/offline.rs
index 6399cf7..566972c 100644
--- a/filamento/src/logic/offline.rs
+++ b/filamento/src/logic/offline.rs
@@ -1,3 +1,5 @@
+use std::process::id;
+
 use chrono::Utc;
 use lampada::error::WriteError;
 use uuid::Uuid;
@@ -6,9 +8,10 @@ use crate::{
     Command,
     chat::{Delivery, Message},
     error::{
-        DatabaseError, DiscoError, Error, IqRequestError, MessageSendError, NickError, RosterError,
-        StatusError,
+        AvatarPublishError, DatabaseError, DiscoError, Error, IqRequestError, MessageSendError,
+        NickError, PEPError, RosterError, StatusError,
     },
+    files::FileStore,
     presence::Online,
     roster::Contact,
 };
@@ -22,7 +25,7 @@ use super::{
     },
 };
 
-pub async fn handle_offline(logic: ClientLogic, command: Command) {
+pub async fn handle_offline<Fs: FileStore + Clone>(logic: ClientLogic<Fs>, command: Command<Fs>) {
     let result = handle_offline_result(&logic, command).await;
     match result {
         Ok(_) => {}
@@ -30,16 +33,24 @@ pub async fn handle_offline(logic: ClientLogic, command: Command) {
     }
 }
 
-pub async fn handle_set_status(logic: &ClientLogic, online: Online) -> Result<(), StatusError> {
+pub async fn handle_set_status<Fs: FileStore + Clone>(
+    logic: &ClientLogic<Fs>,
+    online: Online,
+) -> Result<(), StatusError> {
     logic.db().upsert_cached_status(online).await?;
     Ok(())
 }
 
-pub async fn handle_get_roster(logic: &ClientLogic) -> Result<Vec<Contact>, RosterError> {
+pub async fn handle_get_roster<Fs: FileStore + Clone>(
+    logic: &ClientLogic<Fs>,
+) -> Result<Vec<Contact>, RosterError> {
     Ok(logic.db().read_cached_roster().await?)
 }
 
-pub async fn handle_offline_result(logic: &ClientLogic, command: Command) -> Result<(), Error> {
+pub async fn handle_offline_result<Fs: FileStore + Clone>(
+    logic: &ClientLogic<Fs>,
+    command: Command<Fs>,
+) -> Result<(), Error<Fs>> {
     match command {
         Command::GetRoster(sender) => {
             let roster = handle_get_roster(logic).await;
@@ -77,7 +88,6 @@ pub async fn handle_offline_result(logic: &ClientLogic, command: Command) -> Res
             let user = handle_get_user(logic, jid).await;
             sender.send(user);
         }
-        // TODO: offline queue to modify roster
         Command::AddContact(_jid, sender) => {
             sender.send(Err(RosterError::Write(WriteError::Disconnected)));
         }
@@ -112,7 +122,6 @@ pub async fn handle_offline_result(logic: &ClientLogic, command: Command) -> Res
             let result = handle_set_status(logic, online).await;
             sender.send(result);
         }
-        // TODO: offline message queue
         Command::SendMessage(jid, body) => {
             let id = Uuid::new_v4();
             let timestamp = Utc::now();
@@ -159,7 +168,7 @@ pub async fn handle_offline_result(logic: &ClientLogic, command: Command) -> Res
         Command::DiscoItems(_jid, _node, sender) => {
             sender.send(Err(DiscoError::Write(WriteError::Disconnected)));
         }
-        Command::Publish {
+        Command::PublishPEPItem {
             item: _,
             node: _,
             sender,
@@ -169,6 +178,24 @@ pub async fn handle_offline_result(logic: &ClientLogic, command: Command) -> Res
         Command::ChangeNick(_, sender) => {
             sender.send(Err(NickError::Disconnected));
         }
+        Command::ChangeAvatar(_items, sender) => {
+            sender.send(Err(AvatarPublishError::Disconnected));
+        }
+        Command::DeletePEPNode { node: _, sender } => {
+            sender.send(Err(PEPError::IqResponse(IqRequestError::Write(
+                WriteError::Disconnected,
+            ))));
+        }
+        Command::GetPEPItem {
+            node: _,
+            sender,
+            jid: _,
+            id: _,
+        } => {
+            sender.send(Err(PEPError::IqResponse(IqRequestError::Write(
+                WriteError::Disconnected,
+            ))));
+        }
     }
     Ok(())
 }