apunkt/SurfSense
1
0
Fork 0
mirror of https://github.com/MODSetter/SurfSense.git synced 2026-05-15 18:25:18 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat: add notifications table and configure Electric SQL replication

Browse source 
- Created a new notifications table with necessary fields and indexes.
- Set up Electric SQL replication for notifications, search_source_connectors, and documents tables.
- Implemented idempotent checks for user and publication creation in the migration script.
This commit is contained in:
Anish Sarkar 2026-01-15 11:22:12 +05:30
parent f7f11877ce
commit 32b8bb33f9
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
surfsense_backend/alembic/versions/64_add_notifications_table_and_electric_replication.py → surfsense_backend/alembic/versions/66_add_notifications_table_and_electric_replication.py
View file

@ -1,7 +1,7 @@
"""Add notifications table and Electric SQL replication """Add notifications table and Electric SQL replication
Revision ID: 64 Revision ID: 66
Revises: 63 Revises: 65
Creates notifications table and sets up Electric SQL replication Creates notifications table and sets up Electric SQL replication
(user, publication, REPLICA IDENTITY FULL) for notifications, (user, publication, REPLICA IDENTITY FULL) for notifications,
@ -14,14 +14,14 @@ from alembic import context, op
# Get Electric SQL user credentials from env.py configuration # Get Electric SQL user credentials from env.py configuration
_config = context.config _config = context.config
ELECTRIC_DB_USER = _config.get_main_option("electric_db_user", "electric") ELECTRIC_DB_USER =_config.get_main_option("electric_db_user", "electric")
ELECTRIC_DB_PASSWORD = _config.get_main_option( ELECTRIC_DB_PASSWORD = _config.get_main_option(
"electric_db_password", "electric_password" "electric_db_password", "electric_password"
) )
# revision identifiers, used by Alembic. # revision identifiers, used by Alembic.
revision: str = "64" revision: str = "66"
down_revision: str | None = "63" down_revision: str | None = "65"
branch_labels: str | Sequence[str] | None = None branch_labels: str | Sequence[str] | None = None
depends_on: str | Sequence[str] | None = None depends_on: str | Sequence[str] | None = None