Added embedded postgres to unit test postgres implementation of DB la…

…yer (#203)

* Added embedded postgres to unit test postgres implementation of DB layer

Cargo.toml

@@ -1,4 +1,5 @@
 [workspace]
+resolver = "1"
 members = [
     "sidecar",
     "listener",

rust-toolchain.toml

@@ -1,5 +1,5 @@
 [toolchain]
-channel = "1.68.1"
+channel = "1.72.1"
 components = [ "rustfmt", "clippy" ]
 targets = [ "wasm32-unknown-unknown" ]
 profile = "minimal"

sidecar/Cargo.toml

@@ -67,6 +67,7 @@ tabled = { version = "0.10.0", features = ["derive", "color"] }
 tempfile = "3"
 once_cell = "1.17.1"
 tokio-util = "0.7.8"
+pg-embed = { git = "https://github.com/faokunega/pg-embed", tag = "v0.8.0" }
 
 [package.metadata.deb]
 revision = "0"

sidecar/src/database/mod.rs

@@ -8,4 +8,6 @@ pub mod errors;
 pub mod migration_manager;
 pub mod postgresql_database;
 pub mod sqlite_database;
+#[cfg(test)]
+pub mod tests;
 pub mod types;

sidecar/src/database/postgresql_database.rs

@@ -1,6 +1,7 @@
 mod reader;
+#[cfg(test)]
+mod tests;
 mod writer;
-
 use anyhow::Error;
 use sea_query::PostgresQueryBuilder;
 use sqlx::{
@@ -22,6 +23,17 @@ pub struct PostgreSqlDatabase {
 }
 
 impl PostgreSqlDatabase {
+    #[cfg(test)]
+    pub async fn new_from_postgres_uri(uri: String) -> Result<PostgreSqlDatabase, Error> {
+        let connection_pool = PgPoolOptions::new()
+            .max_connections(30)
+            .connect(uri.as_str())
+            .await?;
+        let db = PostgreSqlDatabase { connection_pool };
+        MigrationManager::apply_all_migrations(db.clone()).await?;
+        Ok(db)
+    }
+
     pub async fn new(config: PostgresqlConfig) -> Result<PostgreSqlDatabase, Error> {
         let host = config.host;
         let database_name = config.database_name;