socket-bot/ica-rs/src/tailchat/client.rs

use crate::data_struct::tailchat::messages::SendingMessage;
// use crate::data_struct::tailchat::{ConverseId, GroupId, MessageId, UserId};

use rust_socketio::asynchronous::Client;

use colored::Colorize;
use serde_json::{json, Value};
use tracing::{debug, info, warn};

pub async fn send_message(client: &Client, message: &SendingMessage) -> bool {
    if message.contain_file() {
        // 处理文件
    }
    let value: Value = message.as_value();
    match client.emit("chat.message.sendMessage", value).await {
        Ok(_) => {
            debug!("send_message {}", format!("{:#?}", message).cyan());
            true
        }
        Err(e) => {
            warn!("send_message failed:{}", format!("{:#?}", e).red());
            false
        }
    }
}

pub async fn emit_join_room(client: &Client) -> bool {
    match client.emit("chat.converse.findAndJoinRoom", json!([])).await {
        Ok(_) => {
            info!("emiting join room");
            true
        }
        Err(e) => {
            warn!("emit_join_room faild:{}", format!("{:#?}", e).red());
            false
        }
    }
}