adding event tracker

dashboard/server/api/metrics/[project_id]/events/metadata_field_group.ts

@@ -0,0 +1,31 @@
+
+import { getUserProjectFromId } from "~/server/LIVE_DEMO_DATA";
+import { EventModel } from "@schema/metrics/EventSchema";
+import { EVENT_METADATA_FIELDS_EXPIRE_TIME, Redis } from "~/server/services/CacheService";
+
+
+export default defineEventHandler(async event => {
+
+    const project_id = getRequestProjectId(event);
+    if (!project_id) return;
+
+    const user = getRequestUser(event);
+
+    const project = await getUserProjectFromId(project_id, user);
+    if (!project) return;
+
+    const { name: eventName, field } = getQuery(event);
+    if (!eventName || !field) return [];
+
+    const aggregation = [
+        { $match: { project_id: project._id, name: eventName } },
+        { $group: { _id: `$metadata.${field}`, count: { $sum: 1 } } }
+    ]
+
+    const metadataGrouped = await EventModel.aggregate(aggregation);
+
+    console.log(metadataGrouped);
+    return metadataGrouped;
+
+
+});

dashboard/server/api/metrics/[project_id]/events/metadata_fields.ts

@@ -0,0 +1,33 @@
+
+import { getUserProjectFromId } from "~/server/LIVE_DEMO_DATA";
+import { EventModel } from "@schema/metrics/EventSchema";
+import { EVENT_METADATA_FIELDS_EXPIRE_TIME, Redis } from "~/server/services/CacheService";
+
+
+export default defineEventHandler(async event => {
+
+    const project_id = getRequestProjectId(event);
+    if (!project_id) return;
+
+    const user = getRequestUser(event);
+
+    const project = await getUserProjectFromId(project_id, user);
+    if (!project) return;
+
+    const { name: eventName } = getQuery(event);
+    if (!eventName) return [];
+
+    const fields: string[] = await Redis.useCache({ key: `metadata_fields:${project_id}:${eventName}`, exp: EVENT_METADATA_FIELDS_EXPIRE_TIME }, async () => {
+        const eventsWithName = await EventModel.find({ project_id, name: eventName }, { metadata: 1 }, { limit: 10, sort: { created_at: -1 } });
+        const allMetadata = eventsWithName.map(e => e.metadata);
+        const allFields = new Set<string>();
+        for (const metadata of allMetadata) {
+            const keys = Object.keys(metadata || {});
+            keys.forEach(key => allFields.add(key));
+        }
+        return Array.from(allFields.values());
+    });
+
+    return fields;
+
+});

dashboard/server/api/metrics/[project_id]/events/names.ts

@@ -14,18 +14,9 @@ export default defineEventHandler(async event => {
     const project = await getUserProjectFromId(project_id, user);
     if (!project) return;
 
-    const names: string[] = await Redis.useCache({
-        key: `counts:${project_id}:event_names`,
-        exp: EVENT_NAMES_EXPIRE_TIME
-    }, async () => {
-
-        const namesAggregation = await EventModel.aggregate([
-            { $match: { project_id: project._id } },
-            { $group: { _id: "$name" } }
-        ]);
-
+    const names: string[] = await Redis.useCache({ key: `event_names:${project_id}`, exp: EVENT_NAMES_EXPIRE_TIME }, async () => {
+        const namesAggregation = await EventModel.aggregate([{ $match: { project_id: project._id } }, { $group: { _id: "$name" } }]);
         return namesAggregation.map(e => e._id);
-
     });
 
     return names;