bytelyst/learning_ai_common_plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(telemetry): 3 bugs — Slack Block Kit text key, cluster reopen clears resolution, affectedInstallIds uses correct ID

Browse Source
This commit is contained in:
saravanakumardb1 2026-02-17 11:22:13 -08:00
parent ae2dae4413
commit 08b9642408
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
services/platform-service/src/modules/telemetry/routes.ts
View File

@ -116,7 +116,7 @@ async function sendClusterAlert(
type: 'section', type: 'section',
text: { text: {
type: 'mrkdwn', type: 'mrkdwn',
value: [ text: [
`*Telemetry Error Cluster Escalated*`, `*Telemetry Error Cluster Escalated*`,
`*Event:* ${cluster.module}/${cluster.eventName}`, `*Event:* ${cluster.module}/${cluster.eventName}`,
`*Platform:* ${cluster.platform} (${cluster.channel})`, `*Platform:* ${cluster.platform} (${cluster.channel})`,
@ -424,8 +424,12 @@ async function updateClusterForEvent(event: TelemetryEventDoc): Promise<void> {
if (uid && event.userId && !existing.affectedUserIds.includes(uid)) { if (uid && event.userId && !existing.affectedUserIds.includes(uid)) {
if (existing.affectedUserIds.length < 100) existing.affectedUserIds.push(uid); if (existing.affectedUserIds.length < 100) existing.affectedUserIds.push(uid);
} }
if (uid && event.anonymousInstallId && !existing.affectedInstallIds.includes(uid)) { if (
if (existing.affectedInstallIds.length < 100) existing.affectedInstallIds.push(uid); event.anonymousInstallId &&
!existing.affectedInstallIds.includes(event.anonymousInstallId)
) {
if (existing.affectedInstallIds.length < 100)
existing.affectedInstallIds.push(event.anonymousInstallId);
} }
if (!existing.affectedOsFamilies.includes(event.osFamily)) { if (!existing.affectedOsFamilies.includes(event.osFamily)) {
existing.affectedOsFamilies.push(event.osFamily); existing.affectedOsFamilies.push(event.osFamily);
@ -861,6 +865,10 @@ export async function telemetryRoutes(app: FastifyInstance) {
if (parsed.data.status === 'resolved' || parsed.data.status === 'ignored') { if (parsed.data.status === 'resolved' || parsed.data.status === 'ignored') {
updates.resolvedBy = req.jwtPayload?.sub ?? 'unknown'; updates.resolvedBy = req.jwtPayload?.sub ?? 'unknown';
updates.resolvedAt = new Date().toISOString(); updates.resolvedAt = new Date().toISOString();
} else if (parsed.data.status === 'open') {
// Clear resolution metadata when reopening
updates.resolvedBy = undefined;
updates.resolvedAt = undefined;
} }
const updated = await repo.updateCluster(id, pk, updates); const updated = await repo.updateCluster(id, pk, updates);