Saving code

src/repo/mod.rs

@@ -119,4 +119,62 @@ pub mod contact {
             },
         }
     }
+
+    pub async fn get_with_user_id(
+        pool: &sqlx::PgPool,
+        user_id: &uuid::Uuid,
+    ) -> Result<Vec<textsender_models::contact::Contact>, sqlx::Error> {
+        match sqlx::query(
+            r#"
+        SELECT id, firstname, lastname, nickname, phone_number, user_id FROM "contacts"
+        WHERE
+            user_id = $1;
+        "#,
+        )
+        .bind(user_id)
+        .fetch_all(pool)
+        .await
+        {
+            Ok(rows) => {
+                let mut contacts: Vec<textsender_models::contact::Contact> = Vec::new();
+                for row in rows {
+                    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")?;
+                    let contact = 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),
+                    };
+                    contacts.push(contact);
+                }
+                Ok(contacts)
+            }
+            Err(_) => Err(sqlx::Error::RowNotFound),
+        }
+    }
 }