Update app.py

app.py

@@ -483,7 +483,7 @@ async def query(request: QueryRequest):
             model_name="BAAI/bge-small-en", model_kwargs={"device": "cpu"}
         )
         jif = impact_factor  # Minimum JIF value for filtering
-        publisher = preferred_publisher  # Preferred publisher list or "no preference"
+        publisher = preferred_publisher.split() if preferred_publisher else []  # Preferred publisher list or "no preference"
 
         # Load the FAISS index from local storage
         db1 = FAISS.load_local(DB_FAISS_PATH, embeddings, allow_dangerous_deserialization=True)
@@ -528,18 +528,31 @@ async def query(request: QueryRequest):
                 # Filter based on JIF and publisher preferences
                 if jif_value >= min_jif :
                     # Create the Journal model instance
-                    journal = Journal(
-                        id=len(journal_list) + 1,  # Incrementing ID for each journal
+                    if publisher and (publisher_value in publisher):
+                        print("inside pubisher match")
+                        journal = Journal(
+                            id=len(journal_list) + 1,
+                            Name=name_value,
+                            JIF=jif_value,
+                            Category=category_value,
+                            Keywords=keywords_value,
+                            Publisher=publisher_value,
+                            Decision_Time=decision_time
+                        )
+                        journal_list.append(journal)
+                    elif not publisher:
+                        journal = Journal(
+                        id=len(journal_list) + 1,
                         Name=name_value,
                         JIF=jif_value,
                         Category=category_value,
                         Keywords=keywords_value,
                         Publisher=publisher_value,
-                        Decision_Time = decision_time
-                    )
+                        Decision_Time=decision_time
+                        )
+                        journal_list.append(journal)
+                    
 
-                    # Add the journal to the list
-                    journal_list.append(journal)
         
         # Return the list of journals as a response or process it further
         return {"result": [journal.dict() for journal in journal_list]}