Update App/routers/portfolio/routes.py

App/routers/portfolio/routes.py

@@ -1200,6 +1200,84 @@ async def get_portfolio_performance(
         raise AppException(status_code=500, detail=f"An unexpected error occurred: {e}")
 
 
+@router.post(
+    "/{portfolio_id}/recalculate-timeseries",
+    response_model=ResponseModel,
+    summary="Recalculate Entire Portfolio Timeseries",
+)
+async def recalculate_portfolio_timeseries(
+    portfolio_id: int,
+    background_tasks: BackgroundTasks,
+    current_user=Depends(get_current_user),
+):
+    """
+    Recalculates the entire portfolio timeseries by regenerating all historical snapshots
+    from the first transaction date to today. This endpoint:
+    
+    1. Validates the portfolio exists and belongs to the user
+    2. Checks if a regeneration task is already running
+    3. Deletes all existing snapshots for the portfolio
+    4. Queues a background task to regenerate snapshots from the earliest transaction
+    
+    Returns task_id for polling the regeneration status.
+    """
+    try:
+        # 1. AUTHENTICATION & VALIDATION
+        portfolio = await Portfolio.get_or_none(
+            id=portfolio_id, user_id=current_user.id
+        )
+        if not portfolio:
+            raise AppException(status_code=404, detail="Portfolio not found")
+
+        # 2. CHECK FOR ACTIVE REGENERATION TASKS
+        active_task = await ImportTask.filter(
+            Q(details__contains={"portfolio_id": portfolio_id}),
+            Q(task_type__in=["portfolio_regeneration", "portfolio_snapshot_history"]),
+            status__in=["pending", "running"],
+        ).first()
+
+        if active_task:
+            return ResponseModel(
+                success=False,
+                message="A timeseries recalculation is already in progress for this portfolio.",
+                data={"task_id": active_task.id, "status": active_task.status},
+            )
+
+        # 3. CREATE A NEW TASK AND QUEUE BACKGROUND WORK
+        task = await ImportTask.create(
+            task_type="portfolio_regeneration",
+            status="pending",
+            details={
+                "portfolio_id": portfolio_id,
+                "reason": "Manual full timeseries recalculation requested by user.",
+            },
+        )
+
+        # Queue the regeneration task without a start_date,
+        # so it will find the earliest transaction and start from there
+        background_tasks.add_task(
+            PortfolioService.regenerate_snapshots_task, task.id, portfolio_id
+        )
+
+        return ResponseModel(
+            success=True,
+            message="Timeseries recalculation started. This may take a few moments.",
+            data={
+                "task_id": task.id,
+                "status": "pending",
+                "portfolio_id": portfolio_id,
+            },
+        )
+
+    except AppException:
+        raise
+    except Exception as e:
+        raise AppException(
+            status_code=500, detail=f"Failed to start timeseries recalculation: {str(e)}"
+        )
+
+
+
 @router.get(
     "/{portfolio_id}/calendar",
     response_model=ResponseModel,