Analysis file/package names in analytics blobs

Expose `file_name` and `package_name` as Analytics Engine blob dimensions instead of treating them as private/redacted fields. Web UI analytics field builders now populate these values for file and report events, and the check script now enforces that both keys stay in `ANALYTICS_BLOB_KEYS` to prevent regressions.

Author: zhaobozhen

packages/apk-webui/functions/analytics.js

@@ -21,8 +21,8 @@ const ANALYTICS_BLOB_KEYS = [
   "source_label",
   "error_name",
   "viewport_bucket",
-  "route",
-  "method",
+  "file_name",
+  "package_name",
 ];
 
 const ANALYTICS_DOUBLE_KEYS = [
@@ -54,8 +54,6 @@ const PRIVATE_EVENT_KEYS = new Set([
   "error_message",
   "error_stack",
   "file_size_bytes",
-  "file_name",
-  "package_name",
   "report_path",
   "url_host",
   "url_path",

packages/apk-webui/scripts/check.mjs

@@ -88,6 +88,13 @@ async function validateAnalyticsEngineKeyBudgets() {
       throw new Error(`${name} has ${values.length} entries; Analytics Engine supports at most 20`);
     }
   }
+
+  const blobKeys = readStringArray(source, "ANALYTICS_BLOB_KEYS");
+  for (const key of ["file_name", "package_name"]) {
+    if (!blobKeys.includes(key)) {
+      throw new Error(`ANALYTICS_BLOB_KEYS must include ${key}`);
+    }
+  }
 }
 
 function readStringArray(source, name) {

packages/apk-webui/src/app/analytics-fields.js

@@ -11,6 +11,7 @@ export function getFileAnalyticsFields(file) {
   }
 
   return compactAnalyticsObject({
+    file_name: file.name || "",
     file_extension: getFileExtension(file.name),
     size_bucket: formatSizeBucket(file.size),
   });
@@ -25,6 +26,8 @@ export function getReportAnalyticsFields(report) {
   const archive = info.archive || null;
 
   return compactAnalyticsObject({
+    file_name: report?.fileName || "",
+    package_name: info.packageName || "",
     file_extension: getFileExtension(report?.fileName),
     size_bucket: formatSizeBucket(report?.fileSizeBytes),
     duration_ms: Number(report?.durationMs) || 0,

packages/apk-webui/src/app/analytics.js

@@ -15,8 +15,6 @@ const PRIVATE_EVENT_KEYS = new Set([
   "chat_id",
   "error_message",
   "error_stack",
-  "file_name",
-  "package_name",
   "report_path",
   "url_host",
   "url_path",

packages/bot-worker/src/index.js

@@ -2214,6 +2214,8 @@ function buildMessageTelemetryFields(update, message, command, botMentioned, loc
     update_type: getUpdateType(update),
     locale,
     chat_type: message.chat?.type || null,
+    chat_title: isTelegramGroupChat(message.chat) ? message.chat?.title || null : null,
+    chat_username: isTelegramGroupChat(message.chat) ? formatTelegramUsername(message.chat?.username) : null,
     chat_id: message.chat?.id != null ? String(message.chat.id) : null,
     message_id: message.message_id || null,
     message_thread_id: message.message_thread_id || null,
@@ -2230,6 +2232,15 @@ function buildMessageTelemetryFields(update, message, command, botMentioned, loc
   };
 }
 
+function isTelegramGroupChat(chat) {
+  return chat?.type === "group" || chat?.type === "supergroup" || chat?.type === "channel";
+}
+
+function formatTelegramUsername(username) {
+  const value = String(username || "").trim().replace(/^@/u, "");
+  return value ? `@${value}` : null;
+}
+
 function getUpdateType(update) {
   if (update?.message) {
     return "message";

packages/bot-worker/src/observability.js

@@ -6,8 +6,8 @@ const ANALYTICS_BLOB_KEYS = [
   "event",
   "surface",
   "route",
-  "method",
-  "path",
+  "chat_title",
+  "chat_username",
   "chat_type",
   "update_type",
   "command",

packages/bot-worker/test/observability.test.mjs

@@ -35,3 +35,36 @@ test("analytics datapoints include APK file and package identifiers", () => {
   assert.ok(datapoints[0].blobs.includes("sample.apk"));
   assert.ok(datapoints[0].blobs.includes("com.example.app"));
 });
+
+test("analytics datapoints include Telegram group title and public username", () => {
+  const datapoints = [];
+  const env = {
+    USAGE_ANALYTICS: {
+      writeDataPoint(point) {
+        datapoints.push(point);
+      },
+    },
+  };
+  const originalLog = console.log;
+  console.log = () => {};
+
+  try {
+    logInfoEvent(
+      env,
+      { request_id: "request-1", surface: "worker", route: "telegram_webhook" },
+      "telegram.update.received",
+      {
+        result: "received",
+        chat_title: "LibChecker Group",
+        chat_username: "@libchecker_group",
+      },
+    );
+  } finally {
+    console.log = originalLog;
+  }
+
+  assert.equal(datapoints.length, 1);
+  assert.equal(datapoints[0].blobs.length, 20);
+  assert.ok(datapoints[0].blobs.includes("LibChecker Group"));
+  assert.ok(datapoints[0].blobs.includes("@libchecker_group"));
+});