|
| 1 | +use pico::{Database, MemoRef, SourceId, Storage}; |
| 2 | +use pico_macros::{Db, Source, memo}; |
| 3 | +use std::sync::atomic::{AtomicUsize, Ordering}; |
| 4 | +use thiserror::Error; |
| 5 | + |
| 6 | +static TRACK_CLONE_COUNT: AtomicUsize = AtomicUsize::new(0); |
| 7 | + |
| 8 | +#[derive(Db, Default)] |
| 9 | +struct TestDatabase { |
| 10 | + storage: Storage<Self>, |
| 11 | +} |
| 12 | + |
| 13 | +#[test] |
| 14 | +fn try_ok_projects_ok_value() { |
| 15 | + let mut db = TestDatabase::default(); |
| 16 | + |
| 17 | + let id = db.set(Input { |
| 18 | + key: "key", |
| 19 | + value: "asdf".to_string(), |
| 20 | + }); |
| 21 | + |
| 22 | + assert_eq!(*process_input(&db, id).unwrap(), 'a'); |
| 23 | +} |
| 24 | + |
| 25 | +#[test] |
| 26 | +fn projected_memo_correctly_restored() { |
| 27 | + let mut db = TestDatabase::default(); |
| 28 | + |
| 29 | + let id = db.set(Input { |
| 30 | + key: "key", |
| 31 | + value: "asdf".to_string(), |
| 32 | + }); |
| 33 | + |
| 34 | + let result = process_input(&db, id).unwrap(); |
| 35 | + assert_eq!(*consume_result(&db, result), 'a'); |
| 36 | +} |
| 37 | + |
| 38 | +#[derive(Debug, Clone, PartialEq, Eq, Source)] |
| 39 | +struct Input { |
| 40 | + #[key] |
| 41 | + pub key: &'static str, |
| 42 | + pub value: String, |
| 43 | +} |
| 44 | + |
| 45 | +#[derive(Debug, Clone, Error, PartialEq, Eq)] |
| 46 | +enum FirstLetterError { |
| 47 | + #[error("empty string")] |
| 48 | + EmptyString, |
| 49 | +} |
| 50 | + |
| 51 | +#[derive(Debug, Clone, Error, PartialEq, Eq)] |
| 52 | +enum ProcessInputError { |
| 53 | + #[error("cannot process input")] |
| 54 | + ReadError(#[from] FirstLetterError), |
| 55 | +} |
| 56 | + |
| 57 | +#[memo] |
| 58 | +fn first_letter(db: &TestDatabase, input_id: SourceId<Input>) -> Result<char, FirstLetterError> { |
| 59 | + db.get(input_id) |
| 60 | + .value |
| 61 | + .chars() |
| 62 | + .next() |
| 63 | + .ok_or(FirstLetterError::EmptyString) |
| 64 | +} |
| 65 | + |
| 66 | +fn process_input( |
| 67 | + db: &TestDatabase, |
| 68 | + input_id: SourceId<Input>, |
| 69 | +) -> Result<MemoRef<char>, ProcessInputError> { |
| 70 | + let result = first_letter(db, input_id).try_ok()?; |
| 71 | + Ok(result) |
| 72 | +} |
| 73 | + |
| 74 | +#[memo] |
| 75 | +fn consume_result(db: &TestDatabase, first_letter: MemoRef<char>) -> char { |
| 76 | + let result = *first_letter; |
| 77 | + result |
| 78 | +} |
| 79 | + |
| 80 | +#[test] |
| 81 | +fn try_ok_never_clones_ok_value() { |
| 82 | + let db = TestDatabase::default(); |
| 83 | + |
| 84 | + let result = ok_value(&db).try_ok().expect("expected ok result"); |
| 85 | + let _ = &*result; |
| 86 | + |
| 87 | + match err_value(&db).try_ok() { |
| 88 | + Ok(_) => panic!("expected error"), |
| 89 | + Err(_err) => {} |
| 90 | + } |
| 91 | + |
| 92 | + assert_eq!(TRACK_CLONE_COUNT.load(Ordering::SeqCst), 1); |
| 93 | +} |
| 94 | + |
| 95 | +#[memo] |
| 96 | +fn ok_value(_db: &TestDatabase) -> Result<PanicOnClone, TrackCloneError> { |
| 97 | + Ok(PanicOnClone) |
| 98 | +} |
| 99 | + |
| 100 | +#[memo] |
| 101 | +fn err_value(_db: &TestDatabase) -> Result<PanicOnClone, TrackCloneError> { |
| 102 | + Err(TrackCloneError::Count) |
| 103 | +} |
| 104 | + |
| 105 | +#[derive(Debug, PartialEq, Eq)] |
| 106 | +struct PanicOnClone; |
| 107 | + |
| 108 | +impl Clone for PanicOnClone { |
| 109 | + fn clone(&self) -> Self { |
| 110 | + panic!("PanicOnClone should not be cloned"); |
| 111 | + } |
| 112 | +} |
| 113 | + |
| 114 | +#[derive(Debug, Error, PartialEq, Eq)] |
| 115 | +enum TrackCloneError { |
| 116 | + #[error("error cloned")] |
| 117 | + Count, |
| 118 | +} |
| 119 | + |
| 120 | +impl Clone for TrackCloneError { |
| 121 | + fn clone(&self) -> Self { |
| 122 | + TRACK_CLONE_COUNT.fetch_add(1, Ordering::SeqCst); |
| 123 | + TrackCloneError::Count |
| 124 | + } |
| 125 | +} |
0 commit comments