database: Add cloudfront_invalidation_queue table

Author: Turbo87

crates/crates_io_database/src/schema.rs

@@ -176,6 +176,18 @@ diesel::table! {
     }
 }
 
+diesel::table! {
+    /// Queue for batching CloudFront CDN invalidation requests
+    cloudfront_invalidation_queue (id) {
+        /// Unique identifier for each queued invalidation path
+        id -> Int8,
+        /// CloudFront path to invalidate (e.g. /crates/serde/serde-1.0.0.crate)
+        path -> Text,
+        /// Timestamp when the path was queued for invalidation
+        created_at -> Timestamptz,
+    }
+}
+
 diesel::table! {
     /// Number of downloads per crate. This was extracted from the `crates` table for performance reasons.
     crate_downloads (crate_id) {
@@ -1141,6 +1153,7 @@ diesel::allow_tables_to_appear_in_same_query!(
     api_tokens,
     background_jobs,
     categories,
+    cloudfront_invalidation_queue,
     crate_downloads,
     crate_owner_invitations,
     crate_owners,

crates/crates_io_database_dump/src/dump-db.toml

@@ -49,6 +49,11 @@ crates_cnt = "public"
 created_at = "public"
 path = "public"
 
+[cloudfront_invalidation_queue.columns]
+id = "private"
+path = "private"
+created_at = "private"
+
 [crate_downloads.columns]
 crate_id = "public"
 downloads = "public"

migrations/2025-09-03-201218_create_cloudfront_invalidation_queue/down.sql

@@ -0,0 +1,2 @@
+-- Drop the CloudFront invalidation queue table
+DROP TABLE IF EXISTS cloudfront_invalidation_queue;

migrations/2025-09-03-201218_create_cloudfront_invalidation_queue/up.sql

@@ -0,0 +1,15 @@
+-- Create table for queuing CloudFront invalidation paths
+CREATE TABLE cloudfront_invalidation_queue (
+    id BIGSERIAL PRIMARY KEY,
+    path TEXT NOT NULL,
+    created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
+);
+
+COMMENT ON TABLE cloudfront_invalidation_queue IS 'Queue for batching CloudFront CDN invalidation requests';
+COMMENT ON COLUMN cloudfront_invalidation_queue.id IS 'Unique identifier for each queued invalidation path';
+COMMENT ON COLUMN cloudfront_invalidation_queue.path IS 'CloudFront path to invalidate (e.g. /crates/serde/serde-1.0.0.crate)';
+COMMENT ON COLUMN cloudfront_invalidation_queue.created_at IS 'Timestamp when the path was queued for invalidation';
+
+-- Index for efficient batch processing (oldest first)
+CREATE INDEX idx_cloudfront_invalidation_queue_created_at
+    ON cloudfront_invalidation_queue (created_at);