Update main.py

main.py

@@ -3,6 +3,7 @@ from pydantic import BaseModel
 from fastapi.staticfiles import StaticFiles
 from fastapi.responses import FileResponse
 from ml_service import MlProcessing
+from ml_service import process_single_comment
 import time
 
 app = FastAPI()
@@ -11,25 +12,43 @@ class TextRatingRequest(BaseModel):
     text: str
     rating: int
 
+class AllTextRatingRequest(BaseModel):
+    reviews = List[Dict[str, float]]]
+
 @app.post("/predict")
-def read_root(text_rating: TextRatingRequest):
+def predict_single_review(text_rating: TextRatingRequest):
     text = text_rating.text
     rating = text_rating.rating
     skip = False
     raw_data = {"text": text, "star_rating": rating, "skip": skip}
     start_time = time.time()
-    ml = MlProcessing(comment_dict=raw_data)
-    processed_data = ml.main()
-    spans = processed_data.get('spans', list())
-    has_sentiments = True
-    if not any(spans):
-        spans = [{'label': text, 'color': '', 'value': '', 'sentiment': '', 'score': ''}]
-        has_sentiments = False
-    processed_data['spans'] = spans
+    # ml = MlProcessing(comment_dict=raw_data)
+    # processed_data = ml.main()
+    # spans = processed_data.get('spans', list())
+    # has_sentiments = True
+    # if not any(spans):
+    #     spans = [{'label': text, 'color': '', 'value': '', 'sentiment': '', 'score': ''}]
+    #     has_sentiments = False
+    # processed_data['spans'] = spans
+    processed_data = process_single_comment(raw_data)
     end_time = time.time()
     print(f"Time taken to process the data : {end_time - start_time} seconds")
     return {"processed_data": processed_data, "has_sentiments":has_sentiments}
 
+@app.post("/predict_all")
+def predict_all_reviews(reviews: AllTextRatingRequest):
+    reviews = list(reviews)
+    skip = False
+    processed_data_list = list()
+    start_time = time.time()
+    for review in reviews:
+        raw_data = {"text":review.get("text", str()), "star_rating":review.get('star_rating', 1), "skip":skip}
+        processed_data = process_single_comment(raw_data)
+        porcessed_data_list.append(processed_data)
+    end_time = time.time()
+    print(f"Time taken to process the data : {end_time - start_time} seconds")
+    return processed_data_list
+
 app.mount("/", StaticFiles(directory="static", html=True), name="static")
 
 @app.get("/")