feat: Create unique index for RecipientId and Sender

Signed-off-by: Awiteb <a@4rs.nl>

crates/oxidetalis/src/database/in_chat_requests.rs

@@ -19,7 +19,7 @@
 use chrono::Utc;
 use oxidetalis_core::types::PublicKey;
 use oxidetalis_entities::prelude::*;
-use sea_orm::DatabaseConnection;
+use sea_orm::{sea_query::OnConflict, DatabaseConnection};
 
 use crate::errors::ServerResult;
 
@@ -40,22 +40,22 @@ impl InChatRequestsExt for DatabaseConnection {
         sender: &PublicKey,
         recipient: &UserModel,
     ) -> ServerResult<()> {
-        if recipient
+        InChatRequestsEntity::insert(InChatRequestsActiveModel {
-            .find_related(InChatRequestsEntity)
-            .filter(InChatRequestsColumn::Sender.eq(sender.to_string()))
-            .one(self)
-            .await?
-            .is_none()
-        {
-            InChatRequestsActiveModel {
             recipient_id: Set(recipient.id),
             sender: Set(sender.to_string()),
             in_on: Set(Utc::now()),
             ..Default::default()
-            }
+        })
-            .save(self)
+        .on_conflict(
+            OnConflict::columns([
+                InChatRequestsColumn::RecipientId,
+                InChatRequestsColumn::Sender,
+            ])
+            .do_nothing()
+            .to_owned(),
+        )
+        .exec(self)
         .await?;
-        }
         Ok(())
     }
 }

crates/oxidetalis_migrations/src/create_incoming_chat_requests_table.rs

@@ -29,6 +29,18 @@ pub struct Migration;
 #[async_trait::async_trait]
 impl MigrationTrait for Migration {
     async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .create_index(
+                Index::create()
+                    .if_not_exists()
+                    .name("sep_request")
+                    .table(InChatRequests::Table)
+                    .col(InChatRequests::RecipientId)
+                    .col(InChatRequests::Sender)
+                    .unique()
+                    .to_owned(),
+            )
+            .await?;
         manager
             .create_table(
                 Table::create()