lda/wakey
1
0
Fork 0
Code Issues 5 Pull Requests Actions Packages Projects Releases 18 Wiki Activity

fix per code review

Browse Source
This commit is contained in:
lda
2026-07-16 22:58:00 +07:00 Verified
parent 6f7363dc0f
commit 2ab320ff17
6 changed files with 93 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files
wakey-control-plane/src/api/terminals.rs
+15 -15
View File
@@ -153,7 +153,7 @@ pub async fn get_terminal(
State(state): State<AppState>,
Path(terminal_id): Path<String>,
) -> Result<Json<TerminalSessionResponse>, ApiError> {
let (agent_id, created_at_unix, agent_attached, operator_attached, expires_at_unix) = state
let summary = state
.terminals
.summary(&terminal_id)
.await
@@ -161,11 +161,11 @@ pub async fn get_terminal(
Ok(Json(TerminalSessionResponse {
websocket_url: operator_ws_path(&terminal_id),
terminal_id,
agent_id,
created_at_unix,
expires_at_unix,
agent_attached,
operator_attached,
agent_id: summary.agent_id,
created_at_unix: summary.created_at_unix,
expires_at_unix: summary.expires_at_unix,
agent_attached: summary.agent_attached,
operator_attached: summary.operator_attached,
attachment_token: None,
}))
}
@@ -192,7 +192,7 @@ pub async fn attach_terminal(
.issue_attachment_token_for_operator(&terminal_id, &request.operator_id)
.await
.map_err(registry_error)?;
let (agent_id, created_at_unix, agent_attached, operator_attached, expires_at_unix) = state
let summary = state
.terminals
.summary(&terminal_id)
.await
@@ -200,11 +200,11 @@ pub async fn attach_terminal(
Ok(Json(TerminalSessionResponse {
websocket_url: operator_ws_path(&terminal_id),
terminal_id,
agent_id,
created_at_unix,
expires_at_unix,
agent_attached,
operator_attached,
agent_id: summary.agent_id,
created_at_unix: summary.created_at_unix,
expires_at_unix: summary.expires_at_unix,
agent_attached: summary.agent_attached,
operator_attached: summary.operator_attached,
attachment_token: Some(attachment_token),
}))
}
@@ -365,10 +365,10 @@ async fn handle_operator_terminal_socket(
warn!(terminal_id, code, "failed to request terminal snapshot");
}
let summary = state.terminals.summary(&terminal_id).await;
if let Some((agent_id, _, _, _, _)) = &summary {
if let Some(summary) = &summary {
append_terminal_audit(
&state,
agent_id,
&summary.agent_id,
&terminal_id,
TerminalAudit {
actor_type: "admin_api",
@@ -382,7 +382,7 @@ async fn handle_operator_terminal_socket(
}
let (mut write, mut read) = socket.split();
if summary.is_some_and(|(_, _, agent_attached, _, _)| agent_attached) {
if summary.is_some_and(|summary| summary.agent_attached) {
let ready = serde_json::to_string(&TerminalControl::Ready)
.expect("terminal ready control serializes");
if send_relay_frame(&mut write, TerminalRelayFrame::Text(ready))
wakey-control-plane/src/runtime/terminals.rs
+50 -31
View File
@@ -448,21 +448,12 @@ impl TerminalRegistry {
Some(detached_at)
}
pub async fn summary(
&self,
terminal_id: &str,
) -> Option<(String, u64, bool, bool, Option<u64>)> {
pub async fn summary(&self, terminal_id: &str) -> Option<TerminalSummary> {
let mut sessions = self.inner.lock().await;
prune_expired_sessions(&mut sessions);
sessions.get(terminal_id).map(|session| {
(
session.agent_id.clone(),
session.created_at_unix,
session.agent_tx.is_some(),
session.operator_tx.is_some(),
session.expiry.unix(),
)
})
sessions
.get(terminal_id)
.map(|session| terminal_summary(terminal_id, session))
}
pub async fn summaries(&self) -> Vec<TerminalSummary> {
@@ -470,20 +461,24 @@ impl TerminalRegistry {
prune_expired_sessions(&mut sessions);
let mut summaries = sessions
.iter()
.map(|(terminal_id, session)| TerminalSummary {
terminal_id: terminal_id.clone(),
agent_id: session.agent_id.clone(),
created_at_unix: session.created_at_unix,
expires_at_unix: session.expiry.unix(),
agent_attached: session.agent_tx.is_some(),
operator_attached: session.operator_tx.is_some(),
})
.map(|(terminal_id, session)| terminal_summary(terminal_id, session))
.collect::<Vec<_>>();
summaries.sort_by_key(|session| std::cmp::Reverse(session.created_at_unix));
summaries
}
}
fn terminal_summary(terminal_id: &str, session: &TerminalSession) -> TerminalSummary {
TerminalSummary {
terminal_id: terminal_id.to_string(),
agent_id: session.agent_id.clone(),
created_at_unix: session.created_at_unix,
expires_at_unix: session.expiry.unix(),
agent_attached: session.agent_tx.is_some(),
operator_attached: session.operator_tx.is_some(),
}
}
fn active_session<'a>(
sessions: &'a mut HashMap<String, TerminalSession>,
terminal_id: &str,
@@ -739,7 +734,7 @@ mod tests {
.summary(&unlimited.terminal_id)
.await
.expect("unlimited summary")
.4,
.expires_at_unix,
None
);
}
@@ -763,7 +758,7 @@ mod tests {
.summary(terminal_id.as_str())
.await
.expect("adopted unlimited session")
.4,
.expires_at_unix,
None
);
}
@@ -805,9 +800,9 @@ mod tests {
.summary(terminal_id.as_str())
.await
.expect("adopted summary");
assert_eq!(summary.0, "router");
assert_eq!(summary.1, created_at_unix);
assert!(summary.2);
assert_eq!(summary.agent_id, "router");
assert_eq!(summary.created_at_unix, created_at_unix);
assert!(summary.agent_attached);
}
#[tokio::test]
@@ -869,7 +864,7 @@ mod tests {
.summary(&created.terminal_id)
.await
.expect("session remains after detach");
assert!(!summary.3);
assert!(!summary.operator_attached);
registry
.issue_attachment_token_for_operator(&created.terminal_id, OPERATOR_A)
.await
@@ -895,7 +890,13 @@ mod tests {
.await
.expect("handoff token");
assert!(!registry.summary(&previous.terminal_id).await.unwrap().3);
assert!(
!registry
.summary(&previous.terminal_id)
.await
.unwrap()
.operator_attached
);
registry
.attach_operator(&next.terminal_id, &next_token, OPERATOR_A)
.await
@@ -930,8 +931,20 @@ mod tests {
.expect_err("occupied target remains protected");
assert_eq!(error, "terminal_operator_already_attached");
assert!(registry.summary(&previous.terminal_id).await.unwrap().3);
assert!(registry.summary(&occupied.terminal_id).await.unwrap().3);
assert!(
registry
.summary(&previous.terminal_id)
.await
.unwrap()
.operator_attached
);
assert!(
registry
.summary(&occupied.terminal_id)
.await
.unwrap()
.operator_attached
);
}
#[tokio::test]
@@ -959,7 +972,13 @@ mod tests {
.await
.is_none()
);
assert!(registry.summary(&created.terminal_id).await.unwrap().3);
assert!(
registry
.summary(&created.terminal_id)
.await
.unwrap()
.operator_attached
);
}
#[tokio::test]
wakey-control-plane/src/ws.rs
+3 -9
View File
@@ -4,14 +4,14 @@ use axum::extract::ws::{Message, WebSocket, WebSocketUpgrade};
use axum::response::IntoResponse;
use futures_util::{SinkExt, StreamExt};
use serde::Deserialize;
use std::time::{Duration, Instant};
use std::time::Instant;
use tokio::sync::mpsc;
use tracing::{debug, info, info_span, warn};
use uuid::Uuid;
use wakey_agent::protocol::{
AgentCapability, AgentCapabilityOptions, AgentTerminalSession, DEFAULT_TERMINAL_MAX_SESSIONS,
DEFAULT_TERMINAL_SESSION_TTL_SECONDS, ErrorPayload, RequestId, ServerMessage,
TerminalCapabilityOptions, TerminalControl, TerminalId,
TerminalCapabilityOptions, TerminalControl, TerminalId, checked_terminal_session_ttl,
};
use wakey_core::Device;
@@ -225,13 +225,7 @@ async fn process_agent_text(
.as_ref()
.map(|terminal| terminal.session_ttl_seconds)
.unwrap_or(DEFAULT_TERMINAL_SESSION_TTL_SECONDS);
if session_ttl_seconds != 0
&& Instant::now()
.checked_add(Duration::from_secs(session_ttl_seconds))
.is_none()
{
anyhow::bail!("terminal session TTL is too large for the platform timer");
}
checked_terminal_session_ttl(session_ttl_seconds).map_err(anyhow::Error::msg)?;
Some(TerminalCapabilityOptions {
max_sessions,
session_ttl_seconds,