.

app.py

@@ -57,7 +57,11 @@ async def sign_in(email, password):
         access_token = res.session.access_token
         refresh_token = res.session.refresh_token
         store_session_check = supabase.table("Stores").select("*").filter("StoreID", "eq", user_id).execute()
-        r_=createUser(username=user_id)
+        r_ = createUser(username=user_id)
+        if r_['output'] == 'SUCCESS':
+            pass
+        else:
+            return r_
         try:
             store_id = store_session_check[1][0]["StoreID"]
         except:
@@ -158,7 +162,7 @@ async def addPDFData(vectorstore: str, pdf: UploadFile = File(...)):
     if newCount < int(limit):
         client.table("ConversAI_ChatbotInfo").update({"charactercount": str(newCount)}).eq("user_id", username).eq(
             "chatbotname", chatbotname).execute()
-        return addDocuments(text=text, source = source, vectorstore=vectorstore)
+        return addDocuments(text=text, source=source, vectorstore=vectorstore)
     else:
         return {
             "output": "DOCUMENT EXCEEDING LIMITS, PLEASE TRY WITH A SMALLER DOCUMENT."
@@ -183,7 +187,7 @@ async def addText(vectorstore: str, text: str):
     if newCount < int(limit):
         client.table("ConversAI_ChatbotInfo").update({"charactercount": str(newCount)}).eq("user_id", username).eq(
             "chatbotname", chatbotname).execute()
-        return addDocuments(text=text, source = "text", vectorstore =vectorstore)
+        return addDocuments(text=text, source="text", vectorstore=vectorstore)
     else:
         return {
             "output": "WEBSITE EXCEEDING LIMITS, PLEASE TRY WITH A SMALLER DOCUMENT."
@@ -208,7 +212,7 @@ async def addText(addQaPair: AddQAPair):
     if newCount < int(limit):
         client.table("ConversAI_ChatbotInfo").update({"charactercount": str(newCount)}).eq("user_id", username).eq(
             "chatbotname", chatbotname).execute()
-        return addDocuments(text=qa, source = "Q&A Pairs", vectorstore=addQaPair.vectorstore)
+        return addDocuments(text=qa, source="Q&A Pairs", vectorstore=addQaPair.vectorstore)
     else:
         return {
             "output": "WEBSITE EXCEEDING LIMITS, PLEASE TRY WITH A SMALLER DOCUMENT."
@@ -231,7 +235,7 @@ async def addWebsite(vectorstore: str, websiteUrls: list[str]):
     if newCount < int(limit):
         client.table("ConversAI_ChatbotInfo").update({"charactercount": str(newCount)}).eq("user_id", username).eq(
             "chatbotname", chatbotname).execute()
-        return addDocuments(text=text, source = "website", vectorstore=vectorstore)
+        return addDocuments(text=text, source="website", vectorstore=vectorstore)
     else:
         return {
             "output": "WEBSITE EXCEEDING LIMITS, PLEASE TRY WITH A SMALLER DOCUMENT."
@@ -296,4 +300,4 @@ async def analyzeAndAnswer(query: str, file: UploadFile = File(...)):
     except:
         return {
             "output": "UNABLE TO ANSWER QUERY"
-        }
+        }