RocketChat/Rocket.Chat

import type { IStats } from '@rocket.chat/core-typings';
import { Statistics } from '@rocket.chat/models';
import type { FindOptions, SchemaMember } from 'mongodb';

import { hasPermissionAsync } from '../../../authorization/server/functions/hasPermission';

type GetStatisticsParams = {
    userId: string;
    query?: Record<string, any>;
    pagination: {
        offset: number;
        count?: number;
        sort?: FindOptions<IStats>['sort'];
        fields?: SchemaMember<IStats, number | boolean>;
    };
};

type GetStatisticsReturn = { statistics: IStats[]; count: number; offset: number; total: number };

export async function getStatistics({
    userId,
    query = {},
    pagination: { offset, count, sort, fields },
}: GetStatisticsParams): Promise<GetStatisticsReturn> {
    if (!(await hasPermissionAsync(userId, 'view-statistics'))) {
        throw new Error('error-not-allowed');
    }

    const { cursor, totalCount } = Statistics.findPaginated(query, {
        sort: sort || { name: 1 },
        skip: offset,
        limit: count,
        projection: fields,
    });

    const [statistics, total] = await Promise.all([cursor.toArray(), totalCount]);

    return {
        statistics,
        count: statistics.length,
        offset,
        total,
    };
}