theFlow

// theFlow Core Cache & Aggregation Handler
export async function getProjectTelemetry(projectId: string) {
  const cacheKey = `telemetry:${projectId}`;
  const cached = await redis.get(cacheKey);
  if (cached) return JSON.parse(cached);

  const stats = await db.collection('events').aggregate([
    { $match: { projectId: new ObjectId(projectId) } },
    { $group: { _id: '$type', count: { $sum: 1 }, avgLatency: { $avg: '$latency' } } }
  ]).toArray();

  await redis.setex(cacheKey, 60, JSON.stringify(stats));
  return stats;
}