okami.mom/albedo

git clone https://git.nkp.pet/okami.mom/albedo

nekomimi.petmake schedule visible7f83187

main
branchesmainall refs →
1.5 KiB39 linesraw
1//// Late recurring advancement must skip missed intervals without duplicate turns.
2//// Explicit timestamps exercise exact due boundaries without a wall-clock race.
3
4import albedo/daemon/store
5import albedo/harness/extensions/schedule/ledger
6import gleam/option.{None, Some}
7import gleeunit/should
8import sqlight
9
10pub fn schedules_are_session_scoped_and_advance_once_test() -> Nil {
11  let assert Ok(db) =
12    store.start(
13      ":memory:",
14      "CREATE TABLE sessions(id TEXT PRIMARY KEY); INSERT INTO sessions VALUES('a'),('b');",
15    )
16  let assert Ok(_) = ledger.initialise(db)
17  let assert Ok(first) =
18    ledger.save(db, "a", None, "recurring", "inspect", 60, Some(60))
19  let assert Ok(one) = ledger.save(db, "b", None, "once", "check", 60, None)
20  let assert Ok([listed]) = ledger.list(db, "a", 200)
21  listed |> should.equal(first)
22  ledger.delete(db, "b", first.id) |> should.equal(Ok(False))
23  let assert Ok([]) = ledger.due(db, first.next_at - 1)
24  let assert Ok([_, _]) = ledger.due(db, first.next_at)
25  ledger.advance(db, first, first.next_at + 180) |> should.equal(Ok(Nil))
26  let assert Ok(advanced) = ledger.get(db, "a", first.id)
27  advanced.next_at |> should.equal(first.next_at + 240)
28  ledger.advance(db, one, one.next_at) |> should.equal(Ok(Nil))
29  ledger.get(db, "b", one.id) |> should.be_error
30  store.query(db, fn(connection) {
31    sqlight.exec(
32      "PRAGMA foreign_keys=ON; DELETE FROM sessions WHERE id='a';",
33      connection,
34    )
35  })
36  |> should.be_ok
37  ledger.list(db, "a", 200) |> should.equal(Ok([]))
38  store.close(db)
39}