Notification Schema¶

notification schema 는 알림 발송 요청과 사용자 선호도를 저장한다.

Schema purpose¶

• PostgreSQL schema — notification
• Corresponding domain — engine/notification/
• sqlc package — db/queries/notification/

Event consumer 가 이벤트 수신 시 NotificationRequest 를 INSERT 하고, asynq 워커가 pickup 하여 발송.

Tables¶

notification.requests¶

발송 요청/이력.

CREATE TABLE notification.requests (
    id               UUID PRIMARY KEY,
    recipient_type   TEXT NOT NULL CHECK (recipient_type IN ('user_dm', 'guild_audit_channel', 'dashboard_toast')),
    recipient_id     TEXT NOT NULL,
    guild_id         UUID REFERENCES guild.guilds(id),
    template_key     TEXT NOT NULL,
    payload          JSONB NOT NULL,
    state            TEXT NOT NULL CHECK (state IN ('pending', 'sent', 'failed', 'suppressed')),
    attempt_count    INTEGER NOT NULL DEFAULT 0,
    last_error       TEXT,
    scheduled_at     TIMESTAMPTZ NOT NULL DEFAULT NOW(),
    sent_at          TIMESTAMPTZ,
    created_at       TIMESTAMPTZ NOT NULL DEFAULT NOW()
);

Columns

Indexes

Foreign keys

Invariants

• attempt_count <= 3
• state = 'sent' 이면 sent_at IS NOT NULL
• template_key 는 코드베이스 정의와 일치 (CI 검증)

notification.preferences¶

사용자별 알림 선호도.

CREATE TABLE notification.preferences (
    user_id                   UUID PRIMARY KEY REFERENCES identity.users(id),
    dm_enabled                BOOLEAN NOT NULL DEFAULT TRUE,
    payment_notifications     BOOLEAN NOT NULL DEFAULT TRUE,
    recovery_notifications    BOOLEAN NOT NULL DEFAULT TRUE,
    antinuke_notifications    BOOLEAN NOT NULL DEFAULT TRUE,
    marketing_notifications   BOOLEAN NOT NULL DEFAULT TRUE,
    updated_at                TIMESTAMPTZ NOT NULL DEFAULT NOW()
);

Columns

Foreign keys

Invariants

• 신규 User 등록 시 기본값으로 자동 생성 (또는 조회 시 lazy create)
• AntiNuke 긴급 알림(antinuke.triggered) 은 이 선호도를 무시할 수 있음 (애플리케이션 레이어)

Relationships¶

erDiagram
    USERS ||--|| PREFERENCES : has
    USERS ||--o{ REQUESTS : "recipient of"
    GUILDS ||--o{ REQUESTS : "related to"

Cross-schema references¶

Query patterns¶

• InsertRequest — consumer 가 이벤트 수신 시
• FetchPendingRequests — asynq 워커 pickup
• MarkSent — 발송 성공
• IncrementAttempt — 재시도 카운트
• MarkFailed — 최대 시도 초과
• GetPreference — 발송 전 확인
• UpsertPreference — 사용자 대시보드에서 수정
• DeleteOldRequests — 90일 경과 정리 cron

Data retention¶

• Requests — 90일 후 삭제 (cron)
• Preferences — User CASCADE

Migration history¶

See also¶

• domain/notification.md — Notification 도메인
• architecture/event-flow.md — Subscribers 컬럼
• data/identity-schema.md — 참조하는 User
• data/guild-schema.md — 참조하는 Guild