async def check_connection_status(
    *,
    db: AsyncSession = Depends(deps.get_db),
    short_name: str,
) -> List[schemas.Connection]:
    """Check if a source connection exists for the given short_name.

    Args:
    -----
        db: The database session
        short_name: The short name of the source to check
        user: The admin user

    Returns:
    --------
        List[schemas.Connection]: List of source connections for the given short_name

    """
    try:
        await integration_settings.get_by_short_name(short_name)
    except Exception as e:
        raise HTTPException(
            status_code=404,
            detail=(
                f"Integration {short_name} not found in the integration settings. "
                "Please add the client id and client secret for the integration in the "
                "backend/airweave/platform/auth/yaml/dev.integrations.yaml file, then restart the "
                "backend server and make a connection through the UI."
            ),
        ) from e

    # Find source connections for the given short_name
    connections = await crud.connection.get_all_by_short_name(db=db, short_name=short_name)

    # Filter for SOURCE connections only
    source_connections = [
        conn for conn in connections if conn.integration_type == IntegrationType.SOURCE
    ]

    if not source_connections:
        raise HTTPException(
            status_code=404,
            detail=f"No source connections found for source with short_name: {short_name}",
        )

    return source_connections
Check if a source connection exists for the given short_name.

    Args:
    -----
        db: The database session
        short_name: The short name of the source to check
        user: The admin user

    Returns:
    --------
        List[schemas.Connection]: List of source connections for the given short_name

    
backend/airweave/api/v1/endpoints/cursor_dev.py