adding lithen to Compliants and summary (#1)

- adding lithen to Compliants and summary (f25d6823866a8de596e0827431523b47ac4a21e8)

main.py

@@ -39,11 +39,14 @@ from email.mime.text import MIMEText
 import os
 import math
 import random
+import threading
+import Classes
+
 # Firebase ininlaziton
 cred = credentials.Certificate(
     "text-to-emotions-firebase-adminsdk-8isbn-dffbdf01e8.json")
 firebase_admin.initialize_app(cred)
-
+db = firestore.client()
 # Model summury
 model_name="abdalrahmanshahrour/auto-arabic-summarization"
 preprocessor = ArabertPreprocessor(model_name="")
@@ -209,7 +212,35 @@ def genereteotp (email):
   s.sendmail(msg['From'], msg['To'], msg.as_string())
   # terminate the SMTP session
   s.quit()    
+#Threading functions
+queuedUnSummurizedShawkas = []
+semphoreShakwas=threading.Semaphore(0)
+def summrizedshakwas():
+   global queuedUnSummurizedShawkas
+   global semphoreShakwas
+   semphoreShakwas.acquire()
+   shawka=queuedUnSummurizedShawkas.pop(0)
+   tmpdict= modelsummary(shawka.complaintbody)
+   shawka.summary=tmpdict['summary']
+   shawka.set_data()
+thread = threading.Thread(target=target_function, args=(input,))
+thread.start()
+    
+#lithening to changes of documnts
+callback_done = threading.Event()
+def on_snapshot(doc_snapshot, changes, read_time):
+    for doc in doc_snapshot:
+        global queuedUnSummurizedShawkas
+        global semphoreShakwas
+        # print(doc.to_dict())
+        shakw = Classes.Shakwa.from_dict(source=doc.to_dict())
+        shakw.complaintbody
+        if shakw.summary==None:
+            queuedUnSummurizedShawkas.append(shakw)
+            semphoreShakwas.release()
+    callback_done.set()
 
+docwatch= db.collection("complaints").on_snapshot(on_snapshot,)    
 # Main Server inilization
 app = FastAPI()