fix(db): run in autocommit mode (#46)

Author: gagantrivedi

src/sse.py

@@ -26,6 +26,8 @@
 
 engine = create_async_engine("sqlite+aiosqlite:///:memory:", future=True)
 
+engine.update_execution_options(isolation_level="AUTOCOMMIT")
+
 router = APIRouter()
 
 
@@ -77,7 +79,6 @@ async def queue_environment_changes(environment_key: str):
             """INSERT OR REPLACE INTO environment(key) VALUES(:environment_key)"""
         )
         await session.execute(statement, {"environment_key": environment_key})
-        await session.commit()
 
 
 @router.post(
@@ -119,7 +120,6 @@ async def did_environment_change() -> bool:
                 await session.execute(
                     delete(Identity).where(Identity.environment_key == environment_key)
                 )
-            await session.commit()
             return environment_updated
 
         async def get_updated_identities() -> List[str]:
@@ -134,7 +134,6 @@ async def get_updated_identities() -> List[str]:
             await session.execute(
                 delete(Identity).where(Identity.environment_key == environment_key)
             )
-            await session.commit()
 
             return hashed_identities
 

src/sse_models.py

@@ -39,4 +39,3 @@ async def put_identities(
                     statement,
                     {"identifier": identifier, "environment_key": environment_key},
                 )
-            await session.commit()