Skip to content

Commit 3ff8203

Browse files
hyperpolymathhyperpolymath
committed
chore: M5 CI/Workflow Sweep - final synchronisation
1 parent 8e8ed20 commit 3ff8203

5 files changed

Lines changed: 38 additions & 38 deletions

File tree

‎src/abi/mod.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,7 @@ impl AuditTrail {
203203
self.entries.drain(0..excess);
204204
}
205205

206-
self.entries.last().unwrap()
206+
self.entries.last().expect("TODO: handle error")
207207
}
208208

209209
/// Verify the integrity of the entire hash chain. Returns the index of
@@ -590,12 +590,12 @@ mod tests {
590590
});
591591
assert_eq!(stack.undo_depth(), 2);
592592

593-
let undone = stack.undo().unwrap();
593+
let undone = stack.undo().expect("TODO: handle error");
594594
assert_eq!(undone.operation_name, "op2");
595595
assert_eq!(stack.undo_depth(), 1);
596596
assert_eq!(stack.redo_depth(), 1);
597597

598-
let redone = stack.redo().unwrap();
598+
let redone = stack.redo().expect("TODO: handle error");
599599
assert_eq!(redone.operation_name, "op2");
600600
assert_eq!(stack.undo_depth(), 2);
601601
assert_eq!(stack.redo_depth(), 0);
@@ -614,7 +614,7 @@ mod tests {
614614
});
615615
}
616616
assert_eq!(stack.undo_depth(), 2);
617-
let entry = stack.undo().unwrap();
617+
let entry = stack.undo().expect("TODO: handle error");
618618
assert_eq!(entry.operation_name, "op4");
619619
}
620620

‎src/codegen/audit_gen.rs‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ impl AuditTrail {{
145145
self.entries.drain(0..excess);
146146
}}
147147
148-
self.entries.last().unwrap()
148+
self.entries.last().expect("TODO: handle error")
149149
}}
150150
151151
/// Verify the integrity of the entire hash chain.
@@ -354,14 +354,14 @@ max-entries = 500
354354
[undo]
355355
max-depth = 20
356356
"#;
357-
let m = manifest::parse_manifest(toml).unwrap();
358-
parser::parse_manifest(&m).unwrap()
357+
let m = manifest::parse_manifest(toml).expect("TODO: handle error");
358+
parser::parse_manifest(&m).expect("TODO: handle error")
359359
}
360360

361361
#[test]
362362
fn test_generate_audit_module_file_storage() {
363363
let parsed = test_parsed();
364-
let audit = generate_audit_module(&parsed).unwrap();
364+
let audit = generate_audit_module(&parsed).expect("TODO: handle error");
365365
assert_eq!(audit.storage_backend, "file");
366366
assert!(audit.hash_chain_enabled);
367367
assert!(
@@ -386,9 +386,9 @@ name = "mem-test"
386386
[audit]
387387
storage = "memory"
388388
"#;
389-
let m = manifest::parse_manifest(toml).unwrap();
390-
let parsed = parser::parse_manifest(&m).unwrap();
391-
let audit = generate_audit_module(&parsed).unwrap();
389+
let m = manifest::parse_manifest(toml).expect("TODO: handle error");
390+
let parsed = parser::parse_manifest(&m).expect("TODO: handle error");
391+
let audit = generate_audit_module(&parsed).expect("TODO: handle error");
392392
assert_eq!(audit.storage_backend, "memory");
393393
assert!(audit.module_code.contains("No-op save"));
394394
}

‎src/codegen/inverse_gen.rs‎

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ pub fn {inverse_fn}({params}) -> Result<InverseResult, OblibeniserError> {{
7979
let result = {forward_fn}_mirror_undo({param_csv})?;
8080
8181
// Log the inverse execution to the audit trail.
82-
AUDIT_TRAIL.lock().unwrap().record(
82+
AUDIT_TRAIL.lock().expect("TODO: handle error").record(
8383
"{inverse_fn}",
8484
&hash_params(&[{param_refs}]),
8585
);
@@ -135,7 +135,7 @@ pub fn {inverse_fn}({params}, mutation_log: &MutationLog) -> Result<InverseResul
135135
}}
136136
137137
// Record the replay in the audit trail.
138-
AUDIT_TRAIL.lock().unwrap().record(
138+
AUDIT_TRAIL.lock().expect("TODO: handle error").record(
139139
"{inverse_fn}",
140140
&hash_params(&[{param_refs}]),
141141
);
@@ -160,10 +160,10 @@ pub fn {op_name}_logged({params}) -> Result<MutationLog, OblibeniserError> {{
160160
{forward_fn}_with_log({param_csv}, &mut log)?;
161161
162162
// Store the log for potential future undo.
163-
MUTATION_LOGS.lock().unwrap().insert(log.id(), log.clone());
163+
MUTATION_LOGS.lock().expect("TODO: handle error").insert(log.id(), log.clone());
164164
165165
// Record in audit trail.
166-
AUDIT_TRAIL.lock().unwrap().record(
166+
AUDIT_TRAIL.lock().expect("TODO: handle error").record(
167167
"{op_name}",
168168
&hash_params(&[{param_refs}]),
169169
);
@@ -203,7 +203,7 @@ pub fn {inverse_fn}(snapshot: &StateSnapshot) -> Result<InverseResult, Oblibenis
203203
restore_state(snapshot)?;
204204
205205
// Record the restoration in the audit trail.
206-
AUDIT_TRAIL.lock().unwrap().record(
206+
AUDIT_TRAIL.lock().expect("TODO: handle error").record(
207207
"{inverse_fn}",
208208
&format!("snapshot_seq_{{}}", snapshot.at_sequence),
209209
);
@@ -229,18 +229,18 @@ pub fn {op_name}_with_snapshot({params}) -> Result<StateSnapshot, OblibeniserErr
229229
{forward_fn}({param_csv})?;
230230
231231
// Record in audit trail.
232-
AUDIT_TRAIL.lock().unwrap().record(
232+
AUDIT_TRAIL.lock().expect("TODO: handle error").record(
233233
"{op_name}",
234234
&hash_params(&[{param_refs}]),
235235
);
236236
237237
// Push onto the undo stack with the snapshot.
238-
UNDO_STACK.lock().unwrap().push(UndoEntry {{
238+
UNDO_STACK.lock().expect("TODO: handle error").push(UndoEntry {{
239239
operation_name: "{op_name}".to_string(),
240240
forward_params: serialize_params(&[{param_refs}]),
241241
inverse_params: vec![],
242242
snapshot: Some(snapshot.clone()),
243-
audit_sequence: AUDIT_TRAIL.lock().unwrap().len() as u64 - 1,
243+
audit_sequence: AUDIT_TRAIL.lock().expect("TODO: handle error").len() as u64 - 1,
244244
}});
245245
246246
Ok(snapshot)
@@ -383,7 +383,7 @@ fn capture_params_state(params: &[&dyn std::fmt::Debug]) -> String {{
383383
/// Capture full application state (application-specific — implement per project).
384384
fn capture_state() -> Result<StateSnapshot, OblibeniserError> {{
385385
Ok(StateSnapshot {{
386-
at_sequence: AUDIT_TRAIL.lock().unwrap().len() as u64,
386+
at_sequence: AUDIT_TRAIL.lock().expect("TODO: handle error").len() as u64,
387387
data: vec![],
388388
}})
389389
}}
@@ -458,21 +458,21 @@ max-entries = 1000
458458
[undo]
459459
max-depth = 50
460460
"#;
461-
let m = manifest::parse_manifest(toml).unwrap();
462-
parser::parse_manifest(&m).unwrap()
461+
let m = manifest::parse_manifest(toml).expect("TODO: handle error");
462+
parser::parse_manifest(&m).expect("TODO: handle error")
463463
}
464464

465465
#[test]
466466
fn test_generate_inverses_count() {
467467
let parsed = test_manifest();
468-
let inverses = generate_inverses(&parsed).unwrap();
468+
let inverses = generate_inverses(&parsed).expect("TODO: handle error");
469469
assert_eq!(inverses.len(), 3);
470470
}
471471

472472
#[test]
473473
fn test_mirror_inverse_contains_function() {
474474
let parsed = test_manifest();
475-
let inverses = generate_inverses(&parsed).unwrap();
475+
let inverses = generate_inverses(&parsed).expect("TODO: handle error");
476476
let mirror = &inverses[0];
477477
assert_eq!(mirror.function_name, "insert_inverse");
478478
assert!(mirror.code.contains("pub fn insert_inverse"));
@@ -482,7 +482,7 @@ max-depth = 50
482482
#[test]
483483
fn test_log_replay_inverse_contains_log() {
484484
let parsed = test_manifest();
485-
let inverses = generate_inverses(&parsed).unwrap();
485+
let inverses = generate_inverses(&parsed).expect("TODO: handle error");
486486
let replay = &inverses[1];
487487
assert_eq!(replay.strategy, InverseStrategy::LogReplay);
488488
assert!(replay.code.contains("mutation_log"));
@@ -492,7 +492,7 @@ max-depth = 50
492492
#[test]
493493
fn test_snapshot_inverse_contains_restore() {
494494
let parsed = test_manifest();
495-
let inverses = generate_inverses(&parsed).unwrap();
495+
let inverses = generate_inverses(&parsed).expect("TODO: handle error");
496496
let snapshot = &inverses[2];
497497
assert_eq!(snapshot.strategy, InverseStrategy::Snapshot);
498498
assert!(snapshot.code.contains("restore_state"));
@@ -502,7 +502,7 @@ max-depth = 50
502502
#[test]
503503
fn test_generate_inverse_module_complete() {
504504
let parsed = test_manifest();
505-
let module = generate_inverse_module(&parsed).unwrap();
505+
let module = generate_inverse_module(&parsed).expect("TODO: handle error");
506506
assert!(module.contains("SPDX-License-Identifier: PMPL-1.0-or-later"));
507507
assert!(module.contains("Generated by oblibeniser"));
508508
assert!(module.contains("pub fn insert_inverse"));

‎src/codegen/parser.rs‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -130,8 +130,8 @@ name = "backup"
130130
forward-fn = "sys::backup"
131131
inverse-strategy = "snapshot"
132132
"#;
133-
let m = manifest::parse_manifest(toml).unwrap();
134-
let parsed = parse_manifest(&m).unwrap();
133+
let m = manifest::parse_manifest(toml).expect("TODO: handle error");
134+
let parsed = parse_manifest(&m).expect("TODO: handle error");
135135
assert_eq!(parsed.project_name, "test-project");
136136
assert_eq!(parsed.operations.len(), 2);
137137
assert_eq!(parsed.operations[0].params.len(), 2);
@@ -160,8 +160,8 @@ forward-fn = "c::d"
160160
params = ["y:i32"]
161161
inverse-strategy = "mirror"
162162
"#;
163-
let m = manifest::parse_manifest(toml).unwrap();
164-
let parsed = parse_manifest(&m).unwrap();
163+
let m = manifest::parse_manifest(toml).expect("TODO: handle error");
164+
let parsed = parse_manifest(&m).expect("TODO: handle error");
165165
assert!(validate_operations(&parsed).is_err());
166166
}
167167

@@ -176,8 +176,8 @@ name = "empty_mirror"
176176
forward-fn = "a::b"
177177
inverse-strategy = "mirror"
178178
"#;
179-
let m = manifest::parse_manifest(toml).unwrap();
180-
let parsed = parse_manifest(&m).unwrap();
179+
let m = manifest::parse_manifest(toml).expect("TODO: handle error");
180+
let parsed = parse_manifest(&m).expect("TODO: handle error");
181181
assert!(validate_operations(&parsed).is_err());
182182
}
183183
}

‎src/manifest/mod.rs‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -264,7 +264,7 @@ name = "do_thing"
264264
forward-fn = "mod::do_thing"
265265
inverse-strategy = "mirror"
266266
"#;
267-
let m = parse_manifest(toml).unwrap();
267+
let m = parse_manifest(toml).expect("TODO: handle error");
268268
assert_eq!(m.project.name, "test");
269269
assert_eq!(m.operations.len(), 1);
270270
assert_eq!(m.operations[0].name, "do_thing");
@@ -299,7 +299,7 @@ max-entries = 500
299299
max-depth = 50
300300
auto-checkpoint-interval = 5
301301
"#;
302-
let m = parse_manifest(toml).unwrap();
302+
let m = parse_manifest(toml).expect("TODO: handle error");
303303
assert_eq!(m.operations.len(), 2);
304304
assert_eq!(m.audit.storage, "memory");
305305
assert_eq!(m.audit.max_entries, 500);
@@ -318,7 +318,7 @@ name = "op"
318318
forward-fn = "fn"
319319
inverse-strategy = "mirror"
320320
"#;
321-
let m = parse_manifest(toml).unwrap();
321+
let m = parse_manifest(toml).expect("TODO: handle error");
322322
assert!(validate(&m).is_err());
323323
}
324324

@@ -333,7 +333,7 @@ name = "op"
333333
forward-fn = "fn"
334334
inverse-strategy = "teleport"
335335
"#;
336-
let m = parse_manifest(toml).unwrap();
336+
let m = parse_manifest(toml).expect("TODO: handle error");
337337
assert!(validate(&m).is_err());
338338
}
339339

@@ -346,7 +346,7 @@ name = "test"
346346
[audit]
347347
storage = "cloud"
348348
"#;
349-
let m = parse_manifest(toml).unwrap();
349+
let m = parse_manifest(toml).expect("TODO: handle error");
350350
assert!(validate(&m).is_err());
351351
}
352352

0 commit comments

Comments
 (0)