feat: Return a view to the project analytics

Author: omardoescode

backend/src/analytics/db.ts

@@ -1,6 +1,6 @@
 import { User } from "@/auth/validation";
 import { PoolClient } from "pg";
-import { UserAnalytics, UserSession } from "./types";
+import { UserAnalytics, UserProjectAnalytics, UserSession } from "./types";
 import { WindowSchemaType } from "./validation";
 
 const getUserAnalytics = async (
@@ -17,6 +17,25 @@ const getUserAnalytics = async (
   return data.rows[0];
 };
 
+const getUserProjectAnalytics = async (
+  client: PoolClient,
+  user_id: User["user_id"],
+  window: WindowSchemaType,
+  project_path: string
+): Promise<UserProjectAnalytics> => {
+  const { count, unit } = window.interval;
+  const interval = `${count} ${unit}`;
+  const data = await client.query({
+    text: `select lang_durations, machine_durations, editor_durations, project_durations, files_durations, activity_durations, work_duration_ms, active_days, coalesce(
+        NULLIF(regexp_replace($2::varchar, '.*/', ''), ''),
+        'Unknown Project'
+    ) AS project_name
+from user_project_analytics_aggregate_period($1, $2, $3, $4::interval)`,
+    values: [user_id, project_path, window.start, interval],
+  });
+  return data.rows[0];
+};
+
 const getOverlappingUserProjectSessions = async (
   client: PoolClient,
   user_id: User["user_id"],
@@ -50,6 +69,7 @@ const db = {
   getUserAnalytics,
   getOverlappingUserProjectSessions,
   getOverlappingUserLangSessions,
+  getUserProjectAnalytics,
 };
 
 export default db;

backend/src/analytics/service.ts

@@ -1,6 +1,10 @@
 import { User } from "@/auth/validation";
 import pool from "@/pool";
-import { NormalizedUserSession, UserAnalytics } from "./types";
+import {
+  NormalizedUserSession,
+  UserAnalytics,
+  UserProjectAnalytics,
+} from "./types";
 import { WindowSchemaType } from "./validation";
 import db from "./db";
 import { normalizeSession } from "./utils";
@@ -19,6 +23,26 @@ const getUserAnalytics = async (
   }
 };
 
+const getUserProjectAnalytics = async (
+  user_id: User["user_id"],
+  project_path: string,
+  window: WindowSchemaType
+): Promise<UserProjectAnalytics> => {
+  const client = await pool.connect();
+
+  try {
+    const data = await db.getUserProjectAnalytics(
+      client,
+      user_id,
+      window,
+      project_path
+    );
+    return data;
+  } finally {
+    client.release();
+  }
+};
+
 const getUserLangSessions = async (
   user_id: User["user_id"],
   window: WindowSchemaType
@@ -54,4 +78,9 @@ const getUserProjectSessions = async (
     client.release();
   }
 };
-export { getUserAnalytics, getUserProjectSessions, getUserLangSessions };
+export {
+  getUserAnalytics,
+  getUserProjectSessions,
+  getUserLangSessions,
+  getUserProjectAnalytics,
+};

backend/src/analytics/types.ts

@@ -14,6 +14,10 @@ export type UserAnalytics = Prettify<{
   active_days: number;
 }>;
 
+export type UserProjectAnalytics = UserAnalytics & {
+  files_duration: Duration;
+};
+
 export type UserSession<T> = T & {
   window_start: Date;
   window_end: Date;