use std::collections::HashMap; use libpso::packet::ship::*; use crate::common::serverstate::ClientId; use crate::common::leveltable::CharacterLevelTable; use crate::ship::ship::{SendShipPacket, ShipError, ClientState, Rooms, Clients}; use crate::ship::character::{CharacterBytesBuilder, FullCharacterBytesBuilder}; use crate::ship::location::{ClientLocation, LobbyId, RoomId, RoomLobby, MAX_ROOMS}; use libpso::character::character; use crate::ship::room; pub fn create_room(id: ClientId, create_room: &CreateRoom, client_location: &mut ClientLocation, clients: &mut Clients, rooms: &mut Rooms) -> Box + Send> { let area = client_location.get_area(id).unwrap(); let area_client = client_location.get_local_client(id).unwrap(); let lobby_neighbors = client_location.get_client_neighbors(id).unwrap(); let room_id = client_location.create_new_room(id).unwrap(); let client = clients.get_mut(&id).unwrap();//.ok_or(ShipError::ClientNotFound(id)).unwrap(); let mut room = room::RoomState::from_create_room(create_room, client.character.section_id).unwrap(); room.bursting = true; let players = [PlayerHeader { tag: 0x10000, guildcard: client.user.id.0, _unknown1: [0; 5], client_id: 0, name: libpso::utf8_to_utf16_array!(client.character.name, 16), _unknown2: 2, }, PlayerHeader::default(), PlayerHeader::default(), PlayerHeader::default()]; let join_room = JoinRoom { flag: 1, maps: room.maps.map_headers(), players: players, client: 0, leader: 0, one: 1, difficulty: create_room.difficulty, battle: create_room.battle, event: 0, section: 0, // TODO challenge: create_room.challenge, random_seed: 23, // TODO episode: create_room.episode, one2: 1, single_player: create_room.single_player, unknown: 0, }; rooms[room_id.0] = Some(room); let leader = client_location.get_area_leader(area); let result = vec![(id, SendShipPacket::JoinRoom(join_room))].into_iter(); match leader { Ok(leader) => Box::new(result.chain(lobby_neighbors .into_iter() .map(move |c| { (c.client, SendShipPacket::LeaveLobby(LeaveLobby::new(area_client.local_client.id(), leader.local_client.id()))) }))), Err(_) => Box::new(result) } } pub fn room_name_request(id: ClientId, client_location: &ClientLocation, rooms: &Rooms) -> Box + Send> { let area = client_location.get_area(id).unwrap(); match area { RoomLobby::Room(room) => Box::new(vec![(id, SendShipPacket::RoomNameResponse(RoomNameResponse {name: rooms[room.0].as_ref().unwrap().name.clone()}))].into_iter()), RoomLobby::Lobby(_) => panic!() } } pub fn join_room(id: ClientId, pkt: &MenuSelect, client_location: &mut ClientLocation, clients: &mut Clients, level_table: &CharacterLevelTable, rooms: &mut Rooms) -> Result, ShipError> { let original_area = client_location.get_area(id).unwrap(); let original_neighbors = client_location.get_client_neighbors(id).unwrap(); let room = rooms.get(pkt.item as usize) .ok_or_else(|| ShipError::InvalidRoom(pkt.item))?.as_ref() .ok_or_else(|| ShipError::InvalidRoom(pkt.item))?; if room.bursting { return Ok(vec![(id, SendShipPacket::SmallDialog(SmallDialog::new("player is bursting\nplease wait".into())))]) } let room_id = RoomId(pkt.item as usize); let original_room_clients = client_location.get_clients_in_room(room_id).map_err(|err| ShipError::ClientError(format!("{:?}", err)))?; client_location.add_client_to_room(id, room_id).unwrap(); // TODO: show room full error or whatever let all_clients = client_location.get_clients_in_room(room_id).map_err(|err| ShipError::ClientError(format!("{:?}", err)))?; let player_headers = all_clients.iter() .enumerate() .fold([PlayerHeader::default(); 4], |mut acc, (i, c)| { let header_client = clients.get(&c.client).ok_or(ShipError::ClientNotFound(id)).unwrap(); acc[i] = PlayerHeader { tag: 0x100, guildcard: header_client.user.id.0, _unknown1: [0,0,0, c.local_client.id() as u32, 0], client_id: 0, name: libpso::utf8_to_utf16_array!(header_client.character.name, 16), _unknown2: 2, }; acc }); let area_client = client_location.get_local_client(id).map_err(|err| ShipError::ClientError(format!("{:?}", err)))?; let leader = client_location.get_room_leader(room_id).map_err(|err| ShipError::ClientError(format!("{:?}", err)))?; let join_room = JoinRoom { flag: all_clients.len() as u32, maps: room.map_headers(), players: player_headers, client: area_client.local_client.id(), leader: leader.local_client.id(), one: 1, difficulty: room.mode.difficulty().into(), battle: matches!(room.mode, room::RoomMode::Battle {..}) as u8, event: 0, section: room.section_id.into(), challenge: matches!(room.mode, room::RoomMode::Challenge {..}) as u8, random_seed: room.random_seed, episode: room.mode.episode().into(), one2: 1, single_player: 0, // TODO unknown: 0, }; let client = clients.get(&id).ok_or(ShipError::ClientNotFound(id))?; let (level, stats) = level_table.get_stats_from_exp(client.character.char_class, client.character.exp); let c = CharacterBytesBuilder::new() .character(&client.character) .stats(&stats) .level(level - 1) .build(); let add_to = AddToRoom { flag: 0x10000, client: area_client.local_client.id(), leader: leader.local_client.id(), one: 0, // TODO: ?????????? lobby: 0xff, block: 0, event: 0, padding: 1, playerinfo: PlayerInfo { header: PlayerHeader { tag: 0x10000, guildcard: client.user.id.0, _unknown1: [0; 5], client_id: area_client.local_client.id() as u32, name: libpso::utf8_to_utf16_array!(client.character.name, 16), _unknown2: 2, }, inventory: character::Inventory { item_count: 0, hp_mats_used: 0, tp_mats_used: 0, language: 0, items: [character::InventoryItem::default(); 30], // TOOD: this should be something }, character: c, }, }; let result = vec![(id, SendShipPacket::JoinRoom(join_room))] .into_iter() .chain(original_room_clients.clone().into_iter() .map(|c| (c.client, SendShipPacket::AddToRoom(add_to.clone()))) ); let room = rooms.get_mut(room_id.0).unwrap().as_mut().unwrap(); room.bursting = true; if let Ok(leader) = client_location.get_area_leader(original_area) { let leave_lobby = SendShipPacket::LeaveLobby(LeaveLobby::new(area_client.local_client.id(), leader.local_client.id())); Ok(result.chain(original_neighbors.into_iter() .map(|c| (c.client, leave_lobby.clone()))).collect()) } else { Ok(result.collect()) } } pub fn done_bursting(id: ClientId, client_location: &ClientLocation, rooms: &mut Rooms) -> Box + Send> { let area = client_location.get_area(id).unwrap(); if let RoomLobby::Room(room_id) = area { let room = rooms.get_mut(room_id.0).unwrap().as_mut().unwrap(); room.bursting = false; } Box::new(client_location.get_client_neighbors(id).unwrap().into_iter() .map(move |client| { vec![ (client.client, SendShipPacket::BurstDone72(BurstDone72::new())), ] }).flatten()) } pub fn request_room_list(id: ClientId, client_location: &ClientLocation, rooms: &Rooms) -> Box + Send> { let active_room_list = rooms.iter() .enumerate() .filter_map(|(i, r)| { r.as_ref().map(|room| { RoomList { menu_id: ROOM_MENU_ID, item_id: i as u32, difficulty: room.get_difficulty_for_room_list(), players: client_location.get_clients_in_room(RoomId(i)).unwrap().len() as u8, name: libpso::utf8_to_utf16_array!(room.name, 16), episode: room.get_episode_for_room_list(), flags: room.get_flags_for_room_list(), } }) }); let baseroom: RoomList = RoomList { menu_id: ROOM_MENU_ID, item_id: ROOM_MENU_ID, difficulty: 0x00, players: 0x00, name: libpso::utf8_to_utf16_array!("Room list menu", 16), episode: 0, flags: 0, }; Box::new(vec![(id, SendShipPacket::RoomListResponse(RoomListResponse { baseroom, rooms: active_room_list.collect() }))].into_iter()) } pub fn cool_62(id: ClientId, cool_62: &Like62ButCooler, client_location: &ClientLocation) -> Box + Send> { let target = cool_62.flag as u8; let cool_62 = cool_62.clone(); Box::new(client_location.get_client_neighbors(id).unwrap().into_iter() .filter(move |client| client.local_client.id() == target) .map(move |client| { (client.client, SendShipPacket::Like62ButCooler(cool_62.clone())) })) }