tunneler-core 0.6.2

use crate::message::Message;
use crate::streams::{error::RecvError, mpsc};

use log::error;
use tokio::io::AsyncWriteExt;

/// Reads messages from the Client for this User and sends them to the User
///
/// Params:
/// * client_id: The ID of the client that handles this
/// * user_id: The ID of the User for this connection
/// * con: The User-Connection
/// * queue: The Queue for messages that need to be send to the user
pub async fn send(
    client_id: u32,
    user_id: u32,
    mut con: tokio::net::tcp::OwnedWriteHalf,
    mut queue: mpsc::StreamReader<Message>,
) {
    loop {
        let msg = match queue.recv().await {
            Ok(m) => m,
            Err(e) => {
                if e != RecvError::Closed {
                    error!("[{}][{}] Receiving from Queue: {}", client_id, user_id, e);
                }
                return;
            }
        };

        let data = msg.get_data();
        match con.write_all(&data).await {
            Ok(_) => {}
            Err(e) => {
                error!("[{}][{}] Sending to User: {}", client_id, user_id, e);
                return;
            }
        };
    }
}