kittybox-rs/migrations/0002_webmention_queue.sql


1
2
3
4
5
6
7
8
9
10
11
12
13

CREATE TABLE kittybox.incoming_webmention_queue (
       id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
       source TEXT NOT NULL,
       target TEXT NOT NULL,
       recv_timestamp TIMESTAMPTZ NOT NULL DEFAULT now(),
       attempts INTEGER NOT NULL DEFAULT 0
);

CREATE INDEX webmention_jobs_by_attempts ON kittybox.incoming_webmention_queue (attempts);

CREATE RULE notify_incoming_webmention AS
ON INSERT TO kittybox.incoming_webmention_queue
DO ALSO NOTIFY incoming_webmention;