Spaces:
Running
Running
Updating
Browse files- db_helper.py +13 -0
db_helper.py
CHANGED
|
@@ -247,7 +247,20 @@ class DB:
|
|
| 247 |
.eq("id", reminder_id)\
|
| 248 |
.execute()
|
| 249 |
return result.data[0] if result.data else None
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 250 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 251 |
|
| 252 |
# ==================== COMPREHENSIVE TESTS ====================
|
| 253 |
|
|
|
|
| 247 |
.eq("id", reminder_id)\
|
| 248 |
.execute()
|
| 249 |
return result.data[0] if result.data else None
|
| 250 |
+
def update_pending_questions(self, journey_id: str, pending_list: List[Dict]):
|
| 251 |
+
"""Save pending MCQs as jsonb array"""
|
| 252 |
+
self.client.table("journeys")\
|
| 253 |
+
.update({"pending_questions": pending_list})\
|
| 254 |
+
.eq("id", journey_id)\
|
| 255 |
+
.execute()
|
| 256 |
|
| 257 |
+
def get_pending_questions(self, journey_id: str) -> List[Dict]:
|
| 258 |
+
"""Load pending MCQs from jsonb"""
|
| 259 |
+
result = self.client.table("journeys")\
|
| 260 |
+
.select("pending_questions")\
|
| 261 |
+
.eq("id", journey_id)\
|
| 262 |
+
.execute()
|
| 263 |
+
return result.data[0]["pending_questions"] if result.data and result.data[0].get("pending_questions") else []
|
| 264 |
|
| 265 |
# ==================== COMPREHENSIVE TESTS ====================
|
| 266 |
|