src/api/v1/servers/uuid/channels/uuid/socket.rs

@@ -97,6 +97,7 @@ pub async fn echo(req: HttpRequest, path: web::Path<(Uuid, Uuid)>, stream: web::
                 Ok(AggregatedMessage::Text(text)) => {
                     // echo text message
                     redis::cmd("PUBLISH").arg(&[channel_uuid.to_string(), text.to_string()]).exec_async(&mut conn).await.unwrap();
+                    channel.new_message(&data.pool, uuid, text.to_string()).await.unwrap();
                 }
 
                 Ok(AggregatedMessage::Binary(bin)) => {

src/structs.rs

@@ -186,6 +186,27 @@ impl Channel {
 
         Ok(message_builders.iter().map(|b| b.build()).collect())
     }
+
+    pub async fn new_message(&self, pool: &Pool<Postgres>, user_uuid: Uuid, message: String) -> Result<Message, HttpResponse> {
+        let message_uuid = Uuid::now_v7();
+
+        let row = sqlx::query(&format!("INSERT INTO messages (uuid, channel_uuid, user_uuid, message) VALUES ('{}', '{}', '{}', $1", message_uuid, self.uuid, user_uuid))
+            .bind(&message)
+            .execute(pool)
+            .await;
+    
+        if let Err(error) = row {
+            error!("{}", error);
+            return Err(HttpResponse::InternalServerError().finish());
+        }
+
+        Ok(Message {
+            uuid: message_uuid,
+            channel_uuid: self.uuid,
+            user_uuid,
+            message,
+        })
+    }
 }
 
 #[derive(Clone, Copy)]