Aligned with staging after HF_Feedback_7_1_25

app/assistants.py

@@ -372,7 +372,7 @@ class Assistant:
             run = self.cm.client.beta.threads.runs.create_and_poll(
                 thread_id=thread.id,
                 assistant_id=self.id,
-                model="gpt-4o-mini",
+                model="gpt-4o",
             )
             just_finished_intro = False
 

app/conversation_manager.py

@@ -120,16 +120,16 @@ class ConversationManager:
         logger.info(f"Run {run.id} {run.status} just finished intro: {just_finished_intro}", extra={"user_id": self.user.user_id, "endpoint": "run_current_thread"})
         
         if 'message' in run.metadata:
-            message = run.metadata['message']
+            info = run.metadata['message']
 
-            if message == 'start_now':
+            if info == 'start_now':
                 self.intro_done = True
                 logger.info(f"Start now", extra={"user_id": self.user.user_id, "endpoint": "run_current_thread"})
-            elif message == 'change_goal':
+            elif info == 'change_goal':
                 self.intro_done = False
                 logger.info(f"Changing goal, reset to intro assistant", extra={"user_id": self.user.user_id, "endpoint": "run_current_thread"})
             # Actually dont need this
-            elif message == 'error':
+            elif info == 'error':
                 logger.error(f"Run was cancelled due to error", extra={"user_id": self.user.user_id, "endpoint": "run_current_thread"})
                 # self.add_message_to_thread(thread.id, "assistant", run.metadata['content'])
                 # return self._get_current_thread_history(remove_system_message=False)[-1], run

app/main.py

@@ -294,7 +294,7 @@ class AssistantItem(BaseModel):
 class ChangeDateItem(BaseModel):
     user_id: str
     date: str
-    day: Optional[int] = None,
+    day: int = None
 
 class BookingItem(BaseModel):
     booking_id: str
@@ -668,7 +668,7 @@ async def add_ai_message(
 ):
     user_id = request.user_id
     message = request.message
-    logger.info("Adding AI response", extra={"user_id": user_id, "endpoint": "/add_ai_message"})
+    logger.info(f"Adding AI response: {message}", extra={"user_id": user_id, "endpoint": "/add_ai_message"})
     print_log("INFO", "Adding AI response", extra={"user_id": user_id, "endpoint": "/add_ai_message"})
  
     user = get_user(user_id)
@@ -824,6 +824,7 @@ async def fetch_daily_alert(
     logger.info(f"Upselling GG for day: {request.day}", extra={"user_id": request.user_id, "endpoint": "/upsell_gg"})
     user = get_user(request.user_id)
     response = user.get_alerts(request.date, request.day)
+    logger.info(f"Alerts fetched: {response}", extra={"user_id": request.user_id, "endpoint": "/upsell_gg"})
     return {"response": response}
 
 @app.post("/chat")

app/user.py

@@ -622,20 +622,37 @@ class User:
     @catch_error
     def get_alerts(self, date, day=None):
         # responses = []
+        logger.info(f"Getting alerts for user: {self.user_id} on {date} for {day if day else self.cumulative_plan_day}", extra={"user_id": self.user_id, "endpoint": "get_alerts"})
         if day is None:
             day = self.cumulative_plan_day
-        if day == 2 or day == 5:
+        if day == 2:
             # upsell the GG
             growth_guide = get_growth_guide(self.user_id)
         
-            upsell_prompt = "introduce WHO their grwoth guide is and how a GG can help them" if day == 2 else "Let the user know that their Growth Guide <Name> (no need to re-introduce them) is available to enhance their current growth journey with you and based on the converstaion history so far and the users personal information, challenges and goals suggest WHAT they can discuss with their growth guide."
+            upsell_prompt = "OMG the user is interested in finding out who their Growth Guide is. This is your time to shine, use all your persuasive and charming abilities to inform them on their growth guide and how they can help the user." 
 
             prompt = f"""You are an expert ambassador/salesman of Growth Guide sessions. 
-            The users' growth guide is {growth_guide}.
+            The users' growth guide is {growth_guide} and they can book a session with them via their Revelation Dashboard: {OURCOACH_DASHBOARD_URL}.
 
-            Respond with a enthusiatic hello! Then, based on the current day ({day}), succintly:
+            Respond with a enthusiatic hello!
             {upsell_prompt}
-            Frame your response like a you are telling the user a fun fact, but dont explicitly mention "fun fact".
+            Frame your response like a you are telling the user a fun fact, but dont explicitly mention "fun fact". Keep this message succint.
+            """   
+
+            # send upsell gg alert at 7pm   
+            timestamp = pd.Timestamp.now().replace(hour=19, minute=0, second=0, microsecond=0).strftime("%d-%m-%Y %a %H:%M:%S")
+        elif day == 5:
+            # upsell the GG
+            growth_guide = get_growth_guide(self.user_id)
+        
+            upsell_prompt = "Now, it is your time to shine. Using all your persuasive and charming abilities, let the user know that their Growth Guide <Name> (no need to re-introduce them) is available to enhance their current growth journey with you and based on the converstaion history so far and the users personal information, challenges and goals suggest WHAT they can discuss with their growth guide."
+
+            prompt = f"""You are an expert ambassador/salesman of Growth Guide sessions. 
+            The users' growth guide is {growth_guide} and they can book a session with them via their Revelation Dashboard: {OURCOACH_DASHBOARD_URL}.
+
+            Respond with a enthusiatic hello!
+            {upsell_prompt}
+            Frame your response like a you are telling the user a fun fact, but dont explicitly mention "fun fact". Keep this message succint.
             """   
 
             # send upsell gg alert at 7pm   
@@ -657,11 +674,7 @@ class User:
             days_left = (subscription_end_date - date).days
             logger.info(f"{subscription_end_date} - {date} =  Days left: {days_left}", extra={"user_id": self.user_id, "endpoint": "get_alerts"})
             if days_left <= 2:
-                subscription_alert = f"""** User's Subscription Information **
-                Users current subscription:
-                {subscription}
-
-                Users growth guide:
+                subscription_alert = f"""Users growth guide:
                 {growth_guide}
 
                 Alert the user that their free trial is ending in {days_left} days and Sell them to subscribe via their Revelation Dashboard: {OURCOACH_DASHBOARD_URL} to continue chatting with you, receiving personalized advice and guidance and access to Growth Guide sessions. Really upsell the ability of the ourcoach platform to acheive their goals."
@@ -686,11 +699,7 @@ class User:
             days_left = (subscription_end_date - date).days
             logger.info(f"{subscription_end_date} - {date} =  Days left: {days_left}", extra={"user_id": self.user_id, "endpoint": "get_alerts"})
             if days_left <= 0:
-                subscription_alert = f"""** User's Subscription Information **
-                Users current subscription:
-                {subscription}
-
-                Users growth guide:
+                subscription_alert = f"""Users growth guide:
                 {growth_guide}
 
                 OMG the users subscription is ending today! If you lose this user you and your family will not be able to survive!
@@ -707,11 +716,13 @@ class User:
             return []
                 
         response, run = self.conversations._run_current_thread(prompt, hidden=True)
+        logger.info(f"Response: {response}", extra={"user_id": self.user_id, "endpoint": "get_alerts"})
         message = run.metadata.get("message", "No message")
         logger.info(f"Message: {message}", extra={"user_id": self.user_id, "endpoint": "upsell_gg"})
        
         # make timestamp ISO
         response['timestamp'] = pd.to_datetime(timestamp).isoformat()
+        logger.info(f"Alert: {response}", extra={"user_id": self.user_id, "endpoint": "get_alerts"})
         return [response]
 
     @catch_error
@@ -784,7 +795,7 @@ class User:
             if len(past_sessions):
                 past_gg_summary = "\n".join([f"** Session {i+1} **\n{json.dumps(session, indent=4)}" for i, session in enumerate(past_sessions)])
                 
-            formatted_message = FINAL_SUMMARY_STATE.format(self.get_current_goal(), day, len(self.growth_plan.array), growth_guide, past_gg_summary)
+            formatted_message = FINAL_SUMMARY_STATE.format(self.get_current_goal(), self.cumulative_plan_day, final_day, growth_guide, past_gg_summary)
         elif theme == "EDUCATION_STATE":
             formatted_message = EDUCATION_STATE.format(self.get_current_goal(), self.cumulative_plan_day, final_day)
         elif theme == "FOLLUP_ACTION_STATE":