async def get_connections_by_type(
        self, db: AsyncSession, integration_type: IntegrationType, user: schemas.User
    ) -> list[schemas.Connection]:
        """Get connections by integration type.

        Args:
            db: The database session
            integration_type: The type of integration
            user: The current user

        Returns:
            A list of connections
        """
        return await crud.connection.get_by_integration_type(
            db, integration_type=integration_type, organization_id=user.organization_id
        )
Get connections by integration type.

        Args:
            db: The database session
            integration_type: The type of integration
            user: The current user

        Returns:
            A list of connections
        
backend/airweave/core/connection_service.py