From a4eded3ffdd6b5d51a6897d7c46aa108d54837ea Mon Sep 17 00:00:00 2001
From: ghassmo <ghxxm@protonmail.com>
Date: Wed, 22 Jun 2022 01:18:16 +0300
Subject: [PATCH] ircd: send messages history to clients

---
 bin/ircd/src/main.rs   | 11 +++++++++--
 bin/ircd/src/server.rs |  1 +
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/bin/ircd/src/main.rs b/bin/ircd/src/main.rs
index 9160f1ca9..04a487f69 100644
--- a/bin/ircd/src/main.rs
+++ b/bin/ircd/src/main.rs
@@ -6,11 +6,11 @@ use std::net::SocketAddr;
 
 use async_channel::{Receiver, Sender};
 use async_executor::Executor;
-
 use futures::{io::BufReader, AsyncBufReadExt, AsyncReadExt, FutureExt};
 use fxhash::FxHashMap;
 use log::{error, info, warn};
 use rand::rngs::OsRng;
+use ringbuffer::RingBufferExt;
 use smol::future;
 use structopt_toml::StructOptToml;
 
@@ -75,6 +75,7 @@ impl Ircd {
             .spawn(async move {
                 while let Ok(msg) = p2p_receiver_cloned.recv().await {
                     for (addr, sender) in senders.lock().await.iter() {
+                        // TODO: this need stop signal instead 
                         if let Err(e) = sender.send(msg.clone()).await {
                             error!("Can't send msg to the client {}: {}", addr, e);
                             // removing a client sender from the hashmap if any error occured
@@ -109,7 +110,13 @@ impl Ircd {
         );
 
         let (sender, receiver) = async_channel::unbounded();
-        self.add_to_senders(&peer_addr, sender).await;
+
+        // send messages history
+        for msg in self.privmsgs_buffer.lock().await.to_vec() {
+            sender.send(msg).await?;
+        }
+
+        self.add_to_senders(&peer_addr, sender.clone()).await;
 
         executor
             .spawn(async move {
diff --git a/bin/ircd/src/server.rs b/bin/ircd/src/server.rs
index a2471f4da..e8bfa1ac5 100644
--- a/bin/ircd/src/server.rs
+++ b/bin/ircd/src/server.rs
@@ -1,4 +1,5 @@
 use async_std::net::TcpStream;
+
 use futures::{io::WriteHalf, AsyncWriteExt};
 use fxhash::FxHashMap;
 use log::{debug, info, warn};