feature(pedm): SQL initialization (#1302)

- adds version tracking in the `pedm_schema_version` table
- adds table initialization
- error checking is strict and initialization only happens if the
version table is not found
- adds SQLite error handling for microsecond timestamp conversion
to/from Chrono
- fixes a bug in the libSQL schema where datetimes were stored
incorrectly
- they were being stored fractionally, instead of the full microseconds
since epoch
- adds `/about` endpoint to get basic info about the running application
  - I used this to ensure that the libsql date handling is functional

Author: allan2

Cargo.lock

@@ -14,10 +14,11 @@ anyhow = "1.0"
 axum = { version = "0.8", default-features = false, features = ["http1", "json", "tokio", "query", "tracing", "tower-log", "form", "original-uri", "matched-path"] }
 base16ct = { version = "0.2", features = ["std", "alloc"] }
 base64 = "0.22"
+chrono = { version = "0.4", features = ["serde"] }
 digest = "0.10"
 hyper = { version = "1.3", features = ["server"] }
 hyper-util = { version = "0.1", features = ["tokio"] }
-schemars = "0.8"
+schemars = { version = "0.8", features = ["chrono"] }
 serde = "1.0"
 serde_json = "1.0"
 sha1 = "0.10"
@@ -39,10 +40,10 @@ uuid = "1"
 dunce = "1.0"
 tower = "0.5"
 futures-util = "0.3"
-libsql = { version = "0.9", optional = true, features = [ "core", "stream"] }
-tokio-postgres = { version = "0.7", optional = true }
-bb8 = { version = "0.9.0", optional = true }
-bb8-postgres = { version = "0.9.0", optional = true }
+libsql = { version = "0.9", optional = true, default-features = false, features = [ "core", "sync"] }
+tokio-postgres = { version = "0.7", optional = true, features = ["with-chrono-0_4"] }
+bb8 = { version = "0.9", optional = true }
+bb8-postgres = { version = "0.9", optional = true }
 
 [features]
 default = ["libsql"]

crates/devolutions-pedm/Cargo.toml

@@ -1,20 +1,39 @@
-/* In SQLite, we store time as integer with microsecond precision. This is the same precision used by TIMESTAMPTZ in Postgres. */
+/* In SQLite, we store time as an 8-byte integer (i64) with microsecond precision. This matches TIMESTAMPTZ in Postgres.
+   Use `chrono::DateTime::timestamp_micros` when inserting or fetching timestamps in Rust.
+*/
 
-CREATE TABLE pedm_run (
-    id         INTEGER PRIMARY KEY AUTOINCREMENT,
-    start_time INTEGER NOT NULL DEFAULT (CAST(strftime('%f', 'now') * 1000000 AS INTEGER)),
-    pipe_name  TEXT NOT NULL
+CREATE TABLE IF NOT EXISTS version
+(
+    version    integer PRIMARY KEY,
+    updated_at integer NOT NULL DEFAULT (
+        CAST(strftime('%s', 'now') AS integer) * 1000000 + CAST(strftime('%f', 'now') * 1000000 AS integer) % 1000000
+        )
 );
 
-CREATE TABLE http_request (
-    id          INTEGER PRIMARY KEY,
-    at          INTEGER NOT NULL DEFAULT (CAST(strftime('%f', 'now') * 1000000 AS INTEGER)),
-    method      TEXT NOT NULL,
-    path        TEXT NOT NULL,
-    status_code INTEGER NOT NULL
+CREATE TABLE IF NOT EXISTS run
+(
+    id         integer PRIMARY KEY AUTOINCREMENT,
+    start_time integer NOT NULL DEFAULT (
+        CAST(strftime('%s', 'now') AS integer) * 1000000 + CAST(strftime('%f', 'now') * 1000000 AS integer) % 1000000
+        ),
+    pipe_name  text    NOT NULL
 );
 
-CREATE TABLE elevate_tmp_request (
-    req_id  INTEGER PRIMARY KEY,
-    seconds INTEGER NOT NULL
+CREATE TABLE IF NOT EXISTS http_request
+(
+    id          integer PRIMARY KEY,
+    at          integer NOT NULL DEFAULT (
+        CAST(strftime('%s', 'now') AS integer) * 1000000 + CAST(strftime('%f', 'now') * 1000000 AS integer) % 1000000
+        ),
+    method      text    NOT NULL,
+    path        text    NOT NULL,
+    status_code integer NOT NULL
 );
+
+CREATE TABLE IF NOT EXISTS elevate_tmp_request
+(
+    req_id  integer PRIMARY KEY,
+    seconds integer NOT NULL
+);
+
+INSERT INTO version (version) VALUES (0) ON CONFLICT DO NOTHING;