1 files changed, 49 insertions, 0 deletions
diff --git a/server/src/main/scala/Repository.scala b/server/src/main/scala/Repository.scala
new file mode 100644
index 0000000..003ac92
--- /dev/null
+++ b/server/src/main/scala/Repository.scala
@@ -0,0 +1,49 @@
+package triad
+
+import java.time.Instant
+
+import slick.jdbc.{JdbcProfile, SQLiteProfile}
+
+class Repository(val profile: JdbcProfile, url: String, driver: String) {
+  val database: profile.backend.DatabaseDef =
+    profile.api.Database.forURL(url, driver)
+
+  import profile.api._
+
+  implicit val instantColumnType = MappedColumnType.base[Instant, Long](
+    { i =>
+      i.toEpochMilli()
+    }, { l =>
+      Instant.ofEpochMilli(l)
+    }
+  )
+
+  class Messages(tag: Tag) extends Table[Message](tag, "messages") {
+    def id = column[String]("id")
+    def content = column[String]("content")
+    def author = column[String]("author")
+    def timestamp = column[Instant]("timestamp")
+    def * =
+      (id, content, author, timestamp) <> ({ cols =>
+        Message(cols._2, cols._3, cols._4)
+      }, { message: Message =>
+        Some((message.id, message.content, message.author, message.timestamp))
+      })
+    def pk = primaryKey("pk", id)
+  }
+
+  val Messages = TableQuery[Messages]
+
+  def initAction = DBIO.seq(
+    Messages.schema.create,
+    Messages += Message("first!", "John Smith")
+  )
+
+}
+
+object Repository {
+
+  def sqlite(name: String) =
+    new Repository(SQLiteProfile, s"jdbc:sqlite:$name", "org.sqlite.JDBC")
+
+}