Adjustable health bar size

Cargo.lock

@@ -1888,6 +1888,7 @@ dependencies = [
  "enum-primitive-derive",
  "flate2",
  "itertools 0.13.0",
+ "lazy_static",
  "local-ip-address",
  "log",
  "memflow",
@@ -1901,6 +1902,7 @@ dependencies = [
  "tokio",
  "tower 0.5.1",
  "tower-http",
+ "uuid",
  "vergen-gitcl",
 ]
 
@@ -2875,6 +2877,15 @@ version = "0.2.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "711b9620af191e0cdc7468a8d14e709c3dcdb115b36f838e601583af800a370a"
 
+[[package]]
+name = "uuid"
+version = "1.12.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b3758f5e68192bb96cc8f9b7e2c2cfdabb435499a28499a42f8f984092adad4b"
+dependencies = [
+ "getrandom",
+]
+
 [[package]]
 name = "vcpkg"
 version = "0.2.15"

Cargo.toml

@@ -41,6 +41,10 @@ itertools = "0.13.0"
 flate2 = "1.0"
 rand = "0.8"
 
+lazy_static = "1.4"
+
+uuid = { version = "1.3", features = ["v4"] }
+
 [build-dependencies]
 reqwest = { version = "0.12.9", features = ["blocking"] }
 serde = { version = "1.0.215", features = ["derive"] }

src/comms.rs

@@ -26,11 +26,14 @@ pub struct PlayerData {
 
     #[serde(rename = "money", default)]
     money: i32,
+
+    #[serde(rename = "health", default)]
+    health: u32,
 }
 
 impl PlayerData {
     pub fn new(pos: Vec3, yaw: f32, player_type: PlayerType, has_bomb: bool, has_awp: bool,
-               is_scoped: bool, player_name: String, weapon_id: i16) -> PlayerData {
+                    is_scoped: bool, player_name: String, weapon_id: i16, money: i32, health: u32) -> PlayerData {
         PlayerData {
             pos,
             yaw,
@@ -40,32 +43,10 @@ impl PlayerData {
             is_scoped,
             player_name,
             weapon_id,
-            money: 0
+            money,
+            health
         }
     }
-
-    pub fn new_with_money(pos: Vec3, yaw: f32, player_type: PlayerType, has_bomb: bool, has_awp: bool,
-                    is_scoped: bool, player_name: String, weapon_id: i16, money: i32) -> PlayerData {
-        PlayerData {
-            pos,
-            yaw,
-            player_type,
-            has_bomb,
-            has_awp,
-            is_scoped,
-            player_name,
-            weapon_id,
-            money
-        }
-    }
-
-    pub fn get_pos(&self) -> &Vec3 {
-        &self.pos
-    }
-
-    pub fn get_player_name(&self) -> &str {
-        &self.player_name
-    }
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -186,10 +167,6 @@ impl RadarData {
     pub fn get_entities(&self) -> &Vec<EntityData> {
         &self.player_data
     }
-
-    pub fn set_entities(&mut self, entities: Vec<EntityData>) {
-        self.player_data = entities;
-    }
 }
 
 unsafe impl Send for RadarData {}

src/dma/context/mod.rs

@@ -117,8 +117,6 @@ impl DmaCtx {
         if money_services_ptr != 0 {
             let money_addr: Address = money_services_ptr.into();
             money = self.process.read(money_addr + cs2dumper::client::CCSPlayerController_InGameMoneyServices::m_iAccount)?;
-
-            log::debug!("Read money value: {} for player", money);
         }
 
         let player_name = if player_name_ptr != 0 {

src/dma/mod.rs

@@ -196,7 +196,7 @@ pub async fn run(radar_data: ArcRwlockRadarData, connector: Connector, pcileech_
 
                 entity_data.push(
                     EntityData::Player(
-                        PlayerData::new_with_money(
+                        PlayerData::new(
                             local_data.pos,
                             local_data.yaw,
                             PlayerType::Local,
@@ -205,11 +205,11 @@ pub async fn run(radar_data: ArcRwlockRadarData, connector: Connector, pcileech_
                             local_data.is_scoped,
                             local_data.player_name,
                             local_data.weapon_id,
-                            local_data.money
+                            local_data.money,
+                            local_data.health
                         )
                     )
                 );
-                log::debug!("Added local player with money: {}", local_data.money);
             }
 
             // Other players
@@ -237,7 +237,7 @@ pub async fn run(radar_data: ArcRwlockRadarData, connector: Connector, pcileech_
 
                         entity_data.push(
                             EntityData::Player(
-                                PlayerData::new_with_money(
+                                PlayerData::new(
                                     player_data.pos,
                                     player_data.yaw,
                                     player_type,
@@ -246,7 +246,8 @@ pub async fn run(radar_data: ArcRwlockRadarData, connector: Connector, pcileech_
                                     player_data.is_scoped,
                                     player_data.player_name,
                                     player_data.weapon_id,
-                                    player_data.money
+                                    player_data.money,
+                                    player_data.health
                                 )
                             )
                         );

src/websocket.rs

@@ -1,4 +1,4 @@
-use std::{sync::Arc, path::PathBuf};
+use std::{sync::Arc, path::PathBuf, collections::HashMap};
 use axum::{
     extract::{ws::{WebSocketUpgrade, WebSocket, Message}, State},
     response::Response,
@@ -7,14 +7,21 @@ use axum::{
 };
 use flate2::{write::GzEncoder, Compression};
 use std::io::Write;
-use tokio::sync::RwLock;
+use tokio::sync::{RwLock, Mutex};
 use tower_http::services::ServeDir;
 
-use crate::comms::RadarData;
+use crate::comms::{RadarData};
+
+struct ClientState {
+    last_entity_count: usize,
+    ping_ms: u32,
+    high_latency: bool,
+}
 
 #[derive(Clone)]
 struct AppState {
-    data_lock: Arc<RwLock<RadarData>>
+    data_lock: Arc<RwLock<RadarData>>,
+    clients: Arc<Mutex<HashMap<String, ClientState>>>,
 }
 
 async fn ws_handler(ws: WebSocketUpgrade, State(state): State<AppState>) -> Response {
@@ -23,25 +30,70 @@ async fn ws_handler(ws: WebSocketUpgrade, State(state): State<AppState>) -> Resp
 }
 
 async fn handle_socket(mut socket: WebSocket, state: AppState) {
+    let client_id = uuid::Uuid::new_v4().to_string();
+
+    {
+        let mut clients = state.clients.lock().await;
+        clients.insert(client_id.clone(), ClientState {
+            last_entity_count: 0,
+            ping_ms: 0,
+            high_latency: false,
+        });
+    }
+
     let mut compression_buffer: Vec<u8> = Vec::with_capacity(65536);
+    let mut frame_counter = 0;
+    let mut skip_frames = false;
 
     while let Some(msg) = socket.recv().await {
         if let Ok(msg) = msg {
             if let Ok(text) = msg.to_text() {
                 if text == "requestInfo" {
-                    let radar_data = state.data_lock.read().await;
+                    frame_counter += 1;
+                    if skip_frames && frame_counter % 2 != 0 {
+                        continue;
+                    }
+
+                    let radar_data = state.data_lock.read().await;
+                    let mut clients = state.clients.lock().await;
+                    let client_state = clients.get_mut(&client_id).unwrap();
+
+                    let entity_count = radar_data.get_entities().len();
+
+                    if entity_count > 5 && !skip_frames && client_state.ping_ms > 100 {
+                        skip_frames = true;
+                        log::info!("Enabling frame skipping for high latency client");
+                    }
+
+                    client_state.last_entity_count = entity_count;
+
+                    let Ok(json) = serde_json::to_string(&*radar_data) else {
+                        continue;
+                    };
 
-                    if let Ok(json) = serde_json::to_string(&*radar_data) {
                     compression_buffer.clear();
 
-                        let mut encoder = GzEncoder::new(Vec::new(), Compression::fast());
+                    let compression_level = if json.len() > 20000 || client_state.high_latency {
+                        Compression::best()
+                    } else if json.len() > 5000 {
+                        Compression::default()
+                    } else {
+                        Compression::fast()
+                    };
+
+                    let mut encoder = GzEncoder::new(Vec::new(), compression_level);
                     if encoder.write_all(json.as_bytes()).is_ok() {
                         match encoder.finish() {
                             Ok(compressed) => {
+                                if compressed.len() < json.len() {
                                     let mut message = vec![0x01];
                                     message.extend_from_slice(&compressed);
-
                                     let _ = socket.send(Message::Binary(message)).await;
+                                } else {
+                                    let mut uncompressed = vec![0x00];
+                                    uncompressed.extend_from_slice(json.as_bytes());
+                                    let _ = socket.send(Message::Binary(uncompressed)).await;
+                                }
                             },
                             Err(_) => {
                                 let mut uncompressed = vec![0x00];
@@ -54,7 +106,6 @@ async fn handle_socket(mut socket: WebSocket, state: AppState) {
                         uncompressed.extend_from_slice(json.as_bytes());
                         let _ = socket.send(Message::Binary(uncompressed)).await;
                     }
-                    }
                 } else if text == "toggleMoneyReveal" {
                     let new_value = {
                         let mut data = state.data_lock.write().await;
@@ -69,19 +120,35 @@ async fn handle_socket(mut socket: WebSocket, state: AppState) {
                     });
 
                     let _ = socket.send(Message::Text(response.to_string())).await;
+                } else if text.starts_with("ping:") {
+                    if let Some(ping_str) = text.strip_prefix("ping:") {
+                        if let Ok(ping_ms) = ping_str.parse::<u32>() {
+                            let mut clients = state.clients.lock().await;
+                            if let Some(client) = clients.get_mut(&client_id) {
+                                client.ping_ms = ping_ms;
+                                client.high_latency = ping_ms > 100;
+                            }
+                        }
+                    }
+                    let _ = socket.send(Message::Text("pong".to_string())).await;
                 }
             }
         } else {
             break;
         }
     }
+    let mut clients = state.clients.lock().await;
+    clients.remove(&client_id);
 }
 
 pub async fn run(path: PathBuf, port: u16, data_lock: Arc<RwLock<RadarData>>) -> anyhow::Result<()> {
     let app = Router::new()
         .nest_service("/", ServeDir::new(path))
         .route("/ws", get(ws_handler))
-        .with_state(AppState { data_lock });
+        .with_state(AppState {
+            data_lock,
+            clients: Arc::new(Mutex::new(HashMap::new()))
+        });
 
     let address = format!("0.0.0.0:{}", port);
     log::info!("Starting WebSocket server on {}", address);

webradar/index.html

@@ -4,7 +4,7 @@
 <head>
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>radarflow</title>
+    <title>radar</title>
     <link href="styles.css" rel="stylesheet" type="text/css" />
     <script src="https://cdnjs.cloudflare.com/ajax/libs/pako/2.1.0/pako.min.js"></script>
 </head>
@@ -39,6 +39,14 @@
                         checked />
                     <label for="moneyDisplay">Display Money</label>
                 </div>
+                <div>
+                    <input type="checkbox" onclick="toggleHealth()" id="healthCheck" name="health" checked />
+                    <label for="healthCheck">Display Health</label>
+                </div>
+                <div>
+                    <input type="checkbox" onclick="toggleOffscreenIndicators()" id="offscreenCheck" name="offscreen" checked />
+                    <label for="offscreenCheck">Off-screen Indicators</label>
+                </div>
                 <div>
                     <input type="checkbox" onclick="toggleRotate()" id="rotateCheck" name="rotate" checked />
                     <label for="rotateCheck">Rotate Map</label>
@@ -46,14 +54,40 @@
                 <div>
                     <input type="checkbox" onclick="toggleCentered()" id="centerCheck" name="center" checked />
                     <label for="centerCheck">Player Centered</label>
+                    <div id="zoomLevelContainer" style="margin-top: 5px; margin-left: 20px; display: none;">
+                        <label for="zoomLevelSlider">Zoom Level: </label>
+                        <span id="zoomLevelValue">1.0</span><br>
+                        <input type="range" id="zoomLevelSlider" min="1.0" max="5.0" step="0.1" value="1.0"
+                            style="width: 100%; margin: 5px 0;" oninput="updateZoomLevel(this.value)">
+                    </div>
                 </div>
-
                 <div class="player-focus">
                     <label for="playerSelect">Focus Player:</label>
                     <select id="playerSelect" onchange="changePlayerFocus()">
                         <option value="local">YOU</option>
                     </select>
                 </div>
+                <div id="sizeControlsContainer"
+                    style="margin-top: 10px; padding: 5px; border-top: 1px solid rgba(255, 255, 255, 0.2);">
+                    <div class="size-control" style="margin-bottom: 8px;">
+                        <label for="textSizeSlider">Text Size: </label>
+                        <span id="textSizeValue">1.0</span><br>
+                        <input type="range" id="textSizeSlider" min="0.1" max="2.0" step="0.1" value="1.0"
+                            style="width: 100%; margin: 5px 0;" oninput="updateTextSize(this.value)">
+                    </div>
+                    <div class="size-control">
+                        <label for="entitySizeSlider">Player Size: </label>
+                        <span id="entitySizeValue">1.0</span><br>
+                        <input type="range" id="entitySizeSlider" min="0.5" max="2.0" step="0.1" value="1.0"
+                            style="width: 100%; margin: 5px 0;" oninput="updateEntitySize(this.value)">
+                    </div>
+                    <div class="size-control" style="margin-top: 8px;">
+                        <label for="healthBarSizeSlider">Health Bar Size: </label>
+                        <span id="healthBarSizeValue">1.0</span><br>
+                        <input type="range" id="healthBarSizeSlider" min="0.5" max="2.5" step="0.1" value="1.0"
+                            style="width: 100%; margin: 5px 0;" oninput="updateHealthBarSize(this.value)">
+                    </div>
+                </div>
                 <button id="showDangerousBtn" onclick="toggleDangerousOptions()">Show Dangerous Options</button>
                 <div class="dangerous-options" id="dangerousOptions">
                     <div>
@@ -68,6 +102,6 @@
     </div>
     <script src="script.js"></script>
     <script src="webstuff.js"></script>
-
 </body>
+
 </html>

webradar/styles.css

@@ -23,6 +23,8 @@ body {
 canvas {
     width: 100%;
     height: 100%;
+    image-rendering: -webkit-optimize-contrast;
+    image-rendering: crisp-edges;
 }
 
 #settingsHolder {
@@ -47,6 +49,25 @@ canvas {
     background-color: rgba(25, 25, 25, 0.7);
     border-radius: 5px;
     transition: opacity 0.3s ease;
+    font-size: 14px;
+    max-height: 90vh;
+    overflow-y: auto;
+}
+
+@media (max-width: 768px) {
+    #settingsHolder .settings {
+        font-size: 16px;
+        padding: 12px;
+    }
+
+    #settingsHolder .settings input[type="checkbox"] {
+        transform: scale(1.2);
+        margin-right: 8px;
+    }
+
+    #settingsHolder .settings>div {
+        padding: 6px 0;
+    }
 }
 
 #settingsHolder:hover .settings {
@@ -92,31 +113,67 @@ canvas {
     background-color: #8a0000;
 }
 
+.size-control {
+    margin-bottom: 10px;
+}
+
+.size-control label {
+    display: inline-block;
+    margin-bottom: 3px;
+}
+
+input[type="range"] {
+    width: 100%;
+    margin: 5px 0;
+    -webkit-appearance: none;
+    height: 6px;
+    background: #555;
+    border-radius: 3px;
+    outline: none;
+}
+
+input[type="range"]::-webkit-slider-thumb {
+    -webkit-appearance: none;
+    appearance: none;
+    width: 16px;
+    height: 16px;
+    border-radius: 50%;
+    background: #68a3e5;
+    cursor: pointer;
+}
+
+input[type="range"]::-moz-range-thumb {
+    width: 16px;
+    height: 16px;
+    border-radius: 50%;
+    background: #68a3e5;
+    cursor: pointer;
+    border: none;
+}
+
 @media (max-width: 600px),
 (max-height: 600px) {
     #settingsHolder {
         display: none;
     }
+
+    #showMenuBtn {
+        display: block !important;
+        font-size: 16px !important;
+        padding: 8px 12px !important;
+    }
 }
 
 @media (max-width: 400px),
 (max-height: 400px) {
     #canvasContainer::before {
-        content: 'settings';
-        position: fixed;
-        top: 10px;
-        left: 10px;
-        background-color: rgba(25, 25, 25, 0.7);
-        color: white;
-        width: 30px;
-        height: 30px;
-        border-radius: 15px;
-        display: flex;
-        align-items: center;
-        justify-content: center;
-        font-size: 16px;
-        cursor: pointer;
-        z-index: 101;
+        content: '';
+        display: none;
+    }
+
+    #showMenuBtn {
+        padding: 6px 10px !important;
+        font-size: 14px !important;
     }
 }
 
@@ -129,6 +186,7 @@ canvas {
     margin-left: 5px;
     cursor: pointer;
     min-width: 150px;
+    font-size: inherit;
 }
 
 #playerSelect:hover {
@@ -147,19 +205,23 @@ canvas {
 
 .player-focus {
     margin-top: 10px;
+    display: flex;
+    align-items: center;
+    flex-wrap: wrap;
 }
 
 #hideMenuBtn {
     background-color: #333;
     color: white;
     border: none;
-    padding: 5px 10px;
+    padding: 8px 10px;
     margin-top: 10px;
     border-radius: 3px;
     cursor: pointer;
     font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
     transition: background-color 0.3s;
     width: 100%;
+    font-size: inherit;
 }
 
 #hideMenuBtn:hover {
@@ -170,19 +232,64 @@ canvas {
     position: fixed;
     top: 10px;
     left: 10px;
-    background-color: rgba(25, 25, 25, 0.7);
+    background-color: rgba(25, 25, 25, 0.9);
     color: white;
     border: none;
-    padding: 5px 10px;
+    padding: 8px 12px;
     border-radius: 15px;
-    font-size: 14px;
+    font-size: 16px;
     cursor: pointer;
     z-index: 101;
     font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
     transition: opacity 0.3s;
-    opacity: 0.6;
+    opacity: 0.8;
+    box-shadow: 0 2px 5px rgba(0, 0, 0, 0.3);
 }
 
 #showMenuBtn:hover {
     opacity: 1;
 }
+
+input[type="checkbox"] {
+    margin-right: 8px;
+}
+
+label {
+    cursor: pointer;
+    user-select: none;
+    margin-bottom: 2px;
+}
+
+.settings>div {
+    margin-bottom: 5px;
+    padding: 3px 0;
+}
+
+.touch-device input[type="checkbox"] {
+    transform: scale(1.3);
+    margin: 2px 10px 2px 2px;
+}
+
+.touch-device input[type="range"]::-webkit-slider-thumb {
+    width: 20px;
+    height: 20px;
+}
+
+.touch-device input[type="range"]::-moz-range-thumb {
+    width: 20px;
+    height: 20px;
+}
+
+.touch-device .settings>div {
+    padding: 6px 0;
+}
+
+@media (prefers-color-scheme: dark) {
+    #settingsHolder .settings {
+        background-color: rgba(15, 15, 15, 0.85);
+    }
+
+    #showMenuBtn {
+        background-color: rgba(15, 15, 15, 0.9);
+    }
+}