Updating workflow for main workflows (#9)

Reviewed-on: phoenix/textsender_api#9
2026-06-14 19:12:25 -04:00
parent ff35a8c3aa
commit 3117f46a73
7 changed files with 282 additions and 99 deletions
@@ -26,4 +26,97 @@ pub mod contact {
            Err(_) => Err(sqlx::Error::RowNotFound),
        }
    }
+
+    pub async fn get(
+        pool: &sqlx::PgPool,
+        id: &uuid::Uuid,
+    ) -> Result<textsender_models::contact::Contact, sqlx::Error> {
+        match sqlx::query(
+            r#"
+        SELECT id, firstname, lastname, nickname, phone_number, user_id FROM "contacts"
+        WHERE
+            id = $1;
+        "#,
+        )
+        .bind(id)
+        .fetch_one(pool)
+        .await
+        {
+            Ok(row) => {
+                let id: uuid::Uuid = row.try_get("id")?;
+
+                let phone_number: String = row.try_get("phone_number")?;
+                let user_id: uuid::Uuid = row.try_get("user_id")?;
+                Ok(textsender_models::contact::Contact {
+                    id: Some(id),
+                    firstname: match row.try_get("firstname") {
+                        Ok(val) => val,
+                        Err(err) => {
+                            eprintln!("Error: {err:?}");
+                            None
+                        }
+                    },
+                    lastname: match row.try_get("lastname") {
+                        Ok(val) => val,
+                        Err(err) => {
+                            eprintln!("Error: {err:?}");
+                            None
+                        }
+                    },
+                    nickname: match row.try_get("nickname") {
+                        Ok(val) => val,
+                        Err(err) => {
+                            eprintln!("Error: nickname has no value for contacts record {err:?}");
+                            None
+                        }
+                    },
+                    phone_number,
+                    user_id: Some(user_id),
+                })
+            }
+            Err(_) => Err(sqlx::Error::RowNotFound),
+        }
+    }
+
+    pub async fn get_with_user_id_and_phone(
+        pool: &sqlx::PgPool,
+        user_id: &uuid::Uuid,
+        phone_number: &str,
+    ) -> Result<textsender_models::contact::Contact, sqlx::Error> {
+        match sqlx::query(
+            r#"
+        SELECT id, firstname, lastname, nickname, phone_number, user_id FROM "contacts"
+        WHERE
+            phone_number = $1 AND user_id = $2;
+        "#,
+        )
+        .bind(phone_number)
+        .bind(user_id)
+        .fetch_one(pool)
+        .await
+        {
+            Ok(row) => {
+                println!("In here");
+                let id: uuid::Uuid = row.try_get("id")?;
+                let firstname: String = row.try_get("firstname")?;
+                let lastname: String = row.try_get("lastname")?;
+                let nickname: String = row.try_get("nickname")?;
+                let phone_number: String = row.try_get("phone_number")?;
+                let user_id: uuid::Uuid = row.try_get("user_id")?;
+                println!("Found");
+                Ok(textsender_models::contact::Contact {
+                    id: Some(id),
+                    firstname: Some(firstname),
+                    lastname: Some(lastname),
+                    nickname: Some(nickname),
+                    phone_number,
+                    user_id: Some(user_id),
+                })
+            }
+            Err(err) => match err {
+                sqlx::Error::RowNotFound => Err(err),
+                _ => Err(sqlx::Error::WorkerCrashed),
+            },
+        }
+    }
 }