Skip to content

Commit 6cc9818

Browse files
hyperpolymathhyperpolymath
committed
chore: M5 CI/Workflow Sweep - final synchronisation
1 parent fd2e497 commit 6cc9818

8 files changed

Lines changed: 50 additions & 50 deletions

File tree

‎examples/basic_usage.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ fn main() {
4040
let query3 = Query::new("What did we discuss about lifetimes?");
4141
match orch.process(query3) {
4242
Ok(response) => {
43-
println!("Project: {}", orch.current_project().unwrap());
43+
println!("Project: {}", orch.current_project().expect("TODO: handle error"));
4444
println!("Response: {}", response.text);
4545
}
4646
Err(e) => println!("Error: {}", e),

‎examples/reservoir_demo.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,9 +73,9 @@ fn main() {
7373

7474
// Example 4: Reset and Restart
7575
println!("\n=== Example 4: Reset Reservoir ===");
76-
println!("State norm before reset: {:.4}", vector_norm(&cm.reservoir_state().unwrap()));
76+
println!("State norm before reset: {:.4}", vector_norm(&cm.reservoir_state().expect("TODO: handle error")));
7777
cm.reset_reservoir();
78-
println!("State norm after reset: {:.4}", vector_norm(&cm.reservoir_state().unwrap()));
78+
println!("State norm after reset: {:.4}", vector_norm(&cm.reservoir_state().expect("TODO: handle error")));
7979

8080
println!("\n✅ Reservoir demo completed!");
8181
}

‎src/context.rs‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,7 @@ mod tests {
247247

248248
let history = cm.project_history("project-1");
249249
assert!(history.is_some());
250-
assert_eq!(history.unwrap().len(), 1);
250+
assert_eq!(history.expect("TODO: handle error").len(), 1);
251251
}
252252

253253
#[test]
@@ -289,8 +289,8 @@ mod tests {
289289
let response = create_test_response("test response");
290290
cm.add_turn(query, response);
291291

292-
let json = cm.to_json().unwrap();
293-
let restored = ContextManager::from_json(&json).unwrap();
292+
let json = cm.to_json().expect("TODO: handle error");
293+
let restored = ContextManager::from_json(&json).expect("TODO: handle error");
294294

295295
assert_eq!(restored.current_project(), cm.current_project());
296296
assert_eq!(restored.conversation_count(), cm.conversation_count());
@@ -333,7 +333,7 @@ mod tests {
333333
// Reservoir state should initially be zeros
334334
let state1 = cm.reservoir_state();
335335
assert!(state1.is_some());
336-
assert_eq!(state1.as_ref().unwrap().len(), 1000);
336+
assert_eq!(state1.as_ref().expect("TODO: handle error").len(), 1000);
337337

338338
// Add a turn - reservoir should update
339339
cm.add_turn(Query::new("Hello world"), create_test_response("Hi"));
@@ -347,7 +347,7 @@ mod tests {
347347
// Snapshot should include reservoir state
348348
let snapshot = cm.snapshot(5);
349349
assert!(snapshot.reservoir_state.is_some());
350-
assert_eq!(snapshot.reservoir_state.unwrap().len(), 1000);
350+
assert_eq!(snapshot.reservoir_state.expect("TODO: handle error").len(), 1000);
351351
}
352352

353353
#[test]
@@ -356,12 +356,12 @@ mod tests {
356356

357357
cm.add_turn(Query::new("test"), create_test_response("response"));
358358

359-
let state = cm.reservoir_state().unwrap();
359+
let state = cm.reservoir_state().expect("TODO: handle error");
360360
assert!(!state.iter().all(|&x| x == 0.0));
361361

362362
cm.reset_reservoir();
363363

364-
let state_after_reset = cm.reservoir_state().unwrap();
364+
let state_after_reset = cm.reservoir_state().expect("TODO: handle error");
365365
assert!(state_after_reset.iter().all(|&x| x == 0.0));
366366
}
367367

‎src/main.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ fn run_interactive() {
9696

9797
loop {
9898
print!("> ");
99-
io::stdout().flush().unwrap();
99+
io::stdout().flush().expect("TODO: handle error");
100100

101101
let mut input = String::new();
102102
if io::stdin().read_line(&mut input).is_err() {

‎src/persistence.rs‎

Lines changed: 34 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -360,14 +360,14 @@ impl ConversationTurn {
360360
fn from_row(row: &rusqlite::Row) -> Self {
361361
use crate::types::{Query, Response, RoutingDecision, ResponseMetadata};
362362

363-
let query_text: String = row.get(0).unwrap();
364-
let query_priority: u8 = row.get(1).unwrap();
365-
let query_timestamp: u64 = row.get(2).unwrap();
363+
let query_text: String = row.get(0).expect("TODO: handle error");
364+
let query_priority: u8 = row.get(1).expect("TODO: handle error");
365+
let query_timestamp: u64 = row.get(2).expect("TODO: handle error");
366366

367-
let response_text: String = row.get(3).unwrap();
368-
let response_route_str: String = row.get(4).unwrap();
369-
let response_confidence: f32 = row.get(5).unwrap();
370-
let latency_ms: i64 = row.get(6).unwrap();
367+
let response_text: String = row.get(3).expect("TODO: handle error");
368+
let response_route_str: String = row.get(4).expect("TODO: handle error");
369+
let response_confidence: f32 = row.get(5).expect("TODO: handle error");
370+
let latency_ms: i64 = row.get(6).expect("TODO: handle error");
371371

372372
// Parse routing decision
373373
let route = match response_route_str.as_str() {
@@ -403,7 +403,7 @@ impl ConversationTurn {
403403
fn current_timestamp() -> u64 {
404404
std::time::SystemTime::now()
405405
.duration_since(std::time::UNIX_EPOCH)
406-
.unwrap()
406+
.expect("TODO: handle error")
407407
.as_secs()
408408
}
409409

@@ -429,13 +429,13 @@ mod tests {
429429

430430
#[test]
431431
fn test_persistence_manager_creation() {
432-
let pm = PersistenceManager::new_in_memory().unwrap();
433-
assert_eq!(pm.conversation_count(None).unwrap(), 0);
432+
let pm = PersistenceManager::new_in_memory().expect("TODO: handle error");
433+
assert_eq!(pm.conversation_count(None).expect("TODO: handle error"), 0);
434434
}
435435

436436
#[test]
437437
fn test_save_and_load_turn() {
438-
let pm = PersistenceManager::new_in_memory().unwrap();
438+
let pm = PersistenceManager::new_in_memory().expect("TODO: handle error");
439439

440440
let query = Query::new("What is Rust?");
441441
let response = Response {
@@ -455,17 +455,17 @@ mod tests {
455455
response: response.clone(),
456456
};
457457

458-
pm.save_turn(None, &turn).unwrap();
458+
pm.save_turn(None, &turn).expect("TODO: handle error");
459459

460-
let history = pm.load_history(None, 10).unwrap();
460+
let history = pm.load_history(None, 10).expect("TODO: handle error");
461461
assert_eq!(history.len(), 1);
462462
assert_eq!(history[0].query.text, query.text);
463463
assert_eq!(history[0].response.text, response.text);
464464
}
465465

466466
#[test]
467467
fn test_project_isolation() {
468-
let pm = PersistenceManager::new_in_memory().unwrap();
468+
let pm = PersistenceManager::new_in_memory().expect("TODO: handle error");
469469

470470
let turn1 = ConversationTurn {
471471
query: Query::new("Project A query"),
@@ -497,11 +497,11 @@ mod tests {
497497
},
498498
};
499499

500-
pm.save_turn(Some("project_a"), &turn1).unwrap();
501-
pm.save_turn(Some("project_b"), &turn2).unwrap();
500+
pm.save_turn(Some("project_a"), &turn1).expect("TODO: handle error");
501+
pm.save_turn(Some("project_b"), &turn2).expect("TODO: handle error");
502502

503-
let history_a = pm.load_history(Some("project_a"), 10).unwrap();
504-
let history_b = pm.load_history(Some("project_b"), 10).unwrap();
503+
let history_a = pm.load_history(Some("project_a"), 10).expect("TODO: handle error");
504+
let history_b = pm.load_history(Some("project_b"), 10).expect("TODO: handle error");
505505

506506
assert_eq!(history_a.len(), 1);
507507
assert_eq!(history_b.len(), 1);
@@ -511,45 +511,45 @@ mod tests {
511511

512512
#[test]
513513
fn test_reservoir_persistence() {
514-
let pm = PersistenceManager::new_in_memory().unwrap();
514+
let pm = PersistenceManager::new_in_memory().expect("TODO: handle error");
515515

516516
let mut esn = EchoStateNetwork::new(384, 1000, 100, 0.7, 0.95);
517517

518518
// Update state to make it non-default
519519
let input = vec![0.5; 384];
520520
esn.update(&input);
521521

522-
pm.save_reservoir_state(Some("test_project"), &esn).unwrap();
522+
pm.save_reservoir_state(Some("test_project"), &esn).expect("TODO: handle error");
523523

524-
let loaded = pm.load_reservoir_state(Some("test_project")).unwrap();
524+
let loaded = pm.load_reservoir_state(Some("test_project")).expect("TODO: handle error");
525525
assert!(loaded.is_some());
526526

527527
// Verify we can use the loaded ESN
528-
let mut loaded_esn = loaded.unwrap();
528+
let mut loaded_esn = loaded.expect("TODO: handle error");
529529
let output = loaded_esn.output();
530530
assert_eq!(output.len(), 100);
531531
}
532532

533533
#[test]
534534
fn test_mlp_persistence() {
535-
let pm = PersistenceManager::new_in_memory().unwrap();
535+
let pm = PersistenceManager::new_in_memory().expect("TODO: handle error");
536536

537537
let mlp = MLP::new(384, vec![100, 50], 3);
538-
pm.save_mlp("router", &mlp, Some(0.85)).unwrap();
538+
pm.save_mlp("router", &mlp, Some(0.85)).expect("TODO: handle error");
539539

540-
let loaded = pm.load_mlp("router").unwrap();
540+
let loaded = pm.load_mlp("router").expect("TODO: handle error");
541541
assert!(loaded.is_some());
542542

543543
// Verify we can use the loaded MLP
544-
let loaded_mlp = loaded.unwrap();
544+
let loaded_mlp = loaded.expect("TODO: handle error");
545545
let input = vec![0.5; 384];
546546
let output = loaded_mlp.forward(&input);
547547
assert_eq!(output.len(), 3);
548548
}
549549

550550
#[test]
551551
fn test_clear_history() {
552-
let pm = PersistenceManager::new_in_memory().unwrap();
552+
let pm = PersistenceManager::new_in_memory().expect("TODO: handle error");
553553

554554
for i in 0..10 {
555555
let turn = ConversationTurn {
@@ -566,18 +566,18 @@ mod tests {
566566
},
567567
},
568568
};
569-
pm.save_turn(None, &turn).unwrap();
569+
pm.save_turn(None, &turn).expect("TODO: handle error");
570570
}
571571

572-
assert_eq!(pm.conversation_count(None).unwrap(), 10);
572+
assert_eq!(pm.conversation_count(None).expect("TODO: handle error"), 10);
573573

574-
pm.clear_history(None).unwrap();
575-
assert_eq!(pm.conversation_count(None).unwrap(), 0);
574+
pm.clear_history(None).expect("TODO: handle error");
575+
assert_eq!(pm.conversation_count(None).expect("TODO: handle error"), 0);
576576
}
577577

578578
#[test]
579579
fn test_history_limit() {
580-
let pm = PersistenceManager::new_in_memory().unwrap();
580+
let pm = PersistenceManager::new_in_memory().expect("TODO: handle error");
581581

582582
let base_timestamp = current_timestamp();
583583
for i in 0..100 {
@@ -599,10 +599,10 @@ mod tests {
599599
},
600600
},
601601
};
602-
pm.save_turn(None, &turn).unwrap();
602+
pm.save_turn(None, &turn).expect("TODO: handle error");
603603
}
604604

605-
let history = pm.load_history(None, 10).unwrap();
605+
let history = pm.load_history(None, 10).expect("TODO: handle error");
606606
assert_eq!(history.len(), 10);
607607

608608
// Should get most recent 10 (90-99) in chronological order (oldest first)

‎src/reservoir.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -379,8 +379,8 @@ mod tests {
379379
let esn = EchoStateNetwork::new(10, 50, 5, 0.7, 0.95);
380380

381381
// Should be serializable
382-
let json = serde_json::to_string(&esn).unwrap();
383-
let deserialized: EchoStateNetwork = serde_json::from_str(&json).unwrap();
382+
let json = serde_json::to_string(&esn).expect("TODO: handle error");
383+
let deserialized: EchoStateNetwork = serde_json::from_str(&json).expect("TODO: handle error");
384384

385385
assert_eq!(esn.reservoir_size, deserialized.reservoir_size);
386386
assert_eq!(esn.state, deserialized.state);

‎src/snn.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -314,7 +314,7 @@ mod tests {
314314
#[test]
315315
fn test_spiking_network_serialization() {
316316
let snn = SpikingNetwork::new(10, 20, 3);
317-
let json = serde_json::to_string(&snn).unwrap();
318-
let _deserialized: SpikingNetwork = serde_json::from_str(&json).unwrap();
317+
let json = serde_json::to_string(&snn).expect("TODO: handle error");
318+
let _deserialized: SpikingNetwork = serde_json::from_str(&json).expect("TODO: handle error");
319319
}
320320
}

‎src/training.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -521,7 +521,7 @@ mod tests {
521521
let mut esn = EchoStateNetwork::new(10, 100, 5, 0.7, 0.95);
522522

523523
let trainer = ReservoirTrainer::new(0.01);
524-
let mse = trainer.train(&mut esn, &inputs, &targets).unwrap();
524+
let mse = trainer.train(&mut esn, &inputs, &targets).expect("TODO: handle error");
525525

526526
// Should learn with reasonable error
527527
assert!(mse < 1.0);

0 commit comments

Comments
 (0)