aboutsummaryrefslogtreecommitdiff
path: root/core/src/pad_data
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/pad_data')
-rw-r--r--core/src/pad_data/game_profile.rs100
-rw-r--r--core/src/pad_data/layout.rs137
-rw-r--r--core/src/pad_data/mod.rs4
-rw-r--r--core/src/pad_data/pad_messages.rs176
-rw-r--r--core/src/pad_data/pad_player_info.rs127
5 files changed, 0 insertions, 544 deletions
diff --git a/core/src/pad_data/game_profile.rs b/core/src/pad_data/game_profile.rs
deleted file mode 100644
index cd2a175..0000000
--- a/core/src/pad_data/game_profile.rs
+++ /dev/null
@@ -1,100 +0,0 @@
-pub mod game_profile {
- use std::fmt::Display;
- use bincode::{Decode, Encode};
- use serde::{Deserialize, Serialize};
-
- #[repr(C)]
- #[derive(Encode, Decode, Serialize, Deserialize, PartialEq, Debug)]
- pub struct GameProfile {
-
- // 游戏名称
- pub game_name: String,
-
- // 游戏描述
- pub game_description: String,
-
- // 游戏组织
- pub organization: String,
-
- // 游戏版本
- pub version: String,
-
- // 工作室 & 游戏 主页
- pub website: String,
-
- // 交流邮箱
- pub email: String
- }
-
- impl Default for GameProfile {
- fn default() -> Self {
- GameProfile {
- game_name: "Unnamed Game".to_string(),
- game_description: "".to_string(),
- organization: "".to_string(),
- version: "0.1".to_string(),
- website: "".to_string(),
- email: "".to_string()
- }
- }
- }
-
- impl Clone for GameProfile {
- fn clone(&self) -> Self {
- GameProfile {
- game_name: self.game_name.clone(),
- game_description: self.game_description.clone(),
- organization: self.organization.clone(),
- version: self.version.clone(),
- website: self.website.clone(),
- email: self.email.clone()
- }
- }
- }
-
- impl Display for GameProfile {
- fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
- let mut string = String::new();
- string += format!("Game Name: {}\n", self.game_name).as_str();
- if !self.game_description.eq("") { string += format!("Description: {}\n", self.game_description).as_str(); }
- if !self.organization.eq("") { string += format!("Org: {}\n", self.organization).as_str(); }
- if !self.website.eq("") { string += format!("- Web: {}\n", self.website).as_str(); }
- if !self.version.eq("") { string += format!("Version: {}\n", self.version).as_str(); }
- if !self.email.eq("") { string += format!("- E-mail: {}\n", self.email).as_str(); }
-
- write!(f, "{}", string)
- }
- }
-
- impl GameProfile {
- pub fn game_name(&mut self, game_name: &str) -> &mut GameProfile {
- self.game_name = game_name.to_string();
- self
- }
-
- pub fn game_description(&mut self, game_description: &str) -> &mut GameProfile {
- self.game_description = game_description.to_string();
- self
- }
-
- pub fn organization(&mut self, organization: &str) -> &mut GameProfile {
- self.organization = organization.to_string();
- self
- }
-
- pub fn version(&mut self, version: &str) -> &mut GameProfile {
- self.version = version.to_string();
- self
- }
-
- pub fn website(&mut self, website: &str) -> &mut GameProfile {
- self.website = website.to_string();
- self
- }
-
- pub fn email(&mut self, email: &str) -> &mut GameProfile {
- self.email = email.to_string();
- self
- }
- }
-} \ No newline at end of file
diff --git a/core/src/pad_data/layout.rs b/core/src/pad_data/layout.rs
deleted file mode 100644
index 4c5f53f..0000000
--- a/core/src/pad_data/layout.rs
+++ /dev/null
@@ -1,137 +0,0 @@
-pub mod layout_data {
- use std::collections::{HashMap, VecDeque};
- use bincode::{Decode, Encode};
- use serde::{Deserialize, Serialize};
- use crate::pad_data::pad_messages::nogamepads_messages::ControlMessage;
- use crate::pad_data::pad_player_info::nogamepads_player_info::PlayerInfo;
- use crate::pad_service::server::nogamepads_server::PadServer;
-
-
- #[derive(Encode, Decode, Serialize, Deserialize, PartialEq, Debug, Clone)]
- pub struct LayoutKeyRegisters {
- pub direction_keys : HashMap<u8, String>, // 注册方向键
- pub axis_keys : HashMap<u8, String>, // 注册轴向键
- pub button_keys : HashMap<u8, String>, // 注册按钮
- }
-
- impl Default for LayoutKeyRegisters {
- fn default() -> LayoutKeyRegisters {
- LayoutKeyRegisters {
- direction_keys: Default::default(),
- axis_keys: Default::default(),
- button_keys: Default::default(),
- }
- }
- }
-
- pub struct LayoutKeyRuntimeData {
- directions : HashMap<u8, HashMap<String, (f64, f64)>>, // <键, <玩家Hash, (x, y)>>
- axes : HashMap<u8, HashMap<String, f64>>, // <键, <玩家Hash, 轴向>>
- button : HashMap<u8, HashMap<String, bool>>, // <键, <玩家Hash, 是否按下>>
-
- events : VecDeque<(String, ControlMessage)>, // (玩家Hash, 信息)
- }
-
- impl Default for LayoutKeyRuntimeData {
- fn default() -> Self {
- LayoutKeyRuntimeData {
- directions: Default::default(),
- axes: Default::default(),
- button: Default::default(),
- events: Default::default(),
- }
- }
- }
-
- impl LayoutKeyRuntimeData {
-
- // 输入控制信息到数据
- pub fn insert_control(&mut self, who: PlayerInfo, msg: ControlMessage) {
- match msg {
- // 消息放入信息队列待读取
- ControlMessage::Msg(_) => {
- self.events.push_back((who.account.player_hash, msg))
- }
-
- // 按钮更新对应玩家的状态，并且放入信息队列待读取
- ControlMessage::Pressed(button_key) => {
- self.button.entry(button_key)
- .or_insert_with(HashMap::new)
- .insert(who.account.player_hash.clone(), true);
- self.events.push_back((who.account.player_hash, msg))
- }
- ControlMessage::Released(button_key) => {
- self.button.entry(button_key)
- .or_insert_with(HashMap::new)
- .insert(who.account.player_hash.clone(), false);
- self.events.push_back((who.account.player_hash, msg))
- }
-
- // 轴向更新直接传入玩家状态
- ControlMessage::Axis(axis_key, axis) => {
- self.axes.entry(axis_key)
- .or_insert_with(HashMap::new)
- .insert(who.account.player_hash.clone(), axis);
- }
- ControlMessage::Dir(dir_key, (x, y)) => {
- self.directions.entry(dir_key)
- .or_insert_with(HashMap::new)
- .insert(who.account.player_hash.clone(), (x, y));
- }
- _ => { }
- }
- }
-
- pub fn pop_control_event(&mut self, server: &PadServer) -> Option<(PlayerInfo, ControlMessage)> {
- let pop = self.events.pop_front();
- if pop.is_some() {
- let (hash, msg) = pop.unwrap();
- let info = server.find_online_player(hash);
- if info.is_some() {
- Some((info.unwrap(), msg))
- } else {
- None
- }
- } else {
- None
- }
- }
-
- pub fn get_direction(&self, who: &PlayerInfo, key: &u8) -> Option<(f64, f64)> {
- Self::get(&self.directions, who, key)
- }
-
- pub fn get_axis(&self, who: &PlayerInfo, key: &u8) -> Option<f64> {
- Self::get(&self.axes, who, key)
- }
-
- pub fn get_button_status(&self, who: &PlayerInfo, key: &u8) -> Option<bool> {
- Self::get(&self.button, who, key)
- }
-
- fn get<V: Clone>(map: &HashMap<u8, HashMap<String, V>>, who: &PlayerInfo, key: &u8) -> Option<V> {
- let key = map.get(key);
- if key.is_some() {
- let value = key.unwrap().get(&who.account.player_hash);
- if value.is_some() {
- let result = value.unwrap();
- Some(result.clone())
- } else { None }
- } else { None }
- }
- }
-}
-
-pub mod layout_gamepad {
- use bincode::{Decode, Encode};
- use serde::{Deserialize, Serialize};
-
- #[derive(Encode, Decode, Serialize, Deserialize, PartialEq, Debug)]
- pub struct PadLayout {
-
- }
-
- pub trait ButtonArea {
-
- }
-} \ No newline at end of file
diff --git a/core/src/pad_data/mod.rs b/core/src/pad_data/mod.rs
deleted file mode 100644
index e041524..0000000
--- a/core/src/pad_data/mod.rs
+++ /dev/null
@@ -1,4 +0,0 @@
-pub mod pad_messages;
-pub mod pad_player_info;
-pub mod game_profile;
-pub mod layout; \ No newline at end of file
diff --git a/core/src/pad_data/pad_messages.rs b/core/src/pad_data/pad_messages.rs
deleted file mode 100644
index f081e5d..0000000
--- a/core/src/pad_data/pad_messages.rs
+++ /dev/null
@@ -1,176 +0,0 @@
-pub mod nogamepads_messages {
- use bincode::{Decode, Encode};
- use crate::pad_data::game_profile::game_profile::GameProfile;
- use crate::pad_data::pad_player_info::nogamepads_player_info::PlayerInfo;
-
- #[derive(Encode, Decode, PartialEq, Debug, Clone)]
- pub enum ControlMessage {
-
- Msg(String),
-
- Pressed(u8),
-
- Released(u8),
-
- Axis(u8, f64),
-
- Dir(u8, (f64, f64)),
-
- Exit,
-
- Err
- }
-
- #[derive(Encode, Decode, PartialEq, Debug, Clone)]
- pub enum GameMessage {
-
- SkinEventTrigger(u8),
-
- DisableKey(u8),
-
- EnableKey(u8),
-
- Leave(LeaveReason),
-
- Err
- }
-
- #[derive(Encode, Decode, PartialEq, Debug, Clone)]
- pub enum LeaveReason {
-
- GameOver,
-
- ServerClosed,
-
- YouAreKicked,
-
- YouAreBanned
- }
-
- #[derive(Encode, Decode, PartialEq, Debug, Clone)]
- pub enum ConnectionMessage {
-
- Connection(PlayerInfo),
-
- RequestProfile,
-
- RequestLayoutConfigure,
-
- RequestSkinPackage,
-
- Ready,
-
- Err
- }
-
- #[derive(Encode, Decode, PartialEq, Debug, Clone)]
- pub enum ConnectionCallbackMessage {
-
- Profile(GameProfile),
-
- Deny(ConnectionErrorType),
-
- Fail(ConnectionErrorType),
-
- Ok,
-
- Welcome,
-
- Err
- }
-
- #[derive(Encode, Decode, PartialEq, Debug, Clone)]
- pub enum ConnectionErrorType {
-
- ContainSamePlayer,
-
- PlayerBanned,
-
- Timeout,
-
- GameLocked,
-
- WhatTheHell
- }
-}
-
-pub mod nogamepads_message_encoder {
- use bincode::{Decode, Encode};
- use crate::{BINCODE_CONFIG, BINCODE_CONVERT_FAILED};
- use crate::pad_data::pad_messages::nogamepads_messages::{ConnectionCallbackMessage, ConnectionMessage, ControlMessage, GameMessage};
-
- pub trait NgpdMessageEncoder<Message: Encode + Decode<()>> {
- fn err_result_decode () -> Message;
- fn err_result_encode () -> Vec<u8> {
- BINCODE_CONVERT_FAILED
- }
-
- fn en(&self) -> Vec<u8> where Self : Encode {
- bincode::encode_to_vec(self, BINCODE_CONFIG)
- .unwrap_or_else(|_| Self::err_result_encode())
- }
-
- fn de(encoded : Vec<u8>) -> Message {
- match bincode::decode_from_slice(&encoded[..], BINCODE_CONFIG) {
- Ok((decoded, _)) => decoded,
- Err(_) => Self::err_result_decode()
- }
- }
- }
-
- impl NgpdMessageEncoder<ControlMessage> for ControlMessage {
- fn err_result_decode() -> ControlMessage {
- ControlMessage::Err
- }
- }
-
- impl NgpdMessageEncoder<GameMessage> for GameMessage {
- fn err_result_decode() -> GameMessage {
- GameMessage::Err
- }
- }
-
- impl NgpdMessageEncoder<ConnectionMessage> for ConnectionMessage {
- fn err_result_decode() -> ConnectionMessage {
- ConnectionMessage::Err
- }
- }
-
- impl NgpdMessageEncoder<ConnectionCallbackMessage> for ConnectionCallbackMessage {
- fn err_result_decode() -> ConnectionCallbackMessage {
- ConnectionCallbackMessage::Err
- }
- }
-}
-
-pub mod nogamepads_message_transfer {
- use bincode::{Decode, Encode};
- use log::error;
- use tokio::io::{AsyncReadExt, AsyncWriteExt};
- use tokio::net::TcpStream;
- use crate::pad_data::pad_messages::nogamepads_message_encoder::NgpdMessageEncoder;
-
- pub async fn send_msg <Message>(stream: &mut TcpStream, msg: impl NgpdMessageEncoder<Message> + Decode<()> + Encode)
- where Message: NgpdMessageEncoder<Message> + Decode<()> + Encode {
- match stream.write_all(NgpdMessageEncoder::en(&msg).as_slice()).await {
- Ok(_) => {}
- Err(_) => {
- error!("Failed to send message.");
- }
- }
- }
-
- pub async fn read_msg<Message>(buffer: &mut [u8], stream: &mut TcpStream) -> Message
- where Message: NgpdMessageEncoder<Message> + Decode<()> + Encode {
- match stream.read(buffer).await {
- Ok(read) => {
- let received = &buffer[..read];
- <Message as NgpdMessageEncoder<Message>>::de(Vec::from(received))
- }
- Err(err) => {
- error!("Error reading from socket: {}", err);
- <Message as NgpdMessageEncoder<Message>>::err_result_decode()
- }
- }
- }
-} \ No newline at end of file
diff --git a/core/src/pad_data/pad_player_info.rs b/core/src/pad_data/pad_player_info.rs
deleted file mode 100644
index 1c8b7e0..0000000
--- a/core/src/pad_data/pad_player_info.rs
+++ /dev/null
@@ -1,127 +0,0 @@
-pub mod nogamepads_player_info {
-
- use bincode::{Decode, Encode};
- use hex::encode;
- use sha1::{Digest, Sha1};
- use serde::{Deserialize, Serialize};
-
- pub const ACCOUNT_HASH_SALT : &str = "Mr.Weicao";
-
- #[repr(C)]
- #[derive(Encode, Decode,
- Serialize, Deserialize,
- PartialEq, Debug)]
- pub struct PlayerInfo {
- pub account: PlayerAccountInfo,
- pub customize: PlayerCustomizeInfo
- }
-
- #[derive(Encode, Decode,
- Serialize, Deserialize,
- PartialEq, Debug)]
- pub struct PlayerAccountInfo {
- pub id: String,
- pub player_hash: String
- }
-
- #[derive(Encode, Decode,
- Serialize, Deserialize,
- PartialEq, Debug)]
- pub struct PlayerCustomizeInfo {
- pub nickname: String,
-
- pub color_hue: i32, // 0 - 360
- pub color_saturation: f64, // 0 - 1
- pub color_value: f64 // 0 - 1
- }
-
- impl PlayerInfo {
-
- pub fn new() -> PlayerInfo {
- PlayerInfo {
- customize: PlayerCustomizeInfo::default(),
- account: PlayerAccountInfo::default()
- }
- }
-
- pub fn set_nickname(&mut self, name: &str) -> &mut PlayerInfo {
- self.customize.nickname = String::from(name);
- self
- }
-
- pub fn set_customize_color_hue(&mut self, mut hue: i32) -> &mut PlayerInfo {
- hue = hue.clamp(0, 360);
- self.customize.color_hue = hue;
- self
- }
-
- pub fn set_customize_color_hsv(&mut self, mut hue: i32, mut saturation: f64, mut value: f64) -> &mut PlayerInfo {
- hue = hue.clamp(0, 360);
- saturation = saturation.clamp(0.0, 1.0);
- value = value.clamp(0.0, 1.0);
-
- self.customize.color_hue = hue;
- self.customize.color_saturation = saturation;
- self.customize.color_value = value;
- self
- }
-
- pub fn setup_account_info(&mut self, id: &str, password: &str) -> &mut PlayerInfo {
-
- let combined = format!("{}{}{}", id, password, ACCOUNT_HASH_SALT);
- let mut hasher = Sha1::new();
- hasher.update(combined);
- let result = hasher.finalize();
-
- self.account.id = String::from(id);
- self.account.player_hash = encode(&result[..]);
- self
- }
- }
-
- impl Clone for PlayerInfo {
- fn clone(&self) -> PlayerInfo {
- PlayerInfo {
- account: PlayerAccountInfo {
- id: String::from(self.account.id.clone()),
- player_hash: String::from(self.account.player_hash.clone())
- },
- customize: PlayerCustomizeInfo {
- nickname: self.customize.nickname.clone(),
- color_hue: self.customize.color_hue.clone(),
- color_saturation: self.customize.color_saturation.clone(),
- color_value: self.customize.color_value.clone()
- }
- }
- }
- }
-
- impl Default for PlayerCustomizeInfo {
- fn default() -> Self {
- PlayerCustomizeInfo {
- nickname: String::from("unnamed"),
-
- color_hue: 120,
- color_saturation: 1.0,
- color_value: 1.0
- }
- }
- }
-
- impl Default for PlayerAccountInfo {
- fn default() -> Self {
- PlayerAccountInfo {
- id: String::from("empty"),
- player_hash: String::from("")
- }
- }
- }
-}
-
-#[cfg(test)]
-mod player_info_test {
- #[test]
- fn test_player_info_setup() {
-
- }
-} \ No newline at end of file
generated by cgit (git 2.34.1) at 2026-08-15 16:56:28 +0000