apunkt/SurfSense
1
0
Fork 0
mirror of https://github.com/MODSetter/SurfSense.git synced 2026-06-26 21:39:43 +02:00
Code Issues Projects Releases Packages Wiki Activity

chore: ran backend linting

Browse source
This commit is contained in:
Anish Sarkar 2026-01-15 04:26:34 +05:30
parent 31a5581af1
commit 94e65129cd
2 changed files with 14 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

4
surfsense_backend/alembic/env.py
View file

@ -27,9 +27,7 @@ if database_url:
# Electric SQL user credentials - centralized configuration for migrations # Electric SQL user credentials - centralized configuration for migrations
# These are used by migrations that set up Electric SQL replication # These are used by migrations that set up Electric SQL replication
config.set_main_option( config.set_main_option("electric_db_user", os.getenv("ELECTRIC_DB_USER", "electric"))
"electric_db_user", os.getenv("ELECTRIC_DB_USER", "electric")
)
config.set_main_option( config.set_main_option(
"electric_db_password", os.getenv("ELECTRIC_DB_PASSWORD", "electric_password") "electric_db_password", os.getenv("ELECTRIC_DB_PASSWORD", "electric_password")
) )

20
surfsense_backend/alembic/versions/64_add_notifications_table_and_electric_replication.py
View file

@ -15,7 +15,9 @@ 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", "electric_password") ELECTRIC_DB_PASSWORD = _config.get_main_option(
"electric_db_password", "electric_password"
)
# revision identifiers, used by Alembic. # revision identifiers, used by Alembic.
revision: str = "64" revision: str = "64"
@ -53,7 +55,7 @@ def upgrade() -> None:
# ===================================================== # =====================================================
# Electric SQL Setup - User and Publication # Electric SQL Setup - User and Publication
# ===================================================== # =====================================================
# Create Electric SQL replication user if not exists # Create Electric SQL replication user if not exists
op.execute( op.execute(
f""" f"""
@ -66,7 +68,7 @@ def upgrade() -> None:
$$; $$;
""" """
) )
# Grant necessary permissions to electric user # Grant necessary permissions to electric user
op.execute( op.execute(
f""" f"""
@ -82,9 +84,13 @@ def upgrade() -> None:
op.execute(f"GRANT USAGE ON SCHEMA public TO {ELECTRIC_DB_USER};") op.execute(f"GRANT USAGE ON SCHEMA public TO {ELECTRIC_DB_USER};")
op.execute(f"GRANT SELECT ON ALL TABLES IN SCHEMA public TO {ELECTRIC_DB_USER};") op.execute(f"GRANT SELECT ON ALL TABLES IN SCHEMA public TO {ELECTRIC_DB_USER};")
op.execute(f"GRANT SELECT ON ALL SEQUENCES IN SCHEMA public TO {ELECTRIC_DB_USER};") op.execute(f"GRANT SELECT ON ALL SEQUENCES IN SCHEMA public TO {ELECTRIC_DB_USER};")
op.execute(f"ALTER DEFAULT PRIVILEGES IN SCHEMA public GRANT SELECT ON TABLES TO {ELECTRIC_DB_USER};") op.execute(
op.execute(f"ALTER DEFAULT PRIVILEGES IN SCHEMA public GRANT SELECT ON SEQUENCES TO {ELECTRIC_DB_USER};") f"ALTER DEFAULT PRIVILEGES IN SCHEMA public GRANT SELECT ON TABLES TO {ELECTRIC_DB_USER};"
)
op.execute(
f"ALTER DEFAULT PRIVILEGES IN SCHEMA public GRANT SELECT ON SEQUENCES TO {ELECTRIC_DB_USER};"
)
# Create the publication if not exists # Create the publication if not exists
op.execute( op.execute(
""" """
@ -101,7 +107,7 @@ def upgrade() -> None:
# ===================================================== # =====================================================
# Electric SQL Setup - Table Configuration # Electric SQL Setup - Table Configuration
# ===================================================== # =====================================================
# Set REPLICA IDENTITY FULL (required by Electric SQL for replication) # Set REPLICA IDENTITY FULL (required by Electric SQL for replication)
op.execute("ALTER TABLE notifications REPLICA IDENTITY FULL;") op.execute("ALTER TABLE notifications REPLICA IDENTITY FULL;")
op.execute("ALTER TABLE search_source_connectors REPLICA IDENTITY FULL;") op.execute("ALTER TABLE search_source_connectors REPLICA IDENTITY FULL;")