async def get_all_for_destination_connection(
        self, db: AsyncSession, destination_connection_id: UUID, current_user: schemas.User
    ) -> list[schemas.Sync]:
        """Get all syncs for a destination connection.

        Args:
            db (AsyncSession): The database session
            destination_connection_id (UUID): The ID of the destination connection
            current_user (schemas.User): The current user

        Returns:
            list[schemas.Sync]: The enriched syncs
        """
        # Use the SyncConnection join table to find syncs with the given destination connection
        stmt = (
            select(Sync)
            .join(SyncConnection, Sync.id == SyncConnection.sync_id)
            .join(Connection, SyncConnection.connection_id == Connection.id)
            .where(SyncConnection.connection_id == destination_connection_id)
            .where(Connection.integration_type == IntegrationType.DESTINATION)
            .where(Sync.organization_id == current_user.organization_id)
        )
        result = await db.execute(stmt)
        syncs = result.scalars().unique().all()

        # Validate permissions for each sync
        for sync in syncs:
            self._validate_if_user_has_permission(sync, current_user)

        # Enrich all syncs in a single efficient query
        return await self.enricher_for_all(db, syncs)
Get all syncs for a destination connection.

        Args:
            db (AsyncSession): The database session
            destination_connection_id (UUID): The ID of the destination connection
            current_user (schemas.User): The current user

        Returns:
            list[schemas.Sync]: The enriched syncs
        
backend/airweave/crud/crud_sync.py