Try2 Analystics

Author: agairola

app/api/analytics/route.ts

@@ -1,9 +1,25 @@
-import { NextResponse } from 'next/server';
+import { NextRequest, NextResponse } from 'next/server';
 import { prisma } from '@/app/prisma';
 import { analyticsCollector } from '@/lib/analytics';
+import { analyticsDB } from '@/lib/analytics-db';
+import { auth } from '@/app/auth';
 
-export async function GET() {
+export async function GET(request: NextRequest) {
   try {
+    // Authentication check
+    const session = await auth();
+    if (!session) {
+      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+    }
+
+    // Check for enhanced analytics request
+    const { searchParams } = new URL(request.url);
+    const enhanced = searchParams.get('enhanced') === 'true';
+    const hours = parseInt(searchParams.get('hours') || '24');
+    
+    if (enhanced) {
+      return getEnhancedAnalytics(hours);
+    }
     // Get current date for time-based queries
     const now = new Date();
     const thirtyDaysAgo = new Date(now.getTime() - 30 * 24 * 60 * 60 * 1000);
@@ -206,4 +222,51 @@ export async function GET() {
       { status: 500 }
     );
   }
+}
+
+// Enhanced analytics using database-backed system
+async function getEnhancedAnalytics(hours = 24) {
+  try {
+    // Validate hours parameter
+    if (hours < 1 || hours > 168) { // Max 7 days
+      return NextResponse.json({ error: 'Hours must be between 1 and 168' }, { status: 400 });
+    }
+
+    // Efficient parallel queries for enhanced analytics
+    const [performance, endpoints, geography, securityEvents] = await Promise.all([
+      analyticsDB.getPerformanceMetrics(hours),
+      analyticsDB.getTopEndpoints(hours, 10),
+      analyticsDB.getGeographyStats(hours),
+      analyticsDB.getSecurityEvents(hours)
+    ]);
+
+    const data = {
+      performance,
+      topEndpoints: endpoints,
+      geography,
+      security: {
+        events: securityEvents,
+        eventCount: securityEvents.length
+      },
+      timeRange: `${hours} hours`,
+      lastUpdated: new Date().toISOString()
+    };
+
+    const response = NextResponse.json(data);
+    
+    // Set cache headers for performance
+    response.headers.set(
+      'Cache-Control',
+      'private, max-age=30, must-revalidate'
+    );
+
+    return response;
+
+  } catch (error) {
+    console.error('Enhanced analytics error:', error);
+    return NextResponse.json(
+      { error: 'Failed to fetch enhanced analytics' },
+      { status: 500 }
+    );
+  }
 }

generated/prisma/edge.js

@@ -200,6 +200,33 @@ exports.Prisma.RefreshTokenScalarFieldEnum = {
   createdAt: 'createdAt'
 };
 
+exports.Prisma.AnalyticsRequestScalarFieldEnum = {
+  id: 'id',
+  timestamp: 'timestamp',
+  endpoint: 'endpoint',
+  method: 'method',
+  statusCode: 'statusCode',
+  responseTime: 'responseTime',
+  clientId: 'clientId',
+  userId: 'userId',
+  ipAddress: 'ipAddress',
+  userAgent: 'userAgent',
+  country: 'country',
+  city: 'city',
+  clientType: 'clientType',
+  platform: 'platform'
+};
+
+exports.Prisma.AnalyticsSecurityScalarFieldEnum = {
+  id: 'id',
+  timestamp: 'timestamp',
+  eventType: 'eventType',
+  ipAddress: 'ipAddress',
+  userAgent: 'userAgent',
+  clientId: 'clientId',
+  details: 'details'
+};
+
 exports.Prisma.SortOrder = {
   asc: 'asc',
   desc: 'desc'
@@ -224,7 +251,9 @@ exports.Prisma.ModelName = {
   Client: 'Client',
   AccessToken: 'AccessToken',
   AuthCode: 'AuthCode',
-  RefreshToken: 'RefreshToken'
+  RefreshToken: 'RefreshToken',
+  AnalyticsRequest: 'AnalyticsRequest',
+  AnalyticsSecurity: 'AnalyticsSecurity'
 };
 
 /**