Progress towards services

.cargo/config.toml

@@ -1,6 +1,6 @@
 [target.'cfg(all())']
 rustflags = [
-    "-Dunsafe_code",
+    "-Funsafe_code",
     "-Dclippy::all",
     "-Wclippy::await_holding_lock",
     "-Wclippy::char_lit_as_u8",

apps/api/src/db.rs

@@ -4,7 +4,7 @@ use std::env;
 
 pub async fn init() -> Result<Pool<Postgres>, Error> {
     let database_url = env::var("DATABASE_URL")
-        .unwrap_or_else(|_| "postgresql://caster:caster@localhost:1701/caster".into());
+        .unwrap_or_else(|_| "postgresql://caster:caster@localhost:1701/caster".to_string());
 
     let pool = PgPoolOptions::new()
         .max_connections(5)

apps/api/src/main.rs

@@ -24,7 +24,7 @@ mod db;
 async fn main() -> Result<(), Error> {
     dotenv().ok();
 
-    let port = env::var("PORT").unwrap_or_else(|_| "3000".into());
+    let port = env::var("PORT").unwrap_or_else(|_| "3000".to_string());
     let addr = format!("http://localhost:{port}", port = port);
 
     let pg_pool = db::init().await?;
@@ -66,7 +66,7 @@ async fn main() -> Result<(), Error> {
 
     let socket_addr: SocketAddr = match addr.parse() {
         Ok(file) => file,
-        Err(_) => ([0, 0, 0, 0], 3000).into(),
+        Err(_) => ([0, 0, 0, 0], 3000).to_string(),
     };
 
     warp::serve(routes).run(socket_addr).await;

libs/shows/src/lib.rs

@@ -3,3 +3,6 @@
 
 /// The GraphQL resolver
 pub mod shows_resolver;
+
+/// The Shows entity service
+pub mod shows_service;

libs/shows/src/shows_resolver.rs

@@ -1,9 +1,13 @@
 use async_graphql::{Context, Object};
 use sqlx::{Pool, Postgres};
 
+use crate::shows_service::ShowsService;
+
 /// The Query segment owned by the Shows library
 #[derive(Default)]
-pub struct ShowsQuery;
+pub struct ShowsQuery {
+    service: ShowsService,
+}
 
 #[Object]
 impl ShowsQuery {

libs/shows/src/shows_service.rs

@@ -0,0 +1,24 @@
+use sqlx::{Pool, Postgres};
+
+/// The Shows entity servicea
+#[derive(Default)]
+pub struct ShowsService {
+    pg_pool: Pool<Postgres>,
+}
+
+impl ShowsService {
+    async fn get(&self, id: &str) -> Result<&str, sqlx::Error> {
+        let countries = sqlx::query!(
+            "
+SELECT *
+FROM \"User\"
+WHERE id = $1
+        ",
+            id
+        )
+        .fetch_optional(&self.pg_pool)
+        .await?;
+
+        Ok("Test")
+    }
+}