update ui

dashboard/server/api/admin/backend.ts

@@ -0,0 +1,18 @@
+
+
+export default defineEventHandler(async event => {
+
+    const userData = getRequestUser(event);
+    if (!userData?.logged) return;
+    if (!userData.user.roles.includes('ADMIN')) return;
+
+
+    const queueRes = await fetch("http://94.130.182.52:3031/metrics/queue");
+    const queue = await queueRes.json();
+    const durationsRes = await fetch("http://94.130.182.52:3031/metrics/durations");
+    const durations = await durationsRes.json();
+
+    return { queue, durations: durations }
+
+
+});

dashboard/server/api/admin/feedbacks.ts

@@ -0,0 +1,31 @@
+
+import { FeedbackModel } from '@schema/FeedbackSchema';
+
+export default defineEventHandler(async event => {
+
+    const userData = getRequestUser(event);
+    if (!userData?.logged) return;
+    if (!userData.user.roles.includes('ADMIN')) return;
+
+    const feedbacks = await FeedbackModel.aggregate([
+        {
+            $lookup: {
+                from: 'users',
+                localField: 'user_id',
+                foreignField: '_id',
+                as: 'user'
+            }
+        },
+        {
+            $lookup: {
+                from: 'projects',
+                localField: 'project_id',
+                foreignField: '_id',
+                as: 'project'
+            }
+        },
+    ])
+
+    return feedbacks;
+
+});

dashboard/server/api/admin/onboardings.ts

@@ -0,0 +1,30 @@
+
+import { OnboardingModel } from '~/shared/schema/OnboardingSchema';
+
+export default defineEventHandler(async event => {
+
+    const userData = getRequestUser(event);
+    if (!userData?.logged) return;
+    if (!userData.user.roles.includes('ADMIN')) return;
+
+    const analytics = await OnboardingModel.aggregate([
+        {
+            $group: {
+                _id: '$analytics',
+                count: { $sum: 1 }
+            }
+        },
+    ]);
+
+    const jobs = await OnboardingModel.aggregate([
+        {
+            $group: {
+                _id: '$job',
+                count: { $sum: 1 }
+            }
+        },
+    ])
+
+    return { analytics, jobs };
+
+});

dashboard/server/api/admin/projects.ts

@@ -38,17 +38,25 @@ export default defineEventHandler(async event => {
     if (!userData?.logged) return;
     if (!userData.user.roles.includes('ADMIN')) return;
 
-    const { page, limit, sortQuery, filterQuery } = getQuery(event);
+    const { page, limit, sortQuery, filterQuery, filterFrom, filterTo } = getQuery(event);
 
     const pageNumber = parseInt(page as string);
     const limitNumber = parseInt(limit as string);
 
-    const count = await ProjectModel.countDocuments(JSON.parse(filterQuery as string));
+    const matchQuery = {
+        ...JSON.parse(filterQuery as string),
+        created_at: {
+            $gte: new Date(filterFrom as string),
+            $lte: new Date(filterTo as string)
+        }
+    }
+
+    const count = await ProjectModel.countDocuments(matchQuery);
 
     const projects = await ProjectModel.aggregate([
-        {
-            $match: JSON.parse(filterQuery as string)
-        },
+        { 
+            $match: matchQuery
+         },
         {
             $lookup: {
                 from: "project_limits",

dashboard/server/api/project/generate_csv.ts

@@ -2,59 +2,7 @@
 
 import { UserModel } from "@schema/UserSchema";
 import { VisitModel } from "@schema/metrics/VisitSchema";
-
-import { google } from 'googleapis';
-
-const { GOOGLE_AUTH_CLIENT_SECRET, GOOGLE_AUTH_CLIENT_ID } = useRuntimeConfig()
-
-async function exportToGoogle(data: string, user_id: string) {
-
-    const user = await UserModel.findOne({ _id: user_id }, { google_tokens: true });
-
-    const authClient = new google.auth.OAuth2({
-        clientId: GOOGLE_AUTH_CLIENT_ID,
-        clientSecret: GOOGLE_AUTH_CLIENT_SECRET
-    })
-
-    authClient.setCredentials({ access_token: user?.google_tokens?.access_token, refresh_token: user?.google_tokens?.refresh_token });
-
-    const sheets = google.sheets({ version: 'v4', auth: authClient });
-
-    try {
-        const createSheetResponse = await sheets.spreadsheets.create({
-            requestBody: {
-                properties: {
-                    title: 'Text export'
-                }
-            }
-        });
-
-        const spreadsheetId = createSheetResponse.data.spreadsheetId;
-
-        await sheets.spreadsheets.values.update({
-            spreadsheetId: spreadsheetId as string,
-            range: 'Sheet1!A1',
-            requestBody: {
-                values: data.split('\n').map(e => {
-                    return e.split(',')
-                })
-            }
-        });
-
-        return { ok: true }
-
-    } catch (error: any) {
-
-        console.error('Error creating Google Sheet from CSV:', error);
-
-        if (error.response && error.response.status === 401) {
-            return { error: 'Auth error, try to logout and login again' }
-        }
-
-        return { error: error.message.toString() }
-
-    }
-}
+import { EventModel } from "~/shared/schema/metrics/EventSchema";
 
 const { SELFHOSTED } = useRuntimeConfig();
 
@@ -120,15 +68,42 @@ export default defineEventHandler(async event => {
         }).join('\n');
 
 
+        return result;
+    } else if (mode === 'events') {
 
-        const isGoogle = getHeader(event, 'x-google-export');
 
-        if (isGoogle === 'true') {
-            const data = await exportToGoogle(result, user.id);
-            return data;
-        }
+        const eventsReportData = await EventModel.find({
+            project_id,
+            created_at: {
+                $gt: Date.now() - timeSub
+            }
+        });
+
+        const csvHeader = [
+            "name",
+            "session",
+            "metadata",            
+            "website",
+            "created_at",
+        ];
+
+      
+        const lines: any[] = [];
+        eventsReportData.forEach(line => lines.push(line.toJSON()));
+
+        const result = csvHeader.join(',') + '\n' + lines.map(element => {
+            const content: string[] = [];
+            for (const key of csvHeader) {
+                content.push(element[key]);
+            }
+            return content.join(',');
+        }).join('\n');
+
 
         return result;
+
+
+
     } else {
         return '';
     }

dashboard/server/api/project/generate_pdf.ts

@@ -1,6 +1,5 @@
 
 import pdfkit from 'pdfkit';
-
 import { PassThrough } from 'node:stream';
 
 import { ProjectModel } from "@schema/project/ProjectSchema";
@@ -33,7 +32,7 @@ function formatNumberK(value: string | number, decimals: number = 1) {
 
 const LINE_SPACING = 0.5;
 
-const resourcePath = process.env.MODE === 'TEST' ? './public/pdf/' : '../public/pdf/';
+const resourcePath = process.env.MODE === 'TEST' ? './public/pdf/' : './.output/public/pdf/';
 
 function createPdf(data: PDFGenerationData) {
 

dashboard/server/api/timeline/events_stacked.ts

@@ -21,7 +21,7 @@ export default defineEventHandler(async event => {
             domain
         })
 
-        return timelineStackedEvents;
+        return timelineStackedEvents.filter(e => e.name != undefined);
     });
 
 });

dashboard/server/api/timeline/visits.ts

@@ -18,7 +18,9 @@ export default defineEventHandler(async event => {
             model: VisitModel,
             from, to, slice, timeOffset, domain
         });
+
         return timelineData;
+
     });