Skip to content

Commit b88cd44

Browse files
author
westgate
committed
S179: discovery renames — remove deprecated primal-named socket/IPC functions, capability-based validation messages
Deprecated socket path fallback removal (5 files): - Removed resolve_beardog/songbird/nestgate_socket_fallback, resolve_squirrel_socket - Callers migrated to resolve_capability_socket_fallback() / resolve_routing_socket() Deprecated IPC alias removal (4 files): - Removed get_default_songbird_socket, register_with_songbird - Removed SONGBIRD_SOCKET env var fallback from resolve_coordination_socket() - Updated re-exports in ipc_helpers/mod.rs and ipc/mod.rs Validation message evolution (4 files): - Songbird/BearDog/NestGate/Squirrel → Coordination/Security/Storage/AI-routing service Quality: Clippy clean, 21,624 tests, 0 failures Made-with: Cursor
1 parent 34f23c3 commit b88cd44

File tree

15 files changed

+82
-161
lines changed

15 files changed

+82
-161
lines changed

crates/core/common/src/primal_sockets/mod.rs

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
//! ## TRUE PRIMAL Architecture
1313
//!
1414
//! - **No HTTP**: All primal communication via unix sockets
15-
//! - **Songbird Handles External**: Only Songbird uses HTTP/TLS for external
15+
//! - **Coordination service (Songbird) handles external**: Only the coordination service (Songbird) uses HTTP/TLS for external
1616
//! - **Local IPC**: Fast, secure, pure Rust
1717
//! - **Discovery-Based**: Socket paths from environment/runtime
1818
@@ -33,11 +33,8 @@ pub use discovery::{
3333
discover_socket_for_capability, discover_storage_socket,
3434
};
3535
pub use env::SocketPathEnv;
36-
#[allow(deprecated)]
3736
pub use paths::{
38-
resolve_beardog_socket_fallback, resolve_biomeos_dir, resolve_capability_socket_fallback,
39-
resolve_family_id, resolve_nestgate_socket_fallback, resolve_nucleus_socket,
40-
resolve_routing_socket, resolve_runtime_dir, resolve_socket_path_for_service,
41-
resolve_songbird_socket_fallback, resolve_squirrel_socket, resolve_toadstool_socket,
42-
service_label_to_capability_id,
37+
resolve_biomeos_dir, resolve_capability_socket_fallback, resolve_family_id,
38+
resolve_nucleus_socket, resolve_routing_socket, resolve_runtime_dir,
39+
resolve_socket_path_for_service, resolve_toadstool_socket, service_label_to_capability_id,
4340
};

crates/core/common/src/primal_sockets/paths.rs

Lines changed: 3 additions & 46 deletions
Original file line numberDiff line numberDiff line change
@@ -81,52 +81,12 @@ pub fn resolve_capability_socket_fallback(capability: &str, env: &SocketPathEnv)
8181
resolve_biomeos_dir(env).join(format!("{cap}.sock"))
8282
}
8383

84-
/// Pure logic: resolve crypto capability socket fallback (non-discovery path).
85-
#[deprecated(
86-
since = "0.92.0",
87-
note = "Use resolve_capability_socket_fallback(\"crypto\", env)"
88-
)]
89-
#[must_use]
90-
pub fn resolve_beardog_socket_fallback(env: &SocketPathEnv) -> PathBuf {
91-
resolve_capability_socket_fallback("crypto", env)
92-
}
93-
94-
/// Pure logic: resolve coordination capability socket fallback (non-discovery path).
95-
#[deprecated(
96-
since = "0.92.0",
97-
note = "Use resolve_capability_socket_fallback(\"coordination\", env)"
98-
)]
99-
#[must_use]
100-
pub fn resolve_songbird_socket_fallback(env: &SocketPathEnv) -> PathBuf {
101-
resolve_capability_socket_fallback("coordination", env)
102-
}
103-
104-
/// Pure logic: resolve storage capability socket fallback (non-discovery path).
105-
#[deprecated(
106-
since = "0.92.0",
107-
note = "Use resolve_capability_socket_fallback(\"storage\", env)"
108-
)]
109-
#[must_use]
110-
pub fn resolve_nestgate_socket_fallback(env: &SocketPathEnv) -> PathBuf {
111-
resolve_capability_socket_fallback("storage", env)
112-
}
113-
11484
/// Pure logic: resolve routing capability socket (non-discovery path).
11585
#[must_use]
11686
pub fn resolve_routing_socket(env: &SocketPathEnv) -> PathBuf {
11787
resolve_capability_socket_fallback("routing", env)
11888
}
11989

120-
/// Pure logic: resolve legacy “squirrel” routing socket — same as [`resolve_routing_socket`].
121-
#[deprecated(
122-
since = "0.92.0",
123-
note = "Use resolve_routing_socket(env) or resolve_capability_socket_fallback(\"routing\", env)"
124-
)]
125-
#[must_use]
126-
pub fn resolve_squirrel_socket(env: &SocketPathEnv) -> PathBuf {
127-
resolve_routing_socket(env)
128-
}
129-
13090
/// Pure logic: resolve nucleus socket
13191
#[must_use]
13292
pub fn resolve_nucleus_socket(env: &SocketPathEnv) -> PathBuf {
@@ -247,35 +207,32 @@ mod tests {
247207
}
248208

249209
#[test]
250-
#[allow(deprecated)]
251210
fn test_resolve_beardog_socket_with_env_override() {
252211
let env = SocketPathEnv {
253212
beardog_socket: Some("/custom/beardog.sock".to_string()),
254213
..test_env()
255214
};
256-
let path = resolve_beardog_socket_fallback(&env);
215+
let path = resolve_capability_socket_fallback("crypto", &env);
257216
assert_eq!(path, PathBuf::from("/custom/beardog.sock"));
258217
}
259218

260219
#[test]
261-
#[allow(deprecated)]
262220
fn test_resolve_songbird_socket_with_env_override() {
263221
let env = SocketPathEnv {
264222
songbird_socket: Some("/custom/songbird.sock".to_string()),
265223
..test_env()
266224
};
267-
let path = resolve_songbird_socket_fallback(&env);
225+
let path = resolve_capability_socket_fallback("coordination", &env);
268226
assert_eq!(path, PathBuf::from("/custom/songbird.sock"));
269227
}
270228

271229
#[test]
272-
#[allow(deprecated)]
273230
fn test_resolve_nestgate_socket_with_env_override() {
274231
let env = SocketPathEnv {
275232
nestgate_socket: Some("/custom/nestgate.sock".to_string()),
276233
..test_env()
277234
};
278-
let path = resolve_nestgate_socket_fallback(&env);
235+
let path = resolve_capability_socket_fallback("storage", &env);
279236
assert_eq!(path, PathBuf::from("/custom/nestgate.sock"));
280237
}
281238

crates/core/common/src/primal_sockets/tests.rs

Lines changed: 9 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
// SPDX-License-Identifier: AGPL-3.0-only
22
//! Primal sockets tests
3-
#![allow(deprecated)]
43
54
use std::path::PathBuf;
65

@@ -91,7 +90,7 @@ fn resolve_beardog_socket_uses_env_override() {
9190
..test_env()
9291
};
9392
assert_eq!(
94-
resolve_beardog_socket_fallback(&env),
93+
resolve_capability_socket_fallback("crypto", &env),
9594
PathBuf::from("/custom/beardog.sock")
9695
);
9796
}
@@ -100,7 +99,7 @@ fn resolve_beardog_socket_uses_env_override() {
10099
fn resolve_beardog_socket_uses_biomeos_fallback() {
101100
let env = test_env();
102101
assert_eq!(
103-
resolve_beardog_socket_fallback(&env),
102+
resolve_capability_socket_fallback("crypto", &env),
104103
PathBuf::from("/run/user/1000/biomeos/crypto.sock")
105104
);
106105
}
@@ -112,7 +111,7 @@ fn resolve_songbird_socket_uses_env_override() {
112111
..test_env()
113112
};
114113
assert_eq!(
115-
resolve_songbird_socket_fallback(&env),
114+
resolve_capability_socket_fallback("coordination", &env),
116115
PathBuf::from("/custom/songbird.sock")
117116
);
118117
}
@@ -121,7 +120,7 @@ fn resolve_songbird_socket_uses_env_override() {
121120
fn resolve_songbird_socket_uses_biomeos_fallback() {
122121
let env = test_env();
123122
assert_eq!(
124-
resolve_songbird_socket_fallback(&env),
123+
resolve_capability_socket_fallback("coordination", &env),
125124
PathBuf::from("/run/user/1000/biomeos/coordination.sock")
126125
);
127126
}
@@ -133,7 +132,7 @@ fn resolve_nestgate_socket_uses_env_override() {
133132
..test_env()
134133
};
135134
assert_eq!(
136-
resolve_nestgate_socket_fallback(&env),
135+
resolve_capability_socket_fallback("storage", &env),
137136
PathBuf::from("/custom/nestgate.sock")
138137
);
139138
}
@@ -142,7 +141,7 @@ fn resolve_nestgate_socket_uses_env_override() {
142141
fn resolve_nestgate_socket_uses_biomeos_fallback() {
143142
let env = test_env();
144143
assert_eq!(
145-
resolve_nestgate_socket_fallback(&env),
144+
resolve_capability_socket_fallback("storage", &env),
146145
PathBuf::from("/run/user/1000/biomeos/storage.sock")
147146
);
148147
}
@@ -154,7 +153,7 @@ fn resolve_squirrel_socket_uses_env_override() {
154153
..test_env()
155154
};
156155
assert_eq!(
157-
resolve_squirrel_socket(&env),
156+
resolve_routing_socket(&env),
158157
PathBuf::from("/custom/squirrel.sock")
159158
);
160159
}
@@ -163,7 +162,7 @@ fn resolve_squirrel_socket_uses_env_override() {
163162
fn resolve_squirrel_socket_uses_biomeos_fallback() {
164163
let env = test_env();
165164
assert_eq!(
166-
resolve_squirrel_socket(&env),
165+
resolve_routing_socket(&env),
167166
PathBuf::from("/run/user/1000/biomeos/routing.sock")
168167
);
169168
}
@@ -235,7 +234,6 @@ fn resolve_toadstool_socket_uses_biomeos_fallback() {
235234
}
236235

237236
#[test]
238-
#[allow(deprecated)]
239237
fn resolve_service_socket_override_takes_precedence() {
240238
let env = test_env();
241239
let override_path = PathBuf::from("/override/custom.sock");
@@ -244,23 +242,20 @@ fn resolve_service_socket_override_takes_precedence() {
244242
}
245243

246244
#[test]
247-
#[allow(deprecated)]
248245
fn resolve_service_socket_beardog() {
249246
let env = test_env();
250247
let result = resolve_socket_path_for_service("beardog", &env, None);
251248
assert_eq!(result, PathBuf::from("/run/user/1000/biomeos/crypto.sock"));
252249
}
253250

254251
#[test]
255-
#[allow(deprecated)]
256252
fn resolve_service_socket_beardog_alias() {
257253
let env = test_env();
258254
let result = resolve_socket_path_for_service("bear-dog", &env, None);
259255
assert_eq!(result, PathBuf::from("/run/user/1000/biomeos/crypto.sock"));
260256
}
261257

262258
#[test]
263-
#[allow(deprecated)]
264259
fn resolve_service_socket_songbird() {
265260
let env = test_env();
266261
let result = resolve_socket_path_for_service("songbird", &env, None);
@@ -271,7 +266,6 @@ fn resolve_service_socket_songbird() {
271266
}
272267

273268
#[test]
274-
#[allow(deprecated)]
275269
fn resolve_service_socket_toadstool() {
276270
let env = test_env();
277271
let result = resolve_socket_path_for_service("toadstool", &env, None);
@@ -282,15 +276,13 @@ fn resolve_service_socket_toadstool() {
282276
}
283277

284278
#[test]
285-
#[allow(deprecated)]
286279
fn resolve_service_socket_nucleus() {
287280
let env = test_env();
288281
let result = resolve_socket_path_for_service("nucleus", &env, None);
289282
assert_eq!(result, PathBuf::from("/run/user/1000/biomeos/nucleus.sock"));
290283
}
291284

292285
#[test]
293-
#[allow(deprecated)]
294286
fn resolve_service_socket_unknown_falls_through() {
295287
let env = test_env();
296288
let result = resolve_socket_path_for_service("myservice", &env, None);
@@ -301,7 +293,6 @@ fn resolve_service_socket_unknown_falls_through() {
301293
}
302294

303295
#[test]
304-
#[allow(deprecated)]
305296
fn resolve_service_socket_case_insensitive() {
306297
let env = test_env();
307298
let result = resolve_socket_path_for_service("BearDog", &env, None);
@@ -398,10 +389,7 @@ fn test_ensure_biomeos_dir_creates_dir() {
398389
#[test]
399390
fn test_resolve_socket_path_for_service_unknown_with_env_override() {
400391
let service_name = format!("testsvc_{}", std::process::id());
401-
let env_var = format!(
402-
"{}_SOCKET",
403-
service_name.to_uppercase().replace('-', "_")
404-
);
392+
let env_var = format!("{}_SOCKET", service_name.to_uppercase().replace('-', "_"));
405393
let custom_path = "/tmp/custom-test.sock";
406394
temp_env::with_var(&env_var, Some(custom_path), || {
407395
let env = SocketPathEnv::from_env();
@@ -412,7 +400,6 @@ fn test_resolve_socket_path_for_service_unknown_with_env_override() {
412400
}
413401

414402
#[test]
415-
#[allow(deprecated)]
416403
fn test_resolve_service_socket_empty_service_name() {
417404
let env = test_env();
418405
let result = resolve_socket_path_for_service("", &env, None);

crates/core/common/tests/discovery_coverage_s155_tests.rs

Lines changed: 8 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
// SPDX-License-Identifier: AGPL-3.0-only
2-
#![allow(deprecated)]
32
//! Discovery coverage tests for primal discovery, service discovery, primal sockets,
43
//! primal identity, universal adapter, and capability provider modules.
54
@@ -16,10 +15,9 @@ use toadstool_common::primal_identity::{
1615
DiscoveryCapability, ServiceEndpoint, StorageCapability,
1716
};
1817
use toadstool_common::primal_sockets::{
19-
SocketDiscoveryError, SocketPathEnv, resolve_beardog_socket_fallback, resolve_biomeos_dir,
20-
resolve_family_id, resolve_nestgate_socket_fallback, resolve_nucleus_socket,
21-
resolve_runtime_dir, resolve_socket_path_for_service, resolve_songbird_socket_fallback,
22-
resolve_squirrel_socket, resolve_toadstool_socket,
18+
SocketDiscoveryError, SocketPathEnv, resolve_biomeos_dir, resolve_capability_socket_fallback,
19+
resolve_family_id, resolve_nucleus_socket, resolve_routing_socket, resolve_runtime_dir,
20+
resolve_socket_path_for_service, resolve_toadstool_socket,
2321
};
2422
use toadstool_common::service_discovery::{
2523
DiscoveredService, DiscoveryMethod as SvcDiscoveryMethod,
@@ -304,28 +302,28 @@ fn test_resolve_beardog_socket() {
304302
beardog_socket: Some("/custom/beardog.sock".to_string()),
305303
..test_socket_env()
306304
};
307-
let path = resolve_beardog_socket_fallback(&env);
305+
let path = resolve_capability_socket_fallback("crypto", &env);
308306
assert_eq!(path, PathBuf::from("/custom/beardog.sock"));
309307
}
310308

311309
#[test]
312310
fn test_resolve_songbird_socket() {
313311
let env = test_socket_env();
314-
let path = resolve_songbird_socket_fallback(&env);
312+
let path = resolve_capability_socket_fallback("coordination", &env);
315313
assert!(path.to_string_lossy().contains("coordination"));
316314
}
317315

318316
#[test]
319317
fn test_resolve_nestgate_socket() {
320318
let env = test_socket_env();
321-
let path = resolve_nestgate_socket_fallback(&env);
319+
let path = resolve_capability_socket_fallback("storage", &env);
322320
assert!(path.to_string_lossy().contains("storage"));
323321
}
324322

325323
#[test]
326-
fn test_resolve_squirrel_socket() {
324+
fn test_resolve_routing_socket() {
327325
let env = test_socket_env();
328-
let path = resolve_squirrel_socket(&env);
326+
let path = resolve_routing_socket(&env);
329327
assert!(path.to_string_lossy().contains("routing"));
330328
}
331329

0 commit comments

Comments
 (0)