- updating the system to be able to work with all brands

Messaging_system/Message_generator.py

@@ -181,6 +181,9 @@ class MessageGenerator:
 Your task is to select the best 'header' and a 'message' for a {self.Core.get_instrument()} student as a push notification. 
 Based on the user instructions, you might need to **modify the selected option** very minimal and slightly to improve personalization if capable.
 **Important Note**: header < {self.Core.config_file["header_limit"]} and message < {self.Core.config_file["message_limit"]} characters.
+
+Don't use below phrases:
+- Hit the high notes / Hit those notes
 """
 
         else:

Messaging_system/MultiMessage.py

@@ -424,50 +424,6 @@ We have previously sent these push notifications to the user and The user has no
             self.Core.users_df.at[idx, k] = v
         return self.Core.users_df.loc[idx]
 
-    # =======================================================================
-    # def fetch_recommendation_data(self, user, message):
-    #     """
-    #     Extracts recommendation data from user's recsys_result and merges it into the given
-    #     message dictionary. Identical to single-message usage.
-    #
-    #     :param user: The user row (with 'recsys_result', 'recommendation', etc.).
-    #     :param message: Dictionary with at least "header" and "message".
-    #     :return: Enriched dict (header, message, content_id, web_url_path, title, thumbnail_url)
-    #     """
-    #     user_id = user["user_id"]
-    #     content_id = int(user["recommendation"])
-    #     recsys_json_str = user["recsys_result"]
-    #     recsys_data = json.loads(recsys_json_str)
-    #
-    #     # Initialize variable to store found item
-    #     found_item = None
-    #     for category, items in recsys_data.items():
-    #         for item in items:
-    #             if item.get("content_id") == content_id:
-    #                 found_item = item
-    #                 break
-    #         if found_item:
-    #             break
-    #
-    #     if not found_item:
-    #         print(f"content_id {content_id} not found in recsys_data for user_id {user_id}.")
-    #         return None
-    #
-    #     web_url_path = found_item.get("web_url_path")
-    #     title = found_item.get("title")
-    #     thumbnail_url = found_item.get("thumbnail_url")
-    #
-    #     # Construct final dictionary
-    #     output_message = {
-    #         "header": message.get("header"),
-    #         "message": message.get("message", "").replace('\\', '').replace('"', ''),
-    #         "content_id": content_id,
-    #         "web_url_path": web_url_path,
-    #         "title": title,
-    #         "thumbnail_url": thumbnail_url
-    #     }
-    #     return output_message
-
     # --------------------------------------------------------------
     # --------------------------------------------------------------
 
@@ -484,6 +440,9 @@ We have previously sent these push notifications to the user and The user has no
 Your task is to select the best 'header' and a 'message' for a {self.Core.get_instrument()} student as a push notification. 
 Based on the user instructions, you might need to **modify the selected option** very minimal and slightly to improve personalization if capable.
 **Important Note**: header < {self.Core.config_file["header_limit"]} and message < {self.Core.config_file["message_limit"]} characters.
+
+Don't use below phrases:
+- Hit the high notes / Hit those notes
 """
 
         else:

Messaging_system/Permes.py

@@ -84,6 +84,9 @@ class Permes:
 
         users_df = self._create_personalized_message(CoreConfig=personalize_message, progress_callback=progress_callback)
 
+        if users_df is None:
+            return None
+
         total_prompt_tokens = personalize_message.total_tokens["prompt_tokens"]
         total_completion_tokens = personalize_message.total_tokens["completion_tokens"]
 
@@ -175,6 +178,10 @@ class Permes:
         datacollect = DataCollector(CoreConfig)
         CoreConfig = datacollect.gather_data()
 
+        if len(CoreConfig.users_df) == 0:
+            print("There is no user to generate messages")
+            return None
+
         # generating recommendations for users, if we want to include recommendations in the message
         if CoreConfig.involve_recsys_result and CoreConfig.messaging_mode != "message":
             Recommender = LLMR(CoreConfig, random=True)

Messaging_system/PromptGenerator.py

@@ -150,14 +150,15 @@ Below is the content we want to recommend to the user:
 → Recommended Content Details:
 {user["recommendation_info"]}
 
-When incorporating this content into the message, follow these guidelines to keep the message friendly, relevant, and casual (not too scripted):
+
+When incorporating this content into the message and header, follow these guidelines to keep them friendly, relevant, and casual (not too scripted):
 
 1. **Title Usage**:
    - Refer to the **CONTENT_TITLE** naturally in the message — paraphrase or describe it, but do *not* quote it or use it verbatim.
    - Avoid making it feel like a promotion; frame it as something that *might interest* or *help* the user.
 
 2. **Content Type Context**:
-   - Mention the **CONTENT_TYPE** (e.g., course, workout, quicktip) only if it flows naturally in the message. 
+   - Mention the **CONTENT_TYPE** (e.g., course, workout, lesson) only if it flows naturally in the message. 
 
 3. **Artist/Instructor Name**:
    - If the full name of the **ARTIST** is available, mention it casually if appropriate (e.g., "led by Jordan Mitchell").
@@ -254,8 +255,8 @@ Goal: Make the recommendation feel personalized and casually relevant — not ge
 **Expected output structure:**
 
 {{
-  "header": "selected header from options",
-  "message": "selected message from options",
+  "header": "output header considering instructions",
+  "message": "output message considering instructions",
 }}
 
 {general_instructions}

Messaging_system/SnowFlakeConnection.py

@@ -243,6 +243,12 @@ class SnowFlakeConn:
     def close_connection(self):
         self.session.close()
 
+    def get_inactive_users_by_brand(self, brand):
+        if brand == "singeo":
+            return self.get_users_in_campaign(brand=brand)
+        else:
+            return self._get_inactive_users(brand=brand)
+
     # ===============================================================
     def get_users_in_campaign(self, brand, campaign_name="Singeo - Inactive Members (for 3 days) - Re-engagement", stage=1, campaign_view='singeo_re_engagement'):
         """
@@ -354,4 +360,33 @@ JOIN latest_msg l
             """
 
         users_df = self.run_read_query(query, data=f"{brand}_campaign")
-        return users_df
+        return users_df
+
+    def _get_inactive_users(self, brand: str):
+        """
+        Return up to 50 USER_IDs in the requested brand whose last interaction is > 5 days ago,
+        restricted to users that exist in ONLINE_RECSYS.PREPROCESSED.USERS.
+        """
+        query = f"""
+        WITH last_touch AS (
+          SELECT
+            USER_ID,
+            MAX(TIMESTAMP) AS last_interaction_at
+          FROM ONLINE_RECSYS.PREPROCESSED.RECSYS_INTEACTIONS
+          WHERE BRAND = '{brand}'
+          GROUP BY USER_ID
+        )
+        SELECT lt.USER_ID
+        FROM last_touch lt
+        INNER JOIN ONLINE_RECSYS.PREPROCESSED.USERS u
+          ON u.USER_ID = lt.USER_ID
+         AND u.BRAND = '{brand}'
+        WHERE lt.last_interaction_at < DATEADD('day', -5, CURRENT_TIMESTAMP())
+        ORDER BY lt.last_interaction_at ASC
+        LIMIT 50;
+        """
+
+        users_df = self.run_read_query(query, data=f"{brand}_campaign")
+        return users_df
+
+

app.py

@@ -161,7 +161,7 @@ with st.sidebar:
         st.session_state.session = Session.builder.configs(conn).create()
 
         snowflake = SnowFlakeConn(session=st.session_state.session, brand=st.session_state.brand)
-        st.session_state.data = snowflake.get_users_in_campaign(brand=st.session_state.brand)
+        st.session_state.data = snowflake.get_inactive_users_by_brand(brand=st.session_state.brand)
         st.success("File loaded!")
 
         st.markdown("---")
@@ -297,6 +297,10 @@ with tab2:
                 personalization=st.session_state.personalization
             )
 
+            if df_msg is None:
+                st.write("##### 👤 There were no eligible user to generate messages. Consider setting higher number of users.")
+
+
             # ─ cache output
             st.session_state.users_message = df_msg
             st.session_state.csv_output = df_msg.to_csv(