Function _get_integration_counts_by_org

api/platform_hub/services.py:396–412

Return a mapping of organisation_id -> total integration count.

(
    org_ids: set[int],
)

def _get_integration_counts_by_org(
    org_ids: set[int],
) -> dict[int, int]:
    """Return a mapping of organisation_id -> total integration count."""
    result: dict[int, int] = defaultdict(int)
    registry = get_integration_registry()

    for model, org_lookup_path, _ in registry.values():
        counts = (
            model.objects.filter(**{f"{org_lookup_path}__in": org_ids})
            .values(**{"org_id": F(org_lookup_path)})
            .annotate(count=Count("id"))
        )
        for row in counts:
            result[row["org_id"]] += row["count"]

    return result


def get_usage_trends(