diff --git a/db/init.sql b/db/init.sql index 2f6181d..e8bacf5 100644 --- a/db/init.sql +++ b/db/init.sql @@ -46,6 +46,7 @@ CREATE TABLE IF NOT EXISTS room_invite_ ( CREATE TABLE IF NOT EXISTS message_ ( id BIGSERIAL PRIMARY KEY, + uuid UUID NOT NULL, sender INT REFERENCES user_(id) NOT NULL, room INT REFERENCES room_(id) NOT NULL, message_type VARCHAR(32) NOT NULL, diff --git a/src/main.rs b/src/main.rs index f5f536a..907a77e 100644 --- a/src/main.rs +++ b/src/main.rs @@ -58,11 +58,11 @@ async fn main() -> anyhow::Result<()> { .layer(Extension(db_pool)) .layer(Extension(realtime)) .layer(GovernorLayer::new(governor_conf)) - .layer( - TraceLayer::new_for_http() - .make_span_with(DefaultMakeSpan::new().level(Level::INFO)) - .on_response(DefaultOnResponse::new().level(Level::INFO)), - ) + // .layer( + // TraceLayer::new_for_http() + // .make_span_with(DefaultMakeSpan::new().level(Level::INFO)) + // .on_response(DefaultOnResponse::new().level(Level::INFO)), + // ) .layer(cors); let port = var("CHATAPP_SERVER_PORT").unwrap_or_else(|_| "8080".to_string()); diff --git a/src/routes/messages.rs b/src/routes/messages.rs index 613d366..5620b1d 100644 --- a/src/routes/messages.rs +++ b/src/routes/messages.rs @@ -23,6 +23,7 @@ pub struct MessageRow { #[derive(sqlx::FromRow, serde::Serialize, Debug, Clone)] pub struct Message { + pub uuid: Uuid, pub sender: String, pub message_type: String, pub content: String, @@ -87,6 +88,7 @@ async fn list_messages( let messages: Vec = messages .into_iter() .map(|m| Message { + uuid: uuid::Uuid::now_v7(), sender: m.sender, message_type: m.message_type, content: m.content, @@ -136,6 +138,7 @@ async fn create_message( let sender_name = username_from_uuid(&db, claims.sub).await?; let message = Message { + uuid: uuid::Uuid::now_v7(), sender: sender_name, message_type: payload.message_type, content: payload.content,