Update Database.py

Database.py

@@ -30,8 +30,8 @@ all_reviews = db.collection("complaints")
 # Create a query against the collection
 documents_to_summarize = all_reviews.get()
 feedbacks = db.collection("feedbacks").where("feedbacks","!=",'').get()
-
-
+allfeedbacks=[]
+emotioncount={"anger":0,"sadness":0,"joy":0,"surprise":0,"love":0,"sympathy":0,"fear":0}
 documents=[]
 documnetskey=set()
 #get all documents for today that have no summary
@@ -151,11 +151,16 @@ def on_snapshot(doc_snapshot, changes, read_time):
 def on_snapshotfeedback(doc_snapshot, changes, read_time):
     global queuedUnLabeledFeedbacks
     global semphoreFeedback
+    global allfeedbacks
     for doc in doc_snapshot:
         feedback=Classes.Feedback.from_dict(source=doc.to_dict())
+        
         if(feedback.label==None):
             queuedUnLabeledFeedbacks.append(feedback)
             semphoreFeedback.release()
+        elif feedback not in allfeedbacks:
+            allfeedbacks.append(feedback)
+            emotioncount[feedback.label]+=1
             
     callback_donefeedback.set()
 docwatch= db.collection("complaints").on_snapshot(on_snapshot,)