chore: testing database

Author: Utilitycoder

.env

@@ -0,0 +1 @@
+DATABASE_URL="postgres://postgres:password@localhost:5432/newsletter"

Cargo.lock

@@ -16,6 +16,7 @@ name = "robust-rust"
 actix-web = "4"
 tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
 serde = {version = "1.0.163", features = ["derive"]}
+config = "0.11"
 
 [dependencies.sqlx]
 version = "0.6.3"

Cargo.toml

@@ -0,0 +1,7 @@
+application_port: 8000
+database:
+  host: "127.0.0.1"
+  port: 5432
+  username: "postgres"
+  password: "password"
+  database_name: "newsletter"

configuration.yaml

@@ -0,0 +1,34 @@
+#[derive(serde::Deserialize)]
+pub struct Settings {
+    pub database: DatabaseSettings,
+    pub application_port: u16,
+}
+
+#[derive(serde::Deserialize)]
+pub struct DatabaseSettings {
+    pub username: String,
+    pub password: String,
+    pub host: String,
+    pub port: u16,
+    pub database_name: String,
+}
+
+impl DatabaseSettings {
+    pub fn connection_string(&self) -> String {
+        format!(
+            "postgres://{}:{}@{}:{}/{}",
+            self.username, self.password, self.host, self.port, self.database_name
+        )
+    }
+}
+
+pub fn get_configuration() -> Result<Settings, config::ConfigError> {
+    // Initialize our configuration reader
+    let mut settings = config::Config::default();
+    // Add configuration values from a file named `configuration`
+    // with the `ini` file format
+    settings.merge(config::File::with_name("configuration"))?;
+    // Try to convert the configuration values it read into
+    // our Settings type
+    settings.try_into()
+}

src/configuration.rs

@@ -1,3 +1,3 @@
-pub mod routes;
 pub mod configuration;
+pub mod routes;
 pub mod startup;

src/lib.rs

@@ -1,11 +1,11 @@
+use robust_rust::configuration::get_configuration;
 use robust_rust::startup::run;
 use std::net::TcpListener;
 
 #[tokio::main]
 async fn main() -> std::io::Result<()> {
-    let listener = TcpListener::bind("127.0.0.1:0").expect("Failed to bind random port");
-    let port = listener.local_addr().unwrap().port();
-    let endpoint = format!("Server running at http://127.0.0.1:{}", port);
-    println!("{}", endpoint);
+    let configuration = get_configuration().expect("Failed to read configuration.");
+    let address = format!("127.0.0.1:{}", configuration.application_port);
+    let listener = TcpListener::bind(address).expect("Failed to bind random port");
     run(listener)?.await
 }

src/main.rs

@@ -2,4 +2,4 @@ use actix_web::HttpResponse;
 
 pub async fn health_check() -> HttpResponse {
     HttpResponse::Ok().into()
-}
+}

src/routes/health_check.rs

@@ -2,4 +2,4 @@ mod health_check;
 mod subscriptions;
 
 pub use health_check::*;
-pub use subscriptions::*;
+pub use subscriptions::*;

src/routes/mod.rs

@@ -9,4 +9,4 @@ pub struct FormData {
 
 pub async fn subscribe(_form: web::Form<FormData>) -> HttpResponse {
     HttpResponse::Ok().finish()
-}
+}

src/routes/subscriptions.rs

@@ -1,7 +1,6 @@
+use crate::routes::{health_check, subscribe};
 use actix_web::{dev::Server, web, App, HttpServer};
 use std::net::TcpListener;
-use crate::routes::{health_check, subscribe};
-
 
 pub fn run(listener: TcpListener) -> Result<Server, std::io::Error> {
     let server = HttpServer::new(|| {