implemented basic client manager functions for new architecture

This commit is contained in:
michael-bailey 2021-03-18 09:20:39 +00:00
parent 22a0d68255
commit a8c37225ae
2 changed files with 19 additions and 19 deletions

View File

@ -2,18 +2,17 @@ pub mod client;
mod traits;
// use crate::lib::server::ServerMessages;
use crate::lib::server::ServerMessages;
use std::sync::Arc;
use std::sync::Mutex;
use std::sync::Weak;
use std::collections::HashMap;
use crossbeam_channel::{unbounded, Receiver, Sender};
use uuid::Uuid;
use crate::lib::Foundation::{IOwner, IOwned};
use self::client::Client;
use self::client::ClientMessage;
use self::traits::TClientManager;
use crate::lib::server::ServerMessages;
use crate::lib::Foundation::IMessagable;
use crate::lib::Foundation::ICooperative;
@ -23,12 +22,10 @@ enum ClientManagerMessages {}
/// This struct manages all connected users
#[derive(Debug)]
pub struct ClientManager {
clients: Mutex<Vec<Arc<Client>>>,
clients: Mutex<HashMap<Uuid, Arc<Client>>>,
server_channel: Sender<ServerMessages>,
// server_channel: Sender<ServerMessages>,
sender: Sender<ClientManagerMessages>,
receiver: Receiver<ClientManagerMessages>,
}
@ -51,29 +48,32 @@ impl ClientManager {
impl TClientManager<Client, ClientMessage> for ClientManager {
fn add_client(&self, client: std::sync::Arc<Client>) {
self.clients.lock().unwrap().push(client);
self.clients.lock().unwrap().insert(client.uuid, client);
}
fn remove_client(&self, _uuid: Uuid) {
self.clients.lock().unwrap().sort();
fn remove_client(&self, uuid: Uuid) {
let _ = self.clients.lock().unwrap().remove(&uuid);
}
fn message_client(&self, _id: Uuid, _msg: ClientMessage) {
todo!()
fn send_message_to_client(&self, uuid: Uuid, msg: ClientMessage) {
let clients = self.clients.lock().unwrap();
let client = clients.get(&uuid).unwrap();
client.send_message(msg);
}
}
impl ICooperative for ClientManager {
fn tick(&self) {
let client_list = self.clients.lock().unwrap();
let _ = client_list.iter().map(|client| client.tick());
}
}
#[cfg(test)]
mod test {
use super::ClientManager;
use std::sync::Arc;
use crate::lib::Foundation::{IOwner};
// use super::ClientManager;
// use std::sync::Arc;
// use crate::lib::Foundation::{IOwner};
#[test]
fn test_get_ref() {

View File

@ -1,3 +1,4 @@
use crate::lib::server::client_management::client::ClientMessage;
use std::sync::Arc;
use uuid::Uuid;
@ -7,7 +8,6 @@ use uuid::Uuid;
*/
pub trait TClientManager<TClient,TClientMessage> {
fn add_client(&self, client: Arc<TClient>);
fn remove_client(&self, id: Uuid);
fn message_client(&self, id: Uuid, msg: TClientMessage);
fn tick(&self, );
fn remove_client(&self, uuid: Uuid);
fn send_message_to_client(&self, uuid: Uuid, msg: ClientMessage);
}