broadcast_next_meme_to_active_more_than_days_ago

src/broadcasts/service.py

@@ -56,3 +56,15 @@ async def get_users_with_language(
         WHERE language_code = '{language_code}'
     """
     return await fetch_all(text(select_query))
+
+
+async def get_users_active_more_than_days_ago(
+    days_ago: int,
+):
+    select_query = f"""
+        SELECT id
+        FROM "user"
+        WHERE last_active_at < NOW() - INTERVAL '{days_ago} DAYS'
+        AND type != 'blocked_bot'
+    """
+    return await fetch_all(text(select_query))

src/flows/broadcasts/meme.py

@@ -5,6 +5,7 @@
 
 from src.broadcasts.service import (
     get_users_active_minutes_ago,
+    get_users_active_more_than_days_ago,
 )
 from src.recommendations.meme_queue import check_queue, get_next_meme_for_user
 from src.recommendations.service import create_user_meme_reaction
@@ -67,3 +68,10 @@ async def broadcast_next_meme_to_active_1w_ago():
 async def broadcast_next_meme_to_active_4w_ago():
     users = await get_users_active_minutes_ago(4 * 7 * 24 * 60, 4 * 7 * 24 * 60 + 60)
     await broadcast_next_meme_to_users(users)
+
+
+@flow
+async def broadcast_next_meme_to_active_more_than_days_ago(days: int = 3):
+    """To call manually sometimes"""
+    users = await get_users_active_more_than_days_ago(days)
+    await broadcast_next_meme_to_users(users)