added changes

api/webhook_routes.py

@@ -3,6 +3,7 @@ import logging
 from services.supabase_service import supabase_service
 from integrations.jira_service import JiraIntegrationService
 from typing import Dict, Any
+from datetime import datetime
 
 logger = logging.getLogger(__name__)
 
@@ -41,16 +42,18 @@ async def receive_jira_webhook(
         elif "user" in payload:
              user_email = payload["user"].get("emailAddress")
              
+        # Try to get accountId from payload to fetch full data later
+        account_id = None
+        if "user" in payload and "accountId" in payload["user"]:
+            account_id = payload["user"]["accountId"]
+        elif "issue" in payload and payload["issue"].get("fields", {}).get("assignee"):
+            account_id = payload["issue"]["fields"]["assignee"].get("accountId")
+        elif "issue" in payload and payload["issue"].get("fields", {}).get("reporter"):
+            account_id = payload["issue"]["fields"]["reporter"].get("accountId")
+
         if not user_email:
             logger.warning("Email not found in payload. Attempting to fetch user details from Jira API.")
             
-            # Try to get accountId from payload
-            account_id = None
-            if "user" in payload and "accountId" in payload["user"]:
-                account_id = payload["user"]["accountId"]
-            elif "issue" in payload and payload["issue"].get("fields", {}).get("assignee"):
-                account_id = payload["issue"]["fields"]["assignee"].get("accountId")
-                
             if account_id:
                 try:
                     jira_service = JiraIntegrationService()
@@ -74,8 +77,39 @@ async def receive_jira_webhook(
             logger.warning(f"No Supabase user found for Jira email: {user_email}")
             return {"status": "ignored", "reason": "user_not_found"}
             
+        # Fetch all data for this user
+        full_data = {
+            "webhook_event": payload,
+            "synced_at": datetime.utcnow().isoformat(),
+            "assigned_issues": [],
+            "projects": [],
+            "boards": []
+        }
+        
+        if account_id:
+            try:
+                # Initialize service (might already be initialized if we fetched email)
+                jira_service = JiraIntegrationService()
+                
+                # 1. Fetch Assigned Issues
+                issues = jira_service.get_issues_assigned_to_user(account_id)
+                full_data["assigned_issues"] = [issue.model_dump(mode='json') for issue in issues]
+                
+                # 2. Fetch All Projects
+                projects = jira_service.get_projects()
+                full_data["projects"] = [project.model_dump(mode='json') for project in projects]
+                
+                # 3. Fetch All Boards
+                boards = jira_service.get_boards()
+                full_data["boards"] = boards # get_boards returns list of dicts already
+                
+                logger.info(f"Synced for user {account_id}: {len(issues)} issues, {len(projects)} projects, {len(boards)} boards")
+                
+            except Exception as e:
+                logger.error(f"Failed to fetch complete data: {str(e)}")
+        
         # Store data
-        success = supabase_service.upsert_jira_data(firebase_id, payload)
+        success = supabase_service.upsert_jira_data(firebase_id, full_data)
         
         if success:
             return {"status": "processed", "user": firebase_id}

integrations/jira_service.py

@@ -110,6 +110,22 @@ class JiraIntegrationService:
             logger.error(f"Error fetching issues for project {project_key}: {str(e)}")
             raise
     
+    def get_issues_assigned_to_user(self, account_id: str, max_results: int = 100) -> List[JiraIssue]:
+        """Fetch all issues assigned to a specific user"""
+        try:
+            jql = f"assignee = '{account_id}' ORDER BY updated DESC"
+            issues = self._search_jql(
+                jql,
+                max_results=max_results,
+                fields=['summary', 'status', 'priority', 'assignee', 'reporter', 'created',
+                       'updated', 'resolutiondate', 'customfield_10016', 'description',
+                       'labels', 'components', 'issuetype', 'timespent', 'timeestimate']
+            )
+            return [self._parse_issue_dict(issue) for issue in issues]
+        except Exception as e:
+            logger.error(f"Error fetching issues for user {account_id}: {str(e)}")
+            return []
+    
     def get_sprint_issues(self, sprint_id: int) -> List[JiraIssue]:
         """Fetch issues for a specific sprint"""
         try: