Replace all raw SQL queries and sqlx pool usage with SeaORM entity API.

@@ -17,3 +16,4 @@ bcrypt = "0.17"
 md-5 = "0.10"
 chrono = "0.4"
 thiserror = "2"
+sea-orm = { version = "0.12", features = ["sqlx-sqlite", "runtime-tokio-rustls", "macros"] }

@@ -21,3 +21,3 @@
     pub text: String,
     pub email: String,
-    pub pub_date: i64,
+    pub pub_date: Option<i64>,

@@ -24,1 +28,4 @@
+        .filter(user::Column::Username.eq(username))
+        .one(db)
         .await?
+        .map(|m| m.user_id as i64)

@@ -33,1 +38,4 @@
+        .filter(user::Column::Username.eq(username))
+        .one(db)
         .await?
+        .map(|m| User { user_id: m.user_id as i64, username: m.username, email: m.email })

@@ -153,0 +167,4 @@
+                .to(user::Column::UserId)
+                .into(),
+        )
+        .filter(follower::Column::WhoId.eq(user_id as i32))

@@ -153,0 +168,4 @@
+                .into(),
+        )
+        .filter(follower::Column::WhoId.eq(user_id as i32))
+        .limit(limit as u64)

@@ -174,2 +192,2 @@
-        .execute(pool)
-        .await?;
+    message::ActiveModel {
+        author_id: Set(author_id as i32),

@@ -245,2 +272,2 @@
-    if bcrypt::verify(password, &row.pw_hash).unwrap_or(false) {
-        Ok(row.user_id)
+    if bcrypt::verify(password, &model.pw_hash).unwrap_or(false) {
+        Ok(model.user_id as i64)

@@ -256,3 +283,3 @@
         .map(|row| MessageView {
             gravatar: gravatar_url(&row.email, 48),
-            pub_date: format_datetime(row.pub_date),
+            pub_date: format_datetime(row.pub_date.unwrap_or(0)),

@@ -85,4 +79,1 @@
     let database_url = std::env::var("DATABASE").unwrap_or_else(|_| DEFAULT_DATABASE.into());
-    let options = SqliteConnectOptions::from_str(&database_url)
-        .expect("Invalid DATABASE URL")
-        .create_if_missing(true);

@@ -16,3 +17,4 @@
 mod state;
 mod web_app;
 
+

@@ -111,3 +107,3 @@
 
     // Migrate: add `latest` table if it doesn't exist yet (safe on existing DBs)
-    sqlx::query(
+    db.execute_unprepared(

@@ -45,3 +48,1 @@
-        let _ = sqlx::query("UPDATE latest SET value = ?1 WHERE id = 1")
-            .bind(val)
-            .execute(&state.pool)
+        let _ = latest::Entity::update_many()

@@ -46,2 +48,2 @@
-            .bind(val)
-            .execute(&state.pool)
+        let _ = latest::Entity::update_many()
+            .col_expr(latest::Column::Value, Expr::value(val as i32))

@@ -65,1 +69,4 @@
         .await
+        .ok()
+        .flatten()
+        .map(|m| m.value as i64)

@@ -96,3 +105,1 @@
-    .bind(limit)
-    .fetch_all(pool)
-    .await?;
+    let limit = limit.unwrap_or(PER_PAGE as i64) as u64;