1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use crate::ddd::application::repository_factory::RepositoryFactory;
use crate::dofus::action_handler::ActionHandler;
use crate::dofus::realm::RealmError::{ClientHandleError, ServerError};
use crate::dofus::realm_config::RealmConfig;
use crate::dofus::realm_handle::{RealmHandle, RealmMessage};
use crate::io::tcp::server::{TcpServer, TcpServerError, BUFFER_SIZE};
use thiserror::Error;
use tokio::select;
use tokio::sync::mpsc;
use tokio::task::JoinError;

#[derive(Error, Debug)]
pub enum RealmError {
    #[error("Error while processing client request")]
    ClientHandleError,
    #[error("The server just returned the following error")]
    ServerError,
}

pub fn start<T: RepositoryFactory + Send + 'static, E: ActionHandler + Send + 'static>(
    config: RealmConfig,
    repository_factory: T,
    action_handler: E,
) -> RealmHandle {
    let RealmConfig {
        name,
        address,
        port,
    } = config;

    let (realm_sender, mut realm_receiver) = mpsc::channel(BUFFER_SIZE);
    let realm_join = tokio::spawn(async move {
        let (tcp_client_sender, mut tcp_client_receiver) = mpsc::channel(BUFFER_SIZE);
        let (server_handle, mut server_join) = TcpServer::start(tcp_client_sender, address, port);
        let mut error: Result<(), RealmError> = Ok(());
        loop {
            select! {
                Some(action) = tcp_client_receiver.recv() => { // handle client actions (e.g connect, dc or data sent)
                    if let Err(msg) =  &action_handler.handle(action, &repository_factory) {
                        error = Err(ClientHandleError);
                        break
                }}
                Some(RealmMessage::Stop) = realm_receiver.recv() => {break} // listen to messages of the realm handle
                server_result = &mut server_join => {
                    if let Err(_) = server_result {
                        error = Err(ServerError);
                        break;
                    }
                }
            }
        }
        match server_join.await {
            // wait for server tcp server to gracefully close
            Err(_) => error = Err(ServerError),     // join error
            Ok(Err(_)) => error = Err(ServerError), // tcp server error
            _ => {}
        }
        error
    });
    RealmHandle::new(realm_sender, realm_join)
}