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 2
2
from typing import AsyncGenerator , List
3
3
4
4
import structlog
5
- from fastapi import APIRouter
5
+ from fastapi import APIRouter , Depends
6
6
from fastapi .responses import StreamingResponse
7
7
8
8
from codegate .dashboard .post_processing import (
15
15
logger = structlog .get_logger ("codegate" )
16
16
17
17
dashboard_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
19
26
20
27
21
28
@dashboard_router .get ("/dashboard/messages" )
22
- def get_messages () -> List [Conversation ]:
29
+ def get_messages (db_reader : DbReader = Depends ( get_db_reader ) ) -> List [Conversation ]:
23
30
"""
24
31
Get all the messages from the database and return them as a list of conversations.
25
32
"""
@@ -29,7 +36,7 @@ def get_messages() -> List[Conversation]:
29
36
30
37
31
38
@dashboard_router .get ("/dashboard/alerts" )
32
- def get_alerts () -> List [AlertConversation ]:
39
+ def get_alerts (db_reader : DbReader = Depends ( get_db_reader ) ) -> List [AlertConversation ]:
33
40
"""
34
41
Get all the messages from the database and return them as a list of conversations.
35
42
"""
You can’t perform that action at this time.
0 commit comments