refactor: migrate statistics endpoints to new chained API pattern

.changeset/refactor-stats-api-chained-pattern.md

@@ -0,0 +1,5 @@
+---
+'@rocket.chat/meteor': patch
+---
+
+Migrated `statistics`, `statistics.list`, and `statistics.telemetry` REST API endpoints from legacy `addRoute` pattern to the new chained `.get()`/`.post()` API pattern with typed response schemas and AJV query parameter validation.

apps/meteor/app/api/server/v1/stats.ts

@@ -1,62 +1,158 @@
+import type { TelemetryEvents, TelemetryMap } from '@rocket.chat/core-services';
+import type { IStats } from '@rocket.chat/core-typings';
+import { ajv, validateUnauthorizedErrorResponse } from '@rocket.chat/rest-typings';
+
 import { getStatistics, getLastStatistics } from '../../../statistics/server';
 import telemetryEvent from '../../../statistics/server/lib/telemetryEvents';
 import { API } from '../api';
 import { getPaginationItems } from '../helpers/getPaginationItems';
 
-API.v1.addRoute(
+API.v1.get(
 	'statistics',
-	{ authRequired: true },
 	{
-		async get() {
-			const { refresh = 'false' } = this.queryParams;
-
-			return API.v1.success(
-				await getLastStatistics({
-					userId: this.userId,
-					refresh: refresh === 'true',
-				}),
-			);
+		authRequired: true,
+		query: ajv.compile<{ refresh?: 'true' | 'false' }>({
+			type: 'object',
+			properties: {
+				refresh: {
+					type: 'string',
+					nullable: true,
+				},
+			},
+			required: [],
+			additionalProperties: false,
+		}),
+		response: {
+			200: ajv.compile<IStats>({
+				type: 'object',
+				properties: {
+					success: {
+						type: 'boolean',
+						enum: [true],
+					},
+				},
+				required: ['success'],
+			}),
+			401: validateUnauthorizedErrorResponse,
 		},
 	},
+	async function action() {
+		const { refresh = 'false' } = this.queryParams;
+
+		const stats = await getLastStatistics({
+			userId: this.userId,
+			refresh: refresh === 'true',
+		});
+
+		if (!stats) {
+			throw new Error('No statistics found');
+		}
+
+		return API.v1.success(stats);
+	},
 );
 
-API.v1.addRoute(
+API.v1.get(
 	'statistics.list',
-	{ authRequired: true },
 	{
-		async get() {
-			const { offset, count } = await getPaginationItems(this.queryParams);
-			const { sort, fields, query } = await this.parseJsonQuery();
-
-			return API.v1.success(
-				await getStatistics({
-					userId: this.userId,
-					query,
-					pagination: {
-						offset,
-						count,
-						sort,
-						fields,
+		authRequired: true,
+		query: ajv.compile<{ fields?: string; count?: number; offset?: number; sort?: string; query?: string }>({
+			type: 'object',
+			properties: {
+				fields: { type: 'string', nullable: true },
+				count: { type: 'number', nullable: true },
+				offset: { type: 'number', nullable: true },
+				sort: { type: 'string', nullable: true },
+				query: { type: 'string', nullable: true },
+			},
+			required: [],
+			additionalProperties: false,
+		}),
+		response: {
+			200: ajv.compile<{
+				statistics: unknown[];
+				count: number;
+				offset: number;
+				total: number;
+			}>({
+				type: 'object',
+				properties: {
+					statistics: { type: 'array' },
+					count: { type: 'number' },
+					offset: { type: 'number' },
+					total: { type: 'number' },
+					success: {
+						type: 'boolean',
+						enum: [true],
 					},
-				}),
-			);
+				},
+				required: ['statistics', 'count', 'offset', 'total', 'success'],
+			}),
+			401: validateUnauthorizedErrorResponse,
 		},
 	},
+	async function action() {
+		const { offset, count } = await getPaginationItems(this.queryParams);
+		const { sort, fields, query } = await this.parseJsonQuery();
+
+		return API.v1.success(
+			await getStatistics({
+				userId: this.userId,
+				query,
+				pagination: {
+					offset,
+					count,
+					sort,
+					fields,
+				},
+			}),
+		);
+	},
 );
 
-API.v1.addRoute(
+API.v1.post(
 	'statistics.telemetry',
-	{ authRequired: true },
 	{
-		post() {
-			const events = this.bodyParams;
+		authRequired: true,
+		body: ajv.compile<{ params: { eventName: string; [key: string]: unknown }[] }>({
+			type: 'object',
+			properties: {
+				params: {
+					type: 'array',
+					items: {
+						type: 'object',
+						properties: {
+							eventName: { type: 'string' },
+						},
+						required: ['eventName'],
+					},
+				},
+			},
+			required: ['params'],
+		}),
+		response: {
+			200: ajv.compile<void>({
+				type: 'object',
+				properties: {
+					success: {
+						type: 'boolean',
+						enum: [true],
+					},
+				},
+				required: ['success'],
+				additionalProperties: false,
+			}),
+			401: validateUnauthorizedErrorResponse,
+		},
+	},
+	function action() {
+		const events = this.bodyParams;
 
-			events?.params?.forEach((event) => {
-				const { eventName, ...params } = event;
-				void telemetryEvent.call(eventName, params);
-			});
+		events.params.forEach((event) => {
+			const { eventName, ...params } = event;
+			void telemetryEvent.call(eventName as TelemetryEvents, params as TelemetryMap[TelemetryEvents]);
+		});
 
-			return API.v1.success();
-		},
+		return API.v1.success();
 	},
 );