Hare/yoi
1
1
Fork 0
Code Actions Packages Releases Activity

style: format merged workspace server changes

Browse Source
This commit is contained in:
Hare
2026-09-29 13:02:16 +09:00
parent 0440e64975
commit 4ab2a2b88a
1 changed files with 6 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/workspace-server/src/server.rs
+6 -15
View File
@@ -119,13 +119,13 @@ use workdir::workspace::{
WorkspaceWorkdirSessionOperationRequest, WorkspaceWorkdirSessionOperationRequest,
}; };
use workdir::{CommandHandle, WorkdirSessionHandle}; use workdir::{CommandHandle, WorkdirSessionHandle};
#[cfg(test)]
use worker_runtime::catalog::WorkingDirectoryAttachmentStatus;
use worker_runtime::http_server::{ use worker_runtime::http_server::{
RUNTIME_HTTP_PROTOCOL_MAX_VERSION, RUNTIME_HTTP_PROTOCOL_MIN_VERSION, RUNTIME_HTTP_PROTOCOL_MAX_VERSION, RUNTIME_HTTP_PROTOCOL_MIN_VERSION,
RUNTIME_HTTP_PROTOCOL_VERSION, RUNTIME_HTTP_PROTOCOL_VERSION,
}; };
#[cfg(test)] #[cfg(test)]
use worker_runtime::catalog::WorkingDirectoryAttachmentStatus;
#[cfg(test)]
use worker_runtime::resource::BackendResourceError; use worker_runtime::resource::BackendResourceError;
use worker_runtime::resource::BackendResourceFetchRequest; use worker_runtime::resource::BackendResourceFetchRequest;
use worker_runtime::worker_backend::{ProfileRuntimeWorkerFactory, WorkerRuntimeExecutionBackend}; use worker_runtime::worker_backend::{ProfileRuntimeWorkerFactory, WorkerRuntimeExecutionBackend};
@@ -22519,13 +22519,8 @@ async fn get_runtime_worker(
.store .store
.list_workdir_registry(&api.config.workspace_id, 500)?; .list_workdir_registry(&api.config.workspace_id, 500)?;
let updated_at = record.updated_at.clone(); let updated_at = record.updated_at.clone();
let worker = project_worker_registry_projection( let worker =
&api, project_worker_registry_projection(&api, Some(&worker), &record, links, &workdirs)?;
Some(&worker),
&record,
links,
&workdirs,
)?;
Ok(Json(server_api::RuntimeWorkerShowResponse { Ok(Json(server_api::RuntimeWorkerShowResponse {
worker, worker,
updated_at, updated_at,
@@ -29729,8 +29724,7 @@ mod tests {
.unwrap(), .unwrap(),
runtime_id: Some(EMBEDDED_WORKER_RUNTIME_ID.to_string()), runtime_id: Some(EMBEDDED_WORKER_RUNTIME_ID.to_string()),
resource_key: None, resource_key: None,
availability: availability: protocol::subscription::SubscriptionWorkerAvailability::Observed,
protocol::subscription::SubscriptionWorkerAvailability::Observed,
subject_revision: 1, subject_revision: 1,
worker_state: None, worker_state: None,
state: protocol::subscription::SubscriptionWorkerState::Paused, state: protocol::subscription::SubscriptionWorkerState::Paused,
@@ -43454,10 +43448,7 @@ mod tests {
selector: selector:
protocol::subscription::EventSubscriptionSelector::WorkerProtocol { .. }, protocol::subscription::EventSubscriptionSelector::WorkerProtocol { .. },
snapshot: snapshot:
protocol::subscription::SubscriptionSnapshot::WorkerProtocol { protocol::subscription::SubscriptionSnapshot::WorkerProtocol { events, .. },
events,
..
},
.. ..
}, },
) = frame.payload ) = frame.payload