BloopAI/dev-manager-mcp
1
0
Fork 0
mirror of https://github.com/BloopAI/dev-manager-mcp.git synced 2026-08-23 11:58:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

PORT env

Browse Source
This commit is contained in:
Louis Knight-Webb
2025-10-30 17:34:00 +00:00
parent b93283b0f0
commit 3ca5218538
1 changed files with 21 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/manager.rs
View File

@@ -171,6 +171,8 @@ impl Manager {
cmd.current_dir(path);
}
cmd.env("PORT", port.to_string());
let child = match cmd.spawn() {
Ok(c) => c,
Err(e) => {
@@ -181,7 +183,7 @@ impl Manager {
};
let entry = ServerEntry::new(child, port);
{
let mut guard = match self.inner.lock() {
Ok(g) => g,
@@ -216,15 +218,15 @@ impl Manager {
match entry.stop().await {
Ok(_) => {
entry.port = 0;
let mut guard = match self.inner.lock() {
Ok(g) => g,
Err(e) => return json!({"error": format!("Lock error: {}", e)}),
};
guard.port_allocator.free(port);
guard.servers.insert(session_key.clone(), entry);
json!({"status": "stopped", "session_key": session_key})
}
Err(e) => json!({"error": format!("Failed to stop server: {}", e)}),
@@ -253,17 +255,21 @@ impl Manager {
}
}
let sessions: Vec<_> = guard.servers.iter_mut().map(|(key, entry)| {
entry.last_activity = Instant::now();
let mut result = json!({
"session_key": key,
"running": entry.is_running()
});
if entry.port != 0 {
result["port"] = json!(entry.port);
}
result
}).collect();
let sessions: Vec<_> = guard
.servers
.iter_mut()
.map(|(key, entry)| {
entry.last_activity = Instant::now();
let mut result = json!({
"session_key": key,
"running": entry.is_running()
});
if entry.port != 0 {
result["port"] = json!(entry.port);
}
result
})
.collect();
json!({"sessions": sessions})
}