server: add insert and get database queries

flake.nix

@@ -84,6 +84,8 @@
         {
           devShells.default = pkgs.mkShell {
             inputsFrom = [ self'.packages.default ];
+            packages = [ pkgs.sqlx-cli ];
+            DATABASE_URL = "sqlite:items.db";
           };
 
           packages = {

server/Cargo.toml

@@ -11,6 +11,7 @@ clap = { version = "4", features = ["derive"] }
 lazy_static = "1.5.0"
 metrics = "0.23"
 metrics-exporter-prometheus = "0.15"
+sqlx = { version = "0.8", features = [ "runtime-tokio-native-tls", "sqlite", "uuid"] }
 tokio = { version = "1", features = [ "full", "tracing"] }
 tracing = "0.1"
 tracing-subscriber = "0.3"

server/migrations/20240916162916_create-items.sql

@@ -0,0 +1,6 @@
+
+CREATE TABLE items (
+    id TEXT PRIMARY KEY NOT NULL,  -- Store UUID as TEXT in SQLite
+    name TEXT NOT NULL,
+    price TEXT NOT NULL  -- Store u128 as TEXT
+);

server/src/db.rs

@@ -0,0 +1,43 @@
+use crate::item::Item;
+use sqlx::{query_as, FromRow, SqlitePool};
+use uuid::Uuid;
+
+#[derive(FromRow)]
+struct DbItem {
+    id: String,
+    name: String,
+    price: String,
+}
+
+impl From<DbItem> for Item {
+    fn from(db_item: DbItem) -> Item {
+        Item {
+            id: Uuid::parse_str(&db_item.id).expect(""),
+            name: db_item.name,
+            price: db_item.price.parse::<u128>().expect(""),
+        }
+    }
+}
+
+pub async fn new_item(pool: &SqlitePool, name: &str, price: u128) -> Result<Item, sqlx::Error> {
+    let id = Uuid::new_v4().to_string();
+    let price = price.to_string();
+    query_as!(
+        DbItem,
+        "insert into items (id, name, price) values ($1, $2, $3) returning *",
+        id,
+        name,
+        price
+    )
+    .fetch_one(pool)
+    .await
+    .map(Into::into)
+}
+
+/// Returns all known items
+pub async fn get_items(pool: &SqlitePool) -> Result<Vec<Item>, sqlx::Error> {
+    query_as!(DbItem, "select * from items")
+        .fetch_all(pool)
+        .await
+        .map(|items| items.into_iter().map(Into::into).collect())
+}

server/src/lib.rs

@@ -1,4 +1,5 @@
 pub mod cli;
+pub mod db;
 pub mod item;
 pub mod routes;