Files
reflector/server/reflector/db/__init__.py
2024-08-28 13:44:24 +02:00

28 lines
683 B
Python

import databases
import sqlalchemy
from reflector.events import subscribers_shutdown, subscribers_startup
from reflector.settings import settings
database = databases.Database(settings.DATABASE_URL)
metadata = sqlalchemy.MetaData()
# import models
import reflector.db.meetings # noqa
import reflector.db.rooms # noqa
import reflector.db.transcripts # noqa
engine = sqlalchemy.create_engine(
settings.DATABASE_URL, connect_args={"check_same_thread": False}
)
metadata.create_all(engine)
@subscribers_startup.append
async def database_connect(_):
await database.connect()
@subscribers_shutdown.append
async def database_disconnect(_):
await database.disconnect()