Add message endpoint (#13)
Reviewed-on: phoenix/textsender_api#13
This commit was merged in pull request #13.
This commit is contained in:
@@ -0,0 +1,25 @@
|
||||
use sqlx::Row;
|
||||
|
||||
pub async fn insert(
|
||||
pool: &sqlx::PgPool,
|
||||
message: &textsender_models::message::Message,
|
||||
user_id: &uuid::Uuid,
|
||||
) -> Result<uuid::Uuid, sqlx::Error> {
|
||||
match sqlx::query(
|
||||
r#"
|
||||
INSERT INTO "messages" (content, user_id)
|
||||
VALUES($1, $2) RETURNING id;
|
||||
"#,
|
||||
)
|
||||
.bind(&message.content)
|
||||
.bind(user_id)
|
||||
.fetch_one(pool)
|
||||
.await
|
||||
{
|
||||
Ok(row) => {
|
||||
let id: uuid::Uuid = row.try_get("id")?;
|
||||
Ok(id)
|
||||
}
|
||||
Err(_) => Err(sqlx::Error::RowNotFound),
|
||||
}
|
||||
}
|
||||
@@ -1 +1,2 @@
|
||||
pub mod contact;
|
||||
pub mod message;
|
||||
|
||||
Reference in New Issue
Block a user