This repository was archived by the owner on Jun 5, 2025. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +11
-4
lines changed
Expand file tree Collapse file tree 1 file changed +11
-4
lines changed Original file line number Diff line number Diff line change 22from typing import AsyncGenerator , List
33
44import structlog
5- from fastapi import APIRouter
5+ from fastapi import APIRouter , Depends
66from fastapi .responses import StreamingResponse
77
88from codegate .dashboard .post_processing import (
1515logger = structlog .get_logger ("codegate" )
1616
1717dashboard_router = APIRouter (tags = ["Dashboard" ])
18- db_reader = DbReader ()
18+ db_reader = None
19+
20+
21+ def get_db_reader ():
22+ global db_reader
23+ if db_reader is None :
24+ db_reader = DbReader ()
25+ return db_reader
1926
2027
2128@dashboard_router .get ("/dashboard/messages" )
22- def get_messages () -> List [Conversation ]:
29+ def get_messages (db_reader : DbReader = Depends ( get_db_reader ) ) -> List [Conversation ]:
2330 """
2431 Get all the messages from the database and return them as a list of conversations.
2532 """
@@ -29,7 +36,7 @@ def get_messages() -> List[Conversation]:
2936
3037
3138@dashboard_router .get ("/dashboard/alerts" )
32- def get_alerts () -> List [AlertConversation ]:
39+ def get_alerts (db_reader : DbReader = Depends ( get_db_reader ) ) -> List [AlertConversation ]:
3340 """
3441 Get all the messages from the database and return them as a list of conversations.
3542 """
You can’t perform that action at this time.
0 commit comments