added webhooks for jira

.env.example

@@ -1,28 +0,0 @@
-# Mock Data Configuration
-USE_MOCK_DATA=False
-
-# Jira Configuration (OPTIONAL - only needed for mock/testing mode)
-# For production, users will provide these via /auth/login endpoint
-JIRA_SERVER_URL=https://yourcompany.atlassian.net
-JIRA_EMAIL=user@company.com
-JIRA_API_TOKEN=your_jira_api_token_here
-
-# Database
-DATABASE_URL=sqlite:///./enterprise_intelligence.db
-
-# Redis (Optional - for caching)
-REDIS_URL=redis://localhost:6379/0
-
-# API Configuration
-API_HOST=0.0.0.0
-API_PORT=8000
-DEBUG=True
-
-# Security (IMPORTANT: Change in production!)
-SECRET_KEY=your-secret-key-change-this-in-production-use-long-random-string
-ALGORITHM=HS256
-ACCESS_TOKEN_EXPIRE_MINUTES=30
-
-# GitHub Configuration (Optional)
-GITHUB_TOKEN=
-GITHUB_ORG=

API_ENDPOINTS.md

@@ -0,0 +1,555 @@
+# API Endpoints Reference
+
+Complete reference for all API endpoints in the Enterprise Delivery & Workforce Intelligence API.
+
+**Base URL (Hugging Face):** `https://rudraaaa76-jira-api.hf.space`  
+**Base URL (Local):** `http://localhost:8000`
+
+**Authentication:** All endpoints (except `/auth/login`) require Bearer token authentication.
+
+---
+
+## Table of Contents
+
+1. [Authentication Endpoints](#authentication-endpoints)
+2. [Jira Data Endpoints](#jira-data-endpoints)
+3. [Intelligence & Analytics Endpoints](#intelligence--analytics-endpoints)
+
+---
+
+## Authentication Endpoints
+
+### POST /auth/login
+**Description:** Authenticate with Jira credentials and receive JWT token  
+**Authentication:** None required  
+**Request Body:**
+```json
+{
+  "jira_email": "rudraparmar1309@gmail.com",
+  "jira_api_token": "your_jira_api_token",
+  "jira_server_url": "https://rudraparmar1309-1770450259652.atlassian.net"
+}
+```
+**Response:**
+```json
+{
+  "access_token": "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...",
+  "token_type": "bearer",
+  "expires_in": 1800
+}
+```
+
+### GET /auth/me
+**Description:** Get current authenticated user information  
+**Authentication:** Required  
+**Response:**
+```json
+{
+  "jira_email": "rudraparmar1309@gmail.com",
+  "jira_server_url": "https://rudraparmar1309-1770450259652.atlassian.net",
+  "authenticated": true
+}
+```
+
+---
+
+## Jira Data Endpoints
+
+### Projects
+
+#### GET /jira/projects
+**Description:** Get all Jira projects  
+**Authentication:** Required  
+**Response:** Array of project objects
+```json
+[
+  {
+    "project_key": "PROJ",
+    "project_name": "Project Name",
+    "project_id": "10000",
+    "lead": "User Name",
+    "description": "Project description"
+  }
+]
+```
+
+#### GET /jira/projects/{project_key}/issues
+**Description:** Get all issues for a specific project  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key (e.g., "PROJ")
+
+**Query Parameters:**
+- `max_results` (integer, optional) - Maximum number of results (1-1000, default: 100)
+- `start_date` (string, optional) - Filter from date (ISO format: YYYY-MM-DD)
+- `end_date` (string, optional) - Filter to date (ISO format: YYYY-MM-DD)
+
+**Example:** `/jira/projects/PROJ/issues?max_results=50&start_date=2026-01-01`
+
+#### GET /jira/projects/{project_key}/team-members
+**Description:** Get all team members for a project  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key
+
+**Response:** Array of team member objects
+
+#### GET /jira/projects/{project_key}/worklogs
+**Description:** Get worklogs for a project  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key
+
+**Query Parameters:**
+- `start_date` (string, optional) - Start date (ISO format)
+- `end_date` (string, optional) - End date (ISO format)
+
+### Boards
+
+#### GET /jira/boards
+**Description:** Get all Jira boards  
+**Authentication:** Required  
+**Response:** Array of board objects
+```json
+[
+  {
+    "id": 1,
+    "name": "Board Name",
+    "type": "scrum",
+    "self": "https://..."
+  }
+]
+```
+
+#### GET /jira/boards/{board_id}/sprints
+**Description:** Get all sprints for a board  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Response:** Array of sprint objects
+
+#### GET /jira/boards/{board_id}/active-sprint
+**Description:** Get the currently active sprint for a board  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Response:** Sprint object or null
+
+#### GET /jira/boards/{board_id}/configuration
+**Description:** Get board configuration including columns and settings  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+#### GET /jira/boards/{board_id}/backlog
+**Description:** Get backlog issues for a board  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Query Parameters:**
+- `max_results` (integer, optional) - Maximum results (1-500, default: 100)
+
+### Sprints
+
+#### GET /jira/sprints/{sprint_id}/issues
+**Description:** Get all issues in a specific sprint  
+**Authentication:** Required  
+**Path Parameters:**
+- `sprint_id` (integer) - Sprint ID
+
+**Response:** Array of issue objects
+
+### Issues
+
+#### GET /jira/issues/{issue_key}
+**Description:** Get a specific issue by key  
+**Authentication:** Required  
+**Path Parameters:**
+- `issue_key` (string) - Issue key (e.g., "PROJ-123")
+
+**Response:** Issue object
+
+#### GET /jira/issues/{issue_key}/transitions
+**Description:** Get available transitions for an issue  
+**Authentication:** Required  
+**Path Parameters:**
+- `issue_key` (string) - Issue key
+
+**Response:** Array of transition objects
+
+#### POST /jira/issues/{issue_key}/transition
+**Description:** Move an issue to a different status  
+**Authentication:** Required  
+**Path Parameters:**
+- `issue_key` (string) - Issue key
+
+**Query Parameters:**
+- `transition_name` (string, required) - Name of transition to execute
+
+**Response:**
+```json
+{
+  "success": true,
+  "message": "Issue PROJ-123 transitioned to Done"
+}
+```
+
+### Kanban Boards
+
+#### GET /jira/kanban/boards
+**Description:** Get all Kanban boards with column configurations  
+**Authentication:** Required  
+**Response:** Array of Kanban board objects with columns
+
+#### GET /jira/kanban/boards/{board_id}
+**Description:** Get a specific Kanban board by ID  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Response:** Kanban board object with columns
+
+#### GET /jira/kanban/boards/{board_id}/issues
+**Description:** Get issues for a Kanban board grouped by columns  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Response:** Array of column objects with their issues
+
+---
+
+## Intelligence & Analytics Endpoints
+
+### Delivery Metrics
+
+#### GET /intelligence/delivery-health/{project_key}
+**Description:** Get delivery health metrics for a project or sprint  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key
+
+**Query Parameters:**
+- `board_id` (integer, optional) - Board ID for sprint context
+- `sprint_id` (integer, optional) - Specific sprint ID
+- `start_date` (string, optional) - Start date (ISO format)
+- `end_date` (string, optional) - End date (ISO format)
+
+**Response:**
+```json
+{
+  "velocity": 45.5,
+  "completion_rate": 87.5,
+  "avg_cycle_time_days": 3.2,
+  "sprint_health_score": 8.5,
+  "total_issues": 120,
+  "completed_issues": 105,
+  "in_progress_issues": 10,
+  "blocked_issues": 5
+}
+```
+
+### Productivity Metrics
+
+#### GET /intelligence/productivity/{project_key}
+**Description:** Get productivity metrics for all team members  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key
+
+**Query Parameters:**
+- `start_date` (string, optional) - Start date (default: 14 days ago)
+- `end_date` (string, optional) - End date (default: today)
+
+**Response:** Array of productivity metrics per team member
+```json
+[
+  {
+    "team_member_id": "user123",
+    "team_member_name": "John Doe",
+    "issues_completed": 12,
+    "story_points_completed": 34,
+    "avg_completion_time_days": 2.5,
+    "work_hours_logged": 80,
+    "productivity_score": 8.7
+  }
+]
+```
+
+### Cost Efficiency
+
+#### GET /intelligence/cost-efficiency/{project_key}
+**Description:** Get cost efficiency metrics for a project  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key
+
+**Query Parameters:**
+- `start_date` (string, optional) - Start date (default: 14 days ago)
+- `end_date` (string, optional) - End date (default: today)
+- `avg_hourly_rate` (float, optional) - Average hourly rate (default: 75.0)
+
+**Response:**
+```json
+{
+  "total_hours_logged": 520,
+  "total_cost": 39000,
+  "cost_per_issue": 325,
+  "cost_per_story_point": 162.5,
+  "efficiency_score": 7.8,
+  "issues_delivered": 120,
+  "story_points_delivered": 240
+}
+```
+
+### Risk Management
+
+#### GET /intelligence/risk-alerts/{project_key}
+**Description:** Get risk alerts for a project  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key
+
+**Query Parameters:**
+- `board_id` (integer, optional) - Board ID
+- `sprint_id` (integer, optional) - Sprint ID
+- `start_date` (string, optional) - Start date (default: 14 days ago)
+- `end_date` (string, optional) - End date (default: today)
+
+**Response:** Array of risk alert objects
+```json
+[
+  {
+    "alert_type": "delivery_risk",
+    "severity": "high",
+    "title": "Sprint at Risk",
+    "description": "Sprint completion rate below 70%",
+    "affected_items": ["Sprint 42"],
+    "recommendation": "Review sprint scope and consider moving items to backlog"
+  }
+]
+```
+
+### Insights & Recommendations
+
+#### GET /intelligence/insights/{project_key}
+**Description:** Get AI-generated insights and recommendations  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key
+
+**Query Parameters:**
+- `board_id` (integer, optional) - Board ID
+- `sprint_id` (integer, optional) - Sprint ID
+- `start_date` (string, optional) - Start date (default: 14 days ago)
+- `end_date` (string, optional) - End date (default: today)
+
+**Response:** Array of insight objects
+```json
+[
+  {
+    "category": "productivity",
+    "priority": "high",
+    "title": "Optimize Team Allocation",
+    "description": "3 team members are over-allocated",
+    "impact": "Could improve delivery by 15%",
+    "action_items": ["Redistribute workload", "Review capacity planning"]
+  }
+]
+```
+
+### Dashboard
+
+#### GET /intelligence/dashboard/{project_key}
+**Description:** Get comprehensive dashboard data with all metrics  
+**Authentication:** Required  
+**Path Parameters:**
+- `project_key` (string) - Project key
+
+**Query Parameters:**
+- `board_id` (integer, optional) - Board ID
+- `sprint_id` (integer, optional) - Sprint ID
+- `start_date` (string, optional) - Start date
+- `end_date` (string, optional) - End date
+
+**Response:** Combined object with all metrics
+```json
+{
+  "delivery_health": {...},
+  "productivity_metrics": [...],
+  "cost_efficiency": {...},
+  "risk_alerts": [...],
+  "insights": [...],
+  "period": {
+    "start": "2026-01-24",
+    "end": "2026-02-07"
+  }
+}
+```
+
+### Kanban Intelligence
+
+#### GET /intelligence/kanban/flow-metrics/{board_id}
+**Description:** Get Kanban flow efficiency metrics  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Query Parameters:**
+- `start_date` (string, optional) - Start date (default: 30 days ago)
+- `end_date` (string, optional) - End date (default: today)
+
+**Response:**
+```json
+{
+  "board_id": 123,
+  "board_name": "Development Board",
+  "cycle_time_avg_days": 4.5,
+  "lead_time_avg_days": 7.2,
+  "throughput": 25,
+  "wip_avg": 15,
+  "flow_efficiency": 62.5,
+  "blocked_items_count": 3
+}
+```
+
+#### GET /intelligence/kanban/column-analysis/{board_id}
+**Description:** Get detailed analysis of each Kanban column  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Response:** Array of column analysis objects
+```json
+[
+  {
+    "column_name": "In Progress",
+    "current_wip": 8,
+    "avg_time_in_column_days": 2.3,
+    "bottleneck_score": 6.5,
+    "issue_count": 8,
+    "recommended_wip_limit": 5
+  }
+]
+```
+
+#### GET /intelligence/kanban/wip-recommendations/{board_id}
+**Description:** Get WIP limit recommendations for columns  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Query Parameters:**
+- `start_date` (string, optional) - Start date (default: 30 days ago)
+- `end_date` (string, optional) - End date (default: today)
+
+**Response:** Array of WIP recommendation objects
+```json
+[
+  {
+    "column_name": "In Progress",
+    "current_wip": 8,
+    "current_limit": null,
+    "recommended_limit": 5,
+    "reason": "High average cycle time and bottleneck detected",
+    "expected_improvement": "Reduce cycle time by 25%"
+  }
+]
+```
+
+#### GET /intelligence/kanban/insights/{board_id}
+**Description:** Get Kanban-specific insights and recommendations  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Query Parameters:**
+- `start_date` (string, optional) - Start date (default: 30 days ago)
+- `end_date` (string, optional) - End date (default: today)
+
+**Response:** Array of Kanban insight objects
+
+#### GET /intelligence/kanban/dashboard/{board_id}
+**Description:** Get comprehensive Kanban dashboard with all metrics  
+**Authentication:** Required  
+**Path Parameters:**
+- `board_id` (integer) - Board ID
+
+**Query Parameters:**
+- `start_date` (string, optional) - Start date (default: 30 days ago)
+- `end_date` (string, optional) - End date (default: today)
+
+**Response:** Combined Kanban metrics object
+```json
+{
+  "flow_metrics": {...},
+  "column_analysis": [...],
+  "wip_recommendations": [...],
+  "insights": [...],
+  "period": {
+    "start": "2026-01-08",
+    "end": "2026-02-07"
+  }
+}
+```
+
+---
+
+## General Endpoints
+
+### GET /
+**Description:** API root endpoint - returns API information  
+**Authentication:** None required  
+**Response:**
+```json
+{
+  "message": "Enterprise Delivery & Workforce Intelligence API",
+  "version": "1.0.0",
+  "status": "operational",
+  "endpoints": {
+    "jira": "/jira",
+    "intelligence": "/intelligence",
+    "docs": "/docs",
+    "redoc": "/redoc"
+  }
+}
+```
+
+### GET /health
+**Description:** Health check endpoint  
+**Authentication:** None required  
+**Response:**
+```json
+{
+  "status": "healthy",
+  "timestamp": "2026-02-07T00:00:00Z"
+}
+```
+
+### GET /docs
+**Description:** Interactive Swagger UI documentation  
+**Authentication:** None required (but needed to test endpoints)  
+**Browser:** Opens interactive API documentation
+
+### GET /redoc
+**Description:** Alternative ReDoc API documentation  
+**Authentication:** None required  
+**Browser:** Opens ReDoc documentation
+
+---
+
+## Summary
+
+**Total Endpoints:** 31
+
+- **Authentication:** 2 endpoints
+- **Jira Data:** 17 endpoints
+- **Intelligence:** 10 endpoints
+- **General:** 4 endpoints
+
+**Authentication Method:** Bearer Token (JWT)  
+**Token Expiration:** 30 minutes  
+**Content Type:** application/json

API_USAGE.md

@@ -1,215 +0,0 @@
-# API Authentication Guide
-
-## Overview
-
-The Enterprise Delivery & Workforce Intelligence API now requires user authentication. Each user must login with their own Jira credentials to access the API endpoints.
-
-## How It Works
-
-1. **Login**: Users authenticate with their Jira credentials
-2. **Token**: System returns a JWT token valid for 30 minutes
-3. **Access**: Use the token to access all protected endpoints
-4. **Security**: Each user only sees data from their own Jira account
-
-## Getting Started
-
-### Step 1: Login
-
-Send a POST request to `/auth/login` with your Jira credentials:
-
-```bash
-curl -X POST "http://localhost:8000/auth/login" \
-  -H "Content-Type: application/json" \
-  -d '{
-    "jira_email": "your-email@company.com",
-    "jira_api_token": "your-jira-api-token",
-    "jira_server_url": "https://yourcompany.atlassian.net"
-  }'
-```
-
-**Response:**
-```json
-{
-  "access_token": "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...",
-  "token_type": "bearer",
-  "expires_in": 1800
-}
-```
-
-### Step 2: Use the Token
-
-Include the token in the Authorization header for all subsequent requests:
-
-```bash
-curl -X GET "http://localhost:8000/jira/projects" \
-  -H "Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9..."
-```
-
-## Getting Your Jira API Token
-
-1. Go to https://id.atlassian.com/manage-profile/security/api-tokens
-2. Click **Create API token**
-3. Give it a label (e.g., "Intelligence API")
-4. Copy the token (you won't be able to see it again)
-
-## Example Usage
-
-### JavaScript/Fetch
-
-```javascript
-// Login
-const loginResponse = await fetch('http://localhost:8000/auth/login', {
-  method: 'POST',
-  headers: { 'Content-Type': 'application/json' },
-  body: JSON.stringify({
-    jira_email: 'your-email@company.com',
-    jira_api_token: 'your-jira-api-token',
-    jira_server_url: 'https://yourcompany.atlassian.net'
-  })
-});
-
-const { access_token } = await loginResponse.json();
-
-// Use the token
-const projectsResponse = await fetch('http://localhost:8000/jira/projects', {
-  headers: { 'Authorization': `Bearer ${access_token}` }
-});
-
-const projects = await projectsResponse.json();
-```
-
-### Python
-
-```python
-import requests
-
-# Login
-login_response = requests.post('http://localhost:8000/auth/login', json={
-    'jira_email': 'your-email@company.com',
-    'jira_api_token': 'your-jira-api-token',
-    'jira_server_url': 'https://yourcompany.atlassian.net'
-})
-
-token = login_response.json()['access_token']
-
-# Use the token
-headers = {'Authorization': f'Bearer {token}'}
-projects_response = requests.get('http://localhost:8000/jira/projects', headers=headers)
-projects = projects_response.json()
-```
-
-### curl Examples
-
-```bash
-# 1. Login and save token
-TOKEN=$(curl -s -X POST "http://localhost:8000/auth/login" \
-  -H "Content-Type: application/json" \
-  -d '{
-    "jira_email": "your-email@company.com",
-    "jira_api_token": "your-jira-api-token",
-    "jira_server_url": "https://yourcompany.atlassian.net"
-  }' | jq -r '.access_token')
-
-# 2. Get projects
-curl -X GET "http://localhost:8000/jira/projects" \
-  -H "Authorization: Bearer $TOKEN"
-
-# 3. Get delivery health metrics
-curl -X GET "http://localhost:8000/intelligence/delivery-health/PROJ" \
-  -H "Authorization: Bearer $TOKEN"
-
-# 4. Get Kanban boards
-curl -X GET "http://localhost:8000/jira/kanban/boards" \
-  -H "Authorization: Bearer $TOKEN"
-```
-
-## Token Management
-
-### Token Expiration
-
-- Tokens expire after **30 minutes** by default
-- When a token expires, you'll receive a `401 Unauthorized` response
-- Simply login again to get a new token
-
-### Checking Token Validity
-
-Verify your current token:
-
-```bash
-curl -X GET "http://localhost:8000/auth/me" \
-  -H "Authorization: Bearer $TOKEN"
-```
-
-**Response:**
-```json
-{
-  "jira_email": "your-email@company.com",
-  "jira_server_url": "https://yourcompany.atlassian.net",
-  "authenticated": true
-}
-```
-
-## API Endpoints
-
-All endpoints now require authentication. Here are the main endpoint categories:
-
-### Authentication (`/auth`)
-- `POST /auth/login` - Login with Jira credentials
-- `GET /auth/me` - Get current user info
-
-### Jira Data (`/jira`)
-- `GET /jira/projects` - List all projects
-- `GET /jira/boards` - List all boards
-- `GET /jira/projects/{project_key}/issues` - Get project issues
-- `GET /jira/boards/{board_id}/sprints` - Get board sprints
-- `GET /jira/kanban/boards` - Get Kanban boards
-- And more...
-
-### Intelligence (`/intelligence`)
-- `GET /intelligence/delivery-health/{project_key}` - Delivery metrics
-- `GET /intelligence/productivity/{project_key}` - Productivity metrics
-- `GET /intelligence/risk-alerts/{project_key}` - Risk alerts
-- `GET /intelligence/kanban/flow-metrics/{board_id}` - Kanban metrics
-- And more...
-
-## Interactive API Documentation
-
-Visit http://localhost:8000/docs for interactive Swagger documentation where you can:
-1. Click the **Authorize** button
-2. Enter your token as: `Bearer your-token-here`
-3. Try out all endpoints interactively
-
-## Security Notes
-
-- **Never commit credentials**: Don't store API tokens in code or version control
-- **Use environment variables**: Store tokens in environment variables or secure vaults
-- **HTTPS in production**: Always use HTTPS in production environments
-- **Token security**: Treat JWT tokens like passwords - keep them secret
-
-## Troubleshooting
-
-### 401 Unauthorized
-- Token expired: Login again to get a new token
-- Invalid token: Check that you're using the correct format: `Bearer {token}`
-- Missing token: Ensure the Authorization header is included
-
-### 403 Forbidden
-- Invalid Jira credentials: Check your Jira email and API token
-- Insufficient permissions: Verify you have access to the Jira resources
-
-### Token Validation Failed
-- Token format error: Ensure token is properly formatted JWT
-- Expired token: Login again to refresh your token
-
-## Migration from .env Setup
-
-Previously, the API used credentials from the `.env` file. Now:
-
-- ❌ **Old**: Credentials in `.env` file (shared by all users)
-- ✅ **New**: Each user provides their own credentials via login
-
-This change provides:
-- **Better security**: No shared credentials
-- **User-specific data**: Each user sees only their Jira data
-- **Audit trail**: Track which user made which requests
-- **Better compliance**: Aligns with enterprise security policies

api/webhook_routes.py

@@ -0,0 +1,61 @@
+from fastapi import APIRouter, Header, Request, HTTPException
+import logging
+from services.supabase_service import supabase_service
+from typing import Dict, Any
+
+logger = logging.getLogger(__name__)
+
+router = APIRouter(prefix="/webhooks/jira", tags=["Webhooks"])
+
+@router.post("")
+async def receive_jira_webhook(
+    request: Request,
+    x_atlassian_webhook_identifier: str = Header(None)
+):
+    """
+    Receive webhook events from Jira
+    """
+    try:
+        payload = await request.json()
+        logger.info(f"Received Jira webhook: {x_atlassian_webhook_identifier}")
+        
+        # Determine the user email from the payload
+        user_email = None
+        
+        # 1. Update issue event
+        if "issue" in payload:
+            issue = payload["issue"]
+            # Try assignee first
+            if issue.get("fields", {}).get("assignee"):
+                user_email = issue["fields"]["assignee"].get("emailAddress")
+            # Fallback to reporter
+            if not user_email and issue.get("fields", {}).get("reporter"):
+                user_email = issue["fields"]["reporter"].get("emailAddress")
+                
+        # 2. User created/updated event
+        elif "user" in payload:
+             user_email = payload["user"].get("emailAddress")
+             
+        if not user_email:
+            logger.warning("Could not identify user email from webhook payload")
+            # We still return 200 to Jira so it doesn't retry
+            return {"status": "ignored", "reason": "no_email_found"}
+            
+        # Find user in Supabase
+        firebase_id = supabase_service.get_user_id_by_email(user_email)
+        
+        if not firebase_id:
+            logger.warning(f"No Supabase user found for Jira email: {user_email}")
+            return {"status": "ignored", "reason": "user_not_found"}
+            
+        # Store data
+        success = supabase_service.upsert_jira_data(firebase_id, payload)
+        
+        if success:
+            return {"status": "processed", "user": firebase_id}
+        else:
+            raise HTTPException(status_code=500, detail="Failed to store data")
+            
+    except Exception as e:
+        logger.error(f"Error processing webhook: {str(e)}")
+        raise HTTPException(status_code=500, detail=str(e))

config/settings.py

@@ -18,6 +18,10 @@ class Settings(BaseSettings):
     # Database
     database_url: str = "sqlite:///./enterprise_intelligence.db"
     
+    # Supabase
+    supabase_url: Optional[str] = None
+    supabase_key: Optional[str] = None
+
     # Redis
     redis_url: str = "redis://localhost:6379/0"
     

main.py

@@ -3,6 +3,7 @@ from fastapi.middleware.cors import CORSMiddleware
 from api.auth_routes import router as auth_router
 from api.jira_routes import router as jira_router
 from api.intelligence_routes import router as intelligence_router
+from api.webhook_routes import router as webhook_router
 from config.settings import settings
 import logging
 
@@ -35,6 +36,7 @@ app.add_middleware(
 app.include_router(auth_router)
 app.include_router(jira_router)
 app.include_router(intelligence_router)
+app.include_router(webhook_router)
 
 
 @app.get("/")

requirements.txt

@@ -3,7 +3,7 @@ uvicorn==0.27.0
 pydantic==2.5.3
 pydantic-settings==2.1.0
 jira==3.8.0
-httpx==0.26.0
+httpx
 python-dotenv==1.0.0
 pandas==2.1.4
 numpy==1.26.3
@@ -15,3 +15,4 @@ passlib[bcrypt]==1.7.4
 python-multipart==0.0.6
 aiohttp==3.9.1
 pydantic[email]
+supabase==2.3.4

services/supabase_service.py

@@ -0,0 +1,76 @@
+from supabase import create_client, Client
+from config.settings import settings
+import logging
+from typing import Optional, Dict, Any
+
+logger = logging.getLogger(__name__)
+
+class SupabaseService:
+    """Service to handle Supabase database operations"""
+    
+    def __init__(self):
+        self.client: Optional[Client] = None
+        if settings.supabase_url and settings.supabase_key:
+            try:
+                self.client = create_client(settings.supabase_url, settings.supabase_key)
+                logger.info("Supabase client initialized successfully")
+            except Exception as e:
+                logger.error(f"Failed to initialize Supabase client: {str(e)}")
+        else:
+            logger.warning("Supabase URL or Key not found in settings. Supabase integration disabled.")
+
+    def get_user_id_by_email(self, email: str) -> Optional[str]:
+        """
+        Find user's firebase_id by email from the Users table
+        """
+        if not self.client:
+            logger.warning("Supabase client not initialized")
+            return None
+            
+        try:
+            # Assuming the table name is "Users" and it has "email" and "firebase_id" columns
+            response = self.client.table("Users").select("firebase_id").eq("email", email).execute()
+            
+            if response.data and len(response.data) > 0:
+                return response.data[0]["firebase_id"]
+            return None
+            
+        except Exception as e:
+            logger.error(f"Error fetching user by email {email}: {str(e)}")
+            return None
+
+    def upsert_jira_data(self, firebase_id: str, data: Dict[str, Any]) -> bool:
+        """
+        Insert or update Jira data for a user
+        """
+        if not self.client:
+            logger.warning("Supabase client not initialized")
+            return False
+            
+        try:
+            # Prepare payload
+            payload = {
+                "user_id": firebase_id,
+                "jira_payload": data,
+                "updated_at": "now()"
+            }
+            
+            # Upsert into jira_data table
+            # Note: The table needs to conflict on user_id if we want 1 row per user,
+            # or we just insert a new log every time. 
+            # Given "store all the data", let's assume we want a log of events.
+            # But the user also said "data gets updated".
+            # Let's insert a new record for every event for now to be safe (Audit Log style).
+            # AND/OR update a current state record.
+            # For simplicity let's insert a new record.
+            
+            self.client.table("jira_data").insert(payload).execute()
+            logger.info(f"Successfully stored Jira data for user {firebase_id}")
+            return True
+            
+        except Exception as e:
+            logger.error(f"Error storing Jira data for {firebase_id}: {str(e)}")
+            return False
+
+# Create singleton
+supabase_service = SupabaseService()