1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
package app
import com.typesafe.config.ConfigFactory
import io.getquill.{SqliteJdbcContext, SnakeCase}
object TodoMvcDb extends cask.MainRoutes{
val tmpDb = java.nio.file.Files.createTempDirectory("todo-cask-sqlite")
object ctx extends SqliteJdbcContext(
SnakeCase,
ConfigFactory.parseString(
s"""{"driverClassName":"org.sqlite.JDBC","jdbcUrl":"jdbc:sqlite:$tmpDb/file.db"}"""
)
)
class transactional extends cask.RawDecorator{
class TransactionFailed(val value: cask.router.Result.Error) extends Exception
def wrapFunction(pctx: cask.Request, delegate: Delegate): OuterReturned = {
try ctx.transaction(
delegate(Map()) match{
case cask.router.Result.Success(t) => cask.router.Result.Success(t)
case e: cask.router.Result.Error => throw new TransactionFailed(e)
}
)
catch{case e: TransactionFailed => e.value}
}
}
case class Todo(id: Int, checked: Boolean, text: String)
object Todo{
implicit def todoRW = upickle.default.macroRW[Todo]
}
ctx.executeAction(
"""CREATE TABLE todo (
| id INTEGER PRIMARY KEY AUTOINCREMENT,
| checked BOOLEAN,
| text TEXT
|);
|""".stripMargin
)
ctx.executeAction(
"""INSERT INTO todo (checked, text) VALUES
|(1, 'Get started with Cask'),
|(0, 'Profit!');
|""".stripMargin
)
import ctx._
@transactional
@cask.get("/list/:state")
def list(state: String) = {
val filteredTodos = state match{
case "all" => run(query[Todo])
case "active" => run(query[Todo].filter(!_.checked))
case "completed" => run(query[Todo].filter(_.checked))
}
upickle.default.write(filteredTodos)
}
@transactional
@cask.post("/add")
def add(request: cask.Request) = {
val body = new String(request.readAllBytes())
run(
query[Todo]
.insert(_.checked -> lift(false), _.text -> lift(body))
.returningGenerated(_.id)
)
}
@transactional
@cask.post("/toggle/:index")
def toggle(index: Int) = {
run(query[Todo].filter(_.id == lift(index)).update(p => p.checked -> !p.checked))
}
@transactional
@cask.post("/delete/:index")
def delete(index: Int) = {
run(query[Todo].filter(_.id == lift(index)).delete)
}
initialize()
}
|
