Function create_features_bulk

server/routers/features.py:221–306

Create multiple features at once. Features are assigned sequential priorities starting from: - starting_priority if specified (must be >= 1) - max(existing priorities) + 1 if not specified This is useful for: - Expanding a project with new features via AI - Importing f

(project_name: str, bulk: FeatureBulkCreate)

@router.post("/bulk", response_model=FeatureBulkCreateResponse)
async def create_features_bulk(project_name: str, bulk: FeatureBulkCreate):
    """
    Create multiple features at once.

    Features are assigned sequential priorities starting from:
    - starting_priority if specified (must be >= 1)
    - max(existing priorities) + 1 if not specified

    This is useful for:
    - Expanding a project with new features via AI
    - Importing features from external sources
    - Batch operations

    Returns:
        {"created": N, "features": [...]}
    """
    project_name = validate_project_name(project_name)
    project_dir = _get_project_path(project_name)

    if not project_dir:
        raise HTTPException(status_code=404, detail=f"Project '{project_name}' not found in registry")

    if not project_dir.exists():
        raise HTTPException(status_code=404, detail="Project directory not found")

    if not bulk.features:
        return FeatureBulkCreateResponse(created=0, features=[])

    # Validate starting_priority if provided
    if bulk.starting_priority is not None and bulk.starting_priority < 1:
        raise HTTPException(status_code=400, detail="starting_priority must be >= 1")

    _, Feature = _get_db_classes()

    try:
        with get_db_session(project_dir) as session:
            # Determine starting priority
            # Note: SQLite uses file-level locking, not row-level locking, so we rely on
            # SQLite's transaction isolation. Concurrent bulk creates may get overlapping
            # priorities, but this is acceptable since priorities can be reordered.
            if bulk.starting_priority is not None:
                current_priority = bulk.starting_priority
            else:
                max_priority_feature = (
                    session.query(Feature)
                    .order_by(Feature.priority.desc())
                    .first()
                )
                current_priority = (max_priority_feature.priority + 1) if max_priority_feature else 1

            created_ids = []

            for feature_data in bulk.features:
                db_feature = Feature(
                    priority=current_priority,
                    category=feature_data.category,
                    name=feature_data.name,
                    description=feature_data.description,