bstein/lesavka
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

everything works?

Browse Source
This commit is contained in:
Brad Stein 2025-07-01 19:42:34 -05:00
parent 8bf356225a
commit b6587fd860
7 changed files with 17 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
client/src/app.rs
View File

@ -169,7 +169,7 @@ impl LesavkaClientApp {
if let Err(e) = msg { warn!("⌨️ server err: {e}"); break; } if let Err(e) = msg { warn!("⌨️ server err: {e}"); break; }
} }
} }
Err(e) => warn!("⌨️ connect failed: {e}"), Err(e) => warn!("❌⌨️ connect failed: {e}"),
} }
tokio::time::sleep(Duration::from_secs(1)).await; // retry tokio::time::sleep(Duration::from_secs(1)).await; // retry
} }
@ -190,7 +190,7 @@ impl LesavkaClientApp {
if let Err(e) = msg { warn!("🖱️ server err: {e}"); break; } if let Err(e) = msg { warn!("🖱️ server err: {e}"); break; }
} }
} }
Err(e) => warn!("🖱️ connect failed: {e}"), Err(e) => warn!("❌🖱️ connect failed: {e}"),
} }
tokio::time::sleep(Duration::from_secs(1)).await; tokio::time::sleep(Duration::from_secs(1)).await;
} }
@ -247,7 +247,7 @@ impl LesavkaClientApp {
if let Ok(pkt) = res { out.push(pkt); } if let Ok(pkt) = res { out.push(pkt); }
} }
} }
Err(e) => tracing::warn!("audio stream err: {e}"), Err(e) => tracing::warn!("❌🔊 audio stream err: {e}"),
} }
tokio::time::sleep(Duration::from_secs(1)).await; tokio::time::sleep(Duration::from_secs(1)).await;
} }
@ -281,7 +281,7 @@ impl LesavkaClientApp {
// Drain and ignore Empty replies // Drain and ignore Empty replies
while resp.get_mut().message().await.transpose().is_some() {} while resp.get_mut().message().await.transpose().is_some() {}
} }
Err(e) => warn!("🎤 connect failed: {e}"), Err(e) => warn!("❌🎤 connect failed: {e}"),
} }
let _ = stop_tx.send(()); let _ = stop_tx.send(());
tokio::time::sleep(Duration::from_secs(1)).await; tokio::time::sleep(Duration::from_secs(1)).await;

4
client/src/input/keyboard.rs
View File

@ -40,11 +40,11 @@ impl KeyboardAggregator {
let events: Vec<InputEvent> = match self.dev.fetch_events() { let events: Vec<InputEvent> = match self.dev.fetch_events() {
Ok(it) => it.collect(), Ok(it) => it.collect(),
Err(e) if e.kind() == std::io::ErrorKind::WouldBlock => return, Err(e) if e.kind() == std::io::ErrorKind::WouldBlock => return,
Err(e) => { if self.dev_mode { error!("read error: {e}"); } return } Err(e) => { if self.dev_mode { error!("⌨️❌ read error: {e}"); } return }
}; };
if self.dev_mode && !events.is_empty() { if self.dev_mode && !events.is_empty() {
trace!("{} kbd evts from {}", events.len(), self.dev.name().unwrap_or("?")); trace!("⌨️ {} kbd evts from {}", events.len(), self.dev.name().unwrap_or("?"));
} }
for ev in events { for ev in events {

6
client/src/input/mouse.rs
View File

@ -41,7 +41,7 @@ impl MouseAggregator {
let evts: Vec<InputEvent> = match self.dev.fetch_events() { let evts: Vec<InputEvent> = match self.dev.fetch_events() {
Ok(it) => it.collect(), Ok(it) => it.collect(),
Err(e) if e.kind() == std::io::ErrorKind::WouldBlock => return, Err(e) if e.kind() == std::io::ErrorKind::WouldBlock => return,
Err(e) => { if self.dev_mode { error!("mouse read err: {e}"); } return } Err(e) => { if self.dev_mode { error!("🖱️❌ mouse read err: {e}"); } return }
}; };
if self.dev_mode && !evts.is_empty() { if self.dev_mode && !evts.is_empty() {
@ -86,9 +86,9 @@ impl MouseAggregator {
if let Err(broadcast::error::SendError(_)) = if let Err(broadcast::error::SendError(_)) =
self.tx.send(MouseReport { data: pkt.to_vec() }) self.tx.send(MouseReport { data: pkt.to_vec() })
{ {
if self.dev_mode { warn!("❌ no HID receiver (mouse)"); } if self.dev_mode { warn!("❌🖱️ no HID receiver (mouse)"); }
} else if self.dev_mode { } else if self.dev_mode {
debug!("📤 mouse {:?}", pkt); debug!("📤🖱️ mouse {:?}", pkt);
} }
} }

2
scripts/install/server.sh
View File

@ -122,7 +122,7 @@ After=network.target lesavka-core.service
[Service] [Service]
ExecStart=/usr/local/bin/lesavka-server ExecStart=/usr/local/bin/lesavka-server
Restart=always Restart=always
Environment=RUST_LOG=lesavka_server=trace,lesavka_server::audio=trace,lesavka_server::video=info,lesavka_server::gadget=trace Environment=RUST_LOG=lesavka_server=info,lesavka_server::audio=info,lesavka_server::video=info,lesavka_server::gadget=info
Environment=RUST_BACKTRACE=1 Environment=RUST_BACKTRACE=1
Environment=GST_DEBUG="*:2,alsasink:6,alsasrc:6" Environment=GST_DEBUG="*:2,alsasink:6,alsasrc:6"
Restart=always Restart=always

0
scripts/manual/audio-clip-fetch.sh Normal file → Executable file
View File

4
scripts/manual/audio-mic-fetch.sh Normal file → Executable file
View File

@ -4,9 +4,9 @@
PI_HOST="nikto@192.168.42.253" # adjust if needed PI_HOST="nikto@192.168.42.253" # adjust if needed
REMOTE_DIR="/tmp" REMOTE_DIR="/tmp"
TMPDIR=$(mktemp -d) TMPDIR=$(mktemp -d)
scp -q "${PI_HOST}:${REMOTE_DIR}/mic-*.aac" "$TMPDIR/" 2>/dev/null \ scp -q "${PI_HOST}:${REMOTE_DIR}/voice-*.aac" "$TMPDIR/" 2>/dev/null \
|| { echo "❌ no mic clip files found yet"; exit 1; } || { echo "❌ no mic clip files found yet"; exit 1; }
LATEST=$(ls -1t "$TMPDIR"/mic-*.aac | head -n1) LATEST=$(ls -1t "$TMPDIR"/voice-*.aac | head -n1)
echo "🎤 playing $(basename "$LATEST") ..." echo "🎤 playing $(basename "$LATEST") ..."
gst-play-1.0 --quiet "$LATEST" gst-play-1.0 --quiet "$LATEST"

5
scripts/manual/vpn-open.sh
View File

@ -1,4 +1,7 @@
#!/usr/bin/env bash #!/usr/bin/env bash
# scripts/manual/vpn-open.sh # scripts/manual/vpn-open.sh
sudo openvpn --config ~/cyberghost/openvpn.ovpn here=$(pwd)
cd /home/brad/cyberghost
sudo openvpn --config openvpn.ovpn
cd $here