Update Database.py

Database.py

@@ -93,7 +93,9 @@ def get_most_common_places():
             dic_place_count[document.governorate] += 1
     return dic_place_count
 queuedUnSummurizedShawkas = []
+queuedUnLabeledFeedbacks=[]
 semphoreShakwas=threading.Semaphore(0)
+semphoreFeedback=threading.Semaphore(0)
 def summrizedshakwas():
    global queuedUnSummurizedShawkas
    global semphoreShakwas
@@ -101,16 +103,24 @@ def summrizedshakwas():
    while True:  
        semphoreShakwas.acquire()
        shawka=queuedUnSummurizedShawkas.pop(0)
-       tmpdict= models.modelsummary(shawka.complaintbody)
-       
+       tmpdict= models.modelsummary(shawka.complaintbody) 
        shawka.summary=tmpdict['summary']
        db.collection("complaints").document(shawka.id).update({"summary":shawka.summary})
-       
+def LabelingFeedback():
+    global queuedUnLabeledFeedbacks
+    global semphoreFeedback
+    global db
+    while True:
+        semphoreFeedback.acquire()
+        feedback=queuedUnLabeledFeedbacks.pop(0)
+        tmpdict=models.getlabelfeedback(feedback.feedback)
+        
 thread = threading.Thread(target=summrizedshakwas)
 thread.start()
     
 #lithening to changes of documnts
 callback_done = threading.Event()
+callback_donefeedback=threading.Event()
 def on_snapshot(doc_snapshot, changes, read_time):
     global queuedUnSummurizedShawkas
     global semphoreShakwas
@@ -131,6 +141,15 @@ def on_snapshot(doc_snapshot, changes, read_time):
     threadofcommonwords = threading.Thread(target=shakwa_common_words)
     threadofcommonwords.start()        
     callback_done.set()
-
+def on_snapshotfeedback(doc_snapshot, changes, read_time):
+    global queuedUnLabeledFeedbacks
+    global semphoreFeedback
+    for doc in doc_snapshot:
+        feedback=Classes.Feedback.from_dict(source=doc.to_dict())
+        if(feedback.label==None):
+            queuedUnLabeledFeedbacks.append(feedback)
+            semphoreFeedback.release()
+            
+    callback_donefeedback.set()
 docwatch= db.collection("complaints").on_snapshot(on_snapshot,)        
-        
+docwatch2=db.collection("feedbacks") .on_snapshot(on_snapshotfeedback,)