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, 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_durations: Duration;
+};
+
 export type UserSession<T> = T & {
   window_start: Date;
   window_end: Date;

backend/src/index.ts

@@ -20,7 +20,11 @@ import {
 import * as heartbeat from "./heartbeat/service";
 import * as analytics from "./analytics/service";
 import { WindowSchema, WindowSchemaInputType } from "./analytics/validation";
-import { NormalizedUserSession, UserAnalytics } from "./analytics/types";
+import {
+  NormalizedUserSession,
+  UserAnalytics,
+  UserProjectAnalytics,
+} from "./analytics/types";
 
 export const graphql = {
   Query: {
@@ -43,6 +47,27 @@ export const graphql = {
         return SuccessResponse<UserAnalytics>(data);
       }
     ),
+    ProjectAnaltyics: authorized(
+      async (
+        user,
+        project_path: string,
+        window: WindowSchemaInputType
+      ): Promise<AppResponse<UserProjectAnalytics>> => {
+        // validate first
+        const parsed_window = WindowSchema.safeParse(window);
+        if (parsed_window.error) {
+          return ErrorResponse(
+            parsed_window.error.issues.map((x) => x.message)
+          );
+        }
+        const data = await analytics.getUserProjectAnalytics(
+          user.user_id,
+          project_path,
+          parsed_window.data
+        );
+        return SuccessResponse<UserProjectAnalytics>(data);
+      }
+    ),
     UserLangSessions: authorized(
       async (
         user,