fix: added biging serialization & updated models & FE types (#675)

* fix: added biging serialization & updated models & FE types

* feat: updated metrics agent cases & cases per status to all time stats & updated endpoints & sql

apps/workflows-dashboard/src/domains/user/api/user-stats/user-stats.api.ts

@@ -3,15 +3,26 @@ import {
   GetUserStatsDto,
   IResolvedCasesDailyMetric,
   IUserStats,
+  UserStats,
 } from '@app/domains/user/api/user-stats/user-stats.types';
 import { request } from '@app/lib/request';
 
-export const fetchUserStats = async (query: GetUserStatsDto): Promise<IUserStats> => {
+export const fetchUserStats = async (query: GetUserStatsDto): Promise<UserStats> => {
   const result = await request.get<IUserStats>(`/metrics/users/workflow-processing-statistic`, {
     params: query,
   });
 
-  return result.data;
+  const { approvalRate, averageAssignmentTime, averageResolutionTime, averageReviewTime } =
+    result.data || ({} as IUserStats);
+
+  const userStats: UserStats = {
+    approvalRate: approvalRate,
+    averageAssignmentTime: Number(averageAssignmentTime),
+    averageResolutionTime: Number(averageResolutionTime),
+    averageReviewTime: Number(averageReviewTime),
+  };
+
+  return userStats;
 };
 
 export const fetchUserDailyCasesResolvedStats = async (

apps/workflows-dashboard/src/domains/user/api/user-stats/user-stats.types.ts

@@ -4,6 +4,13 @@ export interface IResolvedCasesDailyMetric {
 }
 
 export interface IUserStats {
+  approvalRate: number;
+  averageResolutionTime: string;
+  averageAssignmentTime: string;
+  averageReviewTime: string;
+}
+
+export interface UserStats {
   approvalRate: number;
   averageResolutionTime: number;
   averageAssignmentTime: number;

apps/workflows-dashboard/src/domains/user/api/users-stats/users-stats.types.ts

@@ -11,5 +11,5 @@ export interface GetUsersCaseResolvingStats {
 }
 
 export interface GetUsersAssignedCasesStatsDto {
-  fromDate: number;
+  fromDate?: number;
 }

apps/workflows-dashboard/src/domains/workflows/api/workflow-metrics/workflow-metrics.types.ts

@@ -17,5 +17,5 @@ export type ICasesPerStatusStats = Record<IWorkflowStatus, number>;
 
 export interface GetCasesPerStatusDto {
   // UNIX timestamp
-  fromDate: number;
+  fromDate?: number;
 }

apps/workflows-dashboard/src/pages/Overview/components/molecules/UserStats/UserStats.tsx

@@ -1,4 +1,4 @@
-import { IUserStats } from '@app/domains/user/api/user-stats';
+import { UserStats as IUserStats } from '@app/domains/user/api/user-stats';
 import { DurationCard } from '@app/pages/Overview/components/molecules/UserStats/components/DurationCard';
 import { PercentageCard } from '@app/pages/Overview/components/molecules/UserStats/components/PercentageCard';
 

apps/workflows-dashboard/src/pages/Overview/hooks/useUserStatsQuery/useUserStatsQuery.ts

@@ -1,9 +1,9 @@
 import dayjs from 'dayjs';
-import { IUserStats, userStatsQueryKeys } from '@app/domains/user/api/user-stats';
+import { UserStats, userStatsQueryKeys } from '@app/domains/user/api/user-stats';
 import { useQuery } from '@tanstack/react-query';
 import { useMemo } from 'react';
 
-const defaultValues: IUserStats = {
+const defaultValues: UserStats = {
   approvalRate: 0,
   averageResolutionTime: 0,
   averageReviewTime: 0,

apps/workflows-dashboard/src/pages/Workflows/components/molecules/AgentCasesChart/AgentCasesChart.tsx

@@ -30,7 +30,6 @@ export const AgentCasesChart = memo(({ isLoading, data }: Props) => {
   return (
     <MetricListChart
       title="Assigned Cases per agent"
-      description="( last 1 hour )"
       isLoading={isLoading}
       items={chartItems}
       emptyPlaceholder={<div className="text-sm font-medium">No active cases.</div>}

apps/workflows-dashboard/src/pages/Workflows/components/molecules/CasesPerStatusChart/CasesPerStatusChart.tsx

@@ -28,11 +28,6 @@ export const CasesPerStatusChart = ({ isLoading, data }: Props) => {
   );
 
   return (
-    <MetricListChart
-      title="Amount of cases per status"
-      description="( last 1 hour )"
-      isLoading={isLoading}
-      items={chartItems}
-    />
+    <MetricListChart title="Amount of cases per status" isLoading={isLoading} items={chartItems} />
   );
 };

apps/workflows-dashboard/src/pages/Workflows/components/organisms/metrics/AgentCasesStats/hooks/useUsersAssignedCasesStatsQuery/useUsersAssignedCasesStatsQuery.ts

@@ -6,7 +6,7 @@ export const useUsersAssignedCasesStatsQuery = () => {
   const { filters } = useWorkflowFilters();
   const { data, isLoading } = useQuery({
     ...usersStatsQueryKeys.casesAssignedStats({
-      fromDate: filters.fromDate!,
+      // fromDate: filters.fromDate!,
     }),
     enabled: Boolean(filters.fromDate),
   });

apps/workflows-dashboard/src/pages/Workflows/components/organisms/metrics/CasesPerStatusStats/hooks/useCasesPerStatusQuery/useCasesPerStatusQuery.ts

@@ -1,14 +1,11 @@
 import { ICasesPerStatusStats } from '@app/domains/workflows/api/workflow-metrics';
 import { workflowMetricsKeys } from '@app/domains/workflows/api/workflow-metrics/query-keys';
-import { useWorkflowFilters } from '@app/pages/Workflows/components/providers/WorkflowsFiltersProvider/hooks/useWorkflowFilters';
 import { useQuery } from '@tanstack/react-query';
 
 export const useCasesPerStatusQuery = () => {
-  const { filters } = useWorkflowFilters();
   const { data = { active: 0, completed: 0, failed: 0 } as ICasesPerStatusStats, isLoading } =
     useQuery({
-      ...workflowMetricsKeys.workflowCasesPerStatusStats({ fromDate: filters.fromDate! }),
-      enabled: Boolean(filters.fromDate),
+      ...workflowMetricsKeys.workflowCasesPerStatusStats({}),
     });
 
   return {

services/workflows-service/src/metrics/common/types/base-query.params.ts

@@ -1,3 +1,3 @@
 export interface BaseParams {
-  fromDate: Date;
+  fromDate?: Date;
 }

services/workflows-service/src/metrics/dto/get-users-assigned-cases-statistic.dto.ts

@@ -1,3 +1,7 @@
 import { DateQueryParamsDto } from '@/metrics/common/dto/date-query-params.dto';
+import { IsOptional } from 'class-validator';
 
-export class GetUsersAssignedCasesStatisticDto extends DateQueryParamsDto {}
+export class GetUsersAssignedCasesStatisticDto extends DateQueryParamsDto {
+  @IsOptional()
+  fromDate!: Date;
+}

services/workflows-service/src/metrics/dto/get-workflow-runtimes-status-count.dto.ts

@@ -1,3 +1,7 @@
 import { DateQueryParamsDto } from '@/metrics/common/dto/date-query-params.dto';
+import { IsOptional } from 'class-validator';
 
-export class GetWorkflowRuntimesStatusCountDto extends DateQueryParamsDto {}
+export class GetWorkflowRuntimesStatusCountDto extends DateQueryParamsDto {
+  @IsOptional()
+  fromDate!: Date;
+}

services/workflows-service/src/metrics/repository/metrics.repository.ts

@@ -19,7 +19,7 @@ import { IAggregateAverageResolutionTime } from '@/metrics/repository/types/aggr
 import { GetUserAverageAssignmentTimeParams } from '@/metrics/repository/types/get-user-average-assignment-time.params';
 import { IAggregateAverageAssignmentTime } from '@/metrics/repository/types/aggregate-average-assignment-time';
 import { GetUserAverageReviewTimeParams } from '@/metrics/repository/types/get-user-average-review-time.params';
-import { UserAverageReviewTimeModel } from '@/metrics/repository/models/user-average-review-time.model';
+import { AverageReviewTimeModel } from '@/metrics/repository/models/average-review-time.model';
 import { IAggregateAverageReviewTime } from '@/metrics/repository/types/aggregate-average-review-time';
 import { ListUserCasesResolvedDailyParams } from '@/metrics/repository/types/list-user-cases-resolved-daily.params';
 import { CasesResolvedInDay } from '@/metrics/repository/models/cases-resolved-daily.model';
@@ -139,14 +139,14 @@ export class MetricsRepository {
 
   async getUserAverageReviewTime(
     params: GetUserAverageReviewTimeParams,
-  ): Promise<UserAverageReviewTimeModel | null> {
+  ): Promise<AverageReviewTimeModel | null> {
     const results = await this.prismaService.$queryRawUnsafe<IAggregateAverageReviewTime[]>(
       aggregateAverageReviewTimeQuery,
       params.fromDate,
       params.userId,
     );
 
-    return results.length ? plainToClass(UserAverageReviewTimeModel, results.at(-1)) : null;
+    return results.length ? plainToClass(AverageReviewTimeModel, results.at(-1)) : null;
   }
 
   async listCasesResolvedDaily(

services/workflows-service/src/metrics/repository/models/average-assignment-time.model.ts

@@ -1,6 +1,8 @@
 import { ApiProperty } from '@nestjs/swagger';
+import { Transform } from 'class-transformer';
 
 export class AverageAssignmentTimeModel {
   @ApiProperty({ description: 'Average assignment time in milliseconds' })
-  time!: number;
+  @Transform(({ value }) => (!value ? 0 : value.split('.')[0]))
+  time!: string;
 }

services/workflows-service/src/metrics/repository/models/average-resolution-time.model.ts

@@ -3,6 +3,6 @@ import { Transform } from 'class-transformer';
 
 export class AverageResolutionTimeModel {
   @ApiProperty({ description: 'Average resolution time in milliseconds.' })
-  @Transform(({ value }) => (value === null ? 0 : value))
-  time!: number;
+  @Transform(({ value }) => (!value ? 0 : value.split('.')[0]))
+  time!: string;
 }

services/workflows-service/src/metrics/repository/models/user-average-review-time.model.ts → services/workflows-service/src/metrics/repository/models/average-review-time.model.ts

@@ -1,8 +1,8 @@
 import { ApiProperty } from '@nestjs/swagger';
 import { Transform } from 'class-transformer';
 
-export class UserAverageReviewTimeModel {
+export class AverageReviewTimeModel {
   @ApiProperty({ description: 'Average review time in milliseconds' })
-  @Transform(({ value }) => (value === null ? 0 : value))
-  time!: number;
+  @Transform(({ value }) => (!value ? 0 : value.split('.')[0]))
+  time!: string;
 }

services/workflows-service/src/metrics/repository/sql/aggregate-average-assignment-time.sql.ts

@@ -5,11 +5,11 @@ select
 		when "createdAt" notnull and "assignedAt" notnull
 		then (extract(epoch from "assignedAt") - extract(epoch from "createdAt")) * 1000
 		else 0
-		end)::int as time
+		end)::bigint  as time
 	from "WorkflowRuntimeData"
 	where "assigneeId" = "User".id
 	and "assignedAt" >= $1)
-	)::int as time
+	)::varchar as time
 from
 	"User"
 where

services/workflows-service/src/metrics/repository/sql/aggregate-average-resolution-time.sql.ts

@@ -5,11 +5,11 @@ select
 		when "createdAt" notnull and "resolvedAt" notnull
 		then (extract(epoch from "resolvedAt") - extract(epoch from "createdAt")) * 1000
 		else 0
-		end)::int as time
+		end)::bigint as time
 	from "WorkflowRuntimeData"
 	where "assigneeId" = "User".id
 	and "resolvedAt" >= $1)
-	)::int as time
+	)::varchar as time
 from
 	"User"
 where

services/workflows-service/src/metrics/repository/sql/aggregate-average-review-time.sql.ts

@@ -5,11 +5,11 @@ select
 		when "resolvedAt" notnull and "assignedAt" notnull
 		then (extract(epoch from "resolvedAt") - extract(epoch from "assignedAt")) * 1000
 		else 0
-		end)::int as time
+		end)::bigint  as time
 	from "WorkflowRuntimeData"
 	where "assigneeId" = "User".id
 	and "resolvedAt" >= $1)
-	)::int as time
+	)::varchar as time
 from
 	"User"
 where

services/workflows-service/src/metrics/repository/sql/aggregate-users-assigned-cases-statistic.sql.ts

@@ -13,7 +13,7 @@ inner join (
     count(*) as "casesCount"
   from
     "WorkflowRuntimeData"
-  where "assignedAt" >= $1
+  where "assignedAt" >= coalesce($1, '1900-01-01'::timestamp)
   group by "assigneeId"
 ) as agent_workflow_runtime on
 agent_workflow_runtime."assigneeId" = "id"

services/workflows-service/src/metrics/repository/sql/aggregate-workflow-runtime-status-case-count.sql.ts

@@ -25,7 +25,7 @@ from
     count("status") as status_count
   from
     "WorkflowRuntimeData"
-  where "createdAt" >= $1
+  where "createdAt" >= coalesce($1, '1900-01-01'::timestamp)
   group by
     "status"
 ) as workflow_runtime_data`;

services/workflows-service/src/metrics/repository/types/aggregate-average-assignment-time.ts

@@ -1,3 +1,3 @@
 export interface IAggregateAverageAssignmentTime {
-  time: number | null;
+  time: string | null;
 }

services/workflows-service/src/metrics/repository/types/aggregate-average-resolution-time.ts

@@ -1,3 +1,3 @@
 export interface IAggregateAverageResolutionTime {
-  time: number | null;
+  time: string | null;
 }

services/workflows-service/src/metrics/repository/types/aggregate-average-review-time.ts

@@ -1,3 +1,3 @@
 export interface IAggregateAverageReviewTime {
-  time: number | null;
+  time: string | null;
 }

services/workflows-service/src/metrics/service/metrics.service.ts

@@ -52,6 +52,7 @@ export class MetricsService {
       this.metricsRepository.getUserApprovalRate(commonParams),
       this.metricsRepository.getUserAverageAssignmentTime(commonParams),
       this.metricsRepository.getUserAverageResolutionTime(commonParams),
+
       this.metricsRepository.getUserAverageReviewTime(commonParams),
     ]);
 
@@ -70,9 +71,9 @@ export class MetricsService {
     }
 
     statisticModel.approvalRate = approvalRateModel?.approvalRate || 0;
-    statisticModel.averageAssignmentTime = averageAssignmentTimeModel?.time || 0;
-    statisticModel.averageResolutionTime = averageResolutionTimeModel?.time || 0;
-    statisticModel.averageReviewTime = averageReviewTimeModel?.time || 0;
+    statisticModel.averageAssignmentTime = averageAssignmentTimeModel?.time || '0';
+    statisticModel.averageResolutionTime = averageResolutionTimeModel?.time || '0';
+    statisticModel.averageReviewTime = averageReviewTimeModel?.time || '0';
 
     return statisticModel;
   }

services/workflows-service/src/metrics/service/models/user-workflow-processing-statistic.model.ts

@@ -8,11 +8,11 @@ export class UserWorkflowProcessingStatisticModel {
   approvalRate!: number;
 
   @ApiProperty({ description: 'Average resolution time in milliseconds' })
-  averageResolutionTime!: number;
+  averageResolutionTime!: string;
 
   @ApiProperty({ description: 'Average assignment time in milliseconds' })
-  averageAssignmentTime!: number;
+  averageAssignmentTime!: string;
 
   @ApiProperty({ description: 'Average review time in milliseconds' })
-  averageReviewTime!: number;
+  averageReviewTime!: string;
 }