WIP refactor: migrate database from PostgreSQL to SQLite

??? not sure

Cargo.toml

@@ -11,7 +11,7 @@ async-trait = "0.1.80"
 clap = { version = "4.5.9", features = ["derive"] }
 dotenvy = "0.15.0"
 regex = "1.5.4"
-sqlx = { version = "0.7.4", features = ["runtime-tokio-native-tls", "postgres"] }
+sqlx = { version = "0.7.4", features = ["runtime-tokio-native-tls", "sqlite"] }
 tokio = { version = "1.28.0", features = ["full", "test-util"] }
 
 [dev-dependencies]

src/db.rs

@@ -2,7 +2,7 @@ use std::sync::Arc;
 
 use crate::models;
 use async_trait::async_trait;
-use sqlx::postgres::PgPool;
+use sqlx::SqlitePool;
 
 #[cfg_attr(test, mockall::automock)]
 #[async_trait]
@@ -13,20 +13,20 @@ pub trait ContactRepo {
     async fn get_by_id(&self, id: i64) -> anyhow::Result<models::IndexedContact>;
 }
 
-pub struct PostgresContactRepo {
-    pg_pool: Arc<PgPool>,
+pub struct SqliteContactRepo {
+    sqlite_pool: Arc<SqlitePool>,
 }
 
-impl PostgresContactRepo {
-    pub fn new(pg_pool: PgPool) -> Self {
+impl SqliteContactRepo {
+    pub fn new(pool: SqlitePool) -> Self {
         Self {
-            pg_pool: Arc::new(pg_pool),
+            sqlite_pool: Arc::new(pool),
         }
     }
 }
 
 #[async_trait]
-impl ContactRepo for PostgresContactRepo {
+impl ContactRepo for SqliteContactRepo {
     async fn save(&self, contact: models::Contact) -> anyhow::Result<i64> {
         let query = "INSERT INTO contacts
         (first_name, last_name, display_name, email, phone_number)
@@ -39,7 +39,7 @@ impl ContactRepo for PostgresContactRepo {
             .bind(&contact.display_name)
             .bind(&contact.email)
             .bind(&contact.phone_number)
-            .fetch_one(&*self.pg_pool)
+            .fetch_one(&*self.sqlite_pool)
             .await?;
 
         Ok(id)
@@ -53,7 +53,7 @@ impl ContactRepo for PostgresContactRepo {
 
         let contacts_with_id: Vec<models::IndexedContact> =
             sqlx::query_as::<_, models::IndexedContact>(get_contacts_query)
-                .fetch_all(&*self.pg_pool)
+                .fetch_all(&*self.sqlite_pool)
                 .await?;
 
         Ok(contacts_with_id)
@@ -78,7 +78,7 @@ impl ContactRepo for PostgresContactRepo {
             contact.update.phone_number,
             contact.id
         )
-        .execute(&*self.pg_pool)
+        .execute(&*self.sqlite_pool)
         .await?;
 
         println!("Contact updated");
@@ -92,7 +92,7 @@ impl ContactRepo for PostgresContactRepo {
         let contact: models::IndexedContact =
             sqlx::query_as::<_, models::IndexedContact>(query_get_by_id)
                 .bind(id)
-                .fetch_one(&*self.pg_pool)
+                .fetch_one(&*self.sqlite_pool)
                 .await?;
 
         Ok(contact)

src/main.rs

@@ -8,17 +8,17 @@ mod utils;
 
 use clap::Parser;
 use commander::{Cli, Commands};
-use db::{ContactRepo, PostgresContactRepo};
+use db::{ContactRepo, SqliteContactRepo};
 use models::{Contact, ContactBuilder};
-use sqlx::PgPool;
+use sqlx::SqlitePool;
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
     dotenvy::dotenv().ok();
 
-    let pool = PgPool::connect(&env::var("DATABASE_URL")?).await?;
+    let pool = SqlitePool::connect(&env::var("DATABASE_URL")?).await?;
 
-    let contact_repo = PostgresContactRepo::new(pool);
+    let contact_repo = SqliteContactRepo::new(pool);
 
     let cli = Cli::parse();