feat: notifying all users

.github/workflows/notify.yml

@@ -0,0 +1,26 @@
+name: Daily Emotion Check-In Notifications
+
+on:
+  schedule:
+    - cron: "30 3 * * *"
+    - cron: "15 11 * * *"
+  workflow_dispatch: {}
+
+jobs:
+  notify:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Call notify-all endpoint
+        run: |
+          curl -X POST "http://192.168.0.108:8080/home/notify/all" \
+            -H "accept: application/json" \
+            -H "Content-Type: application/json" \
+            -d '{
+              "title": "Jimbal Kae Sambar",
+              "body": "Chitu'\''s Sunday party",
+              "data": {
+                "type": "home_alert",
+                "message": "Chitu invited you to Sunday party!"
+              }
+            }'

alembic/versions/52828bff621c_updated_leave_status_enum_cancelled.py

@@ -0,0 +1,31 @@
+"""updated leave_status enum CANCELLED
+
+Revision ID: 52828bff621c
+Revises: d9bb355538fd
+Create Date: 2025-11-25 20:04:09.823594
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+import sqlmodel.sql.sqltypes
+
+
+# revision identifiers, used by Alembic.
+revision: str = '52828bff621c'
+down_revision: Union[str, Sequence[str], None] = 'd9bb355538fd'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Upgrade schema."""
+    pass
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    pass
+    # ### end Alembic commands ###

src/home/router.py

@@ -6,8 +6,8 @@ from sqlmodel.ext.asyncio.session import AsyncSession
 from src.core.database import get_async_session
 from src.core.schemas import BaseResponse
 from src.auth.utils import get_current_user
-from .schemas import EmotionLogCreate, EmotionLogResponse, HomeResponseData
-from .service import add_or_update_emotion, get_emotions, get_home_data
+from .schemas import EmotionLogCreate, EmotionLogResponse, HomeResponseData, BroadcastNotificationRequest
+from .service import add_or_update_emotion, get_emotions, get_home_data, send_broadcast_notification
 
 router = APIRouter(tags=["Home"])
 
@@ -42,3 +42,28 @@ async def get_user_emotions(
 ):
     data = await get_emotions(user_id, session)
     return {"status_code": 200, "data": data}
+
+@router.post("/notify/all")
+async def notify_all_users(
+    payload: BroadcastNotificationRequest,
+    session: AsyncSession = Depends(get_async_session)
+):
+    if payload.data:
+        safe_data = {k: str(v) for k, v in payload.data.items()}
+    else:
+        safe_data = {}
+
+    from .service import send_broadcast_notification
+
+    result = await send_broadcast_notification(
+        session,
+        payload.title,
+        payload.body,
+        safe_data
+    )
+
+    return {
+        "message": "Broadcast sent",
+        "devices_notified": result["sent"]
+    }
+

src/home/schemas.py

@@ -24,3 +24,8 @@ class HomeResponseData(BaseModel):
     user_name: str
     philosophy_text: str
     recent_emotions: List[EmotionLogResponse]
+
+class BroadcastNotificationRequest(BaseModel):
+    title: str
+    body: str
+    data: dict | None = None

src/home/service.py

@@ -4,7 +4,8 @@ from sqlmodel import select
 from sqlmodel.ext.asyncio.session import AsyncSession
 
 from src.core.models import EmotionLogs, Users
-
+from src.profile.models import UserDevices
+from src.notifications.fcm import send_fcm
 from .schemas import EmotionLogCreate, EmotionLogResponse, HomeResponseData
 
 PHILOSOPHY_TEXT = "Your mind is your greatest asset — train it daily."
@@ -97,3 +98,18 @@ async def get_emotions(user_id: str, session: AsyncSession):
         )
         for log in logs
     ]
+
+async def get_all_device_tokens(session):
+    stmt = select(UserDevices.device_token)
+    rows = (await session.execute(stmt)).all()
+    return [r[0] for r in rows]
+
+
+async def send_broadcast_notification(session, title, body, data=None):
+    tokens = await get_all_device_tokens(session)
+
+    if not tokens:
+        return {"sent": 0}
+
+    await send_fcm(tokens, title, body, data)
+    return {"sent": len(tokens)}