diff options
Diffstat (limited to 'src/network/room_member.cpp')
| -rw-r--r-- | src/network/room_member.cpp | 98 |
1 files changed, 49 insertions, 49 deletions
diff --git a/src/network/room_member.cpp b/src/network/room_member.cpp index 38a6f6bfd..e4f823e98 100644 --- a/src/network/room_member.cpp +++ b/src/network/room_member.cpp | |||
| @@ -280,13 +280,13 @@ void RoomMember::RoomMemberImpl::SendJoinRequest(const std::string& nickname_, | |||
| 280 | const std::string& password, | 280 | const std::string& password, |
| 281 | const std::string& token) { | 281 | const std::string& token) { |
| 282 | Packet packet; | 282 | Packet packet; |
| 283 | packet << static_cast<u8>(IdJoinRequest); | 283 | packet.Write(static_cast<u8>(IdJoinRequest)); |
| 284 | packet << nickname_; | 284 | packet.Write(nickname_); |
| 285 | packet << console_id_hash; | 285 | packet.Write(console_id_hash); |
| 286 | packet << preferred_mac; | 286 | packet.Write(preferred_mac); |
| 287 | packet << network_version; | 287 | packet.Write(network_version); |
| 288 | packet << password; | 288 | packet.Write(password); |
| 289 | packet << token; | 289 | packet.Write(token); |
| 290 | Send(std::move(packet)); | 290 | Send(std::move(packet)); |
| 291 | } | 291 | } |
| 292 | 292 | ||
| @@ -298,12 +298,12 @@ void RoomMember::RoomMemberImpl::HandleRoomInformationPacket(const ENetEvent* ev | |||
| 298 | packet.IgnoreBytes(sizeof(u8)); // Ignore the message type | 298 | packet.IgnoreBytes(sizeof(u8)); // Ignore the message type |
| 299 | 299 | ||
| 300 | RoomInformation info{}; | 300 | RoomInformation info{}; |
| 301 | packet >> info.name; | 301 | packet.Read(info.name); |
| 302 | packet >> info.description; | 302 | packet.Read(info.description); |
| 303 | packet >> info.member_slots; | 303 | packet.Read(info.member_slots); |
| 304 | packet >> info.port; | 304 | packet.Read(info.port); |
| 305 | packet >> info.preferred_game.name; | 305 | packet.Read(info.preferred_game.name); |
| 306 | packet >> info.host_username; | 306 | packet.Read(info.host_username); |
| 307 | room_information.name = info.name; | 307 | room_information.name = info.name; |
| 308 | room_information.description = info.description; | 308 | room_information.description = info.description; |
| 309 | room_information.member_slots = info.member_slots; | 309 | room_information.member_slots = info.member_slots; |
| @@ -312,17 +312,17 @@ void RoomMember::RoomMemberImpl::HandleRoomInformationPacket(const ENetEvent* ev | |||
| 312 | room_information.host_username = info.host_username; | 312 | room_information.host_username = info.host_username; |
| 313 | 313 | ||
| 314 | u32 num_members; | 314 | u32 num_members; |
| 315 | packet >> num_members; | 315 | packet.Read(num_members); |
| 316 | member_information.resize(num_members); | 316 | member_information.resize(num_members); |
| 317 | 317 | ||
| 318 | for (auto& member : member_information) { | 318 | for (auto& member : member_information) { |
| 319 | packet >> member.nickname; | 319 | packet.Read(member.nickname); |
| 320 | packet >> member.mac_address; | 320 | packet.Read(member.mac_address); |
| 321 | packet >> member.game_info.name; | 321 | packet.Read(member.game_info.name); |
| 322 | packet >> member.game_info.id; | 322 | packet.Read(member.game_info.id); |
| 323 | packet >> member.username; | 323 | packet.Read(member.username); |
| 324 | packet >> member.display_name; | 324 | packet.Read(member.display_name); |
| 325 | packet >> member.avatar_url; | 325 | packet.Read(member.avatar_url); |
| 326 | 326 | ||
| 327 | { | 327 | { |
| 328 | std::lock_guard lock(username_mutex); | 328 | std::lock_guard lock(username_mutex); |
| @@ -342,7 +342,7 @@ void RoomMember::RoomMemberImpl::HandleJoinPacket(const ENetEvent* event) { | |||
| 342 | packet.IgnoreBytes(sizeof(u8)); // Ignore the message type | 342 | packet.IgnoreBytes(sizeof(u8)); // Ignore the message type |
| 343 | 343 | ||
| 344 | // Parse the MAC Address from the packet | 344 | // Parse the MAC Address from the packet |
| 345 | packet >> mac_address; | 345 | packet.Read(mac_address); |
| 346 | } | 346 | } |
| 347 | 347 | ||
| 348 | void RoomMember::RoomMemberImpl::HandleWifiPackets(const ENetEvent* event) { | 348 | void RoomMember::RoomMemberImpl::HandleWifiPackets(const ENetEvent* event) { |
| @@ -355,14 +355,14 @@ void RoomMember::RoomMemberImpl::HandleWifiPackets(const ENetEvent* event) { | |||
| 355 | 355 | ||
| 356 | // Parse the WifiPacket from the packet | 356 | // Parse the WifiPacket from the packet |
| 357 | u8 frame_type; | 357 | u8 frame_type; |
| 358 | packet >> frame_type; | 358 | packet.Read(frame_type); |
| 359 | WifiPacket::PacketType type = static_cast<WifiPacket::PacketType>(frame_type); | 359 | WifiPacket::PacketType type = static_cast<WifiPacket::PacketType>(frame_type); |
| 360 | 360 | ||
| 361 | wifi_packet.type = type; | 361 | wifi_packet.type = type; |
| 362 | packet >> wifi_packet.channel; | 362 | packet.Read(wifi_packet.channel); |
| 363 | packet >> wifi_packet.transmitter_address; | 363 | packet.Read(wifi_packet.transmitter_address); |
| 364 | packet >> wifi_packet.destination_address; | 364 | packet.Read(wifi_packet.destination_address); |
| 365 | packet >> wifi_packet.data; | 365 | packet.Read(wifi_packet.data); |
| 366 | 366 | ||
| 367 | Invoke<WifiPacket>(wifi_packet); | 367 | Invoke<WifiPacket>(wifi_packet); |
| 368 | } | 368 | } |
| @@ -375,9 +375,9 @@ void RoomMember::RoomMemberImpl::HandleChatPacket(const ENetEvent* event) { | |||
| 375 | packet.IgnoreBytes(sizeof(u8)); | 375 | packet.IgnoreBytes(sizeof(u8)); |
| 376 | 376 | ||
| 377 | ChatEntry chat_entry{}; | 377 | ChatEntry chat_entry{}; |
| 378 | packet >> chat_entry.nickname; | 378 | packet.Read(chat_entry.nickname); |
| 379 | packet >> chat_entry.username; | 379 | packet.Read(chat_entry.username); |
| 380 | packet >> chat_entry.message; | 380 | packet.Read(chat_entry.message); |
| 381 | Invoke<ChatEntry>(chat_entry); | 381 | Invoke<ChatEntry>(chat_entry); |
| 382 | } | 382 | } |
| 383 | 383 | ||
| @@ -390,10 +390,10 @@ void RoomMember::RoomMemberImpl::HandleStatusMessagePacket(const ENetEvent* even | |||
| 390 | 390 | ||
| 391 | StatusMessageEntry status_message_entry{}; | 391 | StatusMessageEntry status_message_entry{}; |
| 392 | u8 type{}; | 392 | u8 type{}; |
| 393 | packet >> type; | 393 | packet.Read(type); |
| 394 | status_message_entry.type = static_cast<StatusMessageTypes>(type); | 394 | status_message_entry.type = static_cast<StatusMessageTypes>(type); |
| 395 | packet >> status_message_entry.nickname; | 395 | packet.Read(status_message_entry.nickname); |
| 396 | packet >> status_message_entry.username; | 396 | packet.Read(status_message_entry.username); |
| 397 | Invoke<StatusMessageEntry>(status_message_entry); | 397 | Invoke<StatusMessageEntry>(status_message_entry); |
| 398 | } | 398 | } |
| 399 | 399 | ||
| @@ -405,8 +405,8 @@ void RoomMember::RoomMemberImpl::HandleModBanListResponsePacket(const ENetEvent* | |||
| 405 | packet.IgnoreBytes(sizeof(u8)); | 405 | packet.IgnoreBytes(sizeof(u8)); |
| 406 | 406 | ||
| 407 | Room::BanList ban_list = {}; | 407 | Room::BanList ban_list = {}; |
| 408 | packet >> ban_list.first; | 408 | packet.Read(ban_list.first); |
| 409 | packet >> ban_list.second; | 409 | packet.Read(ban_list.second); |
| 410 | Invoke<Room::BanList>(ban_list); | 410 | Invoke<Room::BanList>(ban_list); |
| 411 | } | 411 | } |
| 412 | 412 | ||
| @@ -586,19 +586,19 @@ bool RoomMember::IsConnected() const { | |||
| 586 | 586 | ||
| 587 | void RoomMember::SendWifiPacket(const WifiPacket& wifi_packet) { | 587 | void RoomMember::SendWifiPacket(const WifiPacket& wifi_packet) { |
| 588 | Packet packet; | 588 | Packet packet; |
| 589 | packet << static_cast<u8>(IdWifiPacket); | 589 | packet.Write(static_cast<u8>(IdWifiPacket)); |
| 590 | packet << static_cast<u8>(wifi_packet.type); | 590 | packet.Write(static_cast<u8>(wifi_packet.type)); |
| 591 | packet << wifi_packet.channel; | 591 | packet.Write(wifi_packet.channel); |
| 592 | packet << wifi_packet.transmitter_address; | 592 | packet.Write(wifi_packet.transmitter_address); |
| 593 | packet << wifi_packet.destination_address; | 593 | packet.Write(wifi_packet.destination_address); |
| 594 | packet << wifi_packet.data; | 594 | packet.Write(wifi_packet.data); |
| 595 | room_member_impl->Send(std::move(packet)); | 595 | room_member_impl->Send(std::move(packet)); |
| 596 | } | 596 | } |
| 597 | 597 | ||
| 598 | void RoomMember::SendChatMessage(const std::string& message) { | 598 | void RoomMember::SendChatMessage(const std::string& message) { |
| 599 | Packet packet; | 599 | Packet packet; |
| 600 | packet << static_cast<u8>(IdChatMessage); | 600 | packet.Write(static_cast<u8>(IdChatMessage)); |
| 601 | packet << message; | 601 | packet.Write(message); |
| 602 | room_member_impl->Send(std::move(packet)); | 602 | room_member_impl->Send(std::move(packet)); |
| 603 | } | 603 | } |
| 604 | 604 | ||
| @@ -608,9 +608,9 @@ void RoomMember::SendGameInfo(const GameInfo& game_info) { | |||
| 608 | return; | 608 | return; |
| 609 | 609 | ||
| 610 | Packet packet; | 610 | Packet packet; |
| 611 | packet << static_cast<u8>(IdSetGameInfo); | 611 | packet.Write(static_cast<u8>(IdSetGameInfo)); |
| 612 | packet << game_info.name; | 612 | packet.Write(game_info.name); |
| 613 | packet << game_info.id; | 613 | packet.Write(game_info.id); |
| 614 | room_member_impl->Send(std::move(packet)); | 614 | room_member_impl->Send(std::move(packet)); |
| 615 | } | 615 | } |
| 616 | 616 | ||
| @@ -621,8 +621,8 @@ void RoomMember::SendModerationRequest(RoomMessageTypes type, const std::string& | |||
| 621 | return; | 621 | return; |
| 622 | 622 | ||
| 623 | Packet packet; | 623 | Packet packet; |
| 624 | packet << static_cast<u8>(type); | 624 | packet.Write(static_cast<u8>(type)); |
| 625 | packet << nickname; | 625 | packet.Write(nickname); |
| 626 | room_member_impl->Send(std::move(packet)); | 626 | room_member_impl->Send(std::move(packet)); |
| 627 | } | 627 | } |
| 628 | 628 | ||
| @@ -631,7 +631,7 @@ void RoomMember::RequestBanList() { | |||
| 631 | return; | 631 | return; |
| 632 | 632 | ||
| 633 | Packet packet; | 633 | Packet packet; |
| 634 | packet << static_cast<u8>(IdModGetBanList); | 634 | packet.Write(static_cast<u8>(IdModGetBanList)); |
| 635 | room_member_impl->Send(std::move(packet)); | 635 | room_member_impl->Send(std::move(packet)); |
| 636 | } | 636 | } |
| 637 | 637 | ||