mirror of
https://github.com/MODSetter/SurfSense.git
synced 2026-07-06 22:12:12 +02:00
d948b769ba
Flip search_space_id -> workspace_id and the workspace relationship/back_populates
in the automations, file_storage, notifications, and podcasts persistence models,
and drop the Phase 1 Column("workspace_id", ...) shim. Full SQLAlchemy mapper
configuration now passes (db.py + satellites consistent).
72 lines
1.9 KiB
Python
72 lines
1.9 KiB
Python
"""Per-user inbox notifications, synced to clients via Zero."""
|
|
|
|
from __future__ import annotations
|
|
|
|
from datetime import UTC, datetime
|
|
|
|
from sqlalchemy import (
|
|
TIMESTAMP,
|
|
Boolean,
|
|
Column,
|
|
ForeignKey,
|
|
Index,
|
|
Integer,
|
|
String,
|
|
Text,
|
|
text,
|
|
)
|
|
from sqlalchemy.dialects.postgresql import JSONB, UUID
|
|
from sqlalchemy.orm import relationship
|
|
|
|
from app.db import BaseModel, TimestampMixin
|
|
|
|
|
|
class Notification(BaseModel, TimestampMixin):
|
|
__tablename__ = "notifications"
|
|
__table_args__ = (
|
|
# Serves unread-count queries.
|
|
Index(
|
|
"ix_notifications_user_read_type_created",
|
|
"user_id",
|
|
"read",
|
|
"type",
|
|
"created_at",
|
|
),
|
|
# Serves the paginated inbox list query.
|
|
Index(
|
|
"ix_notifications_user_workspace_created",
|
|
"user_id",
|
|
"workspace_id",
|
|
"created_at",
|
|
),
|
|
)
|
|
|
|
user_id = Column(
|
|
UUID(as_uuid=True),
|
|
ForeignKey("user.id", ondelete="CASCADE"),
|
|
nullable=False,
|
|
index=True,
|
|
)
|
|
workspace_id = Column(
|
|
Integer,
|
|
ForeignKey("workspaces.id", ondelete="CASCADE"),
|
|
nullable=True,
|
|
index=True,
|
|
)
|
|
type = Column(String(50), nullable=False, index=True)
|
|
title = Column(String(200), nullable=False)
|
|
message = Column(Text, nullable=False)
|
|
read = Column(
|
|
Boolean, nullable=False, default=False, server_default=text("false"), index=True
|
|
)
|
|
notification_metadata = Column("metadata", JSONB, nullable=True, default={})
|
|
updated_at = Column(
|
|
TIMESTAMP(timezone=True),
|
|
nullable=True,
|
|
default=lambda: datetime.now(UTC),
|
|
onupdate=lambda: datetime.now(UTC),
|
|
index=True,
|
|
)
|
|
|
|
user = relationship("User", back_populates="notifications")
|
|
workspace = relationship("Workspace", back_populates="notifications")
|