Move send_message to message::send module

This commit is contained in:
xmppftw@kl.netlib.re 2023-12-30 00:38:06 +01:00
parent 12e5299abf
commit f6c47dd394
3 changed files with 30 additions and 10 deletions

View file

@ -9,10 +9,7 @@
use std::path::{Path, PathBuf}; use std::path::{Path, PathBuf};
use std::sync::{Arc, RwLock}; use std::sync::{Arc, RwLock};
pub use tokio_xmpp::parsers; pub use tokio_xmpp::parsers;
use tokio_xmpp::parsers::{ use tokio_xmpp::parsers::{disco::DiscoInfoResult, message::MessageType};
disco::DiscoInfoResult,
message::{Body, Message, MessageType},
};
use tokio_xmpp::AsyncClient as TokioXmppClient; use tokio_xmpp::AsyncClient as TokioXmppClient;
pub use tokio_xmpp::{BareJid, Element, FullJid, Jid}; pub use tokio_xmpp::{BareJid, Element, FullJid, Jid};
#[macro_use] #[macro_use]
@ -104,12 +101,7 @@ impl Agent {
lang: &str, lang: &str,
text: &str, text: &str,
) { ) {
let mut message = Message::new(Some(recipient)); message::send::send_message(self, recipient, type_, lang, text).await
message.type_ = type_;
message
.bodies
.insert(String::from(lang), Body(String::from(text)));
let _ = self.client.send_stanza(message.into()).await;
} }
pub async fn send_room_private_message( pub async fn send_room_private_message(

View file

@ -5,3 +5,4 @@
// file, You can obtain one at http://mozilla.org/MPL/2.0/. // file, You can obtain one at http://mozilla.org/MPL/2.0/.
pub mod receive; pub mod receive;
pub mod send;

27
xmpp/src/message/send.rs Normal file
View file

@ -0,0 +1,27 @@
// Copyright (c) 2023 xmpp-rs contributors.
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
use tokio_xmpp::{
parsers::message::{Body, Message, MessageType},
Jid,
};
use crate::Agent;
pub async fn send_message(
agent: &mut Agent,
recipient: Jid,
type_: MessageType,
lang: &str,
text: &str,
) {
let mut message = Message::new(Some(recipient));
message.type_ = type_;
message
.bodies
.insert(String::from(lang), Body(String::from(text)));
let _ = agent.client.send_stanza(message.into()).await;
}