use std::collections::HashMap; use rand::Rng; use libpso::packet::ship::*; use libpso::packet::login::{Login, LoginResponse, AccountStatus, Session}; use libpso::{PacketParseError, PSOPacket}; use libpso::crypto::bb::PSOBBCipher; use libpso::character::character; use libpso::utf8_to_utf16_array; use crate::common::cipherkeys::{ELSEWHERE_PRIVATE_KEY, ELSEWHERE_PARRAY}; use crate::common::serverstate::{SendServerPacket, RecvServerPacket, ServerState, OnConnect, ClientId}; use crate::entity::gateway::EntityGateway; use crate::entity::account::{UserAccount, UserSettings, USERFLAG_NEWCHAR, USERFLAG_DRESSINGROOM}; use crate::entity::character::Character; use crate::login::login::get_login_status; use crate::ship::location::ClientLocation; pub const SHIP_PORT: u16 = 23423; #[derive(Debug)] pub enum ShipError { ClientNotFound(ClientId), NoCharacterInSlot(ClientId, u32), InvalidSlot(ClientId, u32), } #[derive(Debug)] pub enum RecvShipPacket { Login(Login), MenuSelect(MenuSelect), CharData(CharData), } impl RecvServerPacket for RecvShipPacket { fn from_bytes(data: &[u8]) -> Result { match u16::from_le_bytes([data[2], data[3]]) { 0x93 => Ok(RecvShipPacket::Login(Login::from_bytes(data)?)), 0x10 => Ok(RecvShipPacket::MenuSelect(MenuSelect::from_bytes(data)?)), 0x61 => Ok(RecvShipPacket::CharData(CharData::from_bytes(data)?)), _ => Err(PacketParseError::WrongPacketForServerType(u16::from_le_bytes([data[2], data[3]]), data.to_vec())) } } } #[derive(Debug)] pub enum SendShipPacket { ShipWelcome(ShipWelcome), LoginResponse(LoginResponse), ShipBlockList(ShipBlockList), FullCharacter(FullCharacter), CharDataRequest(CharDataRequest), JoinLobby(JoinLobby), } impl SendServerPacket for SendShipPacket { fn as_bytes(&self) -> Vec { match self { SendShipPacket::ShipWelcome(pkt) => pkt.as_bytes(), SendShipPacket::LoginResponse(pkt) => pkt.as_bytes(), SendShipPacket::ShipBlockList(pkt) => pkt.as_bytes(), SendShipPacket::FullCharacter(pkt) => pkt.as_bytes(), SendShipPacket::CharDataRequest(pkt) => pkt.as_bytes(), SendShipPacket::JoinLobby(pkt) => pkt.as_bytes(), } } } struct ClientState { user: Option, settings: Option, character: Character, session: Session, block: u32, } impl ClientState { fn new() -> ClientState { ClientState { user: None, settings: None, character: Character::default(), session: Session::new(), block: 0, } } } pub struct ShipServerState { entity_gateway: EG, clients: HashMap, client_location: ClientLocation, } impl ShipServerState { pub fn new(entity_gateway: EG) -> ShipServerState { ShipServerState { entity_gateway: entity_gateway, clients: HashMap::new(), client_location: ClientLocation::new(), } } fn validate_login(&mut self, id: ClientId, pkt: &Login) -> Result, ShipError> { let client = self.clients.get_mut(&id).ok_or(ShipError::ClientNotFound(id))?; Ok(match get_login_status(&self.entity_gateway, pkt) { Ok(user) => { let mut response = LoginResponse::by_status(AccountStatus::Ok, Session::new()); response.guildcard = user.guildcard.map_or(24, |gc| gc) as u32; response.team_id = user.team_id.map_or(31, |ti| ti) as u32; client.session = pkt.session; let characters = self.entity_gateway.get_characters_by_user(&user); client.character = characters .get(pkt.session.character_slot as usize) .ok_or(ShipError::InvalidSlot(id, pkt.session.character_slot as u32))? .ok_or(ShipError::NoCharacterInSlot(id, pkt.session.character_slot as u32))?; client.user = Some(user); client.settings = Some(self.entity_gateway.get_user_settings_by_user(&client.user.as_ref().unwrap()) .ok_or(ShipError::ClientNotFound(id))?); vec![SendShipPacket::LoginResponse(response), SendShipPacket::ShipBlockList(ShipBlockList::new(3))] }, Err(err) => { vec![SendShipPacket::LoginResponse(LoginResponse::by_status(err, Session::new()))] } }) } fn block_selected(&mut self, id: ClientId, pkt: &MenuSelect) -> Result, ShipError> { let client = self.clients.get_mut(&id).ok_or(ShipError::ClientNotFound(id))?; let settings = client.settings.as_ref().ok_or(ShipError::ClientNotFound(id))?.settings; client.block = pkt.item as u32; let mut fc = character::FullCharacter::default(); fc.character = client.character.character; fc.key_team_config.key_config = settings.key_config; fc.key_team_config.joystick_config = settings.joystick_config; Ok(vec![ SendShipPacket::FullCharacter(FullCharacter { character: fc, }), SendShipPacket::CharDataRequest(CharDataRequest {}), ]) } fn send_player_to_lobby(&mut self, id: ClientId, pkt: &CharData) -> Result, ShipError> { let mut c = character::Character::default(); let joinlobby = JoinLobby { client: 0, leader: 0, one: 1, lobby: 0, block: 1, event: 0, padding: 0, playerinfo: vec![ PlayerInfo { header: PlayerHeader { tag: 0, guildcard: 12345, _unknown1: [0; 5], client_id: 0, name: utf8_to_utf16_array!("HELLO", 16), _unknown2: 0, }, inventory: character::Inventory { item_count: 0, hp_mats_used: 0, tp_mats_used: 0, language: 0, items: [character::InventoryItem::default(); 30], }, character: c } ] }; Ok(vec![ SendShipPacket::JoinLobby(joinlobby) ]) } } impl ServerState for ShipServerState { type SendPacket = SendShipPacket; type RecvPacket = RecvShipPacket; type PacketError = ShipError; fn on_connect(&mut self, id: ClientId) -> Vec> { self.clients.insert(id, ClientState::new()); let mut rng = rand::thread_rng(); let mut server_key = [0u8; 48]; let mut client_key = [0u8; 48]; rng.fill(&mut server_key[..]); rng.fill(&mut client_key[..]); vec![OnConnect::Packet(SendShipPacket::ShipWelcome(ShipWelcome::new(server_key, client_key))), OnConnect::Cipher((Box::new(PSOBBCipher::new(ELSEWHERE_PARRAY, ELSEWHERE_PRIVATE_KEY, client_key)), Box::new(PSOBBCipher::new(ELSEWHERE_PARRAY, ELSEWHERE_PRIVATE_KEY, server_key)))) ] } fn handle(&mut self, id: ClientId, pkt: &RecvShipPacket) -> Result>, ShipError> { Ok(match pkt { RecvShipPacket::Login(login) => { Box::new(self.validate_login(id, login)?.into_iter().map(move |pkt| (id, pkt))) }, RecvShipPacket::MenuSelect(menuselect) => { match menuselect.menu { BLOCK_MENU_ID => Box::new(self.block_selected(id, menuselect)?.into_iter().map(move |pkt| (id, pkt))), _ => unreachable!(), } }, RecvShipPacket::CharData(chardata) => { Box::new(self.send_player_to_lobby(id, chardata)?.into_iter().map(move |pkt| (id, pkt))) } }) } }