added debug messages

This commit is contained in:
michael-bailey 2022-09-25 11:52:31 +01:00
parent 89b420ee42
commit 962fb5bb5c
2 changed files with 11 additions and 0 deletions

View File

@ -20,10 +20,15 @@ impl ChatManager {
// no need for a remove methods because this is a read only system
fn add_message(&mut self, _ctx: &mut Context<Self>, id: Uuid, content: String) {
println!(
"[ChatManager] add_message id: {:?} content: {:?}",
id, content
);
self.messages.push(Message::new(id, content))
}
fn get_messages(&self, _ctx: &mut Context<Self>) -> ChatManagerDataResponse {
println!("[ChatManager] getting messages");
ChatManagerDataResponse::GotMessages(self.messages.clone())
}
@ -32,6 +37,7 @@ impl ChatManager {
_ctx: &mut Context<Self>,
index: usize,
) -> ChatManagerDataResponse {
println!("[ChatManager] getting message index: {:?}", index);
ChatManagerDataResponse::GotMessage(self.messages.get(index).cloned())
}
}
@ -44,6 +50,7 @@ impl Handler<ChatManagerMessage> for ChatManager {
type Result = ();
fn handle(&mut self, msg: ChatManagerMessage, ctx: &mut Self::Context) -> Self::Result {
println!("[ChatManager] got message: {:?}", msg);
match msg {
ChatManagerMessage::AddMessage(id, content) => self.add_message(ctx, id, content),
}
@ -58,6 +65,7 @@ impl Handler<ChatManagerDataMessage> for ChatManager {
msg: ChatManagerDataMessage,
ctx: &mut Self::Context,
) -> Self::Result {
println!("[ChatManager] got message: {:?}", msg);
match msg {
ChatManagerDataMessage::GetMessages => self.get_messages(ctx),
ChatManagerDataMessage::GetMessage(index) => self.get_message(ctx, index),

View File

@ -130,6 +130,7 @@ impl ClientManager {
sender: WeakAddr<Client>,
content: String,
) {
println!("[ClientManager] sending message to client");
use crate::client_management::client::ClientMessage::SendGlobalMessage;
let client_addr: Vec<Addr<Client>> =
@ -145,6 +146,7 @@ impl ClientManager {
let cont2 = content;
let fut = wrap_future(async move {
println!("[ClientManager] sending to all clients");
let details: ClientDataResponse =
snd1.send(ClientDataMessage::Details).await.unwrap();
@ -166,6 +168,7 @@ impl ClientManager {
});
let chat_manager_fut = wrap_future(async move {
println!("[ClientManager] storing in chat manager");
let details: ClientDataResponse =
snd2.send(ClientDataMessage::Details).await.unwrap();