Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // CREATE / INSERT
- val srs1 = (1 to 10) map { i => SimpleRoot(i = i) }
- val uris = await(repository.insert(srs1))
- locally {
- val h1s = getHistories(srs1)
- h1s.size mustBe srs1.size
- for ((h1, sr1) <- h1s zip srs1) {
- h1.snapshots.size mustBe 1
- h1.snapshots(0).action mustBe "INSERT"
- h1.snapshots(0).value.i mustBe sr1.i
- }
- }
- // READ / FIND
- val srs2 = await(repository.find(uris))
- // UPDATE
- srs2 foreach { _.i *= 10 }
- await(repository.update(srs2))
- locally {
- val h2s = getHistories(srs2)
- h2s.size mustBe srs2.size
- for (((h2, sr1), sr2) <- h2s zip srs1 zip srs2) {
- println(h2.snapshots.size, 2, h2.snapshots.size == 2, h2.snapshots.size mustBe 2)
- h2.snapshots.size mustBe 2
- h2.snapshots(0).action mustBe "INSERT"
- h2.snapshots(0).value.i mustBe sr1.i
- h2.snapshots(1).action mustBe "UPDATE"
- h2.snapshots(1).value.i mustBe sr2.i
- }
- }
- // DELETE
- val srs3 = await(repository.find(uris))
- await(repository.delete(srs3))
- locally {
- val h2s = getHistories(srs3)
- h2s.size mustBe srs3.size
- for ((((h3, sr1), sr2), sr3) <- h2s zip srs1 zip srs2 zip srs3) {
- h3.snapshots.size mustBe 3
- h3.snapshots(0).action mustBe "INSERT"
- h3.snapshots(0).value.i mustBe sr1.i
- h3.snapshots(1).action mustBe "UPDATE"
- h3.snapshots(1).value.i mustBe sr2.i
- h3.snapshots(2).action mustBe "DELETE"
- h3.snapshots(2).value.i mustBe sr3.i
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement