fix: idempotency per-client

migrations/1699887339_notifications-primary-key-includes-client-id.sql

@@ -0,0 +1,8 @@
+ALTER TABLE public.notifications
+DROP CONSTRAINT notifications_pkey;
+
+ALTER TABLE public.notifications
+ALTER COLUMN id SET not null;
+
+ALTER TABLE public.notifications
+ADD PRIMARY KEY (id, client_id);

src/stores/notification.rs

@@ -48,11 +48,12 @@ impl NotificationStore for sqlx::PgPool {
         payload: &MessagePayload,
     ) -> stores::Result<Notification> {
         let res = sqlx::query_as::<sqlx::postgres::Postgres, Notification>(
-            "INSERT INTO public.notifications (id, tenant_id, client_id, last_payload)
-VALUES ($1, $2, $3, $4)
-ON CONFLICT (id)
-    DO UPDATE SET last_received_at  = now()
-RETURNING *;",
+            "
+            INSERT INTO public.notifications (id, tenant_id, client_id, last_payload)
+            VALUES ($1, $2, $3, $4)
+            ON CONFLICT (id, client_id)
+                DO UPDATE SET last_received_at  = now()
+            RETURNING *;",
         )
         .bind(id)
         .bind(tenant_id)