Add indices for event keys in feed queries

Changelog: enchancement

Author: James Youngblood

services/server/migration/src/lib.rs

@@ -14,6 +14,7 @@ mod m20260604_000001_add_content_label_table;
 mod m20260617_000001_add_notification_table;
 mod m20260617_000002_drop_push_token_table;
 mod m20260618_000001_timestamps_to_timestamptz;
+mod m20260625_000001_add_event_key_indices;
 
 pub struct Migrator;
 
@@ -35,6 +36,7 @@ impl MigratorTrait for Migrator {
             Box::new(m20260617_000001_add_notification_table::Migration),
             Box::new(m20260617_000002_drop_push_token_table::Migration),
             Box::new(m20260618_000001_timestamps_to_timestamptz::Migration),
+            Box::new(m20260625_000001_add_event_key_indices::Migration),
         ]
     }
 }

services/server/migration/src/m20260625_000001_add_event_key_indices.rs

@@ -0,0 +1,100 @@
+use ::entity::{
+    content_delete_model, content_label_model, content_reaction_model,
+};
+use sea_orm_migration::prelude::*;
+
+/// `content_delete`, `content_reaction`, and `content_label` are all
+/// queried to match events, but have no index over the `event_key_*`
+/// columns (see `tombstone::list_tombstones_for_event_keys`). We add
+/// an index so that matching events does not require a sequential scan.
+///
+/// Each index mirrors the column order of the existing
+/// `idx-events-event_key` unique index on the `events` table
+/// (collection, identity, public_key_type, public_key, sequence) but is
+/// **non-unique** because a single target event can have multiple
+/// delete / reaction / label rows.
+#[derive(DeriveMigrationName)]
+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("content_delete_event_key_idx")
+                    .table(content_delete_model::Entity)
+                    .col(content_delete_model::Column::EventKeyCollection)
+                    .col(content_delete_model::Column::EventKeyIdentity)
+                    .col(content_delete_model::Column::EventKeyPublicKeyType)
+                    .col(content_delete_model::Column::EventKeyPublicKey)
+                    .col(content_delete_model::Column::EventKeySequence)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .create_index(
+                Index::create()
+                    .if_not_exists()
+                    .name("content_reaction_event_key_idx")
+                    .table(content_reaction_model::Entity)
+                    .col(content_reaction_model::Column::EventKeyCollection)
+                    .col(content_reaction_model::Column::EventKeyIdentity)
+                    .col(content_reaction_model::Column::EventKeyPublicKeyType)
+                    .col(content_reaction_model::Column::EventKeyPublicKey)
+                    .col(content_reaction_model::Column::EventKeySequence)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .create_index(
+                Index::create()
+                    .if_not_exists()
+                    .name("content_label_event_key_idx")
+                    .table(content_label_model::Entity)
+                    .col(content_label_model::Column::EventKeyCollection)
+                    .col(content_label_model::Column::EventKeyIdentity)
+                    .col(content_label_model::Column::EventKeyPublicKeyType)
+                    .col(content_label_model::Column::EventKeyPublicKey)
+                    .col(content_label_model::Column::EventKeySequence)
+                    .to_owned(),
+            )
+            .await?;
+
+        Ok(())
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .drop_index(
+                Index::drop()
+                    .name("content_label_event_key_idx")
+                    .table(content_label_model::Entity)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .drop_index(
+                Index::drop()
+                    .name("content_reaction_event_key_idx")
+                    .table(content_reaction_model::Entity)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .drop_index(
+                Index::drop()
+                    .name("content_delete_event_key_idx")
+                    .table(content_delete_model::Entity)
+                    .to_owned(),
+            )
+            .await?;
+
+        Ok(())
+    }
+}