feat: mailbox

backend/migrations/20251028105101_mailbox.down.sql

@@ -0,0 +1,5 @@
+-- Add down migration script here
+DROP TABLE IF EXISTS mailbox;
+DROP TYPE IF EXISTS mailbox_type;
+DROP SEQUENCE IF EXISTS mailbox_id_seq;
+DROP INDEX IF EXISTS idx_mailbox_type_mailbox_id_message_id;

backend/migrations/20251028105101_mailbox.up.sql

@@ -0,0 +1,19 @@
+-- Add up migration script here
+CREATE SEQUENCE IF NOT EXISTS mailbox_id_seq;
+
+CREATE TYPE mailbox_type AS ENUM (
+    'trigger',
+    'debouncing_stale_data'
+);
+
+CREATE TABLE mailbox(
+    message_id   BIGINT DEFAULT nextval('mailbox_id_seq') PRIMARY KEY, -- Also indicates position in stack
+    mailbox_id   TEXT, -- Can be NULL 
+    workspace_id character varying(50) NOT NULL,
+    type         mailbox_type NOT NULL, -- Type of mailbox
+    created_at   TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(), 
+    payload      JSONB NOT NULL -- Payload of specific message
+);
+
+CREATE INDEX idx_mailbox_type_mailbox_id_message_id 
+ON mailbox(type, mailbox_id, message_id ASC);

backend/windmill-common/src/lib.rs

@@ -59,6 +59,7 @@ pub mod git_sync_ee;
 pub mod git_sync_oss;
 pub mod jobs;
 pub mod jwt;
+pub mod mailbox;
 pub mod mcp_client;
 pub mod more_serde;
 pub mod oauth2;